Ajde_Db_PDO

Complexity

Total Complexity

6

Size/Duplication

Total Lines	52
Duplicated Lines	19.23 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
B	query()	10	34	4
A	getLog()	0	4	1

<?php
/**
 * @source http://www.coderholic.com/php-database-query-logging-with-pdo/
 * Modified for use with Ajde_Document_Processor_Html_Debugger
 */

/**
 * Extends PDO and logs all queries that are executed and how long
 * they take, including queries issued via prepared statements.
 */
class Ajde_Db_PDO extends PDO
{
    public static $log = [];

    public function __construct($dsn, $username = null, $password = null, $options = [])
    {
        $options = $options + [
                PDO::ATTR_STATEMENT_CLASS => ['Ajde_Db_PDOStatement', [$this]],
            ];
        parent::__construct($dsn, $username, $password, $options);
    }

    public function query($query)
    {
        //$cache = Ajde_Db_Cache::getInstance();
        $log = ['query' => $query];
        $start = microtime(true);
        //if (!$cache->has($query)) {

        try {
            $result = parent::query($query);
        } catch (Exception $e) {
            if (config('app.debug') === true) {

This code seems to be duplicated across your project.

                if (isset($this->queryString)) {
                    dump($this->queryString);

The property queryString does not exist. Did you maybe forget to declare it?

                }
                dump('Go to '.config('app.rootUrl').'?install=1 to install DB');
                throw new Ajde_Db_Exception($e->getMessage());
            } else {
                Ajde_Exception_Log::logException($e);

$e is of type object<Exception>, but the function expects a object<Throwable>.

                die('DB connection problem. <a href="?install=1">Install database?</a>');
            }
        }

        //$cache->set($query, serialize($result));
        //	$log['cache'] = false;
        //} else {
        //	$result = $cache->get($query);
        //	$log['cache'] = true;
        //}
        $time = microtime(true) - $start;
        $log['time'] = round($time * 1000, 0);
        self::$log[] = $log;

        return $result;
    }

    public static function getLog()
    {
        return self::$log;
    }
}