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

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.     public function getIterator()
  70.     {
  71.         return $this->getRows();
  72.     }
  74.     /**
  75.      * {@inheritDoc}
  76.      *
  77.      * @api
  78.      */
  79.     public function getColumnNames()
  80.     {
  81.         $columnNames = [];
  83.         foreach ($this->rows as $row) {
  84.             foreach ($row as $columns) {
  85.                 if ('jcr:path' !== substr($columns['dcr:name'], -8)
  86.                     && 'jcr:score' !== substr($columns['dcr:name'], -9)
  87.                 ) {
  88.                     // skip the meta information path and score that is also in the raw result table
  89.                     $columnNames[] = $columns['dcr:name'];
  90.                 }
  91.             }
  92.         }
  94.         return array_unique($columnNames);
  95.     }
  97.     /**
  98.      * {@inheritDoc}
  99.      *
  100.      * @api
  101.      */
  102.     public function getRows()
  103.     {
  104.         return $this->factory->get(RowIterator::class, [$this->objectmanager, $this->rows]);
  105.     }
  107.     /**
  108.      * {@inheritDoc}
  109.      *
  110.      * @api
  111.      */
  112.     public function getNodes($prefetch = false)
  113.     {
  114.         if ($prefetch !== true) {
  115.             return $this->factory->get(NodeIterator::class, [$this->objectmanager, $this->rows]);
  116.         }
  118.         $paths = [];
  120.         foreach ($this->getRows() as $row) {
  121.             $paths[] = $row->getPath();
  122.         }
  124.         return $this->objectmanager->getNodesByPath($paths);
  125.     }
  127.     /**
  128.      * {@inheritDoc}
  129.      *
  130.      * @api
  131.      */
  132.     public function getSelectorNames()
  133.     {
  134.         $selectorNames = [];
  136.         foreach ($this->rows as $row) {
  137.             foreach ($row as $column) {
  138.                 if (array_key_exists('dcr:selectorName', $column)) {
  139.                     $selectorNames[] = $column['dcr:selectorName'];
  140.                 }
  141.             }
  142.         }
  144.         return array_unique($selectorNames);
  145.     }
  146. }