<?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:----UDWjz+g64a090y0DfTT1DcMg6k/vgLRI2XYFPsYxgSRE3o6xJTccbzh6rAkrw/eyb2GWTVlT7ygYckYsdN/reLtauLC7EDm4mxelL2CJjPxAUOss1BldEpfmQwhp2G80jmzH5xuL5NKoQmPD+AJrvFaitX56/Gr1G4DYhnaqJElaHRX00PkvhWKFXA+VE3RvsPLEwW2hrOX4xfNykXqGAKZ8ac9txNqcMl8pIIkBw+orqfkLvmtu1upTZAhnYg+gW6bYzM7ALW9b4TTFMSSKqJgJ5OVQ6inx2zgabFxP30WkcIvW9z+Kc8+d6SoWdtOKJYNOg8R+s4ytPduPdsokWQsHlSm92kEX96X0OYr93pQUswkuodDganCka4R2CAZxzmk7uNFm5E8mKpJdrh1NCdzcV22LSJIyX7wFUhXaLaqI5oCK4jT720g+UHHIgyxO5gMGODBAgvb78bCqph/OKDtPJUA3LnUB8IL0GRo60+H3GxeF3Lk9dQVRdjrXfIa/f9frwNCeNJjQJ4rG4Gf2D7/YoTbsTZgPYhtEXp31KB5XgHrzy+LS0YCSVSzhRwVuWcMKSZt9q4aqLWDambuXEneMRUGK0BnQDKaUFRTZr/55QfwrRbA8bgbR5rOg0zwlHGs4oxs+ge1dnsJ9Ym8O7xR/5s2Qyut5MZAc/Ioj494=----ATTACHMENT:----MTc0MjQyMjE0Mzc3MzIyMCAzNjU2MzUxNDEyMzg3MzU1IDU2NjI5MDM5NzI1NTcxNjQ=