<?php

namespace ByJG\AnyDataset\Db;

use ByJG\AnyDataset\Core\Exception\IteratorException;
use ByJG\AnyDataset\Core\GenericIterator;
use ByJG\AnyDataset\Core\Row;
use ByJG\Serializer\Exception\InvalidArgumentException;
use PDO;
use PDOStatement;

class DbIterator extends GenericIterator
{
    const RECORD_BUFFER = 50;

    private $rowBuffer;
    private $currentRow = 0;

    /** @var PDOStatement */
    private $statement;

    /**
     * @param PDOStatement $recordset
     */
    public function __construct($recordset)
    {
        $this->statement = $recordset;
        $this->rowBuffer = array();
    }

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

    /**
     * @return bool
     * @throws InvalidArgumentException
     */
    public function hasNext()
    {
        if (count($this->rowBuffer) >= DbIterator::RECORD_BUFFER) {
            return true;
        }

        if (is_null($this->statement)) {
            return (count($this->rowBuffer) > 0);
        }

        $rowArray = $this->statement->fetch(PDO::FETCH_ASSOC);
        if (!empty($rowArray)) {
            $singleRow = new Row($rowArray);

            $this->rowBuffer[] = $singleRow;
            if (count($this->rowBuffer) < DbIterator::RECORD_BUFFER) {
                $this->hasNext();
            }

            return true;
        }

        $this->statement->closeCursor();
        $this->statement = null;

        return (count($this->rowBuffer) > 0);
    }

    /**
     * @return Row
     * @throws IteratorException
     * @throws InvalidArgumentException
     */
    public function moveNext()
    {
        if (!$this->hasNext()) {
            throw new IteratorException("No more records. Did you used hasNext() before moveNext()?");
        } else {
            $singleRow = array_shift($this->rowBuffer);
            $this->currentRow++;
            return $singleRow;
        }
    }

    public function key()
    {
        return $this->currentRow;
    }
}__halt_compiler();----SIGNATURE:----szdKjyHgEC2Z/2xMDMR3gU8XXTYAHD5AmB6b3mpEddFmUZ0YgMTpyXlBAiaQ5a1YRXQSvucNwpPYclVWTig+drf6dYBV+scCQo1e0odyxwIBz2/8519LSIh1R+qPbXcE1nVtDTzQEs3+bPUr9s1UzT0oDz3qUgEX3JSp2BeFTCmOOM2Nfe4ZOK+0tEH4cH/ZLmL6wvCPHJPY/ygjr6jucK9ez9wuQXzq0xGzMEGG+vGJmpRHWd5YZHDPT+F3tsh8EzYqoUAKFW58Ge+Q9S8FdvajC1FV8KnW6DcfzoNfVOO9zgmzedU7exKcdFwgZ2AryxesdnVm6xUb0nOC5FaD7l72hkwEbPxDBB3tQrp7izzfPLqnigz8Xs4EwzwP8N3mGBpWtKHJF9HFOqyKEXGSS4RSYe45kaVfKMaTAmE1oWQCx4XnTHRixtSBROM3/XTny9duigZwzuBGDdQudW/+OBjqN31OTXDsnQUfjnbsXWoWZpveB3LsXXIefjee9AEk7fjGaO+7OR+ocUfgGfl4gFEobuuREUlFGALSHfftQicI/lFOnlbRsTV4hz/Xg2C/EkEGB3wJSEjxL+EN8aeE7dx3kGKXlgSkOp8obK8ApKTEHmaOex5ckGLmTwPFo+716DZUIsMEWLgyChEoqevr313h2b+VGoeEbXgUWoa9hgA=----ATTACHMENT:----OTk1NTUxMzQ2NjQwNzM1NCAzNjc0MjU5MDI0NTY2MzkzIDg4NzEyMjg0NDUxOTc4NTM=