Igni\Storage\Driver\Pdo\Connection

Complexity

Total Complexity

16

Size/Duplication

Total Lines	99
Duplicated Lines	0 %

Test Coverage

Coverage

70%

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	quote()	0	3	1
A	beginTransaction()	0	3	1
A	__construct()	0	4	1
A	getBaseConnection()	0	4	1
A	commit()	0	3	1
A	open()	0	11	2
A	inTransaction()	0	3	1
A	execute()	0	13	4
A	log()	0	3	1
A	rollBack()	0	3	1
A	close()	0	3	1
A	isOpen()	0	3	1

<?php declare(strict_types=1);

namespace Igni\Storage\Driver\Pdo;

use Igni\Storage\Driver\Connection as ConnectionInterface;
use Igni\Storage\Exception\ConnectionException;
use PDO;

final class Connection implements ConnectionInterface
{
    /** @var PDO|null */
    private $handler;

    /** @var string */
    private $dsn;

    /** @var ConnectionOptions */
    private $options;

    /** @var array */
    private $queryLog = [];

    public function __construct(string $dsn, ConnectionOptions $options = null)
    {
        $this->dsn = $dsn;
        $this->options = $options ?? new ConnectionOptions();
    }

    public function close(): void
    {
        $this->handler = null;
    }

    public function open(): void
    {
        if ($this->isOpen()) {
            return;
        }

        $this->handler = new PDO(
            $this->dsn,
            $this->options->getUsername(),
            $this->options->getPassword(),
            $this->options->getAttributes()
        );
    }

    public function isOpen(): bool
    {
        return $this->handler !== null;
    }

    /**
     * @param string $query
     * @param array $parameters
     * @return Cursor
     * @throws ConnectionException
     */
    public function execute(...$parameters): Cursor
    {
        if (!$this->isOpen()) {
            $this->open();
        }

        $query = $parameters[0];

        if (isset($parameters[1]) && is_array($parameters[1])) {
            return new Cursor($this, $query, $parameters[1]);
        }

        return new Cursor($this, $query);
    }

    public function beginTransaction(): bool
    {
        return $this->handler->beginTransaction();

The method beginTransaction() does not exist on null.

    }

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

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

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

    public function quote($string): string
    {
        return $this->handler->quote((string) $string);
    }

    public function getBaseConnection(): PDO
    {
        $this->open();
        return $this->handler;
    }

    public function log(string $query)
    {
        $this->queryLog[] = $query;
    }
}