Method iterate

ormar/queryset/queryset.py:1292–1347

Return async iterable generator for all rows from a database for given model. Passing args and/or kwargs is a shortcut and equals to calling `filter(*args, **kwargs).iterate()`. If there are no rows meeting the criteria an empty async generator is returned.

(  # noqa: A003
        self,
        *args: Any,
        **kwargs: Any,
    )

        return result_rows

    async def iterate(  # noqa: A003
        self,
        *args: Any,
        **kwargs: Any,
    ) -> AsyncGenerator["T", None]:
        """
        Return async iterable generator for all rows from a database for given model.

        Passing args and/or kwargs is a shortcut and equals to calling
        `filter(*args, **kwargs).iterate()`.

        If there are no rows meeting the criteria an empty async generator is returned.

        :param kwargs: fields names and proper value types
        :type kwargs: Any
        :return: asynchronous iterable generator of returned models
        :rtype: AsyncGenerator[Model]
        """

        if self._prefetch_related:
            raise QueryDefinitionError(
                "Prefetch related queries are not supported in iterators"
            )

        if kwargs or args:
            async for result in self.filter(*args, **kwargs).iterate():
                yield result
            return

        expr = self.build_select_expression()

        rows: list = []
        last_primary_key = None
        pk_alias = self.model.get_column_alias(self.model_config.pkname)
        # Single shared cache across all yielded chunks so 1-row chunks
        # (the common iterate case) still amortize the plan build.
        plan_cache: dict = {}

        # Server-side cursor (asyncpg/aiomysql) requires an open transaction,
        # which AUTOCOMMIT does not provide.
        async with self.model_config.database.get_query_executor(
            transactional=True
        ) as executor:
            async for row in executor.iterate(expr):
                current_primary_key = row[pk_alias]
                if last_primary_key == current_primary_key or last_primary_key is None:
                    last_primary_key = current_primary_key
                    rows.append(row)
                    continue

                yield (await self._process_query_result_rows(rows, plan_cache))[0]
                last_primary_key = current_primary_key
                rows = [row]

            if rows:
                yield (await self._process_query_result_rows(rows, plan_cache))[0]

    async def create(self, **kwargs: Any) -> "T":