Как вы получаете количество оставшихся записей для выборки подмножеств?

Question

[Игорь]

Как вы получаете количество оставшихся записей для выборки подмножеств?
Поделитесь опытом.

Я например делаю вот так.
Может возможно сделать иначе?

/**
 * @method SupplierJournal|null find($id, $lockMode = null, $lockVersion = null)
 * @method SupplierJournal|null findOneBy(array $criteria, array $orderBy = null)
 * @method SupplierJournal[]    findAll()
 * @method SupplierJournal[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
 */
class SupplierJournalRepository extends ServiceEntityRepository implements RepositoryInterface
{
    private int $last_count_query = 0;

    /**
     * SupplierJournalRepository constructor.
     * @param ManagerRegistry $registry
     */
    public function __construct(ManagerRegistry $registry)
    {
        parent::__construct($registry, SupplierJournal::class);
    }

    /**
     * @param int $supplier_id
     * @param int $count
     * @param int $offset
     * @return mixed
     */
    public function findBySupplierId(int $supplier_id, int $offset = 0, int $count = 100)
    {
        $qb = $this->createQueryBuilder('sj');
        $qb = $qb->andWhere("sj.supplier = :supplier_id")
            ->setParameter("supplier_id", $supplier_id);

        try {
            $this->last_count_query = $qb
                ->select("count(sj)")
                ->getQuery()
                ->enableResultCache(3600)
                ->getSingleScalarResult();
        } catch (NoResultException $e) {
            $this->last_count_query = 0;
        } catch (NonUniqueResultException $e) {
            $this->last_count_query = 0;
        }

        return $qb
            ->select("sj")
            ->orderBy('sj.datetime', 'ASC')
            ->setFirstResult($offset)
            ->setMaxResults($count)
            ->getQuery()
            ->getResult();
    }


    public function countLastQuery(): int
    {
        return $this->last_count_query;
    }
}

В контроллере.

...
public function getActionList()
    {
        $journal = $this->journal_repository->findBySupplierId($this->account->getUserId());
        $count = $this->journal_repository->countLastQuery();
 ...

Спасибо.

Comments

[BoShurik]

А зачем? Для пагинации?

[Игорь]

BoShurik, Да
Конечно.

Схема такая

{
    "count": 2,
    "response": [
        {
            "datetime": 1596793491,
            "type": "x",
            "action": "set"
        },
        {
            "datetime": 1596795963,
            "type": "d",
            "action": "dd"
        }
    ]
}

Answer 1

[BoShurik]

https://github.com/BabDev/Pagerfanta

use Pagerfanta\Pagerfanta;

class PaginatedCollection
{
    private int $page;
    private int $size;
    private int $total;
    private int $pages;
    private array $items;

    public function __construct(Pagerfanta $pagerfanta)
    {
        $this->page = $pagerfanta->getCurrentPage();
        $this->size = $pagerfanta->getMaxPerPage();
        $this->total = $pagerfanta->getNbResults();
        $this->pages = $pagerfanta->getNbPages();
        $this->items = iterator_to_array($pagerfanta);
    }

    public function getPage(): int
    {
        return $this->page;
    }

    public function getSize(): int
    {
        return $this->size;
    }

    public function getTotal(): int
    {
        return $this->total;
    }

    public function getPages(): int
    {
        return $this->pages;
    }

    public function getItems(): array
    {
        return $this->items;
    }
}

// Repository
public function findPaginatedBySupplierId(int $supplier_id)
{
    return new Pagerfanta(DoctrineORMAdapter($this->getSupplierIdQueryBuilder($supplier_id)));
}

private function getSupplierIdQueryBuilder(int $supplier_id)
{
    $qb = $this->createQueryBuilder('sj');
    $qb = $qb
        ->select("sj")
        ->orderBy('sj.datetime', 'ASC')
        ->andWhere("sj.supplier = :supplier_id")
        ->setParameter("supplier_id", $supplier_id);

    return $qb;
}

// Controller
public function action()
{
    // ...
    return $this->json($this->paginatedCollection($repository->findPaginatedBySupplierId($id), $request));
}

// AbstractController
protected function paginatedCollection(Pagerfanta $pagination, Request $request, int $size = 20): PaginatedCollection
{
    $pagination = $this->paginate($pagination, $request, $size);

    return new PaginatedCollection($pagination);
}

protected function paginate(Pagerfanta $pagination, Request $request, int $size = 20): Pagerfanta
{
    $pagination->setMaxPerPage($size);
    $pagination->setCurrentPage($request->query->getInt('page', 1));

    return $pagination;
}

{
    "page": 1,
    "size": 20,
    "total": 76,
    "pages": 4,
    "items": [...]
}

Comments

[Игорь]

Ну а в итоге в чем профит?
Мы экономим количество запросов к базе?

[BoShurik]

Игорь, нет. Но сравните количество кода в репозитории у вас и у меня. При добавлении новых сущностей вам в каждом репозитории и методе придется реализовывать public function countLastQuery(): int.
Это уж не говоря о том, что стейт у репозитория пахнет плохо

[Игорь]

BoShurik, Где вы спалили мой репозиторий?

Вы предлагаете в контроллере дополнительно создавать методы

// Controller
public function action()
{
    // ...
    return $this->json($this->paginatedCollection($repository->findPaginatedBySupplierId($id), $request));
}

protected function paginatedCollection(Pagerfanta $pagination, Request $request, int $size = 20): PaginatedCollection
{
    $pagination = $this->paginate($pagination, $request, $size);

    return new PaginatedCollection($pagination);
}

protected function paginate(Pagerfanta $pagination, Request $request, int $size = 20): Pagerfanta
{
    $pagination->setMaxPerPage($size);
    $pagination->setCurrentPage($request->query->getInt('page', 1));

    return $pagination;
}

У меня десятки контроллеров и в некоторых есть пагинация.
Судя по тому что вы мне предложили, мне нужно дополнительно создать в каждом классе контроллера дополнительно методы.

Вот здесь я не понимаю, где экономия?

Спасибо.

[BoShurik]

Игорь, это всего лишь хелперы, которые лежат в абстрактном контроллере. Можно легко заменить на:

$pagination = $repository->findPaginatedBySupplierId($id);
$pagination->setMaxPerPage($size);
$pagination->setCurrentPage($request->query->getInt('page', 1));

$this->json(new PaginatedCollection($pagination));

[BoShurik]

PaginatedCollection и хелперы - это то, что нужно настроить один раз и больше про пагинацию не вспоминать. Профит в этом.

[Игорь]

Давайте по существу, что бы не разводить холивар.

Чем способ предложенный вами, лучше, чем нативный, средствами репозитория доктрины?

/**
 * @method SupplierJournal|null find($id, $lockMode = null, $lockVersion = null)
 * @method SupplierJournal|null findOneBy(array $criteria, array $orderBy = null)
 * @method SupplierJournal[]    findAll()
 * @method SupplierJournal[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
 */
class SupplierJournalRepository extends ServiceEntityRepository implements RepositoryInterface
{
    private int $last_count_query = 0;

    /**
     * SupplierJournalRepository constructor.
     * @param ManagerRegistry $registry
     */
    public function __construct(ManagerRegistry $registry)
    {
        parent::__construct($registry, SupplierJournal::class);
    }

    /**
     * @param int $supplier_id
     * @param int $count
     * @param int $offset
     * @return mixed
     */
    public function findBySupplierId(int $supplier_id, int $offset = 0, int $count = 100)
    {
        $qb = $this->createQueryBuilder('sj');
        $qb = $qb->andWhere("sj.supplier = :supplier_id")
            ->setParameter("supplier_id", $supplier_id);

        try {
            $this->last_count_query = $qb
                ->select("count(sj)")
                ->getQuery()
                ->enableResultCache(3600)
                ->getSingleScalarResult();
        } catch (NoResultException $e) {
            $this->last_count_query = 0;
        } catch (NonUniqueResultException $e) {
            $this->last_count_query = 0;
        }

        return $qb
            ->select("sj")
            ->orderBy('sj.datetime', 'ASC')
            ->setFirstResult($offset)
            ->setMaxResults($count)
            ->getQuery()
            ->getResult();
    }


    public function countLastQuery(): int
    {
        return $this->last_count_query;
    }
}

Я ведь не спроста спросил.
Я надеялся сэкономить на запросах.
Ну и по возможности на количестве кода.

[Игорь]

PaginatedCollection и хелперы - это то, что нужно настроить один раз и больше про пагинацию не вспоминать. Профит в этом.

Спасибо.

[BoShurik]

Сэкономить на запросах вам поможет, например, SQL_CALC_FOUND_ROWS и FOUND_ROWS https://stackoverflow.com/a/818621/1247234 для MySQL, но сомневаюсь, что доктрина это поддерживает

[BoShurik]

Игорь,
плюс, под капотом используется Doctrine Paginator, если не нравится абстрации, можете использовать его напрямую

[Игорь]

BoShurik, Что касается SQL_CALC_FOUND_ROWS FOUND_ROWS
Я думаю что 2 запроса выполнить это будет гораздо надёжнее.

Тем более, что можно кешировать результат счётчика количества.

[Игорь]

Ваш ответ может являться решением, но не для моего проекта.
Спасибо, что уделили мне своё время.