o !Zh:&@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.Z5d8d5d6Z6d7S)9zDynamic 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@seZdZ ddd d ZdS)DynamicCollectionHistoryNattrDynamicAttributeImplstateInstanceState[_T]passiverapply_to&Optional[DynamicCollectionHistory[_T]]returnNonecCsb|rt||d}t||_|j|_|j|_d|_dSt|_t|_t|_d|_dS)NFT) AppenderQuery autoflushrZOrderedIdentitySetZunchanged_items added_itemsZ deleted_itemsZ_reconcile_collection)selfr&r(r*r+Zcollr3M/var/www/html/lang_env/lib/python3.10/site-packages/sqlalchemy/orm/dynamic.py__init__>s      z!DynamicCollectionHistory.__init__N) r&r'r(r)r*rr+r,r-r.)__name__ __module__ __qualname__r5r3r3r3r4r%=sr%c@s0eZdZUdZeeZded< ddddZdS)r'TzType[AppenderMixin[Any]] query_classNclass_#Union[Type[Any], AliasedClass[Any]]keystrdispatch"_Dispatch[QueryableAttribute[Any]] target_mapper Mapper[_T]order_byr!Optional[Type[AppenderMixin[_T]]]kwrr-r.cKsbtjj|||d|fi|||_|rt||_|st|_dSt| vr*||_dSt ||_dSr6) rZ AttributeImplr5rAtuplerCr/r: AppenderMixinmromixin_user_query)r2r;r=r?rArCr:rEr3r3r4r5Ws     zDynamicAttributeImpl.__init__r6)r;r<r=r>r?r@rArBrCrr:rDrErr-r.) r7r8r9Z_supports_dynamic_iterationr%rZcollection_history_cls__annotations__r5r3r3r3r4r'Rs  r'Zdynamic)Zlazyc@seZdZeZdS) DynaLoaderN)r7r8r9r'Z impl_classr3r3r3r4rKosrKcseZdZUdZdZded<ded<d5fd d Zed6ddZej d7ddZd8ddZ e r3d9ddZ d:ddZ d;d!d"Z dd)d*Zd?d-d.Zd>d/d0Zd?d1d2Zd?d3d4ZZS)@rGzTA 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||dSr6)rr5rAsuper)r2r&r( __class__r3r4r5~s zAppenderMixin.__init__Optional[Session]cCs>t|j}|dur|jr|j|vr|t|jsdS|Sr6)rinstancer0flushorm_utilZ has_identityr2sessr3r3r4sessions  zAppenderMixin.sessionrVrcCs ||_dSr6)rU)r2rVr3r3r4rVs 1Union[result.ScalarResult[_T], result.Result[_T]]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)Z_source_supports_scalars)rVrinstance_staterQZdetachedrwarnrSZ state_strrZIteratorResultZSimpleResultMetaDatar&r;r7_get_collection_historyrPASSIVE_NO_INITIALIZEr1Zscalars _generate_iter)r2rUr(r3r3r4r]s*   zAppenderMixin._iter Iterator[_T]cCsdSr6r3)r2r3r3r4__iter__szAppenderMixin.__iter__indexrUnion[_T, List[_T]]cCs<|j}|dur|jt|jtj|S| | |Sr6) rVr&rZrrXrQrr[Zindexedr\ __getitem__)r2r`rUr3r3r4rbs zAppenderMixin.__getitem__intcCs:|j}|durt|jt|jtjj S| | Sr6) rVlenr&rZrrXrQrr[r1r\countrTr3r3r4res zAppenderMixin.countrU Query[_T]cCs~|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)rV)rQrorm_excZDetachedInstanceErrorrSZ instance_strr&r=r:rAqueryZ_where_criteriaZ _from_objrL)r2rUrQrhr3r3r4r\s 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 NZ _add_all_implr2rir3r3r4add_alls zAppenderMixin.add_allitemr#cC||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 Nrlr2ror3r3r4adds zAppenderMixin.addcCrk)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. Nrlrmr3r3r4extendzAppenderMixin.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. Nrlrqr3r3r4append szAppenderMixin.appendcCrk)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_implrqr3r3r4removertzAppenderMixin.remove)r&r'r(r)r-r.)r-rP)rVrr-r.)r-rW)r-r^)r`rr-ra)r-rcr6)rUrPr-rf)rirjr-r.)ror#r-r.)r7r8r9__doc__r:rJr5propertyrVsetterr]r r_rbrer\rnrrrsrurv __classcell__r3r3rNr4rGts*             rGc@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)r7r8r9rwr3r3r3r4r/sr/clsrr-type[AppenderMixin[Any]]cCsd|j}t|t|fd|iS)zAReturn a new class with AppenderQuery functionality layered over.ZAppenderr:)r7typerG)r{namer3r3r4rI's rIN)r{rr-r|)7rw __future__rtypingrrrrrrr r r r rrrgrrrSbaserrhrrVrZ writeonlyrrrrZenginerrZmapperrrrr(rr eventr!Z sql.elementsr"r#r%r'ZRelationshipPropertyZ strategy_forrKrGr/rIr3r3r3r4sV                                 )