Yiisoft\Db\Pgsql\Connection\PgsqlConnection

Complexity

Total Complexity

10

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	initConnection()	0	11	5
A	createCommand()	0	9	2
A	createPdoInstance()	0	3	1
A	getSchema()	0	7	2

<?php

declare(strict_types=1);

namespace Yiisoft\Db\Pgsql\Connection;

use PDO;
use Yiisoft\Db\Connection\Connection;
use Yiisoft\Db\Command\Command;
use Yiisoft\Db\Exception\Exception;
use Yiisoft\Db\Exception\InvalidConfigException;
use Yiisoft\Db\Exception\NotSupportedException;
use Yiisoft\Db\Pgsql\Schema\PgsqlSchema;

/**
 * Database connection class prefilled for PGSQL Server.
 */
final class PgsqlConnection extends Connection
{
    private ?PgsqlSchema $schema = null;

    /**
     * Creates a command for execution.
     *
     * @param string|null $sql the SQL statement to be executed
     * @param array $params the parameters to be bound to the SQL statement
     *
     * @throws InvalidConfigException
     * @throws Exception
     * @throws NotSupportedException
     *
     * @return Command the DB command
     */
    public function createCommand(?string $sql = null, $params = []): Command
    {
        if ($sql !== null) {
            $sql = $this->quoteSql($sql);
        }

        $command = new Command($this->getProfiler(), $this->getLogger(), $this, $sql);

The method getLogger() does not exist on Yiisoft\Db\Pgsql\Connection\PgsqlConnection.

The method getProfiler() does not exist on Yiisoft\Db\Pgsql\Connection\PgsqlConnection.

        return $command->bindValues($params);
    }

    /**
     * Returns the schema information for the database opened by this connection.
     *
     * @return PgsqlSchema the schema information for the database opened by this connection.
     */
    public function getSchema(): PgsqlSchema
    {
        if ($this->schema !== null) {
            return $this->schema;
        }

        return $this->schema = new PgsqlSchema($this);
    }

    /**
     * Creates the PDO instance.
     *
     * This method is called by {@see open} to establish a DB connection. The default implementation will create a PHP
     * PDO instance. You may override this method if the default PDO needs to be adapted for certain DBMS.
     *
     * @return PDO the pdo instance
     */
    protected function createPdoInstance(): PDO
    {
        return new PDO($this->getDsn(), $this->getUsername(), $this->getPassword(), $this->getAttributes());
    }

    /**
     * Initializes the DB connection.
     *
     * This method is invoked right after the DB connection is established.
     *
     * The default implementation turns on `PDO::ATTR_EMULATE_PREPARES`.
     *
     * if {@see emulatePrepare} is true, and sets the database {@see charset} if it is not empty.
     *
     * It then triggers an {@see EVENT_AFTER_OPEN} event.
     */
    protected function initConnection(): void
    {
        if ($this->getPDO() !== null) {
            $this->getPDO()->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

            if ($this->getEmulatePrepare() !== null && constant('PDO::ATTR_EMULATE_PREPARES')) {

The method getEmulatePrepare() does not exist on Yiisoft\Db\Pgsql\Connection\PgsqlConnection.

                $this->getPDO()->setAttribute(PDO::ATTR_EMULATE_PREPARES, $this->getEmulatePrepare());
            }

            if ($this->getCharset() !== null) {

The method getCharset() does not exist on Yiisoft\Db\Pgsql\Connection\PgsqlConnection.

                $this->getPDO()->exec('SET NAMES ' . $this->getPDO()->quote($this->getCharset()));
            }
        }
    }
}