Xiag\Rql\Parser\QueryBuilder

Complexity

Total Complexity

13

Size/Duplication

Total Lines	90
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

96.97%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
B	addNode()	0	14	5
A	getQuery()	0	4	1
A	addSelect()	0	6	1
A	addQuery()	0	13	3
A	addSort()	0	6	1
A	addLimit()	0	6	1
A	__construct()	0	4	1

<?php
namespace Xiag\Rql\Parser;

use Xiag\Rql\Parser\Exception\UnknownNodeException;
use Xiag\Rql\Parser\Node\SelectNode;
use Xiag\Rql\Parser\Node\AbstractQueryNode;
use Xiag\Rql\Parser\Node\SortNode;
use Xiag\Rql\Parser\Node\LimitNode;
use Xiag\Rql\Parser\Node\Query\LogicalOperator\AndNode;

class QueryBuilder
{
    /**
     * @var Query
     */
    protected $query;

    public function __construct()
    {
        $this->query = new Query();
    }

    /**
     * @param AbstractNode $node
     * @return $this
     */
    public function addNode(AbstractNode $node)
    {
        if ($node instanceof SelectNode) {
            return $this->addSelect($node);
        } elseif ($node instanceof AbstractQueryNode) {
            return $this->addQuery($node);
        } elseif ($node instanceof SortNode) {
            return $this->addSort($node);
        } elseif ($node instanceof LimitNode) {
            return $this->addLimit($node);
        }

        throw new UnknownNodeException(sprintf('Unknown node type "%s" (%s)', $node->getNodeName(), get_class($node)));
    }

    /**
     * @return Query
     */
    public function getQuery()
    {
        return $this->query;
    }

    /**
     * @param SelectNode $select
     * @return $this
     */
    public function addSelect(SelectNode $select)
    {
        $this->query->setSelect($select);

        return $this;
    }

    /**
     * @param AbstractQueryNode $query
     * @return $this
     */
    public function addQuery(AbstractQueryNode $query)
    {
        $current = $this->query->getQuery();
        if ($current === null) {
            $this->query->setQuery($query);
        } elseif ($current instanceof AndNode) {
            $current->addQuery($query);
        } else {
            $this->query->setQuery(new AndNode([$current, $query]));
        }

        return $this;
    }

    /**
     * @param SortNode $sort
     * @return $this
     */
    public function addSort(SortNode $sort)
    {
        $this->query->setSort($sort);

        return $this;
    }

    /**
     * @param LimitNode $limit
     * @return $this
     */
    public function addLimit(LimitNode $limit)
    {
        $this->query->setLimit($limit);

        return $this;
    }
}