h0hddlmZddlmZmZmZmZmZmZdZ dZ dZ GddeZ Gdd eZ y ) )OperationError)CASCADEDENY DO_NOTHINGNULLIFYPULL BaseQuerySet)QuerySetQuerySetNoCacherrrrrdcTeZdZdZdZdZdZdZdZdZ dZ dZ d fd Z d Z xZS) r zThe default queryset, that builds queries and handles a set of results returned from a query. Wraps a MongoDB cursor, providing :class:`~mongoengine.Document` objects as the results. TNcrd|_|jr|jSt|jS)zIteration utilises a results cache which iterates the cursor in batches of ``ITER_CHUNK_SIZE``. If ``self._has_more`` the cursor hasn't been exhausted so cache then batch. Otherwise iterate the result_cache. T)_iter _has_more _iter_resultsiter _result_cacheselfs [/var/www/html/eduruby.in/venv/lib/python3.12/site-packages/mongoengine/queryset/queryset.py__iter__zQuerySet.__iter__&s4 >>%%' 'D&&''c|j |jS|jrt|jt |j |_|jS)zSince __len__ is called quite frequently (for example, as part of list(qs)), we populate the result cache and cache the length. )_lenrlistrlenrrs r__len__zQuerySet.__len__5sP 99 99  >> ##% &**+ yyrc|jry|j|jdtdz}t |tkDrd|d<t |S)z/Provide a string representation of the QuerySet.. queryset mid-iteration ..N$...(remaining elements truncated)...)r_populate_cacherREPR_OUTPUT_SIZErrepr)rdatas r__repr__zQuerySet.__repr__DsQ ::1 !!"8$4q$89 t9' '=DHDzrc#0K|jg|_d} |t|jkr/|j||dz }|t|jkr/|jsyt|j|kr|j}w)zA generator for iterating over the result cache. Also populates the cache if there are more possible results to yield. Raises StopIteration when there are no more results. Nrr!)rrrr$)rposs rrzQuerySet._iter_resultsOs    %!#D D..//((--qD..// >>4%%&#-$$&)s AB 6Bc|jg|_|jsy ttD]&}|jj t |(y#t $r d|_YywxYw)z{ Populates the result cache with ``ITER_CHUNK_SIZE`` more entries (until the cursor is exhausted). NF)rrrangeITER_CHUNK_SIZEappendnext StopIteration)r_s rr$zQuerySet._populate_cacheosm    %!#D ~~  #?+ 6""))$t*5 6 ##DN  #s8AA.-A.c|durt||S|jt|||_|jS)zCount the selected elements in the query. :param with_limit_and_skip (optional): take any :meth:`limit` or :meth:`skip` that has been applied to this cursor into account when getting the count F)supercountr)rwith_limit_and_skip __class__s rr4zQuerySet.countsB % '7=!45 5 99  &9:DIyyrc|j td|jt|j|j S)z!Convert to a non-caching querysetzQuerySet already cached)rr _clone_intor _document _collectionrs rno_cachezQuerySet.no_caches<    ) !:; ;@P@P QRRr)F)__name__ __module__ __qualname____doc__rrrrrr(rr$r4r; __classcell__)r6s@rr r s>I DM (  '@#0 Srr c"eZdZdZdZdZdZy)r zA non caching QuerySetc`|jt|j|jS)zConvert to a caching queryset)r8r r9r:rs rcachezQuerySetNoCache.caches$9I9I JKKrc|jryg}ttdzD]} |jt |t |tkDrd|d<|jt|S#t $rY>wxYw)z2Provides the string representation of the QuerySetr r!r"r#) rr,r%r.r/r0rrewindr&)rr'r1s rr(zQuerySetNoCache.__repr__s ::1'!+, A  DJ'  t9' '=DH Dz!  sA44 BBcb|}|jr|j}|j|S)N)rclonerE)rquerysets rrzQuerySetNoCache.__iter__s( >>zz|HrN)r<r=r>r?rCr(rrrr r s L$rr N)mongoengine.errorsrmongoengine.queryset.baserrrrrr __all__r%r-r r rIrrrMsC- BS|BSJlr