BenTools\SimpleDBAL\Model\Adapter\PDO\Result

Complexity

Total Complexity

48

Size/Duplication

Total Lines	231
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	1

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getLastInsertId()	0	4	1
A	count()	0	4	1
B	asArray()	0	23	9
B	asRow()	0	23	7
B	asList()	0	30	7
B	asValue()	0	28	9
B	getIterator()	0	26	7
A	shouldResetResultset()	0	4	4
A	resetResultset()	0	4	1
A	withoutStorage()	0	7	1

<?php

namespace BenTools\SimpleDBAL\Model\Adapter\PDO;

use BenTools\SimpleDBAL\Contract\ResultInterface;
use BenTools\SimpleDBAL\Model\Exception\DBALException;
use IteratorAggregate;
use PDO;
use PDOStatement;

class Result implements IteratorAggregate, ResultInterface
{
    /**
     * @var PDO
     */
    private $pdo;

    /**
     * @var Statement
     */
    private $stmt;

    /**
     * @var array
     */
    private $storage = [];

    /**
     * @var bool
     */
    private $storageEnabled = true;

    /**
     * Result constructor.
     * @param PDO $pdo
     * @param Statement $stmt
     */
    public function __construct(PDO $pdo, PDOStatement $stmt = null)
    {
        $this->pdo = $pdo;
        $this->stmt = $stmt;

It seems like $stmt can also be of type object<PDOStatement>. However, the property $stmt is declared as type object<BenTools\SimpleDBAL\Model\Adapter\PDO\Statement>. Maybe add an additional type check?

    }

    /**
     * @inheritDoc
     */
    public function getLastInsertId()
    {
        return $this->pdo->lastInsertId();
    }

    /**
     * @inheritDoc
     */
    public function count()
    {
        return $this->stmt->rowCount();

The method rowCount() does not seem to exist on object<BenTools\SimpleDBAL\Model\Adapter\PDO\Statement>.

    }

    /**
     * @inheritDoc
     */
    public function asArray(): array
    {
        if (null === $this->stmt) {
            throw new DBALException("No \PDOStatement object provided.");
        }
        if (!empty($this->storage['row']) || !empty($this->storage['value']) || !empty($this->storage['list']) || !empty($this->storage['yield'])) {
            $this->stmt->execute();

The method execute() does not seem to exist on object<BenTools\SimpleDBAL\Model\Adapter\PDO\Statement>.

        }
        if (empty($this->storage['array'])) {
            if ($this->shouldResetResultset()) {
                $this->resetResultset();
            }

            $result = $this->stmt->fetchAll(PDO::FETCH_ASSOC);

The method fetchAll() does not seem to exist on object<BenTools\SimpleDBAL\Model\Adapter\PDO\Statement>.

            if (true === $this->storageEnabled) {
                $this->storage['array'] = $result;
            }

            return $result;
        }
        return $this->storage['array'];
    }

    /**
     * @inheritDoc
     */
    public function asRow(): ?array
    {
        if (null === $this->stmt) {
            throw new DBALException("No \PDOStatement object provided.");
        }
        if (empty($this->storage['row'])) {
            if (isset($this->storage['array'][0])) {
                $this->storage['row'] = &$this->storage['array'][0];
            } else {
                if ($this->shouldResetResultset()) {
                    $this->resetResultset();
                }

                $result = $this->stmt->fetch(PDO::FETCH_ASSOC) ?: null;

The method fetch() does not seem to exist on object<BenTools\SimpleDBAL\Model\Adapter\PDO\Statement>.

                if (true === $this->storageEnabled) {
                    $this->storage['row'] = $result;
                }
                return $result;
            }
        }
        return $this->storage['row'];
    }

    /**
     * @inheritDoc
     */
    public function asList(): array
    {
        if (null === $this->stmt) {
            throw new DBALException("No \PDOStatement object provided.");
        }
        if (empty($this->storage['list'])) {
            if (!empty($this->storage['array'])) {
                $this->storage['list'] = array_column($this->storage['array'], array_keys($this->storage['array'][0])[0]);
            } else {
                if ($this->shouldResetResultset()) {
                    $this->resetResultset();
                }

                $generator = function (\PDOStatement $stmt) {
                    while ($value = $stmt->fetchColumn(0)) {
                        yield $value;
                    }
                };

                $result = iterator_to_array($generator($this->stmt));

                if (true === $this->storageEnabled) {
                    $this->storage['list'] = $result;
                }

                return $result;
            }
        }
        return $this->storage['list'];
    }

    /**
     * @inheritDoc
     */
    public function asValue()
    {
        if (null === $this->stmt) {
            throw new DBALException("No \PDOStatement object provided.");
        }
        if (empty($this->storage['value'])) {
            if (!empty($this->storage['list'][0])) {
                $this->storage['value'] = $this->storage['list'][0];
            } elseif (!empty($this->storage['row'])) {
                $this->storage['value'] = array_values($this->storage['row'])[0];
            } elseif (!empty($this->storage['array'])) {
                $this->storage['value'] = array_values($this->storage['array'][0])[0];
            } else {
                if ($this->shouldResetResultset()) {
                    $this->resetResultset();
                }

                $result = $this->stmt->fetchColumn(0) ?: null;

The method fetchColumn() does not seem to exist on object<BenTools\SimpleDBAL\Model\Adapter\PDO\Statement>.

                if (true === $this->storageEnabled) {
                    $this->storage['value'] = $result;
                }

                return $result;
            }
        }
        return $this->storage['value'];
    }


    /**
     * @inheritDoc
     */
    public function getIterator()
    {
        if (null === $this->stmt) {
            throw new DBALException("No \PDOStatement object provided.");
        }

        // If asArray() was called earlier, iterate over the stored resultset.
        if (!empty($this->storage['array'])) {
            foreach ($this->storage['array'] as $key => $value) {
                yield $key => $value;
            }
        } else {
            $wrappedStmt = $this->stmt;

            if ($this->shouldResetResultset()) {
                $this->resetResultset();
            }

            while ($row = $wrappedStmt->fetch(PDO::FETCH_ASSOC)) {

The method fetch() does not seem to exist on object<BenTools\SimpleDBAL\Model\Adapter\PDO\Statement>.

                if (empty($this->storage['yield'])) {
                    $this->storage['yield'] = true;
                }
                yield $row;
            }
        }
    }

    /**
     * If asRow(), asList() or asValue() was called earlier, the iterator may be incomplete.
     * In such case we need to rewind the iterator by executing the statement a second time.
     * You should avoid to call getIterator() and asRow(), etc. with the same resultset.
     *
     * @return bool
     */
    private function shouldResetResultset(): bool
    {
        return !empty($this->storage['row']) || !empty($this->storage['value']) || !empty($this->storage['list']) || !empty($this->storage['yield']);
    }

    /**
     * Reset the resultset.
     */
    private function resetResultset()
    {
        $this->stmt->execute();

The method execute() does not seem to exist on object<BenTools\SimpleDBAL\Model\Adapter\PDO\Statement>.

    }

    /**
     * @return ResultInterface
     */
    public function withoutStorage(): ResultInterface
    {
        $clone = clone $this;
        $clone->storage = [];
        $clone->storageEnabled = false;
        return $clone;
    }
}