o i!@spdZddlmZddlmZddlmZddlmZddlmZddlmZdd l m Z dd l m Z dd l m Z dd l mZdd lmZddlmZddlmZddlmZddlmZddlmZdd l mZddlmZervddlmZededZGdddeZGdddeZe 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)DynamicCollectionHistoryNcCsb|rt||d}t||_|j|_|j|_d|_dSt|_t|_t|_d|_dS)NFT) AppenderQuery autoflushr OrderedIdentitySetunchanged_items added_items deleted_items_reconcile_collection)selfattrstatepassiveapply_tocollr&V/var/www/html/LicenciasMIG/venv/lib/python3.10/site-packages/sqlalchemy/orm/dynamic.py__init__2s      z!DynamicCollectionHistory.__init__N)__name__ __module__ __qualname__r(r&r&r&r'r1src@s eZdZdZeZ dddZdS)DynamicAttributeImplTNc Ksbtjj|||||fi|||_|rt||_|st|_dSt| vr*||_dSt ||_dSr)) r AttributeImplr( target_mappertupleorder_byr query_class AppenderMixinmromixin_user_query) r class_key typecallabledispatchr/r1r2kwr&r&r'r(Ds     zDynamicAttributeImpl.__init__r))r*r+r,_supports_dynamic_iterationrcollection_history_clsr(r&r&r&r'r-@s  r-dynamic)lazyc@seZdZeZdS) DynaLoaderN)r*r+r,r- impl_classr&r&r&r'r?]sr?cseZdZdZdZfddZed(ddZejd)d dZd d Z e r(d*ddZ d+ddZ d,ddZ d-ddZd.ddZd/d d!Zd.d"d#Zd/d$d%Zd/d&d'ZZS)0r3zTA mixin that expects to be mixing in a Query class with AbstractAppender. Ncs"t||jdt||dSr))r r(r/super)r r!r" __class__r&r'r(kszAppenderMixin.__init__returnrcCsDt|j}|dur|jr|jr|j|vr|t|js dS|Sr))rinstancerflushorm_util has_identityr sessr&r&r'sessionos   zAppenderMixin.sessionrKNonecCs ||_dSr))rJ)r rKr&r&r'rK~s cCsz|j}|dur6t|j}|jrtdt|t j t |j j jg|j t|jtjjddS||S)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)rKr instance_staterEdetachedr warnrG state_strrIteratorResultSimpleResultMetaDatar!r6r*_get_collection_historyPASSIVE_NO_INITIALIZErscalars _generate_iter)r rJr"r&r&r'rXs*   zAppenderMixin._iter Iterator[_T]cCsdSr)r&)r r&r&r'__iter__szAppenderMixin.__iter__indexrrcCs<|j}|dur|jt|jtj|S|| |Sr)) rKr!rTr rNrErUindexedrW __getitem__)r r[rJr&r&r'r]s zAppenderMixin.__getitem__intcCs:|j}|durt|jt|jtjjS| | Sr)) rKlenr!rTr rNrErUrrWcountrIr&r&r'r`s zAppenderMixin.countcCs~|j}|durt|}|durtdt||jjf|jr*|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)rK)rErorm_excDetachedInstanceErrorrG instance_strr!r7r2r/query_where_criteria _from_obj_order_by_clauses)r rJrErdr&r&r'rWs zAppenderMixin._generateiterator Iterable[_T]cC||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 N _add_all_implr rhr&r&r'add_alls zAppenderMixin.add_allitemcC||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 Nrkr ror&r&r'adds zAppenderMixin.addcCrj)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. Nrkrmr&r&r'extendzAppenderMixin.extendcCrp)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. Nrkrqr&r&r'appendszAppenderMixin.appendcCrj)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) _remove_implrqr&r&r'removertzAppenderMixin.remove)rDr)rKrrDrL)rDrY)r[rrDr)rDr^r))rhrirDrL)rorrDrL)r*r+r,__doc__r2r(propertyrKsetterrXrrZr]r`rWrnrrrsrurw __classcell__r&r&rBr'r3bs&          r3c@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,rxr&r&r&r'rsrcCsd|j}t|t|fd|iS)zAReturn a new class with AppenderQuery functionality layered over.Appenderr2)r*typer3)clsnamer&r&r'r5s r5N)%rx __future__rtypingrrrrrr r rar r rGrdr rKr writeonlyrrrrenginerrrrr-RelationshipProperty strategy_forr?r3rr5r&r&r&r's<                    %