a ~gX&@sdZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z dd lm Z dd lm Z dd lm Z dd lm Z d dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZddlmZddl m!Z!e rd dlm"Z"d dl#m$Z$d dlm%Z%d dlm&Z&d dl'm(Z(d d lm)Z)dd!l*m+Z+dd"l,m-Z-e d#ed$Z.Gd%d&d&ee.Z/Gd'd(d(eZ0ej1j2d)d*Gd+d,d,eZ3Gd-d.d.ee.Z4Gd/d0d0e4e.ee.Z5d1d2d3d4d5Z6d6S)7zDynamic 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)List)Optional)Tuple)Type) TYPE_CHECKING)TypeVar)Union) attributes)exc) relationships)util) PassiveFlag)Query)object_session)AbstractCollectionWriter)WriteOnlyAttributeImpl)WriteOnlyHistory)WriteOnlyLoader)result)QueryableAttribute)Mapper)_RelationshipOrderByArg)Session) InstanceState) AliasedClass) _Dispatch) ColumnElement_T)boundc@s$eZdZd dddddddd ZdS) DynamicCollectionHistoryNDynamicAttributeImplInstanceState[_T]rz&Optional[DynamicCollectionHistory[_T]]None)attrstatepassiveapply_toreturncCs`|r8t||d}t||_|j|_|j|_d|_n$t|_t|_t|_d|_dS)NFT) AppenderQuery autoflushrOrderedIdentitySetZunchanged_items added_items deleted_itemsZ_reconcile_collection)selfr)r*r+r,collr5[/var/www/html/emsaiapi.evdpl.com/venv/lib/python3.9/site-packages/sqlalchemy/orm/dynamic.py__init__>s    z!DynamicCollectionHistory.__init__)N)__name__ __module__ __qualname__r7r5r5r5r6r%=sr%c @s@eZdZUdZeeZded<dddddd d d d d ddZdS)r&TzType[AppenderMixin[Any]] query_classNz#Union[Type[Any], AliasedClass[Any]]strz"_Dispatch[QueryableAttribute[Any]]z Mapper[_T]rz!Optional[Type[AppenderMixin[_T]]]rr()class_keydispatch target_mapperorder_byr;kwr-cKs^tjj|||d|fi|||_|r0t||_|sr?r@rAr;rBr5r5r6r7Ws    zDynamicAttributeImpl.__init__)N) r8r9r:Z_supports_dynamic_iterationr%rZcollection_history_cls__annotations__r7r5r5r5r6r&Rs  r&dynamic)lazyc@seZdZeZdS) DynaLoaderN)r8r9r:r& impl_classr5r5r5r6rLosrLcseZdZUdZdZded<ded<ddd d fd d Zed dddZej dd dddZddddZ e rddddZ dddddZ ddd d!Zd4d d"d#d$d%Zd&d d'd(d)Zd*d d+d,d-Zd&d d'd.d/Zd*d d+d0d1Zd*d d+d2d3ZZS)5rFzTA mixin that expects to be mixing in a Query class with AbstractAppender. NzOptional[Type[Query[_T]]]r;zTuple[ColumnElement[Any], ...]_order_by_clausesr&r'r()r)r*r-cs"t||jdt||dSrC)rr7r@super)r3r)r* __class__r5r6r7~s zAppenderMixin.__init__zOptional[Session])r-cCsBt|j}|dur*|jr*|j|vr*|t|js:dS|SdSrC)rinstancer/flushorm_util has_identityr3sessr5r5r6sessions   zAppenderMixin.sessionr)rXr-cCs ||_dSrC)rW)r3rXr5r5r6rXsz1Union[result.ScalarResult[_T], result.Result[_T]]cCs|j}|durpt|j}|jr4tdt|t j t |j j jgt|j t|jtjjddS||SdS)NzInstance %s is detached, dynamic relationship cannot return a correct result. This warning will become a DetachedInstanceError in a future release.T)_source_supports_scalars)rXrinstance_staterRdetachedrwarnrT state_strrIteratorResultSimpleResultMetaDatar)r=r8iter_get_collection_historyrPASSIVE_NO_INITIALIZEr1scalars _generate_iter)r3rWr*r5r5r6res(   zAppenderMixin._iterz Iterator[_T]cCsdSrCr5)r3r5r5r6__iter__zAppenderMixin.__iter__rzUnion[_T, List[_T]])indexr-cCs@|j}|dur,|jt|jtj|S| | |SdSrC) rXr)rarrZrRrrbZindexedrd __getitem__)r3rhrWr5r5r6ris zAppenderMixin.__getitem__intcCs>|j}|dur,t|jt|jtjj S| | SdSrC) rXlenr)rarrZrRrrbr1rdcountrVr5r5r6rls zAppenderMixin.countz Query[_T])rWr-cCs~|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)rX)rRrorm_excDetachedInstanceErrorrT instance_strr)r>r;r@query_where_criteria _from_objrN)r3rWrRrpr5r5r6rds zAppenderMixin._generatez Iterable[_T])iteratorr-cCs||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_implr3rsr5r5r6add_alls zAppenderMixin.add_allr#)itemr-cCs||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 Nrtr3rwr5r5r6adds 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. Nrtrur5r5r6extendszAppenderMixin.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. Nrtrxr5r5r6append szAppenderMixin.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_implrxr5r5r6removeszAppenderMixin.remove)N)r8r9r:__doc__r;rIr7propertyrXsetterrer rfrirlrdrvryrzr{r| __classcell__r5r5rPr6rFts(       rFc@seZdZdZdS)r.zA 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)r8r9r:r}r5r5r5r6r.sr.rztype[AppenderMixin[Any]])clsr-cCsd|j}t|t|fd|iS)zAReturn a new class with AppenderQuery functionality layered over.ZAppenderr;)r8typerF)rnamer5r5r6rH)s rHN)7r} __future__rtypingrrrrrrr r r r rrrmrrrTbaserrprrXr writeonlyrrrrenginerrmapperrrrr*rr eventr!Z sql.elementsr"r#r%r&RelationshipProperty strategy_forrLrFr.rHr5r5r5r6 sT                                  +