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

  1. <?php
  3. namespace Knp\Component\Pager\Event\Subscriber\Paginate\Doctrine;
  5. use Doctrine\DBAL\Query\QueryBuilder;
  6. use Knp\Component\Pager\Event\ItemsEvent;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. /**
  10.  * DBALQueryBuilderSubscriber.php
  11.  *
  12.  * @author Vladimir Chub <v@chub.com.ua>
  13.  */
  14. class DBALQueryBuilderSubscriber implements EventSubscriberInterface
  15. {
  16.     public function items(ItemsEvent $event): void
  17.     {
  18.         if ($event->target instanceof QueryBuilder) {
  19.             $target = $event->target;
  20.         
  21.             // count results
  22.             $qb = clone $target;
  23.             
  24.             //reset count orderBy since it can break query and slow it down
  25.             if (method_exists($qb, 'resetOrderBy')) {
  26.                 $qb->resetOrderBy();
  27.             } else {
  28.                 $qb->resetQueryParts(['orderBy']);
  29.             }
  31.             // get the query
  32.             $sql = $qb->getSQL();
  34.             $qb
  35.                 ->select('count(*) as cnt')
  36.             ;
  38.             $compat = $qb->executeQuery();
  39.             $event->count = method_exists($compat, 'fetchColumn') ? $compat->fetchColumn(0) : $compat->fetchOne();
  41.             // if there is results
  42.             $event->items = [];
  43.             if ($event->count) {
  44.                 $qb = clone $target;
  45.                 $qb
  46.                     ->setFirstResult($event->getOffset())
  47.                     ->setMaxResults($event->getLimit())
  48.                 ;
  49.                 
  50.                 $event->items = $qb
  51.                     ->executeQuery()
  52.                     ->fetchAllAssociative()
  53.                 ;
  54.             }
  55.             
  56.             $event->stopPropagation();
  57.         }
  58.     }
  60.     public static function getSubscribedEvents(): array
  61.     {
  62.         return [
  63.             'knp_pager.items' => ['items', 10 /*make sure to transform before any further modifications*/],
  64.         ];
  65.     }
  66. }