Method find_all

src/core/db/repository.py:199–239

(
        self,
        filters: list[Filter] | None = None,
        order_by: list[OrderBy] | None = None,
        pagination: Pagination | None = None,
        pager: Pager | None = None,
    )

            return result.rowcount or 0

    async def find_all(
        self,
        filters: list[Filter] | None = None,
        order_by: list[OrderBy] | None = None,
        pagination: Pagination | None = None,
        pager: Pager | None = None,
    ) -> Sequence[T] | Paginator[T]:
        query = select(self._model)

        if filters:
            query = self._apply_filters(query, filters)

        if order_by:
            query = self._apply_ordering(query, order_by)

        if pagination is not None:
            count_query = select(func.count()).select_from(query.subquery())
            if pagination.per_page is not None:
                query = query.limit(pagination.per_page)
            if pagination.offset is not None:
                query = query.offset(pagination.offset)
            async with self.get_session() as session:
                total_result = await session.execute(count_query)
                total = total_result.scalar_one()
                result = await session.execute(query)
                items = result.scalars().all()
                return Paginator(
                    items=items,
                    total=total,
                    page=pagination.page or 1,
                    per_page=pagination.per_page or total,
                )
        elif pager is not None:
            if pager.limit is not None:
                query = query.limit(pager.limit)
            if pager.offset is not None:
                query = query.offset(pager.offset)

        async with self.get_session() as session:
            result = await session.execute(query)
            return result.scalars().all()

    async def find_one(
        self,