U !Jj&@s&dZddlmZddlmZddlmZddlmZddlmZddlmZddlm 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/Z6d2d3d4d5d6Z7d7S)8zDynamic 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@s$eZdZd dddddddd ZdS) DynamicCollectionHistoryNDynamicAttributeImplInstanceState[_T]rz&Optional[DynamicCollectionHistory[_T]]None)attrstatepassiveapply_toreturncCs`|r8t||d}t||_|j|_|j|_d|_n$t|_t|_t|_d|_dS)NFT) AppenderQuery autoflushrZOrderedIdentitySetZunchanged_items added_itemsZ deleted_itemsZ_reconcile_collection)selfr*r+r,r-Zcollr3w/var/www/api.dyntland.com/public_html/python_social_comments/venv/lib/python3.8/site-packages/sqlalchemy/orm/dynamic.py__init__>s    z!DynamicCollectionHistory.__init__)N)__name__ __module__ __qualname__r5r3r3r3r4r&=sr&c @s@eZdZUdZeeZded<dddddd d d d d ddZdS)r'TzType[AppenderMixin[Any]] query_classNz#Union[Type[Any], AliasedClass[Any]]strz"_Dispatch[QueryableAttribute[Any]]z Mapper[_T]rz!Optional[Type[AppenderMixin[_T]]]rr))class_keydispatch target_mapperorder_byr9kwr.cKsZtjj|||d|f|||_|r,t||_|s8t|_nt| krL||_n t ||_dSN) rZ AttributeImplr5r>tupler?r/r9 AppenderMixinmromixin_user_query)r2r;r<r=r>r?r9r@r3r3r4r5Ws"   zDynamicAttributeImpl.__init__)N) r6r7r8Z_supports_dynamic_iterationr&rZcollection_history_cls__annotations__r5r3r3r3r4r'Rs  r'Zdynamic)Zlazyc@seZdZeZdS) DynaLoaderN)r6r7r8r'Z impl_classr3r3r3r4rGosrGcs0eZdZUdZdZded<ded<ddd d fd d Zed dddZej dd dddZddddZ e rddddZ e dddddZe dd dd!dZd"d#dd$dZddd%d&Zd8d d'd(d)d*Zd+d d,d-d.Zdd d/d0d1Zd+d d,d2d3Zdd d/d4d5Zdd d/d6d7ZZS)9rCzTA mixin that expects to be mixing in a Query class with AbstractAppender. NzOptional[Type[Query[_T]]]r9zTuple[ColumnElement[Any], ...]_order_by_clausesr'r(r))r*r+r.cs"t||jdt||dSrA)rr5r>super)r2r*r+ __class__r3r4r5~s zAppenderMixin.__init__zOptional[Session])r.cCsBt|j}|dk r*|jr*|j|kr*|t|js:dS|SdSrA)rinstancer0flushorm_utilZ has_identityr2sessr3r3r4sessions   zAppenderMixin.sessionr)rQr.cCs ||_dSrA)rP)r2rQr3r3r4rQsz1Union[result.ScalarResult[_T], result.Result[_T]]cCs|j}|dkrpt|j}|jr4tdt|t j t |j j jgt|j t|jtjjddS||SdS)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)rQrinstance_staterLZdetachedrwarnrNZ state_strrZIteratorResultZSimpleResultMetaDatar*r;r6iter_get_collection_historyrPASSIVE_NO_INITIALIZEr1Zscalars _generate_iter)r2rPr+r3r3r4rXs(   zAppenderMixin._iterz Iterator[_T]cCsdSrAr3)r2r3r3r4__iter__zAppenderMixin.__iter__intr$)indexr.cCsdSrAr3r2r\r3r3r4 __getitem__szAppenderMixin.__getitem__slicezList[_T]cCsdSrAr3r]r3r3r4r^szUnion[int, slice]zUnion[_T, List[_T]]cCs@|j}|dkr,|jt|jtj|S| | |SdSrA) rQr*rUrrRrLrrVZindexedrWr^)r2r\rPr3r3r4r^s cCs>|j}|dkr,t|jt|jtjj S| | SdSrA) rQlenr*rUrrRrLrrVr1rWcountrOr3r3r4ras zAppenderMixin.countz Query[_T])rPr.cCs~|j}|dkr:t|}|dkr:tdt||jjf|jrT|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)rQ)rLrorm_excZDetachedInstanceErrorrNZ instance_strr*r<r9r>queryZ_where_criteriaZ _from_objrH)r2rPrLrcr3r3r4rWs zAppenderMixin._generatez Iterable[_T])iteratorr.cCs||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_implr2rdr3r3r4add_alls zAppenderMixin.add_all)itemr.cCs||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 Nrer2rhr3r3r4adds zAppenderMixin.addcCs||dS)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. Nrerfr3r3r4extendszAppenderMixin.extendcCs||gdS)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. Nrerir3r3r4appendszAppenderMixin.appendcCs||dS)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_implrir3r3r4removeszAppenderMixin.remove)N)r6r7r8__doc__r9rFr5propertyrQsetterrXr rYrr^rarWrgrjrkrlrm __classcell__r3r3rJr4rCts0       rCc@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)r6r7r8rnr3r3r3r4r/$sr/rztype[AppenderMixin[Any]])clsr.cCsd|j}t|t|fd|iS)zAReturn a new class with AppenderQuery functionality layered over.ZAppenderr9)r6typerC)rrnamer3r3r4rE/s rEN)8rn __future__rtypingrrrrrrr r r r r rrrbrrrNbaserrcrrQrZ writeonlyrrrrZenginerrZmapperrrrr+r r!eventr"Z sql.elementsr#r$r&r'ZRelationshipPropertyZ strategy_forrGrCr/rEr3r3r3r4 sV                                   1