vendor/sulu/sulu/src/Sulu/Component/DocumentManager/Subscriber/Phpcr/QuerySubscriber.php line 87

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of Sulu.
  5.  *
  6.  * (c) Sulu GmbH
  7.  *
  8.  * This source file is subject to the MIT license that is bundled
  9.  * with this source code in the file LICENSE.
  10.  */
  12. namespace Sulu\Component\DocumentManager\Subscriber\Phpcr;
  14. use PHPCR\Query\QueryInterface;
  15. use PHPCR\Query\QueryManagerInterface;
  16. use PHPCR\SessionInterface;
  17. use Sulu\Component\DocumentManager\Collection\QueryResultCollection;
  18. use Sulu\Component\DocumentManager\Event\QueryCreateEvent;
  19. use Sulu\Component\DocumentManager\Event\QueryExecuteEvent;
  20. use Sulu\Component\DocumentManager\Events;
  21. use Sulu\Component\DocumentManager\Query\Query;
  22. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  23. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  25. /**
  26.  * Handles creation of query and query builder objects.
  27.  */
  28. class QuerySubscriber implements EventSubscriberInterface
  29. {
  30.     /**
  31.      * @var SessionInterface
  32.      */
  33.     private $session;
  35.     /**
  36.      * @var EventDispatcherInterface
  37.      */
  38.     private $eventDispatcher;
  40.     public function __construct(SessionInterface $session, EventDispatcherInterface $eventDispatcher)
  41.     {
  42.         $this->session = $session;
  43.         $this->eventDispatcher = $eventDispatcher;
  44.     }
  46.     public static function getSubscribedEvents()
  47.     {
  48.         return [
  49.             Events::QUERY_CREATE => ['handleCreate', 500],
  50.             Events::QUERY_CREATE_BUILDER => ['handleCreateBuilder', 500],
  51.             Events::QUERY_EXECUTE => ['handleQueryExecute', 500],
  52.         ];
  53.     }
  55.     /**
  56.      * Create a new Sulu Query object.
  57.      */
  58.     public function handleCreate(QueryCreateEvent $event)
  59.     {
  60.         $innerQuery = $event->getInnerQuery();
  62.         if (\is_string($innerQuery)) {
  63.             $phpcrQuery = $this->getQueryManager()->createQuery($innerQuery, QueryInterface::JCR_SQL2);
  64.         } elseif ($innerQuery instanceof QueryInterface) {
  65.             $phpcrQuery = $innerQuery;
  66.         } else {
  67.             throw new \InvalidArgumentException(\sprintf(
  68.                 'Expected inner query to be either a string or a PHPCR query object, got: "%s"',
  69.                 \is_object($innerQuery) ? \get_class($innerQuery) : \gettype($innerQuery)
  70.             ));
  71.         }
  73.         $event->setQuery(
  74.             new Query(
  75.                 $phpcrQuery,
  76.                 $this->eventDispatcher,
  77.                 $event->getLocale(),
  78.                 $event->getOptions(),
  79.                 $event->getPrimarySelector()
  80.             )
  81.         );
  82.     }
  84.     /**
  85.      * Handle query execution.
  86.      */
  87.     public function handleQueryExecute(QueryExecuteEvent $event)
  88.     {
  89.         $query = $event->getQuery();
  90.         $locale = $query->getLocale();
  91.         $phpcrResult = $query->getPhpcrQuery()->execute();
  93.         $event->setResult(
  94.             new QueryResultCollection($phpcrResult, $this->eventDispatcher, $locale, $event->getOptions())
  95.         );
  96.     }
  98.     /**
  99.      * @return QueryManagerInterface
  100.      */
  101.     private function getQueryManager()
  102.     {
  103.         return $this->session->getWorkspace()->getQueryManager();
  104.     }
  105. }