vendor/jackalope/jackalope/src/Jackalope/Query/RowIterator.php line 89

Open in your IDE?
  1. <?php
  3. namespace Jackalope\Query;
  5. use Countable;
  6. use SeekableIterator;
  7. use OutOfBoundsException;
  8. use Jackalope\ObjectManager;
  9. use Jackalope\FactoryInterface;
  11. /**
  12.  * Iterator to efficiently iterate over the raw query result.
  13.  *
  14.  * @license http://www.apache.org/licenses Apache License Version 2.0, January 2004
  15.  * @license http://opensource.org/licenses/MIT MIT License
  16.  */
  17. class RowIterator implements SeekableIterator, Countable
  18. {
  19.     /**
  20.      * @var ObjectManager
  21.      */
  22.     protected $objectManager;
  24.     /**
  25.      * @var FactoryInterface
  26.      */
  27.     protected $factory;
  29.     /**
  30.      * @var array
  31.      */
  32.     protected $rows;
  34.     /**
  35.      * @var integer
  36.      */
  37.     protected $position = 0;
  39.     /**
  40.      * Create the iterator.
  41.      *
  42.      * @param FactoryInterface $factory       the object factory
  43.      * @param ObjectManager    $objectManager
  44.      * @param array            $rows          Raw data as described in QueryResult and \Jackalope\Transport\TransportInterface
  45.      */
  46.     public function __construct(FactoryInterface $factory, ObjectManager $objectManager, $rows)
  47.     {
  48.         $this->factory = $factory;
  49.         $this->objectManager = $objectManager;
  50.         $this->rows = $rows;
  51.     }
  53.     /**
  54.      * @param int $position
  55.      *
  56.      * @throws OutOfBoundsException
  57.      */
  58.     public function seek($position)
  59.     {
  60.         $this->position = $position;
  62.         if (!$this->valid()) {
  63.             throw new OutOfBoundsException("invalid seek position ($position)");
  64.         }
  65.     }
  67.     /**
  68.      * @return integer
  69.      */
  70.     public function count()
  71.     {
  72.         return count($this->rows);
  73.     }
  75.     public function rewind()
  76.     {
  77.         $this->position = 0;
  78.     }
  80.     public function current()
  81.     {
  82.         if (!$this->valid()) {
  83.             return null;
  84.         }
  86.         return $this->factory->get(Row::class, [$this->objectManager, $this->rows[$this->position]]);
  87.     }
  89.     public function key()
  90.     {
  91.         return $this->position;
  92.     }
  94.     public function next()
  95.     {
  96.         ++$this->position;
  97.     }
  99.     /**
  100.      * @return boolean
  101.      */
  102.     public function valid()
  103.     {
  104.         return isset($this->rows[$this->position]);
  105.     }
  106. }