Micro\Db\Drivers\MysqlDriver

Complexity

Total Complexity

32

Size/Duplication

Total Lines	286
Duplicated Lines	7.69 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	4
Bugs	0	Features	0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	switchDatabase()	0	4	1
A	infoDatabase()	0	18	2
A	listDatabases()	0	17	3
A	listTables()	0	4	1
A	createTable()	0	6	1
A	removeTable()	0	4	1
A	listFields()	0	18	2
A	fieldInfo()	0	8	2
C	insert()	22	22	8
A	update()	0	19	4
A	delete()	0	4	1
A	count()	0	15	4
A	exists()	0	14	2

<?php /** MysqlDriverMicro */

namespace Micro\Db\Drivers;

/**
 * MySQL Driver class file.
 *
 * @author Oleg Lunegov <testuser@mail.linpax.org>
 * @link https://github.com/linpax/microphp-framework
 * @copyright Copyright (c) 2013 Oleg Lunegov
 * @license https://github.com/linpax/microphp-framework/blob/master/LICENSE
 * @package Micro
 * @subpackage Db\Drivers
 * @version 1.0
 * @since 1.0
 */
class MysqlDriver extends Driver
{
    /**
     * Set current database
     *
     * @access public
     *
     * @param string $dbName Database name
     *
     * @return boolean
     */
    public function switchDatabase($dbName)
    {
        return $this->conn->exec("USE {$dbName};") !== false;
    }

    /**
     * Info of database
     *
     * @access public
     * @param string $dbName Database name
     * @return array
     */
    public function infoDatabase($dbName)
    {
        $sth = $this->conn->query("SHOW TABLE STATUS FROM {$dbName};");

        $result = [];
        foreach ($sth->fetchAll() AS $row) {
            $result[] = [
                'name' => $row['Name'],
                'engine' => $row['Engine'],
                'rows' => $row['Rows'],
                'length' => $row['Avg_row_length'],
                'increment' => $row['Auto_increment'],
                'collation' => $row['Collation']
            ];
        }

        return $result;
    }

    /**
     * List database names on this connection
     *
     * @access public
     * @return array
     */
    public function listDatabases()
    {
        $sql = 'SHOW DATABASES;';

        if ($this->getDriverType() === 'pgsql') {
            $sql = 'SELECT datname FROM pg_database;';
        }

        $sth = $this->conn->query($sql);
        $result = [];

        foreach ($sth->fetchAll() AS $row) {
            $result[] = $row[0];
        }

        return $result;
    }

    /**
     * List tables in db
     *
     * @access public
     * @return array
     */
    public function listTables()
    {
        return $this->conn->query('SHOW TABLES;')->fetchAll(\PDO::FETCH_COLUMN, 0);
    }

    /**
     * Create a new table
     *
     * @param string $name Table name
     * @param array $elements Table elements
     * @param string $params Table params
     *
     * @return int
     */
    public function createTable($name, array $elements = [], $params = '')
    {
        return $this->conn->exec(
            sprintf('SELECT TABLE IF NOT EXISTS `%s` (%s) %s;', $name, implode(', ', $elements), $params)
        );
    }

    /**
     * Remove table from database
     *
     * @access public
     *
     * @param string $name Table name
     *
     * @return mixed
     */
    public function removeTable($name)
    {
        return $this->conn->exec("DROP TABLE {$name};");
    }

    /**
     * Get array fields into table
     *
     * @access public
     *
     * @param string $table Table name
     *
     * @return array
     */
    public function listFields($table)
    {
        $sth = $this->conn->query("SHOW COLUMNS FROM {$table};");

        $result = [];
        foreach ($sth->fetchAll(\PDO::FETCH_ASSOC) as $row) {
            $result[] = [
                'field' => $row['Field'],
                'type' => $row['Type'],
                'null' => $row['Null'],
                'key' => $row['Key'],
                'default' => $row['Default'],
                'extra' => $row['Extra']
            ];
        }

        return $result;
    }

    /**
     * Get info of a field
     *
     * @access public
     *
     * @param string $field Field name
     * @param string $table Table name
     *
     * @return array|boolean
     */
    public function fieldInfo($field, $table)
    {
        if ($this->fieldExists($field, $table)) {
            return $this->conn->query("SELECT {$field} FROM {$table} LIMIT 1;")->getColumnMeta(0);
        }

        return false;
    }

    /**
     * Insert row into table
     *
     * @access public
     *
     * @param string $table Table name
     * @param array $line Line or lines to added
     * @param bool $multi Is multi rows
     *
     * @return bool
     */
    public function insert($table, array $line = [], $multi = false)

This method seems to be duplicated in your project.

    {
        $fields = '`' . implode('`, `', array_keys($multi ? $line[0] : $line)) . '`';

        $values = ':'.implode(', :', array_keys($multi ? $line[0] : $line));
        $rows = $multi ? $line : [$line];
        $id = null;

        if ($rows) {

The expression $rows of type array is implicitly converted to a boolean; are you sure this is intended? If so, consider using ! empty($expr) instead to make it clear that you intend to check for an array without elements.

            $this->conn->beginTransaction();

            $dbh = null;
            foreach ($rows AS $row) {
                $dbh = $this->conn->prepare("INSERT INTO {$table} ({$fields}) VALUES ({$values});")->execute($row);
            }

            $id = $dbh ? $this->conn->lastInsertId() : false;
            $this->conn->commit();
        }

        return $id ?: false;
    }

    /**
     * Update row in table
     *
     * @access public
     *
     * @param string $table Table name
     * @param array $elements Elements to update
     * @param string $conditions Conditions for search
     *
     * @return bool
     */
    public function update($table, array $elements = [], $conditions = '')
    {
        $keys = array_keys($elements);
        if (0 === count($keys)) {
            return false;
        }

        $valStr = [];
        foreach ($keys as $key) {
            $valStr[] = '`'.$key.'` = :'.$key;
        }
        $valStr = implode(',', $valStr);

        if ($conditions) {
            $conditions = 'WHERE '.$conditions;
        }

        return $this->conn->prepare("UPDATE {$table} SET {$valStr} {$conditions};")->execute($elements);
    }

    /**
     * Delete row from table
     *
     * @access public
     *
     * @param string $table Table name
     * @param string $conditions Conditions to search
     * @param array $params Params array
     *
     * @return bool
     */
    public function delete($table, $conditions, array $params = [])
    {
        return $this->conn->prepare("DELETE FROM {$table} WHERE {$conditions};")->execute($params);
    }

    /**
     * Count element in sub-query
     *
     * @access public
     *
     * @param string $query Query
     * @param string $table Table name
     *
     * @return integer|boolean
     */
    public function count($query = '', $table = '')
    {
        if ($query) {
            $sth = $this->conn->prepare("SELECT COUNT(*) FROM ({$query}) AS m;");
        } elseif ($table) {
            $sth = $this->conn->prepare("SELECT COUNT(*) FROM {$table} AS m;");
        } else {
            return false;
        }
        if ($sth->execute()) {
            return $sth->fetchColumn();
        }

        return false;
    }

    /**
     * Exists element in the table by params
     *
     * @access public
     *
     * @param string $table Table name
     * @param array $params Params array
     *
     * @return bool
     */
    public function exists($table, array $params = [])
    {
        $keys = [];

        foreach ($params AS $key => $val) {
            $keys[] = $table . '.' . $key . '=\'' . $val . '\'';
        }

        $sth = $this->conn->prepare('SELECT * FROM ' . $table . ' WHERE ' . implode(' AND ', $keys) . ' LIMIT 1;');
        /** @noinspection PdoApiUsageInspection */
        $sth->execute();

        return (bool)$sth->rowCount();
    }
}