<?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:----MoaWgrxh8oAkO7t3i9oWG5e1WVCv0NQMFWrxq5OVaUq6VO+Dz3/PxNbDF7XWjwD8jlCLQaOSg2NGbdhu8H6U4LpKvEg5AugSEf4JJXpYCTsgrbFe0R/aRV8zAfUbO86rnLWI+xMDhkWHyMXs6AtwoNcZP1RLLu7d/Hb3YWRO7XqJSMd4xJgI2adgo3T7umbW9VOOKXcCJxHjulIPeK/TaykEntMFIDA3MyPtJnHcex+ZVwW+odTdWZpPVXooEEZ3qpW8ArYRj+ukItk0YYTELzUkY5rYzXBKMbjUZdTq2VMaKbqgYJJeeH1J4xVvkwkJOoY7RBptobvkxn57U1IO2/IOsgjNnvWKcj7zXFV3Bm7yjbJ4UyaVfuOfdx2GVZKci1iIwOflcuX4GBzco78mTwOsHIsF+szUOedsDKNZeiPxXsh/vsem455DFgBELghddz1RR5Fh2y8i6d6Qofzkh0ggFClAXydfuDkSb/xV7WgKyd6brngZgYzuckwi6iSeWxlIvxClOKjjDWKY8XJLEPd9jvtLBElUvFARu1aG4YAYsYJEKI1ZhvizVtEhYcO0qjFcQMbvm30Aw0ifutW56oY9Hn7dJFA8BcLOjL0/Jmru/K3KGkZgyQ3/E7dDN6CiJE+lYBLxzkHRRBCCQV2i58JHcp98ro9QjDY0N306YiA=----ATTACHMENT:----NTkzNDExNjM5Mjc5MTQ0MCA2NDU5NzE3NDgzMDkyMTA0IDQ5NzE3ODkyMDg5ODc0NjE=