U
|
¸ý°d¾N ã @ sf d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z dd lm
|
Z
|
dd
|
lm Z dd lm Z dd lm Z dd lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddl m Z dd l m Z dd l m Z dd l m!Z! dd l"m#Z# dd l"m$Z$ dd!l"m%Z% dd"l&m'Z' e rÒdd#l(m)Z) dd$lm*Z* dd%lm+Z+ dd&lm,Z, dd'lm-Z- dd(l.m/Z/ dd)l0m1Z1 e d*ed+Z2G d,d- d-Z3G d.d/ d/ej4ej5Z6ej7ej8j9d0d1G d2d3 d3ej:ej;Z<G d4d5 d5Z=G d6d7 d7ee2 Z>G d8d9 d9e>e2 Z?d:S );zèWrite-only collection API.
|
|
This is an alternate mapped attribute style that only supports single-item
|
collection mutation operations. To read the collection, a select()
|
object must be executed each time.
|
|
.. versionadded:: 2.0
|
|
|
é )Ú annotations)ÚAny)ÚGeneric)ÚIterable)ÚNoReturn)ÚOptional)Úoverload)ÚTuple)Ú TYPE_CHECKING)ÚTypeVar)ÚUnion)Ú bindparamé )Ú
|
attributes)Ú
|
interfaces)Ú relationships)Ú
|
strategies)Ú object_mapper)Ú PassiveFlag)ÚRelationshipDirectioné )Úexc)Úinspect)Úlog)Úutil)Údelete)Úinsert)Úselect)Úupdate)ÚDelete)ÚInsert)ÚUpdate)ÚLiteral)Ú _InstanceDict)Ú_AdaptedCollectionProtocol)ÚAttributeEventToken)ÚCollectionAdapter)ÚLoaderCallableStatus)Ú InstanceState)ÚSelectÚ_T)Úboundc @ sR e Zd ZdZdddZedd Zedd Zd d
|
Zd d Z d d Z
|
dd Z dS )ÚWriteOnlyHistoryzDOverrides AttributeHistory to receive append/remove events directly.Nc C sp |rH|t j@ r&t d| d| d¡|j| _|j| _|j| _|j| _n$t ¡ | _t ¡ | _t ¡ | _d| _d S )Nz
|
Attribute z¬ can't load the existing state from the database for this operation; full iteration is not permitted. If this is a delete operation, configure passive_deletes=True on the z- relationship in order to resolve this error.F)
|
r ÚSQL_OKr ÚInvalidRequestErrorÚunchanged_itemsÚ added_itemsÚ deleted_itemsÚ_reconcile_collectionr ZOrderedIdentitySet)ÚselfÚattrÚstateÚpassiveÚapply_to© r8 úOd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/orm/writeonly.pyÚ__init__G s
|
ÿ
|
|
|
|
zWriteOnlyHistory.__init__c C s t | j | j¡S ©N)Úlistr0 Úunionr/ ©r3 r8 r8 r9 Úadded_plus_unchanged\ s z%WriteOnlyHistory.added_plus_unchangedc C s t | j | j¡ | j¡S r; )r< r0 r= r/ r1 r> r8 r8 r9 Ú all_items` s
|
ÿÿzWriteOnlyHistory.all_itemsc C s` | j r0| j | j¡}| j | j¡}| j |¡}n| j| j| j }}}t t|t|t|¡S r; ) r2 r0 Ú
|
differencer/ r1 Ú intersectionr ZHistoryr< )r3 ÚaddedZdeletedZ unchangedr8 r8 r9 Ú
|
as_historyh s ý
|
zWriteOnlyHistory.as_historyc C s t | j| S r; )r< r0 )r3 Úindexr8 r8 r9 Úindexedu s zWriteOnlyHistory.indexedc C s | j |¡ d S r; )r0 Úadd©r3 Úvaluer8 r8 r9 Ú add_addedx s zWriteOnlyHistory.add_addedc C s( || j kr| j |¡ n | j |¡ d S r; )r0 Úremover1 rG rH r8 r8 r9 Ú add_removed{ s
|
z WriteOnlyHistory.add_removed)N) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r: Úpropertyr? r@ rD rF rJ rL r8 r8 r8 r9 r, D s
|
|
|
r, c s~ e Zd ZdZdZdZdZdZdZdZ e
|
Z fddZ e jfddZed:d d
|
d d d dddZed;d d
|
ddd dddZed<d d
|
ddddddZdejfd d
|
ddddddZejdd Zejdd Zd=d d Zd>d d Zd!d" Zdejdddfd d
|
d#d$dd#d%d%d&d' d(d)Zd*d+ Zd,d- Z e j fd.d/Z e j fd0d1Z d2d3 Z!e j fd4d5Z"e j fd6d7Z#e j fd8d9Z$ Z%S )?ÚWriteOnlyAttributeImplTFr8 c s4 t j||||f| || _t| _|r0t|| _d S r; )Úsuperr: Ú target_mapperÚWriteOnlyCollectionÚ query_classÚtupleÚorder_by)r3 Úclass_ÚkeyZ typecallableÚdispatchrT rX Úkw©Ú __class__r8 r9 r: s
|
|
z WriteOnlyAttributeImpl.__init__c C s* |t j@ s| |t j¡jS | | |¡S d S r; )r r- Ú_get_collection_historyÚPASSIVE_NO_INITIALIZEr0 rV )r3 r5 Údict_r6 r8 r8 r9 Úget s
|
ÿzWriteOnlyAttributeImpl.get.zInstanceState[Any]r# z Literal[None]z Literal[PassiveFlag.PASSIVE_OFF]r& )r5 ra Ú user_datar6 Úreturnc C s d S r; r8 ©r3 r5 ra rc r6 r8 r8 r9 Úget_collection¦ s z%WriteOnlyAttributeImpl.get_collectionr$ r c C s d S r; r8 re r8 r8 r9 rf ° s z$Optional[_AdaptedCollectionProtocol]zIUnion[Literal[LoaderCallableStatus.PASSIVE_NO_RESULT], CollectionAdapter]c C s d S r; r8 re r8 r8 r9 rf º s
|
Nc C s4 |t j@ s| ||¡j}n| ||¡}|j}t|S r; )r r- r_ r0 r? ÚDynamicCollectionAdapter)r3 r5 ra rc r6 ÚdataÚhistoryr8 r8 r9 rf Æ s
|
|
c C s t | t j¡S r; )r r% Z OP_APPENDr> r8 r8 r9 Ú _append_tokenÖ s z$WriteOnlyAttributeImpl._append_tokenc C s t | t j¡S r; )r r% Z OP_REMOVEr> r8 r8 r9 Ú _remove_tokenÚ s z$WriteOnlyAttributeImpl._remove_tokenc C sd |d kr| ||¡}| |¡ | jjD ]}||||p8| j}q&| jr`|d k r`| t |¡|d¡ d S ©NT) Ú_modified_eventrJ r[ Úappendrj Ú trackparentÚ sethasparentr Úinstance_state©r3 r5 ra rI Ú initiatorÚcollection_historyÚfnr8 r8 r9 Úfire_append_eventÞ s
|
z(WriteOnlyAttributeImpl.fire_append_eventc C sd |d kr| ||¡}| |¡ | jr@|d k r@| t |¡|d¡ | jjD ]}||||pZ| j qHd S )NF) rm rL ro rp r rq r[ rK rk rr r8 r8 r9 Úfire_remove_eventì s
|
z(WriteOnlyAttributeImpl.fire_remove_eventc C sJ | j |jkr$| | |tj¡|j| j < | || tj¡ d|| j < |j| j S rl )rZ Úcommitted_stateÚcollection_history_clsr ÚPASSIVE_NO_FETCHrm r Z NEVER_SET)r3 r5 ra r8 r8 r9 rm ú s ÿ
|
z&WriteOnlyAttributeImpl._modified_eventr z Optional[AttributeEventToken]ÚboolÚNone) r5 ra rI rs r6 Ú check_oldÚpopÚ_adaptrd c C sö |r|j | j krd S |r$|d kr$d S |} t| }
|
|jrd| jsNt d| d¡t | j|||d¡} | ||¡} |js~| j
|
} n | | j
|
¡} | |
|
¡} t |
|
¡ | ¡}| | ¡}|
|
D ] }||kr²| j|||d | d q²|D ]}| j|||d | d qØd S )Nz Collection "zV" does not support implicit iteration; collection replacement operations can't be used©r6 )rt )Z parent_tokenr< Ú has_identityÚ_supports_dynamic_iterationr r. r Z IdentitySetrb rm r0 r= rB rA rv rw )r3 r5 ra rI rs r6 r} r~ r ÚiterableZ
|
new_valuesZold_collectionrt Ú constantsZ additionsZremovalsÚmemberr8 r8 r9 Úset sP
|
ÿÿ ÿ
|
|
ûûzWriteOnlyAttributeImpl.setc O s
|
t d S r; ©ÚNotImplementedError)r3 ÚargsÚkwargsr8 r8 r9 r E s z WriteOnlyAttributeImpl.deletec C s t dd S )Nz7Dynamic attributes don't support collection population.r )r3 r5 ra rI r8 r8 r9 Úset_committed_valueH s ÿz*WriteOnlyAttributeImpl.set_committed_valuec C s | ||¡}| ¡ S r; )r_ rD ©r3 r5 ra r6 Úcr8 r8 r9 Ú get_historyM s z"WriteOnlyAttributeImpl.get_historyc C s | ||¡}dd |jD S )Nc S s g | ]}t |¡|fqS r8 )r rq )Ú.0Úxr8 r8 r9 Ú
|
<listcomp>U s z:WriteOnlyAttributeImpl.get_all_pending.<locals>.<listcomp>)r_ r@ r r8 r8 r9 Úget_all_pendingQ s z&WriteOnlyAttributeImpl.get_all_pendingc C sT | j |jkr|j| j }n| | |tj¡}|jrL|tj@ rL| j| |||dS |S d S )N)r7 )rZ rx ry r rz r r ZINIT_OK)r3 r5 r6 r r8 r8 r9 r_ W s ÿ ÿz.WriteOnlyAttributeImpl._get_collection_historyc C s || k r| ||||¡ d S r; )rv ©r3 r5 ra rI rs r6 r8 r8 r9 rn f s z WriteOnlyAttributeImpl.appendc C s || k r| ||||¡ d S r; )rw r r8 r8 r9 rK q s z WriteOnlyAttributeImpl.removec C s | j |||||d d S )Nr )rK r r8 r8 r9 r~ | s zWriteOnlyAttributeImpl.pop)..)..)..)N)N)&rM rN rO Z uses_objectsZ default_accepts_scalar_loaderZsupports_populationr Z
|
collectionZdynamicrX r, ry r: r Z PASSIVE_OFFrb r rf r r Zmemoized_propertyrj rk rv rw rm r r r rz r r` r r_ rn rK r~ Ú __classcell__r8 r8 r] r9 rR sh û û ûû
|
|
ÿ
|
ÿ
|
÷ =ÿ
|
ú
|
ú
|
úrR Z
|
write_only)Zlazyc @ s e Zd ZeZdd ZdS )ÚWriteOnlyLoaderc C s\ d| _ | jr | jjtjtjfkr0t d| j ¡t j
|
| j|d| j | jj | jj | jjd d S )NTztOn relationship %s, 'dynamic' loaders cannot be used with many-to-one/one-to-one relationships and/or uselist=False.)Z useobjectÚ
|
impl_classrT rX rV )Zis_class_levelZuselistZparent_propertyÚ directionr Ú ONETOMANYZ
|
MANYTOMANYr r. r Z_register_attributer ÚmapperrX rV )r3 r r8 r8 r9 Úinit_class_attribute s& þþÿùz$WriteOnlyLoader.init_class_attributeN)rM rN rO rR r r r8 r8 r8 r9 r s r c @ s8 e Zd ZdZdd Zdd Zdd Zdd Zd
|
d Zd S ) rg z9simplified CollectionAdapter for internal API consistencyc C s
|
|| _ d S r; )rh )r3 rh r8 r8 r9 r: ¦ s z!DynamicCollectionAdapter.__init__c C s
|
t | jS r; )Úiterrh r> r8 r8 r9 Ú__iter__© s z!DynamicCollectionAdapter.__iter__c C s d S r; r8 r> r8 r8 r9 Ú _reset_empty¬ s z%DynamicCollectionAdapter._reset_emptyc C s
|
t | jS r; )Úlenrh r> r8 r8 r9 Ú__len__¯ s z DynamicCollectionAdapter.__len__c C s dS rl r8 r> r8 r8 r9 Ú__bool__² s z!DynamicCollectionAdapter.__bool__N) rM rN rO rP r: r r r r r8 r8 r8 r9 rg £ s rg c @ s@ e Zd ZdZesdZdd Zddddd Zd
|
dd d d ZdS )ÚAbstractCollectionWriterzsVirtual collection which includes append/remove methods that synchronize
|
into the attribute event system.
|
|
r8 c C s~ | ¡ | _}|| _t|}|j| jj }|jd k rH|j ¡ |jf| _ nd| _ |j
|
|ddf| _ | jj rt| jj | _ nd| _ d S )Nr8 F)Zalias_secondary)ÚobjÚinstancer4 r Ú_propsrZ Z secondaryr Z__clause_element__Ú _from_objZ _with_parentÚ_where_criteriarX Ú_order_by_clauses)r3 r4 r5 r£ r Úpropr8 r8 r9 r: ¿ s
|
|
ÿ z!AbstractCollectionWriter.__init__ú Iterable[_T]r| ©Úiteratorrd c C s0 |D ]&}| j t | j¡t | j¡|d ¡ qd S r; )r4 rn r rq r£ Ú instance_dict)r3 r« Úitemr8 r8 r9 Ú _add_all_implÞ s
|
|
üz&AbstractCollectionWriter._add_all_implr* ©r rd c C s& | j t | j¡t | j¡|d ¡ d S r; )r4 rK r rq r£ r¬ ©r3 r r8 r8 r9 Ú _remove_implç s
|
|
üz%AbstractCollectionWriter._remove_implN) rM rN rO rP r
|
Ú __slots__r: r® r± r8 r8 r8 r9 r¡ ¶ s r¡ c @ s e Zd ZdZdZddddZdddd Zd
|
dd d Zd dddZddddZ dddddZ
|
dddddZ dddd d Z d S ) rU a Write-only collection which can synchronize changes into the
|
attribute event system.
|
|
The :class:`.WriteOnlyCollection` is used in a mapping by
|
using the ``"write_only"`` lazy loading strategy with
|
:func:`_orm.relationship`. For background on this configuration,
|
see :ref:`write_only_relationship`.
|
|
.. versionadded:: 2.0
|
|
.. seealso::
|
|
:ref:`write_only_relationship`
|
|
)r£ r4 r¦ r¥ r§ r )rd c C s t dd S )Nz°WriteOnly collections don't support iteration in-place; to query for collection items, use the select() method to produce a SQL statement and execute it with session.scalars().)Ú TypeErrorr> r8 r8 r9 r s ÿz WriteOnlyCollection.__iter__zSelect[Tuple[_T]]c C s< t | jjj| j }| jr&|j| j }| jr8|j| j }|S )zProduce a :class:`_sql.Select` construct that represents the
|
rows within this instance-local :class:`_orm.WriteOnlyCollection`.
|
|
) r r4 rT Úwherer¦ r¥ Ú select_fromr§ rX )r3 Zstmtr8 r8 r9 r s zWriteOnlyCollection.selectz
|
Insert[_T]c C s t | j}|j}|j| jj }|jtjk r4t
|
d¡i }|j D ],\}}| |||j |¡}td|d||j< q>t| jjjf |S )aN For one-to-many collections, produce a :class:`_dml.Insert` which
|
will insert new rows in terms of this this instance-local
|
:class:`_orm.WriteOnlyCollection`.
|
|
This construct is only supported for a :class:`_orm.Relationship`
|
that does **not** include the :paramref:`_orm.relationship.secondary`
|
parameter. For relationships that refer to a many-to-many table,
|
use ordinary bulk insert techniques to produce new objects, then
|
use :meth:`_orm.AbstractCollectionWriter.add_all` to associate them
|
with the collection.
|
|
|
z
Write only bulk INSERT only supported for one-to-many collections; for many-to-many, use a separate bulk INSERT along with add_all().N)Z callable_)r r£ r r¤ r4 rZ r r r r r. Zsynchronize_pairsZ_get_attr_w_warn_on_noneÚdictr r rT Úvalues)r3 r5 r r¨ ra ÚlÚrru r8 r8 r9 r s"
|
ÿüzWriteOnlyCollection.insertz
|
Update[_T]c C s t | jjj| j S )zProduce a :class:`_dml.Update` which will refer to rows in terms
|
of this instance-local :class:`_orm.WriteOnlyCollection`.
|
|
)r r4 rT r´ r¦ r> r8 r8 r9 r D s zWriteOnlyCollection.updatez
|
Delete[_T]c C s t | jjj| j S )zProduce a :class:`_dml.Delete` which will refer to rows in terms
|
of this instance-local :class:`_orm.WriteOnlyCollection`.
|
|
)r r4 rT r´ r¦ r> r8 r8 r9 r K s zWriteOnlyCollection.deleter© r| rª c C s | |¡ dS )zÐAdd an iterable of items to this :class:`_orm.WriteOnlyCollection`.
|
|
The given items will be persisted to the database in terms of
|
the parent instance's collection on the next flush.
|
|
N©r® )r3 r« r8 r8 r9 Úadd_allR s zWriteOnlyCollection.add_allr* r¯ c C s | |g¡ dS )zÂAdd an item to this :class:`_orm.WriteOnlyCollection`.
|
|
The given item will be persisted to the database in terms of
|
the parent instance's collection on the next flush.
|
|
Nrº r° r8 r8 r9 rG [ s zWriteOnlyCollection.addc C s | |¡ dS )z®Remove an item from this :class:`_orm.WriteOnlyCollection`.
|
|
The given item will be removed from the parent instance's collection on
|
the next flush.
|
|
N)r± r° r8 r8 r9 rK d s zWriteOnlyCollection.removeN) rM rN rO rP r² r r r r r r» rG rK r8 r8 r8 r9 rU ð s ( rU N)@rP Ú
|
__future__r Útypingr r r r r r r r
|
r r Zsqlalchemy.sqlr Ú r r r r Úbaser r r r r r r Zsqlr r r r Zsql.dmlr r r! Z util.typingr" Ú_typingr# r$ r% r& r' r5 r( Zsql.selectabler) r* r, ZHasCollectionAdapterZ AttributeImplrR Z class_loggerZRelationshipPropertyZ strategy_forZAbstractRelationshipLoaderZ
|
Identifiedr rg r¡ rU r8 r8 r8 r9 Ú<module>
|
sj >
|
ÿ :
|
