o -hX&@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 autoflushrOrderedIdentitySetZunchanged_items added_items deleted_itemsZ_reconcile_collection)selfr&r(r*r+collr6^/var/www/html/figdemos/bartoux_crm/venv/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__r8r6r6r6r7r%=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 ||_dSr9) r AttributeImplr8rDtuplerFr/r= AppenderMixinmromixin_user_query)r4r>r@rBrDrFr=rHr6r6r7r8Ws     zDynamicAttributeImpl.__init__r9)r>r?r@rArBrCrDrErFrr=rGrHrr-r.) r:r;r<Z_supports_dynamic_iterationr%rZcollection_history_cls__annotations__r8r6r6r6r7r'Rs  r'dynamic)lazyc@seZdZeZdS) DynaLoaderN)r:r;r<r' impl_classr6r6r6r7rQosrQcseZdZUdZdZded<ded<d5fd d Zed6ddZej d7ddZd8ddZ e r3d9ddZ d:ddZ d;d!d"Z dd)d*Zd?d-d.Zd>d/d0Zd?d1d2Zd?d3d4ZZS)@rKzTA 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||dSr9)rr8rDsuper)r4r&r( __class__r6r7r8~s zAppenderMixin.__init__Optional[Session]cCs>t|j}|dur|jr|j|vr|t|jsdS|Sr9)rinstancer0flushorm_util has_identityr4sessr6r6r7sessions  zAppenderMixin.sessionr^rcCs ||_dSr9)r])r4r^r6r6r7r^s 1Union[result.ScalarResult[_T], result.Result[_T]]cCs~|j}|dur8t|j}|jrtdt|t j t |j j jgt|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)r^rinstance_staterXdetachedrwarnrZ state_strrIteratorResultSimpleResultMetaDatar&r>r:iter_get_collection_historyrPASSIVE_NO_INITIALIZEr2scalars _generate_iter)r4r]r(r6r6r7rls.    zAppenderMixin._iter Iterator[_T]cCsdSr9r6)r4r6r6r7__iter__szAppenderMixin.__iter__indexrUnion[_T, List[_T]]cCs<|j}|dur|jt|jtj|S| | |Sr9) r^r&rhrrarXrriZindexedrk __getitem__)r4ror]r6r6r7rqs zAppenderMixin.__getitem__intcCs:|j}|durt|jt|jtjj S| | Sr9) r^lenr&rhrrarXrrir2rkcountr\r6r6r7rts zAppenderMixin.countr] 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)r^)rXrorm_excDetachedInstanceErrorrZ instance_strr&r@r=rDquery_where_criteria _from_objrS)r4r]rXryr6r6r7rks 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_implr4r|r6r6r7add_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 Nrr4rr6r6r7adds zAppenderMixin.addcCr~)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. Nrrr6r6r7extendzAppenderMixin.extendcCr)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. Nrrr6r6r7append szAppenderMixin.appendcCr~)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_implrr6r6r7removerzAppenderMixin.remove)r&r'r(r)r-r.)r-rW)r^rr-r.)r-r_)r-rm)rorr-rp)r-rrr9)r]rWr-ru)r|r}r-r.)rr#r-r.)r:r;r<__doc__r=rNr8propertyr^setterrlr rnrqrtrkrrrrr __classcell__r6r6rUr7rKts*             rKc@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)r:r;r<rr6r6r6r7r/sr/clsrr-type[AppenderMixin[Any]]cCsd|j}t|t|fd|iS)zAReturn a new class with AppenderQuery functionality layered over.ZAppenderr=)r:typerK)rnamer6r6r7rM)s rMN)rrr-r)7r __future__rtypingrrrrrrr r r r rrrvrrrZbaserryrr^r writeonlyrrrrenginerrmapperrrrr(rr eventr!Z sql.elementsr"r#r%r'RelationshipProperty strategy_forrQrKr/rMr6r6r6r7sV                                 +