SimpleCrud\Queries\Select

Complexity

Total Complexity

9

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	2
A	one()	0	7	1
A	run()	0	15	3
A	createRow()	0	16	3

<?php
declare(strict_types = 1);

namespace SimpleCrud\Queries;

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

final 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',
        'orWhere',
        'catWhere',
        'limit',
        'offset',
        'distinct',
        'forUpdate',
        'setFlag',
    ];

    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()
    {
        $statement = $this->__invoke();
        $statement->setFetchMode(PDO::FETCH_ASSOC);

        if ($this->one) {
            $data = $statement->fetch();

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

        $rows = array_map(Closure::fromCallable([$this, 'createRow']), $statement->fetchAll());

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

    private function createRow(array $data): Row
    {
        $values = [];
        $extraData = [];
        $fields = $this->table->getFields();

        foreach ($data as $name => $value) {
            if (isset($fields[$name])) {
                $values[$name] = $fields[$name]->format($value);
            } else {
                $extraData[$name] = $value;
            }
        }

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