ZfcDatagrid\DataSource\Doctrine2

Complexity

Total Complexity

15

Size/Duplication

Total Lines	107
Duplicated Lines	23.36 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	12	12	3
A	getData()	0	4	1
C	execute()	13	70	11

<?php

namespace ZfcDatagrid\DataSource;

use Doctrine\ORM;
use Doctrine\ORM\Query\Expr;
use ZfcDatagrid\Column;
use ZfcDatagrid\Column\Type;
use ZfcDatagrid\DataSource\Doctrine2\Paginator as PaginatorAdapter;

class Doctrine2 extends AbstractDataSource
{
    /**
     * @var ORM\QueryBuilder
     */
    private $qb;

    /**
     * Data source.
     *
     * @param mixed $data
     */
    public function __construct($data)

This method seems to be duplicated in your project.

    {
        if ($data instanceof ORM\QueryBuilder) {
            $this->qb = $data;
        } else {
            $return = $data;
            if (is_object($data)) {
                $return = get_class($return);
            }
            throw new \InvalidArgumentException('Unknown data input...'.$return);
        }
    }

    /**
     * @return ORM\QueryBuilder
     */
    public function getData()
    {
        return $this->qb;
    }

    /**
     * @throws \Exception
     */
    public function execute()
    {
        $qb = $this->getData();

        /*
         * Step 1) Apply needed columns
         */
        $selectColumns = [];
        foreach ($this->getColumns() as $col) {

This code seems to be duplicated across your project.

            if (!$col instanceof Column\Select) {
                continue;
            }

            $colString = $col->getSelectPart1();
            if ($col->getSelectPart2() != '') {
                $colString .= '.'.$col->getSelectPart2();
            }
            $colString .= ' '.$col->getUniqueId();

            $selectColumns[] = $colString;
        }
        $qb->resetDQLPart('select');
        $qb->select($selectColumns);

        /*
         * Step 2) Apply sorting
         */
        if (!empty($this->getSortConditions())) {
            // Minimum one sort condition given -> so reset the default orderBy
            $qb->resetDQLPart('orderBy');

            foreach ($this->getSortConditions() as $key => $sortCondition) {
                /* @var $col \ZfcDatagrid\Column\AbstractColumn */
                $col = $sortCondition['column'];

                if (!$col instanceof Column\Select) {
                    throw new \Exception('This column cannot be sorted: '.$col->getUniqueId());
                }

                /* @var $col \ZfcDatagrid\Column\Select */
                $colString = $col->getSelectPart1();
                if ($col->getSelectPart2() != '') {
                    $colString .= '.'.$col->getSelectPart2();
                }

                if ($col->getType() instanceof Type\Number) {
                    $qb->addSelect('ABS('.$colString.') sortColumn'.$key);
                    $qb->add('orderBy', new Expr\OrderBy('sortColumn'.$key, $sortCondition['sortDirection']), true);

new \Doctrine\ORM\Query\Expr\OrderBy('sortColumn' . $key, $sortCondition['sortDirection']) is of type object<Doctrine\ORM\Query\Expr\OrderBy>, but the function expects a object<Doctrine\ORM\Query\Expr\Base>.

                } else {
                    $qb->add('orderBy', new Expr\OrderBy($col->getUniqueId(), $sortCondition['sortDirection']), true);

new \Doctrine\ORM\Query\Expr\OrderBy($col->getUniqueId(), $sortCondition['sortDirection']) is of type object<Doctrine\ORM\Query\Expr\OrderBy>, but the function expects a object<Doctrine\ORM\Query\Expr\Base>.

                }
            }
        }

        /*
         * Step 3) Apply filters
         */
        $filterColumn = new Doctrine2\Filter($qb);
        foreach ($this->getFilters() as $filter) {
            /* @var $filter \ZfcDatagrid\Filter */
            if ($filter->isColumnFilter() === true) {
                $filterColumn->applyFilter($filter);
            }
        }

        /*
         * Step 4) Pagination
         */
        $this->setPaginatorAdapter(new PaginatorAdapter($qb));
    }
}