Yiisoft\Db\Mssql\Connection

Complexity

Total Complexity

11

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Test Coverage

Coverage

70.83%

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	createCommand()	0	9	2
A	initConnection()	0	6	3
A	isSybase()	0	3	1
A	getDriverName()	0	3	1
A	sybase()	0	3	1
A	createPdoInstance()	0	9	2
A	getSchema()	0	3	1

<?php

declare(strict_types=1);

namespace Yiisoft\Db\Mssql;

use Yiisoft\Db\Connection\Connection as AbstractConnection;
use Yiisoft\Db\Command\Command;

use function in_array;

/**
 * Database connection class prefilled for MSSQL Server.
 */
final class Connection extends AbstractConnection
{
    private bool $isSybase = false;
    private ?Schema $schema = null;

    public function createCommand(?string $sql = null, array $params = []): Command
    {
        if ($sql !== null) {
            $sql = $this->quoteSql($sql);
        }

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

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

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

    public function isSybase(): bool
    {
        return $this->isSybase;
    }

    /**
     * @param bool $value set the database connected via pdo_dblib is SyBase, for default it's false.
     */
    public function sybase(bool $value): void
    {
        $this->isSybase = $value;
    }

    protected function createPdoInstance(): \PDO
    {
        if ($this->getDriverName() === 'sqlsrv') {
            $pdo = new SqlsrvPDO($this->getDsn(), $this->getUsername(), $this->getPassword(), $this->getAttributes());
        } else {
            $pdo = new PDO($this->getDsn(), $this->getUsername(), $this->getPassword(), $this->getAttributes());
        }

        return $pdo;
    }

    protected function initConnection(): void
    {
        $this->getPDO()->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

        if (!$this->isSybase && in_array($this->getDriverName(), ['mssql', 'dblib'], true)) {
            $this->getPDO()->exec('SET ANSI_NULL_DFLT_ON ON');
        }
    }

    /**
     * Returns the name of the DB driver.
     *
     * @return string name of the DB driver
     */
    public function getDriverName(): string
    {
        return 'sqlsrv';
    }
}