vendor/jackalope/jackalope/src/Jackalope/Query/QueryResult.php line 105

Open in your IDE?
  1. <?php
  3. namespace Jackalope\Query;
  5. use Iterator;
  6. use Jackalope\ObjectManager;
  7. use Jackalope\FactoryInterface;
  8. use PHPCR\Query\QueryResultInterface;
  9. use IteratorAggregate;
  10. use PHPCR\RepositoryException;
  12. /**
  13.  * {@inheritDoc}
  14.  *
  15.  * @license http://www.apache.org/licenses Apache License Version 2.0, January 2004
  16.  * @license http://opensource.org/licenses/MIT MIT License
  17.  *
  18.  * @api
  19.  */
  20. class QueryResult implements IteratorAggregate, QueryResultInterface
  21. {
  22.     /**
  23.      * @var ObjectManager
  24.      */
  25.     protected $objectmanager;
  27.     /**
  28.      * @var FactoryInterface
  29.      */
  30.     protected $factory;
  32.     /**
  33.      * Storing the query result raw data
  34.      * @see QueryInterface::query()
  35.      * @var array
  36.      */
  37.     protected $rows = [];
  39.     /**
  40.      * Create a new query result from raw data from transport.
  41.      *
  42.      * @see QueryInterface::query() The raw data format
  43.      *
  44.      * @param FactoryInterface $factory       the object factory
  45.      * @param array            $rawData       the data as returned by the transport
  46.      * @param ObjectManager    $objectManager
  47.      */
  48.     public function __construct(FactoryInterface $factory, $rawData, ObjectManager $objectManager)
  49.     {
  50.         $this->factory = $factory;
  51.         $this->rows = $rawData;
  52.         $this->objectmanager = $objectManager;
  53.     }
  55.     /**
  56.      * Implement the IteratorAggregate interface and returns exactly the same
  57.      * iterator as QueryResult::getRows()
  58.      *
  59.      * @return Iterator implementing <b>SeekableIterator</b> and <b>Countable</b>.
  60.      *      Keys are the row position in this result set, Values are the
  61.      *      RowInterface instances.
  62.      *
  63.      * @throws RepositoryException if this call is the second time
  64.      *      getIterator(), getRows() or getNodes() has been called on the same
  65.      *      QueryResult object or if another error occurs.
  66.      *
  67.      * @api
  68.      */
  69.     #[\ReturnTypeWillChange]
  70.     public function getIterator()
  71.     {
  72.         return $this->getRows();
  73.     }
  75.     /**
  76.      * {@inheritDoc}
  77.      *
  78.      * @api
  79.      */
  80.     public function getColumnNames()
  81.     {
  82.         $columnNames = [];
  84.         foreach ($this->rows as $row) {
  85.             foreach ($row as $columns) {
  86.                 if ('jcr:path' !== substr($columns['dcr:name'], -8)
  87.                     && 'jcr:score' !== substr($columns['dcr:name'], -9)
  88.                 ) {
  89.                     // skip the meta information path and score that is also in the raw result table
  90.                     $columnNames[] = $columns['dcr:name'];
  91.                 }
  92.             }
  93.         }
  95.         return array_unique($columnNames);
  96.     }
  98.     /**
  99.      * {@inheritDoc}
  100.      *
  101.      * @api
  102.      */
  103.     public function getRows()
  104.     {
  105.         return $this->factory->get(RowIterator::class, [$this->objectmanager, $this->rows]);
  106.     }
  108.     /**
  109.      * {@inheritDoc}
  110.      *
  111.      * @api
  112.      */
  113.     public function getNodes($prefetch = false)
  114.     {
  115.         if ($prefetch !== true) {
  116.             return $this->factory->get(NodeIterator::class, [$this->objectmanager, $this->rows]);
  117.         }
  119.         $paths = [];
  121.         foreach ($this->getRows() as $row) {
  122.             $paths[] = $row->getPath();
  123.         }
  125.         return $this->objectmanager->getNodesByPath($paths);
  126.     }
  128.     /**
  129.      * {@inheritDoc}
  130.      *
  131.      * @api
  132.      */
  133.     public function getSelectorNames()
  134.     {
  135.         $selectorNames = [];
  137.         foreach ($this->rows as $row) {
  138.             foreach ($row as $column) {
  139.                 if (array_key_exists('dcr:selectorName', $column)) {
  140.                     $selectorNames[] = $column['dcr:selectorName'];
  141.                 }
  142.             }
  143.         }
  145.         return array_unique($selectorNames);
  146.     }
  147. }