vendor/knplabs/knp-components/src/Knp/Component/Pager/Event/Subscriber/Paginate/Doctrine/ORM/QuerySubscriber.php line 16

Open in your IDE?
  1. <?php
  3. namespace Knp\Component\Pager\Event\Subscriber\Paginate\Doctrine\ORM;
  5. use Doctrine\ORM\Query;
  6. use Doctrine\ORM\Tools\Pagination\CountWalker;
  7. use Doctrine\ORM\Tools\Pagination\Paginator;
  8. use Knp\Component\Pager\Event\ItemsEvent;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class QuerySubscriber implements EventSubscriberInterface
  12. {
  13.     public const HINT_COUNT = 'knp_paginator.count';
  14.     public const HINT_FETCH_JOIN_COLLECTION = 'knp_paginator.fetch_join_collection';
  16.     public function items(ItemsEvent $event): void
  17.     {
  18.         if (!$event->target instanceof Query) {
  19.             return;
  20.         }
  21.         $event->stopPropagation();
  23.         $useOutputWalkers = $event->options['wrap-queries'] ?? false;
  25.         $event->target
  26.             ->setFirstResult($event->getOffset())
  27.             ->setMaxResults($event->getLimit())
  28.             ->setHint(CountWalker::HINT_DISTINCT, $event->options['distinct'])
  29.         ;
  31.         $fetchJoinCollection = true;
  32.         if ($event->target->hasHint(self::HINT_FETCH_JOIN_COLLECTION)) {
  33.             $fetchJoinCollection = $event->target->getHint(self::HINT_FETCH_JOIN_COLLECTION);
  34.         } else if (isset($event->options['distinct'])) {
  35.             $fetchJoinCollection = $event->options['distinct'];
  36.         }
  38.         $paginator = new Paginator($event->target, $fetchJoinCollection);
  39.         $paginator->setUseOutputWalkers($useOutputWalkers);
  40.         if (($count = $event->target->getHint(self::HINT_COUNT)) !== false) {
  41.             $event->count = (int) $count;
  42.         } else {
  43.             $event->count = count($paginator);
  44.         }
  45.         $event->items = iterator_to_array($paginator);
  46.     }
  48.     public static function getSubscribedEvents(): array
  49.     {
  50.         return [
  51.             'knp_pager.items' => ['items', 0],
  52.         ];
  53.     }
  54. }