csphere\core\database\Driver_PDO_MYSQL

Complexity

Total Complexity

9

Size/Duplication

Total Lines	126
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
B	__construct()	0	30	4
A	limits()	0	6	1
A	replace()	0	20	2
B	info()	0	31	2

<?php

/**
 * Adds support for MySQL databases
 *
 * PHP Version 5
 *
 * @category  Core
 * @package   Database
 * @author    Hans-Joachim Piepereit <contact@csphere.eu>
 * @copyright 2013 cSphere Team
 * @license   http://opensource.org/licenses/bsd-license Simplified BSD License
 * @link      http://www.csphere.eu
 **/

namespace csphere\core\database;

/**
 * Adds support for MySQL databases
 *
 * @category  Core
 * @package   Database
 * @author    Hans-Joachim Piepereit <contact@csphere.eu>
 * @copyright 2013 cSphere Team
 * @license   http://opensource.org/licenses/bsd-license Simplified BSD License
 * @link      http://www.csphere.eu
 **/

class Driver_PDO_MYSQL extends Base_PDO
{
    /**
     * Creates the database handler object
     *
     * @param array $config Configuration details as an array
     *
     * @throws \Exception
     *
     * @return \csphere\core\database\Driver_PDO_MYSQL
     **/

Adding a @return annotation to constructors is generally not recommended as a constructor does not have a meaningful return value.

There must be no blank lines after the function comment

    public function __construct(array $config)
    {
        parent::__construct($config);

        if (!extension_loaded('pdo_mysql')) {

            throw new \Exception('Extension "pdo_mysql" not found');
        }

        $dsn = empty($config['host']) ? '' :
               'host=' . $config['host'] . ';';

        $dsn .= 'dbname=' . $config['schema'];

        $options = [\PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8'];

        // Use try catch to hide connection details
        try {

            $this->con = new \PDO(
                'mysql:' . $dsn, $config['username'], $config['password'], $options
            );

            $this->con->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
        }
        catch(\PDOException $pdo_error) {

            $this->error('Connect', [], $pdo_error->getMessage(), false);
        }
    }

    /**
     * Builds the query string part for limit and offset
     *
     * @param integer $first Number of the first dataset to show
     * @param integer $max   Number of datasets to show from first on
     *
     * @return string
     **/

There must be no blank lines after the function comment

    protected function limits($first, $max)
    {
        $string = 'LIMIT ' . (int)$first . ',' . (int)$max;

        return $string;
    }

    /**
     * Replaces driver specific query placeholders
     *
     * @param string $replace The string to use for replaces
     *
     * @return string
     **/

There must be no blank lines after the function comment

    protected function replace($replace)
    {
        // Use InnoDB as default storage engine
        $engine = ' ENGINE=innodb DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci';

        $change_mysql = ['{engine}' => $engine,
                         '{integer}' => 'integer',
                         '{optimize}' => 'OPTIMIZE TABLE',
                         '{serial}' => 'integer NOT NULL auto_increment',
                         '{text}' => 'text',
                         '{longtext}' => 'longtext',
                         '{varchar}' => 'varchar'];

        foreach ($change_mysql AS $key => $mysql) {

            $replace = str_replace($key, $mysql, $replace);
        }

        return $replace;
    }

    /**
     * Returns a formatted array with statistics
     *
     * @return array
     **/

There must be no blank lines after the function comment

    public function info()
    {
        // Get general PDO information
        $info = parent::info();

        // Get encoding of database
        $query = 'SHOW VARIABLES WHERE Variable_name = \'character_set_server\'';

        $encoding = $this->query($query, [], 0, 0);

        $info['encoding'] = $encoding[0]['Value'];

        // Get size of database and amount of tables
        $query = 'SHOW TABLE STATUS LIKE \''
               . $this->config['prefix'] . '%\'';

        $tables = $this->query($query, [], 0, 0);

        $info['tables'] = count($tables);
        $info['size']   = 0;

        foreach ($tables AS $table) {

            $info['size'] += $table['Data_length'];
        }

        // Shorten mysqlnd client version
        $info['client'] = explode('$Id', $info['client'])[0];

        return $info;
    }
}