Brouzie\Sphinxy\Connection\PdoConnection

Complexity

Total Complexity

14

Size/Duplication

Total Lines	83
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

76.92%

Importance

Changes	6
Bugs	1	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	query()	0	14	2
A	multiQuery()	0	20	4
A	exec()	0	10	2
A	quote()	0	10	2
A	initialize()	0	10	3

<?php

namespace Brouzie\Sphinxy\Connection;

use Brouzie\Sphinxy\Exception\ConnectionException;

class PdoConnection implements ConnectionInterface
{
    /**
     * @var \PDO
     */
    private $pdo;

    private $dsn;

    public function __construct($dsn)
    {
        $this->dsn = $dsn;
    }

    public function query($query)
    {
        $this->initialize();

        try {
            $stmt = $this->pdo->query($query);
        } catch (\PDOException $e) {
            throw new ConnectionException($e->getMessage(), $e->getCode(), $e);
        }

        $result = $stmt->fetchAll(\PDO::FETCH_ASSOC);

        return $result;
    }

    public function multiQuery($query, array $resultSetNames = array())
    {
        $this->initialize();

        try {
            $stmt = $this->pdo->query($query);
        } catch (\PDOException $e) {
            throw new ConnectionException($e->getMessage(), $e->getCode(), $e);
        }

        $results = array();
        $i = 0;
        do {
            $key = isset($resultSetNames[$i]) ? $resultSetNames[$i] : $i;
            $results[$key] = $stmt->fetchAll(\PDO::FETCH_ASSOC);
            $i++;
        } while ($stmt->nextRowset());

        return $results;
    }

    public function exec($query)
    {
        $this->initialize();

        try {
            return $this->pdo->exec($query);
        } catch (\PDOException $e) {
            throw new ConnectionException($e->getMessage(), $e->getCode(), $e);
        }
    }

    public function quote($value)
    {
        $this->initialize();

        if (false === $value = $this->pdo->quote((string)$value)) {
            throw new ConnectionException($this->pdo->errorInfo(), $this->pdo->errorCode());
        }

        return $value;
    }

    protected function initialize()
    {
        if (null === $this->pdo) {
            try {
                $this->pdo = new \PDO($this->dsn, null, null, array(\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION));
            } catch (\PDOException $e) {
                throw new ConnectionException($e->getMessage(), $e->getCode(), $e);
            }
        }
    }
}