Micro\Db\Drivers\PgsqlDriver

Complexity

Total Complexity

24

Size/Duplication

Total Lines	218
Duplicated Lines	16.51 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	5
Bugs	0	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	2
A	switchDatabase()	0	4	1
A	infoDatabase()	0	4	1
A	listTables()	0	6	1
A	listDatabases()	0	6	1
A	createTable()	0	6	1
A	listFields()	0	16	3
C	insert()	0	23	8
B	update()	22	22	4
A	exists()	14	14	2

<?php /** PgsqlDriverMicro */

namespace Micro\Db\Drivers;

use Micro\Base\Exception;

/**
 * PostgreSQL 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 PgsqlDriver extends Driver
{
    /** @var string $tableSchema Table schema for postgres */
    protected $tableSchema = 'public';


    /**
     * Driver constructor.
     *
     * @access public
     *
     * @param string $dsn DSN connection string
     * @param array $config Configuration of connection
     * @param array $options Other options
     *
     * @result void
     * @throws Exception
     */
    public function __construct($dsn, array $config = [], array $options = [])
    {
        parent::__construct($dsn, $config, $options);

        if (!empty($config['schema'])) {
            $this->tableSchema = $config['schema'];
        }
    }

    /**
     * Set current database
     *
     * @access public
     *
     * @param string $dbName Database name
     *
     * @return boolean
     * @throws \InvalidArgumentException
     */
    public function switchDatabase($dbName)
    {
        // TODO: Implement switchDatabase() method.
    }

    /**
     * Info of database
     *
     * @access public
     *
     * @param string $dbName Database name
     *
     * @return array
     */
    public function infoDatabase($dbName)
    {
        // TODO: Implement infoDatabase() method.
    }

    /**
     * List tables in db
     *
     * @access public
     * @return array
     */
    public function listTables()
    {
        return $this->conn->query(
            'SELECT table_name FROM information_schema.tables WHERE table_schema = \'' . $this->tableSchema . '\';'
        )->fetchAll(\PDO::FETCH_COLUMN, 0);
    }

    /**
     * List database names on this connection
     *
     * @access public
     * @return mixed
     */
    public function listDatabases()
    {
        return $this->conn->query(
            'SELECT datname FROM pg_database WHERE datistemplate = false and datname != \'postgres\';'
        )->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)
        );
    }

    /**
     * Get array fields into table
     *
     * @access public
     *
     * @param string $table Table name
     *
     * @return array
     */
    public function listFields($table)
    {
        $sth = $this->conn->query('SELECT * FROM information_schema.columns WHERE table_name =\'' . $table . '\'');
        $result = [];

        foreach ($sth->fetchAll(\PDO::FETCH_ASSOC) as $row) {
            $result[] = [
                'field' => $row['column_name'],
                'type' => $row['data_type'] . (($max = $row['character_maximum_length']) ? '(' . $max . ')' : ''),
                'null' => $row['is_nullable'],
                'default' => $row['column_default']
            ];
        }

        return $result;
    }

    /**
     * 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)
    {
        $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) {
                $res = $this->conn->prepare('INSERT INTO ' . $table . ' (' . $fields . ') VALUES (' . $values . ');');
                $dbh = $res->execute($row);

$dbh is not used, you could remove the assignment.

                die(var_dump($res->errorCode() . ': ' . print_r($res->errorInfo(), true)));

var_dump($res->errorCode() . ': ' . print_r($res->errorInfo(), true)); looks like debug code. Are you sure you do not want to remove it? This might expose sensitive data.

The method insert() contains an exit expression.

            }

            $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 = '')

This method seems to be duplicated in your project.

    {
        $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);
    }

    /**
     * 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 = [])

This method seems to be duplicated in your project.

    {
        $keys = [];

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

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

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