SimpleCrud\Queries\Select

Complexity

Total Complexity

10

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	2
A	one()	0	7	1
A	run()	0	12	3
A	getArray()	0	11	3
A	createRow()	0	9	1

<?php
declare(strict_types = 1);

namespace SimpleCrud\Queries;

use Closure;
use PDO;
use SimpleCrud\Row;
use SimpleCrud\Table;

class Select extends Query
{
    use Traits\HasRelatedWith;
    use Traits\HasPagination;
    use Traits\HasJoinRelation;

    private $one;
    protected const ALLOWED_METHODS = [
        'from',
        'columns',
        'join',
        'catJoin',
        'groupBy',
        'having',
        'orHaving',
        'orderBy',
        'catHaving',
        'where',
        'whereEquals',
        'orWhere',
        'catWhere',
        'limit',
        'offset',
        'distinct',
        'forUpdate',
        'setFlag',
        'bindValue',
    ];

    public function __construct(Table $table)
    {
        $this->table = $table;

        $this->query = $table->getDatabase()
            ->select()
            ->from((string) $table);

        foreach ($table->getFields() as $field) {
            $field->select($this->query);
        }
    }

    public function one(): self
    {
        $this->one = true;
        $this->query->limit(1);

The method limit does only exist in Atlas\Query\Delete and Atlas\Query\Select and Atlas\Query\Update, but not in Atlas\Query\Insert.

        return $this;
    }

    public function run()
    {
        $data = $this->getArray();

        if ($this->one) {
            return $data ? $this->createRow($data) : null;
        }

        $rows = array_map(Closure::fromCallable([$this, 'createRow']), $data);

        return $this->table->createCollection($rows);
    }

    public function getArray(): ?array
    {
        $statement = $this->__invoke();
        $statement->setFetchMode(PDO::FETCH_ASSOC);

        if ($this->one) {
            return $statement->fetch() ?: null;
        }

        return $statement->fetchAll();
    }

    private function createRow(array $data): Row
    {
        $data = $this->table->format($data);
        $fields = $this->table->getFields();
        $extraData = array_diff_key($data, $fields);
        $values = array_intersect_key($data, $fields);

        return $this->table->create($values)->setData($extraData);
    }
}