Fabfuel\Prophiler\Decorator\PDO\PDO

Complexity

Total Complexity

13

Size/Duplication

Total Lines	114
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	__call()	0	4	1
A	query()	0	12	2
A	exec()	0	11	2
A	prepare()	0	11	3
A	getPdo()	0	4	1
A	setPdo()	0	4	1
A	getProfiler()	0	4	1
A	setProfiler()	0	4	1

<?php
/**
 * @author @fabfuel <fabian@fabfuel.de>
 * @created 07.12.14, 13:12 
 */
namespace Fabfuel\Prophiler\Decorator\PDO;

use Fabfuel\Prophiler\ProfilerInterface;

/**
 * Class PDO
 * @package Fabfuel\Prophiler\Adapter\Pdo
 * @pattern decorator
 * @mixin \PDOStatement
 */
class PDO
{
    /**
     * @var \PDO
     */
    protected $pdo;

    /**
     * @var ProfilerInterface
     */
    protected $profiler;

    /**
     * @param \PDO $pdo
     * @param ProfilerInterface $profiler
     */
    public function __construct(\PDO $pdo, ProfilerInterface $profiler)
    {
        $this->setPdo($pdo);
        $this->setProfiler($profiler);
    }

    /**
     * @param string $name
     * @param array $arguments
     * @return mixed
     */
    public function __call($name, array $arguments)
    {
        return call_user_func_array([$this->getPdo(), $name], $arguments);
    }

    /**
     * @param string $statement
     * @return \PDOStatement
     */
    public function query($statement)
    {
        $metadata = ['statement' => $statement];
        $benchmark = $this->getProfiler()->start('PDO::query', [], 'Database');
        $result = $this->getPdo()->query($statement);
        if ($result instanceof \PDOStatement) {
            $metadata['rows'] = $result->rowCount();
            $metadata['columns'] = $result->columnCount();
        }
        $this->getProfiler()->stop($benchmark, $metadata);
        return $result;
    }

    /**
     * @param string $statement
     * @return int Number of rows affected
     */
    public function exec($statement)
    {
        $metadata = ['statement' => $statement];
        $benchmark = $this->getProfiler()->start('PDO::exec', [], 'Database');
        $result = $this->getPdo()->exec($statement);
        if ($result !== false) {
            $metadata['affected rows'] = $result;
        }
        $this->getProfiler()->stop($benchmark, $metadata);
        return $result;
    }

    /**
     * @param string $statement
     * @param array $options
     * @return PDOStatement|bool
     */
    public function prepare($statement, $options = null)
    {
        $benchmark = $this->getProfiler()->start('PDO::prepare', ['statement' => $statement], 'Database');
        $pdoStatement = $this->getPdo()->prepare($statement, $options ?: []);
        $this->getProfiler()->stop($benchmark);
        if (!$pdoStatement) {
            return false;
        }
        $profiledStatement = new PDOStatement($pdoStatement, $this->getProfiler());
        return $profiledStatement;
    }

    /**
     * @return \PDO
     */
    public function getPdo()
    {
        return $this->pdo;
    }

    /**
     * @param \PDO $pdo
     */
    public function setPdo(\PDO $pdo)
    {
        $this->pdo = $pdo;
    }

    /**
     * @return ProfilerInterface
     */
    public function getProfiler()
    {
        return $this->profiler;
    }

    /**
     * @param ProfilerInterface $profiler
     */
    public function setProfiler(ProfilerInterface $profiler)
    {
        $this->profiler = $profiler;
    }
}