a c g!@spdZddlmZddlmZddlmZddlmZddlmZddlmZdd l m Z dd l m Z dd l m Z dd l mZdd lmZddlmZddlmZddlmZddlmZddlmZdd l mZddlmZerddlmZededZGdddeZGdddeZe jj ddGdddeZ!Gd d!d!eeZ"Gd"d#d#e"eeeZ#d$d%Z$d&S)'zDynamic collection API. Dynamic collections act like Query() objects for read operations and support basic add/delete mutation. .. legacy:: the "dynamic" loader is a legacy feature, superseded by the "write_only" loader. ) annotations)Any)Iterable)Iterator) TYPE_CHECKING)TypeVar) attributes)exc) relationships)util)Query)object_session)AbstractCollectionWriter)WriteOnlyAttributeImpl)WriteOnlyHistory)WriteOnlyLoader)result)Session_T)boundc@seZdZdddZdS)DynamicCollectionHistoryNcCs`|r8t||d}t||_|j|_|j|_d|_n$t|_t|_t|_d|_dS)NFT) AppenderQuery autoflushr ZOrderedIdentitySetZunchanged_items added_itemsZ deleted_itemsZ_reconcile_collection)selfattrstateZpassiveZapply_toZcollrY/var/www/html/llm_bihealth/app/venv/lib/python3.9/site-packages/sqlalchemy/orm/dynamic.py__init__2s    z!DynamicCollectionHistory.__init__)N)__name__ __module__ __qualname__r!rrrr r1src@seZdZdZeZdddZdS)DynamicAttributeImplTNc Ks^tjj|||||fi|||_|r0t||_|sr7rAZindexedrB __getitem__)rrEr;rrr rFs zAppenderMixin.__getitem__intcCs>|j}|dur,t|jt|jtjjS| | SdSr&) r<lenrr@r r>r7rArrBcountr:rrr rIs zAppenderMixin.countcCs~|j}|dur:t|}|dur:tdt||jjf|jrT|j|jj |d}n| |jj }|j |_ |j |_ |j |_ |S)NzParent instance %s is not bound to a Session, and no contextual session is established; lazy load operation of attribute '%s' cannot proceed)r<)r7rorm_excZDetachedInstanceErrorr9Z instance_strrr/r*r'queryZ_where_criteriaZ _from_objZ_order_by_clauses)rr;r7rKrrr rBs zAppenderMixin._generatez Iterable[_T])iteratorr6cCs||dS)a~Add an iterable of items to this :class:`_orm.AppenderQuery`. The given items will be persisted to the database in terms of the parent instance's collection on the next flush. This method is provided to assist in delivering forwards-compatibility with the :class:`_orm.WriteOnlyCollection` collection class. .. versionadded:: 2.0 NZ _add_all_implrrLrrr add_alls zAppenderMixin.add_all)itemr6cCs||gdS)apAdd an item to this :class:`_orm.AppenderQuery`. The given item will be persisted to the database in terms of the parent instance's collection on the next flush. This method is provided to assist in delivering forwards-compatibility with the :class:`_orm.WriteOnlyCollection` collection class. .. versionadded:: 2.0 NrMrrPrrr adds zAppenderMixin.addcCs||dS)zAdd an iterable of items to this :class:`_orm.AppenderQuery`. The given items will be persisted to the database in terms of the parent instance's collection on the next flush. NrMrNrrr extendszAppenderMixin.extendcCs||gdS)zAppend an item to this :class:`_orm.AppenderQuery`. The given item will be persisted to the database in terms of the parent instance's collection on the next flush. NrMrQrrr appendszAppenderMixin.appendcCs||dS)zRemove an item from this :class:`_orm.AppenderQuery`. The given item will be removed from the parent instance's collection on the next flush. N)Z _remove_implrQrrr removeszAppenderMixin.remove)N)r"r#r$__doc__r*r!propertyr<setterrCrrDrFrIrBrOrRrSrTrU __classcell__rrr4r r+bs$     r+c@seZdZdZdS)rzA dynamic query that supports basic collection storage operations. Methods on :class:`.AppenderQuery` include all methods of :class:`_orm.Query`, plus additional methods used for collection persistence. N)r"r#r$rVrrrr rsrcCsd|j}t|t|fd|iS)zAReturn a new class with AppenderQuery functionality layered over.ZAppenderr*)r"typer+)clsnamerrr r-s r-N)%rV __future__rtypingrrrrrr r rJr r r9rKr r<rZ writeonlyrrrrZenginerrrrr%ZRelationshipPropertyZ strategy_forr2r+rr-rrrr  s:                     %