o i&@sdZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z dd lm Z dd lm Z dd lm Z dd lm Z dd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z ddlmZddl!m"Z"e rddlm#Z#ddl$m%Z%ddlm&Z&ddlm'Z'dd l(m)Z)dd!lm*Z*dd"l+m,Z,dd#l-m.Z.e d$ed%Z/Gd&d'd'ee/Z0Gd(d)d)eZ1ej2j3d*d+Gd,d-d-e Z4Gd.d/d/ee/Z5Gd0d1d1e5e/ee/Z6d9d6d7Z7d8S):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)List)Optional)overload)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 autoflushrOrderedIdentitySetunchanged_items added_items deleted_items_reconcile_collection)selfr'r)r+r,collr9V/var/www/html/arapca_proje/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__r;r9r9r9r:r&>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 ||_dSr<) r AttributeImplr;rGtuplerIr0r@ AppenderMixinmromixin_user_query)r7rArCrErGrIr@rKr9r9r:r;Xs     zDynamicAttributeImpl.__init__r<)rArBrCrDrErFrGrHrIrr@rJrKrr.r/) r=r>r?_supports_dynamic_iterationr&rcollection_history_cls__annotations__r;r9r9r9r:r(Ss  r(dynamic)lazyc@seZdZeZdS) DynaLoaderN)r=r>r?r( impl_classr9r9r9r:rVpsrVcseZdZUdZdZded<ded<d9fd d Zed:ddZej d;ddZdddZe d?d"dZd@d%dZdAd&d'Z dBdCd*d+ZdDd.d/ZdEd1d2ZdDd3d4ZdEd5d6ZdEd7d8ZZS)FrNzTA 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||dSr<)rr;rGsuper)r7r'r) __class__r9r:r;s zAppenderMixin.__init__Optional[Session]cCs>t|j}|dur|jr|j|vr|t|jsdS|Sr<)rinstancer1flushorm_util has_identityr7sessr9r9r:sessions  zAppenderMixin.sessionrcrcCs ||_dSr<)rb)r7rcr9r9r:rcs 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)rcrinstance_stater]detachedrwarnr_ state_strrIteratorResultSimpleResultMetaDatar'rAr=iter_get_collection_historyrPASSIVE_NO_INITIALIZEr4scalars _generate_iter)r7rbr)r9r9r:rqs.    zAppenderMixin._iter Iterator[_T]cCdSr<r9)r7r9r9r:__iter__szAppenderMixin.__iter__indexintr$cCrsr<r9r7rur9r9r: __getitem__zAppenderMixin.__getitem__sliceList[_T]cCrsr<r9rwr9r9r:rxryUnion[int, slice]Union[_T, List[_T]]cCs<|j}|dur|jt|jtj|S| | |Sr<) rcr'rmrrfr]rrnindexedrprx)r7rurbr9r9r:rxs cCs:|j}|durt|jt|jtjj S| | Sr<) rclenr'rmrrfr]rrnr4rpcountrar9r9r:rs zAppenderMixin.countrb 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)rc)r]rorm_excDetachedInstanceErrorr_ instance_strr'rCr@rGquery_where_criteria _from_objrX)r7rbr]rr9r9r:rps 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_implr7rr9r9r: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 Nrr7rr9r9r:adds 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. Nrrr9r9r:extend zAppenderMixin.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. Nrrr9r9r:appendszAppenderMixin.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) _remove_implrr9r9r:removerzAppenderMixin.remove)r'r(r)r*r.r/)r.r\)rcrr.r/)r.rd)r.rr)rurvr.r$)rurzr.r{)rur|r.r})r.rvr<)rbr\r.r)rrr.r/)rr$r.r/)r=r>r?__doc__r@rSr;propertyrcsetterrqr rtrrxrrprrrrr __classcell__r9r9rZr:rNus2               rNc@seZdZdZdS)r0zA 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?rr9r9r9r:r0%sr0clsrr.type[AppenderMixin[Any]]cCsd|j}t|t|fd|iS)zAReturn a new class with AppenderQuery functionality layered over.Appenderr@)r=typerN)rnamer9r9r:rP0s rPN)rrr.r)8r __future__rtypingrrrrrrr r r r r rrrrrr_baserrrrcr writeonlyrrrrenginerrmapperrrrr)r r!eventr" sql.elementsr#r$r&r(RelationshipProperty strategy_forrVrNr0rPr9r9r9r:sX                                  1