Phuria\UnderQuery\Query\Query

Complexity

Total Complexity

8

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

50%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getSQL()	0	4	1
A	__construct()	0	6	1
A	getParameters()	0	4	1
A	getConnection()	0	4	1
A	setParameter()	0	6	1
A	prepareStatement()	0	10	2
A	getResult()	0	7	1

<?php

/**
 * This file is part of UnderQuery package.
 *
 * Copyright (c) 2016 Beniamin Jonatan Šimko
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Phuria\UnderQuery\Query;

use Doctrine\DBAL\Driver\Connection as ConnectionInterface;
use Doctrine\DBAL\Driver\Statement as StatementInterface;
use Doctrine\DBAL\Driver\ResultStatement as ResultStatementInterface;
use Phuria\UnderQuery\Parameter\ParameterCollection;
use Phuria\UnderQuery\Parameter\ParameterCollectionInterface;

/**
 * @author Beniamin Jonatan Šimko <spam@simko.it>
 */
class Query implements QueryInterface
{
    /**
     * @var string
     */
    private $compiledSQL;

    /**
     * @var ParameterCollectionInterface
     */
    private $parameterCollection;

    /**
     * @var ConnectionInterface|null
     */
    private $connection;

    /**
     * @param string                   $compiledSQL
     * @param array                    $parameters
     * @param ConnectionInterface|null $connection
     */
    public function __construct($compiledSQL, array $parameters = [], ConnectionInterface $connection = null)
    {
        $this->compiledSQL = $compiledSQL;
        $this->parameterCollection = new ParameterCollection($parameters);
        $this->connection = $connection;
    }

    /**
     * @return string
     */
    public function getSQL()
    {
        return $this->compiledSQL;
    }

    /**
     * @return ParameterCollectionInterface
     */
    public function getParameters()
    {
        return $this->parameterCollection;
    }

    /**
     * @return ConnectionInterface|null
     */
    public function getConnection()
    {
        return $this->connection;
    }

    /**
     * @param int|string $name
     * @param mixed      $value
     *
     * @return $this
     */
    public function setParameter($name, $value)
    {
        $this->getParameters()->setValue($name, $value);

        return $this;
    }

    /**
     * @return StatementInterface
     */
    public function prepareStatement()
    {
        $stmt = $this->connection->prepare($this->getSQL());

        foreach ($this->getParameters()->toArray() as $parameter) {
            $stmt->bindValue($parameter->getName(), $parameter->getValue());
        }

        return $stmt;
    }

    /**
     * @return ResultStatementInterface
     */
    public function getResult()
    {
        $stmt = $this->prepareStatement();
        $stmt->execute();

        return $stmt;
    }
}