o 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.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 autoflushrOrderedIdentitySetunchanged_items added_items deleted_items_reconcile_collection)selfr&r(r*r+collr8X/var/www/html/ecg_monitoring/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:r8r8r8r9r%=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:rFtuplerHr/r? AppenderMixinmromixin_user_query)r6r@rBrDrFrHr?rJr8r8r9r:Ws     zDynamicAttributeImpl.__init__r;)r@rArBrCrDrErFrGrHrr?rIrJrr-r.) r<r=r>_supports_dynamic_iterationr%rcollection_history_cls__annotations__r:r8r8r8r9r'Rs  r'dynamic)lazyc@seZdZeZdS) DynaLoaderN)r<r=r>r' impl_classr8r8r8r9rUosrUcseZdZUdZdZded<ded<d5fd d Zed6ddZej d7ddZd8ddZ e r3d9ddZ d:ddZ d;d!d"Z dd)d*Zd?d-d.Zd>d/d0Zd?d1d2Zd?d3d4ZZS)@rMzTA 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:rFsuper)r6r&r( __class__r8r9r:~s zAppenderMixin.__init__Optional[Session]cCs>t|j}|dur|jr|j|vr|t|jsdS|Sr;)rinstancer0flushorm_util has_identityr6sessr8r8r9sessions  zAppenderMixin.sessionrbrcCs ||_dSr;)ra)r6rbr8r8r9rbs 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)rbrinstance_stater\detachedrwarnr^ state_strrIteratorResultSimpleResultMetaDatar&r@r<iter_get_collection_historyrPASSIVE_NO_INITIALIZEr3scalars _generate_iter)r6rar(r8r8r9rps.    zAppenderMixin._iter Iterator[_T]cCsdSr;r8)r6r8r8r9__iter__szAppenderMixin.__iter__indexrUnion[_T, List[_T]]cCs<|j}|dur|jt|jtj|S| | |Sr;) rbr&rlrrer\rrmindexedro __getitem__)r6rsrar8r8r9rvs zAppenderMixin.__getitem__intcCs:|j}|durt|jt|jtjj S| | Sr;) rblenr&rlrrer\rrmr3rocountr`r8r8r9rys zAppenderMixin.countra 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)rb)r\rorm_excDetachedInstanceErrorr^ instance_strr&rBr?rFquery_where_criteria _from_objrW)r6rar\r~r8r8r9ros 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_implr6rr8r8r9add_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 Nrr6rr8r8r9adds 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. Nrrr8r8r9extendzAppenderMixin.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. Nrrr8r8r9append 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) _remove_implrr8r8r9removerzAppenderMixin.remove)r&r'r(r)r-r.)r-r[)rbrr-r.)r-rc)r-rq)rsrr-rt)r-rwr;)rar[r-rz)rrr-r.)rr#r-r.)r<r=r>__doc__r?rRr:propertyrbsetterrpr rrrvryrorrrrr __classcell__r8r8rYr9rMts*             rMc@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>rr8r8r8r9r/sr/clsrr-type[AppenderMixin[Any]]cCsd|j}t|t|fd|iS)zAReturn a new class with AppenderQuery functionality layered over.Appenderr?)r<typerM)rnamer8r8r9rO)s rON)rrr-r)7r __future__rtypingrrrrrrr r r r rrr{rrr^baserr~rrbr writeonlyrrrrenginerrmapperrrrr(rr eventr! sql.elementsr"r#r%r'RelationshipProperty strategy_forrUrMr/rOr8r8r8r9sV                                 +