Persistence::countFrom() - Code Metrics - Inspection of "Update Persistence.php" - rdorado/site-analyzer - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — master ( 359a20...4078c2 )

by Ruben
created 2018-11-09 21:40 UTC
Persistence::countFrom() A

↳ Parent: Persistence
Complexity

Conditions	6
Paths	15
Size

Total Lines	18
Code Lines	15
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	6
eloc	15
nc	15
nop	3
dl	0
loc	18
rs	9.2222
c	0
b	0
f	0
<?php
/**
 *
 * (c) Ruben Dorado <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
namespace SiteAnalyzer;

use Exception;
use PDO;

/**
 * class SiteAnalyzer
 *
 * @package   SiteAnalyzer
 * @author    Ruben Dorado <[email protected]>
 * @copyright 2018 Ruben Dorado
 * @license   http://www.opensource.org/licenses/MIT The MIT License
 */
class Persistence
{

    /*
     * @param Configuration $config
     *
     * @return PDO
     */
    public static function getPDO($config) {
        $options = array(
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION
        );
        
        if ($config->getDsn()) {
            try {
                return new PDO($config->getDsn(), $config->getUser(), $config->getPassword(), $options);
            } catch (Exception $e) {                
                if (!$config->getUseOnMemoryDB()) {
                    throw new Exception("Could not create a db connection. Check permissions, configuration, and documentation. ".$e->getMessage());
                }
            }
        }
        
        if ($config->getUseOnMemoryDB()) {
            try {
                return new PDO("sqlite::memory:", null, null, $options);
            } catch (Exception $e) {
                throw new Exception("Could not create a db connection. Check permissions, configuration, and documentation. ".$e->getMessage());                
            }
        }
        throw new Exception("Error when trying to obtain a connection to a database. Check the configuration. ");

    }


    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    public static function crateDatabase($pdo, $config) {
        try {
            $db_hit_table = $config->getHitTableName();
            $db_options_table = $config->getOptionsTableName();           
            $db_from_table = $config->getFromTableName();
            $db_url_table = $config->getUrlTableName();

            $stmt = $pdo->prepare("CREATE TABLE $db_hit_table (id VARCHAR(255), count INT)");
            $stmt->execute();
            $stmt = $pdo->prepare("CREATE TABLE $db_options_table (id VARCHAR(255), time TIMESTAMP, user VARCHAR(255))");
            $stmt->execute();
            $stmt = $pdo->prepare("CREATE TABLE $db_from_table (id VARCHAR(255), from_id VARCHAR(255), count INT)");
            $stmt->execute();
            $stmt = $pdo->prepare("CREATE TABLE $db_url_table (id VARCHAR(255), url VARCHAR(255), count INT)");
            $stmt->execute();
        } catch (Exception $e) {
            throw new Exception("Could not create the database. ".$e->getMessage());
        }        
        return true;
    }


    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    public static function deleteDatabase($pdo, $config) {
        $resp = true;
        
        $db_hit_table = $config->getHitTableName();
        $db_options_table = $config->getOptionsTableName();
        $db_from_table = $config->getFromTableName();
        $db_url_table = $config->getUrlTableName();
        
        $resp = $resp && Persistence::dropTable($pdo, $db_hit_table);
        $resp = $resp && Persistence::dropTable($pdo, $db_options_table);
        $resp = $resp && Persistence::dropTable($pdo, $db_from_table);
        $resp = $resp && Persistence::dropTable($pdo, $db_url_table);
        
        return $resp;
    }


    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    private static function dropTable($pdo, $tableName) {
        try {            
            $stmt = $pdo->prepare("DROP TABLE $tableName");
            $stmt->execute();
           
        } catch (Exception $e) {
            throw new Exception("Problem deleting the table $tableName. ".$e->getMessage());
        }
        return true;
    }
    

    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    public static function checkTables($pdo, $config) {
        $resp = true;      
        try {
            
            $resp = $resp && Persistence::checkHitTable($pdo, $config);
            $resp = $resp && Persistence::checkOptionsTable($pdo, $config);
            $resp = $resp && Persistence::checkFromTable($pdo, $config);
            $resp = $resp && Persistence::checkUrlTable($pdo, $config);
        } catch (Exception $e) {
            return false;
        }        
        return $resp;

    }

    /*
     * @param $pdo PDO
     * @param $config Configuration
     */
    public static function checkFromTable($pdo, $config) {
        try {
            $db_from_table = $config->getFromTableName();
            $stmt = $pdo->prepare("SELECT * FROM $db_from_table WHERE 1==0");
            $stmt->execute();
        } catch (Exception $e) {
            return false;
        }
        return true;
    }
        
    /*
     * @param $pdo PDO
     * @param $config Configuration
     */
    public static function checkUrlTable($pdo, $config) {
        try {
            $db_url_table = $config->getUrlTableName();
            $stmt = $pdo->prepare("SELECT * FROM $db_url_table WHERE 1==0");
            $stmt->execute();            
        } catch (Exception $e) {
            return false;
        }
        return true;
    }
    
   
    
    /*
     * @param $pdo PDO
     * @param $config Configuration
     */
    public static function checkOptionsTable($pdo, $config) {
        try {
            $db_options_table = $config->getOptionsTableName();
            $stmt = $pdo->prepare("SELECT * FROM $db_options_table WHERE 1==0");
            $stmt->execute();
        } catch (Exception $e) {
            return false;
        }
        return true;
    }
    
    /*
     * @param $pdo PDO
     * @param $config Configuration
     */
    public static function checkHitTable($pdo, $config) {
        try {
            $db_hit_table = $config->getHitTableName();
            $stmt = $pdo->prepare("SELECT * FROM $db_hit_table WHERE 1==0");
            $stmt->execute();            
        } catch (Exception $e) {
            return false;
        }
        return true;        
    }
     
    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    public static function countHit($pdo, $config, $options = []) {
        if (array_key_exists('url', $options)) {
            $url = $options['url'];
        } else if (array_key_exists('HTTP_HOST', $_SERVER)) {
            $url = "http://".$_SERVER['HTTP_HOST'];
            if (array_key_exists('REQUEST_URI', $_SERVER)) {
                $url = $url.$_SERVER['REQUEST_URI'];
            }               
        } else {
            $url = "No Info";
        }

        if ($config->getRemoveQueryString()) {
            $url = preg_replace('/\?.*/', '', $url);
        }
        
        if (array_key_exists('id', $options)) {
            $id = $options['id'];
        } else {
            $id = $url;
        }

        $stmt = $pdo->prepare("UPDATE $db_hit_table SET count = count + 1 WHERE id = ?");

        $stmt->execute([$id]);
        if ($stmt->rowCount()==0) {
            $stmt = $pdo->prepare("INSERT INTO $db_hit_table (id, count) VALUES (?, 1)");
            $stmt->execute([$id]);
        }

        $stmt = $pdo->prepare("UPDATE $db_url_table SET count = count + 1 WHERE id = ? and url = ?");

        $stmt->execute([$id, $url]);
        if ($stmt->rowCount()==0) {
            $stmt = $pdo->prepare("INSERT INTO $db_url_table (id, url, count) VALUES (?, ?, 1)");
            $stmt->execute([$id, $url]);
        }
        
    }
    
    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    public static function countFrom($pdo, $config, $options = []) {
        if (array_key_exists('from_id', $options)) {
            $ids = [$options['from_id']];
        } else {
            $from_url = isset($_SERVER['HTTP_REFERER']) ? $_SERVER['HTTP_REFERER'] : 'No referer info';
            $ids = Persistence::findHitIdsByUrl($pdo, $config, $from_url); 
            if (count($ids)==0) {
                $stmt = $pdo->prepare("INSERT INTO $db_url_table (id, url, count) VALUES (?, ?, 1)");

                $stmt->execute([$from_url, $from_url]);
                $ids = [$from_url];
            }
        }
        foreach ($ids as $from_id) {
            $stmt = $pdo->prepare("UPDATE $db_from_table SET count = count + 1 WHERE id = ? and from_id = ?");

            $stmt->execute([$id, $from_id]);

            if ($stmt->rowCount()==0) {
                $stmt = $pdo->prepare("INSERT INTO $db_from_table (id, from_id, count) VALUES (?, ?, 1)");
                $stmt->execute([$id, $from_id]);
            }
        }
    }
    
    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    public static function countOptions($pdo, $config, $options = []) {
    public static function countOptions($pdo, /** @scrutinizer ignore-unused */ $config, $options = []) {
        $user = null;
        if ($store_user) {

            if (array_key_exists('user', $options)) {
                $user = $options['user'];
            }    
        }
        
        if ($store_time || $store_user) {

            $stmt = $pdo->prepare("INSERT INTO $db_options_table (id, time, user) VALUES (?, ?, ?)");

            $stmt->execute([$id, time(), $user]);

        }        
    }
    
    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    public static function updateCount($pdo, $config, $options = []) {

        $db_hit_table = $config->getHitTableName();

        $db_options_table = $config->getOptionsTableName();

        $db_from_table = $config->getFromTableName();

        $db_url_table = $config->getUrlTableName();


        $store_from = true;

        $store_time = true;

        $store_user = true;

        
        Persistence::countHit($pdo, $config, $options);
        Persistence::countFrom($pdo, $config, $options);           
        Persistence::countOptions($pdo, $config, $options); 
                       

        
        return true;
    }

    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    public static function findHitIdsByUrl($pdo, $config, $url) {
        $resp = [];
        try {
            
            $dbtable = $config->getUrlTableName();
            $stmt = $pdo->prepare("SELECT id,url,count FROM $dbtable WHERE url = '$url'");
            if ($stmt->execute()) {
                while ($row = $stmt->fetch()) {
                    $resp[] = $row['id'];
                }
            }
        } catch (Exception $e) {
            throw new Exception("Error executing function 'findHitsByUrl'. ".$e->getMessage());
        }
        return $resp;        
    }

    
    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    public static function getAllHits($pdo, $config) {
        $resp = [];
        try {
            $dbtable = $config->getHitTableName();
            $stmt = $pdo->prepare("SELECT id,count FROM $dbtable");
            if ($stmt->execute()) {
                while ($row = $stmt->fetch()) {
                    $resp[] = [$row['id'], $row['count']];
                }
            }
            
        } catch (Exception $e) {
            throw new Exception("Error executing function 'getAllHits'. ".$e->getMessage());
        }
        return $resp;        
    }

    
    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    public static function findUrls($pdo, $config, $by = []) {
        $resp = [];
        try {
            $dbtable = $config->getUrlTableName();
            $qdata = [];
            $tquery = [];
            if (array_key_exists('id', $by)) {
                $qdata[] = $by['id'];
                $tquery[] = "id = ?";
            }
            
            if (array_key_exists('url', $by)) {
                $qdata[] = $by['url'];
                $tquery[] = "url = ?";
            }
            
            $sql = "SELECT id,url,count FROM $dbtable";
            if (count($tquery) > 0) {
                $sql = $sql." WHERE ".join(" AND ", $tquery);
            }
            
            $stmt = $pdo->prepare($sql);
            if ($stmt->execute($qdata)) {
                while ($row = $stmt->fetch()) {
                    $resp[] = [$row['id'], $row['url'], $row['count']];
                }
            }
            
        } catch (Exception $e) {
            throw new Exception("Error executing function 'getAllUrls'. ".$e->getMessage());
        }
        return $resp;
    }

    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    public static function findIdByTimeUser($pdo, $config, $by = []) {
        $resp = [];
        try {
            $dbtable = $config->getOptionsTableName();
            $qdata = [];
            $tquery = [];
            if (array_key_exists('from', $by)) {
                $qdata[] = $by['from'];
                $tquery[] = "time >= ?";
            }
            
            if (array_key_exists('to', $by)) {
                $qdata[] = $by['to'];
                $tquery[] = "time <= ?";
            }
            
            if (array_key_exists('user', $by)) {
                $qdata[] = $by['user'];
                $tquery[] = "user = ?";
            }
            
            $sql = "SELECT id,time,user FROM $dbtable";
            if (count($tquery) > 0) {
                $sql = $sql." WHERE ".join(" AND ", $tquery);
            }
            
            $stmt = $pdo->prepare($sql);
            if ($stmt->execute($qdata)) {
                while ($row = $stmt->fetch()) {
                    $resp[] = [$row['id'], $row['time'], $row['user']];
                }
            }
            
        } catch (Exception $e) {
            throw new Exception("Error executing function 'getAllUrls'. ".$e->getMessage());
        }
        return $resp;
    }
    

    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    public static function findByFrom($pdo, $config, $by = []) {
        $resp = [];
        try {
            $dbFromtable = $config->getFromTableName();
            $dbUrltable = $config->getUrlTableName();
            $qdata = [];
            $tquery = [];
            
            if (array_key_exists('url', $by) && array_key_exists('id', $by)) {
                $qdata = [$by['url'], $by['id']];
                $tquery = "SELECT f.* FROM  $dbFromtable f,$dbUrltable u WHERE (f.from_id = u.id and f.url = ?) or f.from_id = ?";                
            } else if (array_key_exists('url', $by)) {
                $qdata = [$by['url']];
                $tquery = "SELECT f.* FROM $dbFromtable f,$dbUrltable u where f.from_id = u.id and u.url = ?";
            } else if (array_key_exists('id', $by)) {
                $qdata = [$by['id']];
                $tquery = "SELECT f.* FROM $dbFromtable f where f.from_id = ?";
            } else {
                $qdata = [];
                $tquery = "SELECT f.* FROM $dbFromtable f";
            }
                                    
            $stmt = $pdo->prepare($tquery);
            if ($stmt->execute($qdata)) {
                while ($row = $stmt->fetch()) {
                    $resp[] = [$row['id'], $row['from_id'], $row['count']];
                }
            }
            
        } catch (Exception $e) {
            throw new Exception("Error executing function 'findByFrom'. ".$e->getMessage());
        }
        return $resp;
    }
    
    
    
    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    public static function getCounts($pdo, $config)
    {
        $resp = [];
        try {

            $dbHitTable = $config->getHitTableName();
            $dbUrlTable = $config->getUrlTableName();
            $stmt = $pdo->prepare("SELECT h.id, u.url, h.count FROM $dbHitTable h, $dbUrlTable u WHERE h.id=u.id");
            if ($stmt->execute()) {
                while ($row = $stmt->fetch()) {
                    $resp[] = [$row[0], $row[1], $row[2]];
                }
            }
            
        } catch (Exception $e) {
            throw new Exception("Error reading the database. Method getCounts().".$e->getMessage());
        }        
        return $resp;
    }

    
    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */
    public static function getHitsWithOptions($pdo, $config) {
        $resp = [];
        try {
            
            $dbOptionsTable = $config->getOptionsTableName();
            $stmt = $pdo->prepare("SELECT o.id, o.time, o.user FROM $dbOptionsTable o");
            if ($stmt->execute()) {
                while ($row = $stmt->fetch()) {
                    $resp[] = ['id'=>$row[0], 'time'=>$row[1], 'user'=>$row[2]];
                }
            }
            
        } catch (Exception $e) {
            throw new Exception("Error reading the database. Method getCounts().".$e->getMessage());
        }
        return $resp;
    }
    
    /*
     * @param $pdo PDO
     * @param $config Configuration
     *
     */    
    public static function getCountsById($pdo, $config) {
    public static function getCountsById($pdo, /** @scrutinizer ignore-unused */ $config) {
        return "Works";
    }
}


            

rdorado / site-analyzer

Push — master ( 359a20...4078c2 )

Persistence::countFrom() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
