ArekX\PQL\Drivers\Pdo\PdoResultReader

Complexity

Total Complexity

11

Size/Duplication

Total Lines	105
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	getAllRows()	0	9	2
A	finalize()	0	4	1
A	getNextRow()	0	3	1
A	create()	0	3	1
A	getNextColumn()	0	3	1
A	reset()	0	8	2
A	getColumnRows()	0	9	2

<?php
/**
 * Copyright 2021 Aleksandar Panic
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

namespace ArekX\PQL\Drivers\Pdo;

use ArekX\PQL\Contracts\ResultReader;

/**
 * PDO Reader for reading data from Statements.
 */
class PdoResultReader implements ResultReader
{
    /**
     * Current statement in use.
     * @var \PDOStatement
     */
    public \PDOStatement $statement;

    /**
     * Current fetch mode.
     * @var int
     */
    public int $fetchMode = \PDO::FETCH_ASSOC;

    /**
     * Whether statement was executed.
     * @var bool
     */
    protected bool $isExecuted = false;

    /**
     * Constructor for PDO Result reader
     * @param \PDOStatement $statement Statement to be read from.
     */
    public function __construct(\PDOStatement $statement)
    {
        $this->statement = $statement;
    }


    /**
     * Create a reader from PDO statement.
     *
     * @param \PDOStatement $statement
     * @return static
     */
    public static function create(\PDOStatement $statement): static
    {
        return new static($statement);
    }

    /**
     * @inheritDoc
     */
    public function getAllRows(): array
    {
        $results = [];

        while (($row = $this->getNextRow()) !== false) {
            $results[] = $row;
        }

        return $results;
    }

    /**
     * @inheritDoc
     */
    public function getNextRow(): mixed
    {
        return $this->statement->fetch($this->fetchMode);
    }

    /**
     * @inheritDoc
     */
    public function getColumnRows($columnIndex = 0): array
    {
        $results = [];

        while (($column = $this->getNextColumn($columnIndex)) !== false) {
            $results[] = $column;
        }

        return $results;
    }

    /**
     * @inheritDoc
     */
    public function getNextColumn($columnIndex = 0): mixed
    {
        return $this->statement->fetchColumn($columnIndex);
    }

    /**
     * @inheritDoc
     */
    public function reset(): void
    {
        if ($this->isExecuted) {
            $this->finalize();
        }

        $this->statement->execute();
        $this->isExecuted = true;
    }

    /**
     * @inheritDoc
     */
    public function finalize(): void
    {
        $this->statement->closeCursor();
        $this->isExecuted = false;
    }
}