SimpleCrud\Query\Select

Complexity

Total Complexity

8

Size/Duplication

Total Lines	83
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	22	2
A	one()	0	7	1
A	run()	0	15	3
A	formatRow()	0	8	2

<?php
declare(strict_types = 1);

namespace SimpleCrud\Query;

use Closure;
use PDO;
use SimpleCrud\Events\CreateSelectQuery;
use SimpleCrud\Table;

final class Select implements QueryInterface
{
    use Traits\Common;
    use Traits\HasRelatedWith;
    use Traits\HasPagination;
    use Traits\HasJoinRelation;

    private $one;
    private $allowedMethods = [
        'from',
        'join',
        'catJoin',
        'groupBy',
        'having',
        'orHaving',
        'orderBy',
        'catHaving',
        'where',
        'orWhere',
        'catWhere',
        'limit',
        'offset',
        'distinct',
        'forUpdate',
        'setFlag',
    ];

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

        $fields = array_map(
            function ($field) {
                return (string) $field;
            },
            array_values($table->getFields())
        );

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

        $eventDispatcher = $table->getEventDispatcher();

        if ($eventDispatcher) {
            $eventDispatcher->dispatch(new CreateSelectQuery($this));

new \SimpleCrud\Events\CreateSelectQuery($this) is of type object<SimpleCrud\Events\CreateSelectQuery>, but the function expects a object<Psr\EventDispatcher\object>.

        }
    }

    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->table->create($this->formatRow($data)) : null;
        }

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

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

    private function formatRow(array $data): array
    {
        foreach ($data as $fieldName => &$value) {
            $value = $this->table->{$fieldName}->format($value);
        }

        return $data;
    }
}