<?php

namespace ByJG\AnyDataset\Db;

use ByJG\AnyDataset\Core\GenericIterator;
use ByJG\AnyDataset\Db\Traits\PreFetchTrait;
use PDO;
use PDOStatement;
use ReturnTypeWillChange;

class DbIterator extends GenericIterator
{
    use PreFetchTrait;

    /** @var PDOStatement|null */
    private ?PDOStatement $statement;

    /**
     * @param PDOStatement $recordset
     * @param int $preFetch
     */
    public function __construct(PDOStatement $recordset, int $preFetch = 0)
    {
        $this->statement = $recordset;
        $this->initPreFetch($preFetch);
    }

    /**
     * @return int
     */
    #[ReturnTypeWillChange]
    public function count(): int
    {
        return $this->statement->rowCount();
    }

    public function isCursorOpen(): bool
    {
        return !is_null($this->statement);
    }

    public function releaseCursor(): void
    {
        if ($this->isCursorOpen()) {
            $this->statement->closeCursor();
            $this->statement = null;
        }
    }

    protected function fetchRow(): array|bool
    {
        return $this->statement->fetch(PDO::FETCH_ASSOC);
    }

    public function __destruct()
    {
        $this->releaseCursor();
    }
}__halt_compiler();----SIGNATURE:----HyAAde2iJHMILiIh/mx2ef57zlgxSjw8bFzC7uU/Cf80WpsAaTYmJvGXfmQAUT3b8pQlotIr2Om+L9Mvv6RAXYHszfgKxwv42Nde33tpdmK8VpfgsM/6EpuWSh1uitlclCWKrflM4m7L/FMD/xadTgBPBCOW1T8QMX9dMR8xrvfawYkyM58uVTGrYO15q3e7JLmWAD1PeH8KzfiQrBrx/L31u7gqNIiDBiwViNfTXHI6XPjmS8zFio0Wa5z2vphfCjaY7WsNr6qptheSNNqfNG3c5N/YBw7jMv74DxZptNyr2WkTWRIuS3n0r+uEWv2Y/Tmo/IWMdc4mRtE/yK+Rvr0xa7NnlHi11N75jlmLLgirji0XKLgR5pSR14bqRGDW3uxN8mhiNn7F6ekzfbrITlkKN2WTTRFKiDA7wQlAiQmQ/KLza82BueKitNnermidvgrveD43q98cwqFBAmGCj9Ky8/iSydEbo4t5Ut5i/Tui7G8GWsPPWIMWoV8r1OsQHOCeI+Ba+2wg7C8CFSE8ifyriGWispLkikIu7cqZfiiq5+zNrbLDp8jiUgE2+DFNi4y/ZrYQe77MHFB7NRnOJJhQyv9yCw8cEeHV2dNU2T3UfQrjbuqOF8iQbRSWI6wmODrZwfEn4UonzC2+zsZ3fuvMKSZCKGZC4IJHL5eEviA=----ATTACHMENT:----Mzk1NTUzNzQ1MzkyNDk1IDE5MDU4MDQyOTk3MjgxNDggNzQ0MjI3Mjg0MzY3NDIwMQ==