Soupmix\SQLQueryBuilder

Complexity

Total Complexity

14

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

92%

Importance

Changes	8
Bugs	3	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
B	run()	0	22	4
A	getQueryBuilder()	0	8	2
A	getCount()	0	7	1
A	setSortOrders()	0	8	3
A	setReturnFields()	0	9	3
A	setOffsetAndLimit()	0	5	1

<?php

namespace Soupmix;


class SQLQueryBuilder extends AbstractQueryBuilder
{

    private $queryBuilder;

    public function run(){
        $this->queryBuilder = $this->getQueryBuilder();
        $count = $this->getCount();
        $numberOfRows = 0;
        $result = null;
        if (isset($count[0]['total']) && ($count[0]['total']>0)) {
            $numberOfRows = $count[0]['total'];
            $this->setSortOrders();
            $this->setReturnFields();
            $this->setOffsetAndLimit();
            $stmt = $this->soupmix->getConnection()
                ->executeQuery(
                    $this->queryBuilder->getSql(),
                    $this->queryBuilder->getParameters()
                );
            $result = $stmt->fetchAll(\PDO::FETCH_ASSOC);
            if($this->distinctFieldName !== null){
                $numberOfRows = count($result);
            }
        }
        return ['total' => $numberOfRows, 'data' => $result];
    }

    private function getQueryBuilder()
    {
        if ($this->orFilters !== null){
            $this->andFilters[] = $this->orFilters;
        }
        $this->filters      = $this->andFilters;
        return $this->soupmix->buildQuery($this->collection, $this->filters);
    }

    private function getCount()
    {
        $queryBuilderCount = clone $this->queryBuilder;
        $queryBuilderCount->select(" COUNT(*) AS total ");
        $stmt = $this->soupmix->getConnection()->executeQuery($queryBuilderCount->getSql(), $queryBuilderCount->getParameters());
        return $stmt->fetchAll(\PDO::FETCH_ASSOC);
    }

    private function setSortOrders()
    {
        if ($this->sortFields !== null) {
            foreach ($this->sortFields as $sortKey => $sortDir) {
                $this->queryBuilder->addOrderBy($sortKey, $sortDir);
            }
        }
    }

    private function setReturnFields()
    {
        if ($this->distinctFieldName === null) {
            $fieldNames = ($this->fieldNames === null) ? "*" : $this->fieldNames;
            $this->queryBuilder->select($fieldNames);
            return;
        }
        $this->queryBuilder->select('DISTINCT (`' . $this->distinctFieldName . '`)');
    }

    private function setOffsetAndLimit()
    {
        $this->queryBuilder->setFirstResult($this->offset)
            ->setMaxResults($this->limit);
    }
}