vendor/sulu/sulu/src/Sulu/Component/Content/Query/ContentQueryExecutor.php line 72

  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\Content\Query;
  14. use Jackalope\Query\Row;
  15. use Sulu\Component\Content\Mapper\ContentMapperInterface;
  16. use Sulu\Component\PHPCR\SessionManager\SessionManagerInterface;
  17. use Symfony\Component\Stopwatch\Stopwatch;
  19. /**
  20.  * Executes a query over the content.
  21.  */
  22. class ContentQueryExecutor implements ContentQueryExecutorInterface
  23. {
  24.     /**
  25.      * @var SessionManagerInterface
  26.      */
  27.     private $sessionManager;
  29.     /**
  30.      * @var ContentMapperInterface
  31.      */
  32.     private $contentMapper;
  34.     /**
  35.      * @var Stopwatch
  36.      */
  37.     private $stopwatch;
  39.     public function __construct(
  40.         SessionManagerInterface $sessionManager,
  41.         ContentMapperInterface $contentMapper,
  42.         Stopwatch $stopwatch = null
  43.     ) {
  44.         $this->sessionManager = $sessionManager;
  45.         $this->contentMapper = $contentMapper;
  46.         $this->stopwatch = $stopwatch;
  47.     }
  49.     public function execute(
  50.         $webspaceKey,
  51.         $locales,
  52.         ContentQueryBuilderInterface $contentQueryBuilder,
  53.         $flat = true,
  54.         $depth = -1,
  55.         $limit = null,
  56.         $offset = null,
  57.         $moveUp = false,
  58.         $permission = null
  59.     ) {
  60.         if ($this->stopwatch) {
  61.             $this->stopwatch->start('ContentQuery::execute.build-query');
  62.         }
  64.         list($sql2, $fields) = $contentQueryBuilder->build($webspaceKey, $locales);
  66.         if ($this->stopwatch) {
  67.             $this->stopwatch->stop('ContentQuery::execute.build-query');
  68.             $this->stopwatch->start('ContentQuery::execute.execute-query');
  69.         }
  71.         $query = $this->createSql2Query($sql2, $limit, $offset);
  72.         $queryResult = $query->execute();
  74.         if ($this->stopwatch) {
  75.             $this->stopwatch->stop('ContentQuery::execute.execute-query');
  76.             $this->stopwatch->start('ContentQuery::execute.preload-nodes.get-paths');
  77.         }
  79.         // this preloads all node which should are selected in the statement before
  80.         // prevent the system to load each node individual
  81.         $rootDepth = \substr_count($this->sessionManager->getContentPath($webspaceKey), '/');
  82.         $paths = [];
  83.         /** @var Row $row */
  84.         foreach ($queryResult as $row) {
  85.             $pageDepth = \substr_count($row->getPath('page'), '/') - $rootDepth;
  87.             if (null === $depth || $depth < 0 || ($depth > 0 && $pageDepth <= $depth)) {
  88.                 $paths[] = $row->getPath('page');
  89.             }
  90.         }
  92.         if ($this->stopwatch) {
  93.             $this->stopwatch->stop('ContentQuery::execute.preload-nodes.get-paths');
  94.             $this->stopwatch->start('ContentQuery::execute.preload-nodes.execute');
  95.         }
  97.         $this->sessionManager->getSession()->getNodes($paths);
  99.         if ($this->stopwatch) {
  100.             $this->stopwatch->stop('ContentQuery::execute.preload-nodes.execute');
  101.             $this->stopwatch->start('ContentQuery::execute.rowsToList');
  102.         }
  104.         $result = $this->contentMapper->convertQueryResultToArray(
  105.             $queryResult,
  106.             $webspaceKey,
  107.             $locales,
  108.             $fields,
  109.             $depth,
  110.             $contentQueryBuilder->getPublished(),
  111.             $permission
  112.         );
  114.         if ($this->stopwatch) {
  115.             $this->stopwatch->stop('ContentQuery::execute.rowsToList');
  116.         }
  118.         if (!$flat) {
  119.             if ($this->stopwatch) {
  120.                 $this->stopwatch->start('ContentQuery::execute.build-tree');
  121.             }
  123.             $converter = new ListToTreeConverter($moveUp);
  124.             $result = $converter->convert($result);
  126.             if ($this->stopwatch) {
  127.                 $this->stopwatch->stop('ContentQuery::execute.build-tree');
  128.             }
  129.         }
  131.         return $result;
  132.     }
  134.     /**
  135.      * returns a sql2 query.
  136.      */
  137.     private function createSql2Query($sql2, $limit = null, $offset = null)
  138.     {
  139.         $queryManager = $this->sessionManager->getSession()->getWorkspace()->getQueryManager();
  140.         $query = $queryManager->createQuery($sql2, 'JCR-SQL2');
  142.         if ($limit) {
  143.             $query->setLimit($limit);
  144.         }
  145.         if ($offset) {
  146.             $query->setOffset($offset);
  147.         }
  149.         return $query;
  150.     }
  151. }