Spiral\Database\Drivers\Postgres\PostgresDriver

Complexity

Total Complexity

7

Size/Duplication

Total Lines	136
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	3

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	hasTable()	0	6	1
A	truncateData()	0	4	1
A	tableNames()	0	11	2
B	getPrimary()	0	32	1
A	insertBuilder()	0	7	1
A	createPDO()	0	8	1

<?php
/**
 * Spiral Framework.
 *
 * @license   MIT
 * @author    Anton Titov (Wolfy-J)
 */

namespace Spiral\Database\Drivers\Postgres;

use Spiral\Database\Builders\InsertQuery;
use Spiral\Database\DatabaseInterface;
use Spiral\Database\Entities\Driver;
use Spiral\Database\Exceptions\DriverException;

//use Spiral\Database\Drivers\Postgres\Schemas\Commander;

45% of this comment could be valid code. Did you maybe forget this after debugging?

//use Spiral\Database\Drivers\Postgres\Schemas\TableSchema;

/**
 * Talks to postgres databases.
 */
class PostgresDriver extends Driver
{
    /**
     * Driver type.
     */
    const TYPE = DatabaseInterface::POSTGRES;

    /**
     * Driver schemas.
     */
    //const SCHEMA_TABLE = TableSchema::class;

    /**
     * Commander used to execute commands. :).
     */
    //const COMMANDER = Commander::class;

    /**
     * Query compiler class.
     */
    const QUERY_COMPILER = QueryCompiler::class;

    /**
     * Default timestamp expression.
     */
    const TIMESTAMP_NOW = 'now()';

    /**
     * Cached list of primary keys associated with their table names. Used by InsertBuilder to
     * emulate last insert id.
     *
     * @var array
     */
    private $primaryKeys = [];

    /**
     * {@inheritdoc}
     */
    public function hasTable(string $name): bool
    {
        $query = 'SELECT "table_name" FROM "information_schema"."tables" WHERE "table_schema" = \'public\' AND "table_type" = \'BASE TABLE\' AND "table_name" = ?';

        return (bool)$this->query($query, [$name])->fetchColumn();
    }

    /**
     * {@inheritdoc}
     */
    public function truncateData(string $table)
    {
        $this->statement("TRUNCATE TABLE {$this->identifier($table)}");
    }

    /**
     * {@inheritdoc}
     */
    public function tableNames(): array
    {
        $query = 'SELECT "table_name" FROM "information_schema"."tables" WHERE "table_schema" = \'public\' AND "table_type" = \'BASE TABLE\'';

        $tables = [];
        foreach ($this->query($query) as $row) {
            $tables[] = $row['table_name'];
        }

        return $tables;
    }

    /**
     * Get singular primary key associated with desired table. Used to emulate last insert id.
     *
     * @param string $prefix Database prefix if any.
     * @param string $table  Fully specified table name, including postfix.
     *
     * @return string|null
     *
     * @throws DriverException
     */
    public function getPrimary(string $prefix, string $table): string

The parameter $prefix is not used and could be removed.

The parameter $table is not used and could be removed.

    {
//        if (!empty($this->cacheStore) && empty($this->primaryKeys)) {

57% of this comment could be valid code. Did you maybe forget this after debugging?

//            $this->primaryKeys = (array)$this->cacheStore->get($this->getSource() . '/keys');
//        }
//
//        if (!empty($this->primaryKeys) && array_key_exists($table, $this->primaryKeys)) {
//            return $this->primaryKeys[$table];
//        }
//
//        if (!$this->hasTable($table)) {
//            throw new DriverException(
//                "Unable to fetch table primary key, no such table '{$table}' exists"
//            );
//        }
//
//        $this->primaryKeys[$table] = $this->tableSchema($table)->getPrimaryKeys();
//        if (count($this->primaryKeys[$table]) === 1) {
//            //We do support only single primary key
//            $this->primaryKeys[$table] = $this->primaryKeys[$table][0];
//        } else {
//            $this->primaryKeys[$table] = null;
//        }
//
//        //Caching
//        if (!empty($this->memory)) {
//            $this->cacheStore->forever($this->getSource() . '/keys', $this->primaryKeys);
//        }
//
//        return $this->primaryKeys[$table];
        return '';
    }

    /**
     * {@inheritdoc}
     *
     * Postgres uses custom insert query builder in order to return value of inserted row.
     */
    public function insertBuilder(string $prefix, array $parameters = []): InsertQuery
    {
        return $this->factory->make(
            PostgresInsertQuery::class,
            ['driver' => $this, 'compiler' => $this->queryCompiler($prefix),] + $parameters
        );
    }

    /**
     * {@inheritdoc}
     */
    protected function createPDO(): \PDO
    {
        //Spiral is purely UTF-8
        $pdo = parent::createPDO();
        $pdo->exec("SET NAMES 'UTF-8'");

        return $pdo;
    }
}