U
|
¸ý°dÂ" ã @ sp d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd l m
|
Z
|
dd
|
l m Z dd l m Z dd l mZ dd lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd l mZ ddlmZ erìddlmZ ededZ G dd deZ G dd deZ e j j d d G d d d eZ!G d d! d!ee Z"G d"d# d#e"e ee Z#d$d% Z$d&S )'zâDynamic 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)Ú TYPE_CHECKING)ÚTypeVaré )Ú
|
attributes)Úexc)Ú relationships)Úutil)ÚQuery)Úobject_session)ÚAbstractCollectionWriter)ÚWriteOnlyAttributeImpl)ÚWriteOnlyHistory)ÚWriteOnlyLoaderé )Úresult)ÚSessionÚ_T)Úboundc @ s e Zd ZdddZdS )ÚDynamicCollectionHistoryNc C s` |r8t || d¡}t |¡| _|j| _|j| _d| _n$t ¡ | _t ¡ | _t ¡ | _d| _d S )NFT)Ú AppenderQueryÚ autoflushr ZOrderedIdentitySetZunchanged_itemsÚ added_itemsZ deleted_itemsZ_reconcile_collection)ÚselfÚattrÚstateZpassiveZapply_toZcoll© r úMd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/orm/dynamic.pyÚ__init__2 s
|
|
|
z!DynamicCollectionHistory.__init__)N)Ú__name__Ú
|
__module__Ú __qualname__r! r r r r r 1 s r c @ s e Zd ZdZeZdddZdS )ÚDynamicAttributeImplTNc K sZ t jj| ||||f| || _|r,t|| _|s8t| _n t| ¡ krL|| _n
|
t
|
|| _d S ©N) r Z AttributeImplr! Ú target_mapperÚtupleÚorder_byr Ú query_classÚ AppenderMixinÚmroÚmixin_user_query) r Úclass_ÚkeyZ typecallableÚdispatchr' r) r* Úkwr r r r! D s" ÿÿ
|
z DynamicAttributeImpl.__init__)N)r" r# r$ Z_supports_dynamic_iterationr Zcollection_history_clsr! r r r r r% @ s
|
ør% Zdynamic)Zlazyc @ s e Zd ZeZdS )Ú
|
DynaLoaderN)r" r# r$ r% Z
|
impl_classr r r r r2 ] s r2 c sÞ e Zd ZdZdZ fddZeddddZejdd d
|
d dZd d Z e
|
r^ddddZ dddddZ ddddZ d(ddZdd d d d Zdd d d d!Zdd d d"d#Zdd d d$d%Zdd d d&d'Z ZS ))r+ zTA mixin that expects to be mixing in a Query class with
|
AbstractAppender.
|
|
|
Nc s" t | |jd ¡ t ||¡ d S r& )r r! r' Úsuper)r r r ©Ú __class__r r r! k s zAppenderMixin.__init__r )Úreturnc C sH t | j}|d k r0| jr0|jr0| j|kr0| ¡ t | j¡s@d S |S d S r& )r Úinstancer ÚflushÚorm_utilZ has_identity©r Úsessr r r Úsessiono s
|
ÿþýü zAppenderMixin.sessionÚNone)r< r6 c C s
|
|| _ d S r& )r; )r r< r r r r< ~ s c C s~ | j }|d krlt | j¡}|jr4t dt |¡ ¡ t j
|
t | j j jg¡| j t | j¡tj¡jdd ¡ S | |¡ ¡ S d 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)r< r Úinstance_stater7 Zdetachedr Úwarnr9 Z state_strr ZIteratorResultZSimpleResultMetaDatar r. r" Ú_get_collection_historyÚPASSIVE_NO_INITIALIZEr ZscalarsÚ _generateÚ_iter)r r; r r r r rC s$ ýÿ
|
þú
|
zAppenderMixin._iterz Iterator[_T]c C s d S r& r )r r r r Ú__iter__ s zAppenderMixin.__iter__r r )Úindexr6 c C s@ | j }|d kr,| j t | j¡tj¡ |¡S | |¡ |¡S d S r& )
|
r< r r@ r r> r7 rA ZindexedrB Ú __getitem__)r rE r; r r r rF s
|
þýzAppenderMixin.__getitem__Úintc C s> | j }|d kr,t| j t | j¡tj¡jS | |¡
|
¡ S d S r& ) r< Úlenr r@ r r> r7 rA r rB Úcountr: r r r rI ¨ s
|
þÿzAppenderMixin.countc C s~ | j }|d kr:t|}|d kr:t dt |¡| 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)r< )r7 r Úorm_excZDetachedInstanceErrorr9 Z instance_strr r/ r* r' ÚqueryZ_where_criteriaZ _from_objZ_order_by_clauses)r r; r7 rK r r r rB ´ s ýÿzAppenderMixin._generatez Iterable[_T])Úiteratorr6 c C s | |¡ 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©Z _add_all_impl©r rL r r r Úadd_allÎ s zAppenderMixin.add_all)Úitemr6 c C s | |g¡ dS )ap Add 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
|
|
NrM ©r rP r r r ÚaddÜ s zAppenderMixin.addc C s | |¡ dS )zÊ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.
|
|
NrM rN r r r Úextendê s zAppenderMixin.extendc C s | |g¡ dS )z¿Append 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.
|
|
NrM rQ r r r Úappendó s zAppenderMixin.appendc C s | |¡ dS )z¨Remove 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_implrQ r r r Úremoveü s zAppenderMixin.remove)N)r" r# r$ Ú__doc__r* r! Úpropertyr< ÚsetterrC r rD rF rI rB rO rR rS rT rU Ú __classcell__r r r4 r r+ b s$
|
|
r+ c @ s e Zd ZdZdS )r zÞA 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$ rV r r r r r s r c C s d| j }t|t| fd| iS )zAReturn a new class with AppenderQuery functionality layered over.ZAppenderr* )r" Útyper+ )ÚclsÚnamer r r r- s
|
r- N)%rV Ú
|
__future__r Útypingr r r r r Ú r r
|
rJ r r r9 rK r r< r Z writeonlyr r r r Zenginer r r r r% ZRelationshipPropertyZ strategy_forr2 r+ r r- r r r r Ú<module>
|
s: %
|
