\Č̀ d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z d Z
G d
d e Z G d d
e Z
G d de
Z G d de Z G d de
e Z G d de Z G d de Z G d de Z G d de Z G d d e Z G d d e Zd S )!zThe internals for the unit of work system.
The session's flush() process passes objects to a contextual object
here, which assembles flush tasks based on mappers and their properties,
organizes them in order of dependency, and executes.
attributes)exc) persistence)util )event) topologicalc |j fd}fd}fd}t j | d|dd t j | d|dd t j | d|dd d S )
z\Establish event listeners on object attributes which handle
cascade-on-set/append.
c @ |d S | j }|r|j r| d | j j j }t
j | }|j j r<|j
s |j k r*| | s|
| |S )Nzcollection append)session_warn_on_events_flush_warningmanagermapper_propsr instance_state_cascade save_updatecascade_backrefskey_contains_state_save_or_update_statestateitem initiatorsessprop
item_stater s m/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/sqlalchemy/orm/unitofwork.pyappendz$track_cascade_events..append s < F} 7#
9##$7888='.s3D#2488J
)
7*
7.1Y].B.B ,,Z88 /C **:666 c |d S | j }| j j j }|r%|j r | |j rdnd ||t j uru|t j uri|j
j r_t j | }|j
| r3|r ||j v r| | d S d|_ d S d S d S d S d S d S )Nzcollection removezrelated attribute deleteT)r
r r r r r uselistr NEVER_SETPASSIVE_NO_RESULTr
delete_orphanr
_is_orphan_newexpunge _orphaned_outside_of_sessionr s r! removez$track_cascade_events..remove6 s# < F}}#*3/ D( <0##/
J 000J 888
+ 9 $2488J{%%j11
C CJ$) 3 3LL&&&&& ?CJ;;;!
008888
C
Cr# c 6 ||u r|S | j }|r|j r| d | j j j }|\t
j | }|j j r<|j
s |j k r*| | s|
| |t|t j urf|t j urX|j j rLt
j | }||j v r/|j | r| | |S )Nzrelated attribute set)r
r r r r r r r r r r r r r r& r' r( r* r) r+ ) r newvalueoldvaluer r r newvalue_stateoldvalue_stater s r! set_z"track_cascade_events..set_X sB x O} +#
=##$;<<<='.s3D#!+!:8!D!DM-? .?25 2F2F 0 0 @ @ 3G ..~>>> $ J$888 J$@@@M/ A ",!:8!D!D!TY..4;3I3I"4 4. LL***r# r" T)rawretvalr- setN)r r listen)
descriptorr r" r- r3 r s @r! track_cascade_eventsr9 s
(C , C C C C CD# # # # #J
LXv4EEEE LXv4EEEE LUDd4@@@@@@r# c e Zd Zd Zed Zd Zd Zd Zd Z e
j fdZ d Z
d Z dd Zd
Zd Zej d Zd Zd Zd Zd Zd Zd S )UOWTransactionc || _ i | _ t j t | _ t j t | _ i | _ i | _ t | _ i | _
t j d | _ d S )Nc : t t fS N)r6 r# r! z)UOWTransaction.__init__.. s CEE355> r# ) r
r r defaultdictr6 depsmapperspresort_actionspostsort_actions dependenciesstatespost_update_states)selfr
s r! __init__zUOWTransaction.__init__ s $S))
',,
"
!# EE
#'"23I3I"J"J r# c * t | j S r> )boolrG rI s r! has_workzUOWTransaction.has_work s DK r# c |j rS | |t j n1# t j $ r | j |g Y dS w xY wdS )zZReturn ``True`` if the given state is expired and was deleted
previously.
TF)expired
_load_expiredr PASSIVE_OFForm_excObjectDeletedErrorr
_remove_newly_deletedrI r s r! was_already_deletedz"UOWTransaction.was_already_deleted ss =
##E:+ABBBB-
22E7;;;tt
us * *AAc : || j v o| j | d S )z[Return ``True`` if the given state is marked as deleted
within this uowtransaction. rG rV s r!
is_deletedzUOWTransaction.is_deleted s" #= E(:1(==r# c Z || j v r
| j | S | x| j |< }|S r> r )rI r callable_rets r! memozUOWTransaction.memo s8 $/ ! !?3' ')2 4DOC 3Jr# c D | j | d }|df| j |< dS )z;Remove pending actions for a state from the uowtransaction.rY TNrZ )rI r isdeletes r! remove_state_actionsz#UOWTransaction.remove_state_actions s, ;u%a( & - Er# c 6 d||f}|| j v r| j | \ }}}|t j z s|t j z rr|j | j }| ||j t j t j z }|r |j r| }n|}|||f| j |< nh|j | j }| ||j |t j z }|r |j r| }n|}|||f| j |< |S )zOFacade to attributes.get_state_history(), including
caching of results.history)
r SQL_OKr impl get_historydictrR LOAD_AGAINST_COMMITTED uses_objectsas_state) rI r r passivehashkeyrd
state_historycached_passiverf s r! get_attribute_historyz$UOWTransaction.get_attribute_history sN eS) do % %59_W5M 2G]N
#Z%66
Mj //
M }S). **J *Z-NN
,t 0 ,$+$4$4$6$6MM$+M,3]G+L(=%*D &&uz7Z-N#N G
(4,
( ' 0 0 2 2
'
(/ 'HDOG $ r# c |df| j v S )NT)rD )rI processors r! has_depzUOWTransaction.has_dep s 4 D$888r# c T ||f}|| j vrt || | j |< d S d S r> )rD
Preprocess)rI rr
fromparentr s r! register_preprocessorz$UOWTransaction.register_preprocessor s? *% d* * *(29j(I(ID % % % + *r# FNc | j | s;|j s2|0t j dt j | d|d|d dS || j vrW|j j }|| j
vr| | | j
| | ||f| j |< n|s|s|r |df| j |< dS )NzObject of type z not in session, z operation along 'z' will not proceedFT)
r
r deletedr warnorm_utilstate_class_strrG r r rC _per_mapper_flush_actionsadd)rI r ra listonly
cancel_delete operationr r s r! register_objectz UOWTransaction.register_object s |++E22
=
Y%: /6666 444I
5 # #])FT\))..v666 L $ $U + + +"*H!5DK
7
7]
7&.%6 E"tr# c |j j j }| j | \ }}| | | | d S r> )r r base_mapperrH r~ update)rI r post_update_colsr rG colss r! register_post_updatez#UOWTransaction.register_post_update- sK %1.v6
5 $%%%%%r# c , t | |j }t | |j }| j ||f |j D ]}| | |j D ]&}|j r
|j }| | 'd S r> )
SaveUpdateAllr DeleteAllrF r~ _dependency_processorsper_property_preprocessors
relationshipsviewonly_dependency_processor)rI r savesdeletesdepr s r! r} z(UOWTransaction._per_mapper_flush_actions3 s dF$677D&"455 ug .///0 1 1C * *4 0 0 0 0( 1 1D}
,C * *4 0 0 0 0 1 1r# c , t j d S )a return a dynamic mapping of (Mapper, DependencyProcessor) to
True or False, indicating if the DependencyProcessor operates
on objects of that Mapper.
The result is stored in the dictionary persistently once
calculated.
c r | d j | d j | d j u S )NrY r )r getr r )tups r! r@ z0UOWTransaction._mapper_for_dep..L s+ A
))#a&*55QD r# )r PopulateDictrM s r! _mapper_for_depz UOWTransaction._mapper_for_depA s D D
r# c 2 | j fd|D S )zmFilter the given list of InstanceStates to those relevant to the
given DependencyProcessor.
c < g | ]}|j j f |S r? )r r ).0sr mapper_for_deps r!
z8UOWTransaction.filter_states_for_dep..U s- MMMa^QY5Es4K%LMMMMr# )r )rI r rG r s ` @r! filter_states_for_depz$UOWTransaction.filter_states_for_depO s+
-MMMMM6MMMMr# c # z K ||f}|j j D ]'}| j | D ]}| j | |k r|V (d S r> )r self_and_descendantsrC rG )rI r ra r checktupr s r! states_for_mapper_hierarchyz*UOWTransaction.states_for_mapper_hierarchyW sf h' (= F f-
;u%11 KKK
r# c
d}t j D ]}| rd}|snFt j j t j x _ }|r1t fd|D }t j D ] }d|v s/|d j
s"|d j
s| | r j | Q|d |v rN j | ||d D ]$} j
||d f %|d |v rM j | ||d D ]$} j
|d |f %t d j D | S )z}Generate the full, unsorted collection of PostSortRecs as
well as dependency pairs for this UOWTransaction.
TFc 3 ` K | ](}|t | fV )d S r> )r6 per_state_flush_actions)r recrI s r! z3UOWTransaction._generate_actions..v sO BEc#55d;;<<= r# NrY r c g | ] }|j | S r? disabled)r as r! r z4UOWTransaction._generate_actions.. s I I I1aj IQ I I Ir# )listrD valuesexecuter
find_cyclesrF rE cyclesrh r
issupersetr- r~ r6
difference)rI r^ actionr convertedger s ` r! _generate_actionsz UOWTransaction._generate_actions^ sV C t 3 : : < <==
>>$'' C
+ 6 tD$9$@$@$B$B C C
f > IO G T .//
>
>DLLAw' !Aw' ! ((.. !
%,,T2222!W&&%,,T222 &tAw / > > )--sDGn====>!W&&%,,T222 &tAw / > > )--tAwn==== I I-4466 I I I
*V
r# c : | }| j rMt j | j | D ]0}|r,| }| | | |,1d S t j | j | D ]}| | d S r> ) r r r
sort_as_subsetsrF popexecute_aggregatesortr )rI rE r3 nr s r! r zUOWTransaction.execute s 1133 ; "#3!#3
4
4 4
A''d333 4
4
4 #'(9;KLL
"
" D!!!!
"
"r# c > | j sdS t | j }t d | j D }| | }|r| j | |r | j | dS dS )zMark processed objects as clean / deleted after a successful
flush().
This method is called within the flush() method after the
execute() method has succeeded and the transaction has been committed.
Nc 3 * K | ]\ }\ }}|
|V d S r> r? )r r ra r s r! r z8UOWTransaction.finalize_flush_changes.. sD
+1*xh
r# )rG r6 itemsr r
rU _register_persistent)rI rG isdelothers r! finalize_flush_changesz%UOWTransaction.finalize_flush_changes s { FT[!!
/3{/@/@/B/B
!!%(( 6 L . .u 5 5 5 5 L - -e 4 4 4 4 4 5 5r# )FFFNN)__name__
__module__ __qualname__rJ propertyrN rW r[ r_ rb r PASSIVE_NO_INITIALIZErp rs rw r r r} r memoized_propertyr r r r r r r? r# r! r; r; sn +K +K +KZ ! ! X!
> > > . . . #-"B- - - - ^9 9 9J J J
D& & & 1 1 1
N N N 2 2 2 h" " ",5 5 5 5 5r# r; c e Zd Zd ZdS )IterateMappersMixinc j r+t fd j j j D S j j j S )Nc 3 D K | ]}j |j f |V d S r> )r dependency_processor)r mrI uows r! r z/IterateMappersMixin._mappers.. sM &4+D'EF r# )rv iterr parentr r rI r s ``r! _mappersz IterateMappersMixin._mappers sf ? I 29N
,3H Hr# N)r r r r r? r# r! r r s( I I I I Ir# r c e Zd ZdZd Zd ZdS )ru )r rv processedsetup_flush_actionsc V || _ || _ t | _ d| _ d S NF)r rv r6 r r )rI r rv s r! rJ zPreprocess.__init__ s* $8!$ #( r# c t }t }| | D ]i}|j | | j D ]A}|j | \ }}|s-|r| | ,| | Bj|r5| j || | j | |r5| j
|| | j | |s|rb| j sY| j ||d s | j ||d r!| j
| d| _ dS dS NTF)r6 r rC r r rG r~ r presort_deletesr
presort_savesr prop_has_changesper_property_flush_actions)rI r
delete_states save_statesr r ra r s r! r zPreprocess.execute s
ee mmC(( / /F V,77GG
/
/'*z%'8$8 / /%))%0000#...
/ 1 % 5 5c= I I I N ! !- 0 0 0 / % 3 3C E E E N ! !+ . . .
K
+
0)::
0 ,==e
0 )DDSIII+/(45r# Nr r r __slots__rJ r r? r# r! ru ru s9 I) ) ) ! ! ! ! !r# ru c e Zd ZdZd Zd ZdS ) PostSortRecr c | f|z }||j v r
|j | S t | x|j |< }d|_ |S r )rE object__new__r )clsr argsr r^ s r! r zPostSortRec.__new__ sS ftm #& & &', ,.4nnS.A.A AC % CLJr# c 0 | | d S r> )r )rI r recss r! r z PostSortRec.execute_aggregate s Sr# N)r r r r r r r? r# r! r r s7 I r# r c 0 e Zd ZdZd Zd Zd Zd Zd ZdS )
ProcessAll)r ra rv c || _ || _ || _ |j |j j | d S r> )r ra rv rB r r r~ )rI r r ra rv s r! rJ zProcessAll.__init__ sK $8!
$ %,89==
r# c | | }| j r | j || d S | j || d S r> ) _elementsra r process_deletes
process_saves)rI r rG s r! r zProcessAll.execute s\ $$ = A % 5 5c6 B B B B B % 3 3C @ @ @ @ @r# c t g S r> )r r s r! r z"ProcessAll.per_state_flush_actions s
Bxxr# c @ | j j d| j d| j dS )N(z , isdelete=)) __class__r r ra rM s r! __repr__zProcessAll.__repr__% s/ N # # # % % % MMM
r# c # K | | D ]3}|j | D ]#}|j | \ }}|| j k r|s|V $4d S r> )r rC rG ra )rI r r r ra r s r! r zProcessAll._elements, ss mmC(( F V,
'*z%'8$8t},,X, KKK
r# N) r r r r rJ r r r r r? r# r! r r sg @I
A A A
r# r c e Zd ZdZd Zd ZdS )
PostUpdateAllr ra c " || _ || _ d S r> r )rI r r ra s r! rJ zPostUpdateAll.__init__7 s
r# c j j \ }} fd|D }t j j || d S )Nc L g | ] }j | d j k |!S rY )rG ra )r r rI r s r! r z)PostUpdateAll.execute..= s0 IIIsz!}Q'74='H'H!'H'H'Hr# )rH r r post_update)rI r rG r s `` r! r zPostUpdateAll.execute; sR -dk: IIIIIVIII VS$?????r# Nr r? r# r! r r 4 s< $I! ! !@ @ @ @ @r# r c * e Zd ZdZd Zd Zd Zd ZdS )r r c * || _ ||j u sJ d S r> r r rI r r s r! rJ zSaveUpdateAll.__init__E # +++++++r# c p t j | j | | j dd | d S r )r save_objr r r s r! r zSaveUpdateAll.executeI s@ K + +DK F F
r# c # K t | | j dd }| j j }t || }|D ]2}t || }|j ||f |V 3|j | j D ]/}| || }|
||d 0d S r ) r r r r r SaveUpdateStaterF r~ rB r r ) rI r rG r
delete_allr r r states_for_props r! r z%SaveUpdateAll.per_state_flush_actionsP s + +DK F F
k- sK00
E %S%00F &*!5 6 6 6LLLL8DK( E EC ! 7 7V D DO ' '_e D D D D E Er# c 0 | j j d| j dS Nr r r r r rM s r! r zSaveUpdateAll.__repr__a >222DKKK@@r# Nr r r r rJ r r r r? r# r! r r B s] I, , ,
E E E"A A A A Ar# r c * e Zd ZdZd Zd Zd Zd ZdS )r r c * || _ ||j u sJ d S r> r r s r! rJ zDeleteAll.__init__h r
r# c p t j | j | | j dd | d S r )r
delete_objr r r s r! r zDeleteAll.executel s@ K + +DKu E E
r# c # K t | | j dd }| j j }t || }|D ]2}t || }|j ||f |V 3|j | j D ]/}| || }|
||d 0d S r ) r r r r r DeleteStaterF r~ rB r r ) rI r rG r save_allr r r r s r! r z!DeleteAll.per_state_flush_actionss s + +DKu E E
k- k22 E !e,,F (F!3 4 4 4LLLL8DK( D DC ! 7 7V D DO ' '_d C C C C D Dr# c 0 | j j d| j dS r r rM s r! r zDeleteAll.__repr__ r r# Nr r? r# r! r r e s] I, , ,
D D D"A A A A Ar# r c $ e Zd ZdZd Zd Zd ZdS ) ProcessStater ra r c 0 || _ || _ || _ d S r> r )rI r r ra r s r! rJ zProcessState.__init__ s $8!
r# c
| j | j | j fd|D }| | | j gd |D z }r || d S || d S )Nc J g | ] }|j u r|j u r |j u | S r? )r r ra )r rcls_r ra s r! r z2ProcessState.execute_aggregate.. sN
{d""&*>>>
h&&
'&&r# c g | ] }|j
S r? r r r$ s r! r z2ProcessState.execute_aggregate.. ; ; ;Q ; ; ;r# )r r ra difference_updater r r )rI r r our_recsrG r% r ra s @@@r! r z ProcessState.execute_aggregate s ~ # 8 =
x(((* ; ;( ; ; ;; < 0 0f = = = = = . .sF ; ; ; ; ;r# c t | j j d| j dt j | j d| j dS )Nr z, z , delete=r )r r r r{ state_strr ra rM s r! r zProcessState.__repr__ sE N # # # % % % tz * * * * MMM
r# Nr r r r rJ r r r? r# r! r r sF ;I
< < <$
r# r c $ e Zd ZdZd Zd Zd ZdS )r r r c 6 || _ |j j | _ d S r> r r r rI r r s r! rJ zSaveUpdateState.__init__
l. r# c | j | j fd|D }| | t j | j gd |D z | d S )Nc 8 g | ]}|j u |j u |S r? r r r r$ r% r s r! r z5SaveUpdateState.execute_aggregate.. 8
q{d 2 2qx67I7IA7I7I7Ir# c g | ] }|j
S r? r' r( s r! r z5SaveUpdateState.execute_aggregate.. s #>#>#>AG#>#>#>r# )r r r* r r r )rI r r r+ r% r s @@r! r z!SaveUpdateState.execute_aggregate s ~
x((( TZL#>#>X#>#>#>>
r# c T | j j dt j | j dS r r r r{ r- r rM s r! r zSaveUpdateState.__repr__ 0 N # # # tz * * * *
r# Nr. r? r# r! r r sF !I/ / /
r# r c $ e Zd ZdZd Zd Zd ZdS )r r0 c 6 || _ |j j | _ d S r> r2 r3 s r! rJ zDeleteState.__init__ r4 r# c | j | j fd|D }| | | j gd |D z }t j fd|D d S )Nc 8 g | ]}|j u |j u |S r? r7 r8 s r! r z1DeleteState.execute_aggregate.. r9 r# c g | ] }|j
S r? r' r( s r! r z1DeleteState.execute_aggregate.. r) r# c : g | ]}j | d |S r rZ )r r r s r! r z1DeleteState.execute_aggregate.. s) ;;;1#*Q-*:;Q;;;r# )r r r* r r r )rI r r r+ rG r% r s ` @@r! r z DeleteState.execute_aggregate s ~
x(((* ; ;( ; ; ;; ;;;;;;;S
r# c T | j j dt j | j dS r r< rM s r! r zDeleteState.__repr__ r= r# Nr. r? r# r! r r sF !I/ / /
r# r N)__doc__ r r rS r r r{ r r
r9 r r; r ru r r r r r r r r r? r# r! rG s fA fA fARy5 y5 y5 y5 y5V y5 y5 y5x I I I I I& I I I/ / / / /$ / / /d
&
% % % % % $k % % % P @ @ @ @ @K @ @ @ A A A A AK A A AF A A A A A A A AF
;
F
k
2
+
r#