Rougin\Windstorm\Doctrine\Builder

Complexity

Total Complexity

10

Size/Duplication

Total Lines	96
Duplicated Lines	0 %

Test Coverage

Coverage

95%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getSql()	0	29	5
A	__construct()	0	8	2
A	values()	0	14	2
A	set()	0	9	1

<?php

namespace Rougin\Windstorm\Doctrine;

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Query\QueryBuilder;
use Rougin\Windstorm\Doctrine\Builder\DeleteQuery;
use Rougin\Windstorm\Doctrine\Builder\InsertQuery;
use Rougin\Windstorm\Doctrine\Builder\SelectQuery;
use Rougin\Windstorm\Doctrine\Builder\UpdateQuery;

/**
 * Query Builder
 *
 * @package Windstorm
 * @author  Rougin Gutib <rougingutib@gmail.com>
 */
class Builder extends QueryBuilder
{
    /**
     * @var \Doctrine\DBAL\Platforms\AbstractPlatform
     */
    protected $platform;

    /**
     * Initializes the platform instance.
     *
     * @param \Doctrine\DBAL\Connection|\Doctrine\DBAL\Platforms\AbstractPlatform $platform
     */
    public function __construct($platform)
    {
        if ($platform instanceof Connection)
        {
            $platform = $platform->getDatabasePlatform();
        }

        $this->platform = $platform;
    }

    /**
     * Returns the complete SQL string.
     *
     * @return string
     */
    public function getSql()
    {
        $first = $this->getFirstResult();

        $max = $this->getMaxResults();

        $parts = $this->getQueryParts();

        switch ($this->getType()) {
            case self::INSERT:
                $sql = new InsertQuery($parts);

                break;
            case self::DELETE:
                $sql = new DeleteQuery($parts);

                break;
            case self::UPDATE:
                $sql = new UpdateQuery($parts);

                break;
            case self::SELECT:
            default:
                $sql = new SelectQuery($parts, $this->platform, $max, $first);

                break;
        }

        return (string) $sql->get();
    }

    /**
     * Sets a new value for a column in a bulk update query.
     *
     * @param  string $key
     * @param  mixed  $value
     * @return self
     */
    public function set($key, $value)
    {
        $parameters = $this->getParameters();

        $index = count((array) $parameters);

        $this->setParameter($index, $value);

        return $this->add('set', $key . ' = ?', true);
    }

    /**
     * Specifies values for an insert query indexed by column names.
     *
     * @param  array  $values
     * @return self
     */
    public function values(array $values)
    {
        $index = 0;

        foreach ($values as $key => $value)
        {
            $this->setParameter($index, $value);

            $index = $index + 1;

            $values[$key] = '?';
        }

        return $this->add('values', $values);

$values of type array is incompatible with the type string expected by parameter $sqlPart of Doctrine\DBAL\Query\QueryBuilder::add().

    }
}