Lagdo\DbAdmin\Driver\Db\Pdo\Connection

Complexity

Total Complexity

20

Size/Duplication

Total Lines	119
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	nextResult()	0	7	2
A	storedResult()	0	10	3
A	result()	0	12	5
A	dsn()	0	10	2
A	multiQuery()	0	4	1
A	serverInfo()	0	3	1
A	query()	0	15	4
A	close()	0	3	1
A	quote()	0	3	1

<?php

namespace Lagdo\DbAdmin\Driver\Db\Pdo;

use Exception;
use Lagdo\DbAdmin\Driver\Db\Connection as AbstractConnection;
use Lagdo\DbAdmin\Driver\Db\Pdo\Statement;
use Lagdo\DbAdmin\Driver\Exception\AuthException;
use PDO;

use function count;

abstract class Connection extends AbstractConnection
{
    /**
     * Create a PDO connection
     *
     * @param string $dsn
     * @param string $username
     * @param string $password
     * @param array $options
     *
     * @return void
     */
    public function dsn(string $dsn, string $username, string $password, array $options = [])
    {
        try {
            $this->client = new PDO($dsn, $username, $password, $options);
        } catch (Exception $ex) {
            // auth_error(h($ex->getMessage()));
            throw new AuthException($this->utils->str->html($ex->getMessage()));
        }
        $this->client->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
        $this->client->setAttribute(PDO::ATTR_STATEMENT_CLASS, array(Statement::class));
    }

    /**
     * @inheritDoc
     */
    public function serverInfo()
    {
        return @$this->client->getAttribute(PDO::ATTR_SERVER_VERSION);
    }

    /**
     * @inheritDoc
     */
    public function quote(string $string)
    {
        return $this->client->quote($string);
    }

    /**
     * @inheritDoc
     */
    public function query(string $query, bool $unbuffered = false)
    {
        $statement = $this->client->query($query);
        $this->driver->setError();
        if (!$statement) {
            list(, $errno, $error) = $this->client->errorInfo();
            $this->driver->setErrno($errno);
            $this->driver->setError(($error) ? $error : $this->utils->trans->lang('Unknown error.'));
            return false;
        }
        // rowCount() is not guaranteed to work with all drivers
        if (($statement->numRows = $statement->rowCount()) > 0) {
            $this->setAffectedRows($statement->numRows);
        }
        return $statement;
    }

    /**
     * @inheritDoc
     */
    public function multiQuery(string $query)
    {
        $this->statement = $this->driver->execute($query);
        return $this->statement !== false;
    }

    /**
     * @inheritDoc
     */
    public function storedResult()
    {
        if (!$this->statement) {
            return null;
        }
        // rowCount() is not guaranteed to work with all drivers
        if ($this->statement->rowCount() > 0) {
            $this->setAffectedRows($this->statement->rowCount());
        }
        return $this->statement;
    }

    /**
     * @inheritDoc
     */
    public function nextResult()
    {
        if (!$this->statement) {
            return false;
        }
        $this->statement->offset = 0;
        return $this->statement->nextRowset(); // @ - PDO_PgSQL doesn't support it
    }

    /**
     * @inheritDoc
     */
    public function result(string $query, int $field = -1)
    {
        if ($field < 0) {
            $field = $this->defaultField();
        }
        if (!($statement = $this->driver->execute($query))) {
            return null;
        }
        if (!($row = $statement->fetchRow())) {
            return null;
        }
        return count($row) > $field ? $row[$field] : null;
    }

    /**
     * @inheritDoc
     */
    public function close()
    {
        $this->client = null;
    }
}