jE * d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddlm
Z
dd lm Z d
dlmZ d
d lm
Z
d
dlmZ G d d
e Z G d de Z G d de Z G d de Z G d de Ze ee
ee eiZdS )z Relationship dependencies.
)
attributes)exc)sync)
unitofwork)util)
MANYTOMANY) MANYTOONE) ONETOMANY )sqlc e Zd Zd Zed Zd Zd Zd Zd Z d Z
d Z d Z d
Z
d Zd Zd
Zd ZddZd Zd ZdS )DependencyProcessorc || _ |j | _ |j | _ |j | _ |j | _ |j | _ |j | _ |j | _ |j | _ |j | _ | j rt j | _ nt j
| _ | j rt j | _ nt j
| _ |j | _ | j j s t# j d| j z d S )Nz|Can't build a DependencyProcessor for relationship %s. No target attributes to populate between parent and child are present)propcascademapperparent secondary direction post_updatepassive_deletespassive_updatesenable_typechecksr PASSIVE_NO_INITIALIZE_passive_delete_flag PASSIVE_OFF_passive_update_flagkeysynchronize_pairssa_exc
ArgumentError)selfr s m/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/sqlalchemy/orm/dependency.py__init__z DependencyProcessor.__init__ s | k k + # 3 # 3 !%!7 ?(2(HD % %(2(>D % ?(2(HD % %(2(>D %8y* &$&*i0
c 6 t |j | S N)_direction_to_processorr )clsr s r# from_relationshipz%DependencyProcessor.from_relationship6 s &t~6t<< r=
child_actionschild_in_cyclesr? rA parent_in_cyclesr0 sum_ child_statechild child_actiondeletedlistonly
childisdeletes r# per_state_flush_actionsz+DependencyProcessor.per_state_flush_actionsg s !K ; .s4EFF ",S2CDD
' & 1#tT4 H HM%)M " "#.sD%FFJ"&J cj ( (
!
2222 *5 1M43H IM #OO "O (%3T[, L .2 1N]sz))#' ' 1#t{7N O ON(, ,L: ++#' 7 7 E =*/??
6)) 5 D
J * 7T4 O O
# H%/%;C%G%GN ' 4S$u M M
# J#-#=c5#I#IL
7 "
*. 7 7&K"#*44'3 .1j.E+(" * 6sK H H $, LL !+ :3 L L %, L "(( 6666 0=
+ m++ " ! !
[7 7 r% c dS NF r" uowcommitrO s r# presort_deletesz#DependencyProcessor.presort_deletes ur% c dS r` ra rb s r#
presort_savesz!DependencyProcessor.presort_saves re r% c d S r' ra rb s r# process_deletesz#DependencyProcessor.process_deletes r% c d S r' ra rb s r#
process_savesz!DependencyProcessor.process_saves rj r% c * |r| j r
t j }n'| j t u r
t j }n t j }|D ]7}| || j | }|r| s dS 8|o| j
j o
| j |j
v S )NT)r r r r r PASSIVE_NO_FETCH_RELATEDr get_attribute_historyr emptyr _is_self_referentialr mappers)r" rc rO rR passiveshistorys r# prop_has_changesz$DependencyProcessor.prop_has_changes s -4/ - 6GG
^y
(
( 9GG ,G A 55a7KKG
w}}
tt 5 665K9#44
r% c | j j r | t j d| j || j || j s| j |d r5t j d|j | j | j j | j dz t j d|j | j | j j dz d S d S )Nz+Can't flush None value found in collection )allow_subtypesTaE Attempting to flush an item of type %(x)s as a member of collection "%(y)s". Expected an object of type %(z)s or a polymorphic subclass of this type. If %(x)s is a subclass of %(z)s, configure mapper "%(zm)s" to load this subtype polymorphically, or set enable_typechecks=False to allow any subtype to be accepted for flush. )xyzzmzAttempting to flush an item of type %(x)s as a member of collection "%(y)s". Expected an object of type %(z)s or a polymorphic subclass of this type.)ry rz r{ )r uselistr
FlushErrorr _canloadr class_r/ s r# _verify_canloadz#DependencyProcessor._verify_canload s 9 & ..#'99/
t{';'; d&<"< (< (
(
{##E$#??
n= #\ !Y ![ / "k $ n! #\ !Y ![ / -
r% c t r' NotImplementedError)r" r0 rY associationrow clearkeysrc s r# _synchronizez DependencyProcessor._synchronize" !###r% c | j j sd S t t | j gd | j j D z }| d|ft S )Nc g | ] }|j
S ra )r ).0ps r#
zCDependencyProcessor._get_reversed_processed_set..* s L L L1 L L Lr% reverse_key)r _reverse_propertytuplesortedr memoset)r" r4 process_keys r# _get_reversed_processed_setz/DependencyProcessor._get_reversed_processed_set% sf y* 4 DH: L L 0K L L LL M M
xx 4c:::r% Fc r |D ]3}|r|-| |d | j j D d S 4d S )Nc g | ]\ }}|S ra ra )r lrs r# r z4DependencyProcessor._post_update..2 s FFF$!QAFFFr% )register_post_updater r )r" r0 rc related
is_m2o_deletery s r# _post_updatez DependencyProcessor._post_update. sf A
AM..FF$)*EFFF %2 r% c t r' r r" rc r0 s r# _pks_changedz DependencyProcessor._pks_changed6 r r% c 0 | j j d| j dS )N()) __class____name__r )r" s r# __repr__z DependencyProcessor.__repr__9 s >222DIII>>r% N)F)r
__module__ __qualname__r$ classmethodr* r. r5 rC r^ rd rg ri rl rv r r r r r r ra r% r# r r s, 8 = = [=M M M. . .
8n n n`
,' ' 'R$ $ $; ; ; $ $ $? ? ? ? ?r% r c > e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d S )
OneToManyDPc
N | j rnt j || j j d }t j || j j d } |j ||f||f||f|| f| |f| |fg d S |j ||f||f||f||f||f||f||fg d S r7 r r
PostUpdateAllr r: dependenciesupdate)
r" r4 r? r@ rA rB r= r> child_post_updateschild_pre_updatess
r# r< z%OneToManyDP.per_property_dependencies> s !+!9T[4e" " !+ 8T[4d! !
# # *-!:. !34"$56&7&
6
# #!:. - / .1"N3"K0"M2
r% c D | j rt j || j j d } t j || j j d }
|sI|r"|j ||f|| fg d S |j ||f||f|| fg d S |r"|j ||
f|
|fg d S |j ||
f|
|fg d S |s%|j ||f||f||fg d S |j ||f||fg d S r7 r ) r" r4 save_parent
delete_parentrZ r= r> rR r] r r s r# rQ z"OneToManyDP.per_state_dependenciesg s 5 !+!9T[4e" " !+ 8T[4d! !
$++ ): 6 '); < $++ (* 5 ): 6 '); < !
$++ *,= > .
> $++ *,= > .
> # # *- . ,/
# # . }0MN
r% c | j j o | j dk }|D ]}| || j | j }|r|j D ]T}|P| | du r9| j j r| |d ?| | U|r)|j
D ]!}| | |d| j "d S )NallFTrR delete operationr ) r r r ro r r r[ r.
delete_orphanregister_object unchangedr r" rc rO should_null_fksr0 ru rY s r# rd zOneToManyDP.presort_deletes s
# # ID,@E,I(I E 55tx!: G
$_ = =E (T^^E-B-Be-K-K <5 = % 5 5ed 5 K K K K % 5 5e < < <" !(!2 , % 5 5 % 6 r% c h | d| ft }| j j o | j dk }|D ]w}| || }|r| j r
t j }n t j }|
|| j | }|r|j D ]"} | |
| dd| j #| |j |j D ]} | j j s!|r |
| dd| j /| | du rX|
| dd| j | j d| D ] \ }
} } }
|
| d |r2|r0|j D ](} | $|
| d| j d
| j )yd S ) Nchildren_addedr Tadd)
cancel_deleter r Fr rR r r r z pk changer )r r r r r r r r r r ro r addedr r r r[ r. r cascade_iteratorr )r" rc rO r r r0 pks_changedrs ru rY cmst_dct_s r# rg zOneToManyDP.presort_saves sW " )94(@#FF * *
2(E11
4 4 E ++Iu==K
1$"6
1$:$0 55eTXwOOG
J $] E (!11 !*.&+!% 2 %%gm444 $_ J JE <5 J* % 5 5 %).*2%)Y 6 ..%77!11 !%)&.!% 2 04{/K/K $e0 0 J JOAq#t & 5 5cD 5 I I I I
!(!2 , % 5 5 % % $ 4*5%)Y 6 ]4 4 r% c
j | j s | j dk s | d| ft }|D ]}| || j | j }|r|j D ]V}|R| | du r;| ||d d|d | j r|r|
|||g W| j s | j j sgt |j
| D ]?}|;| ||d d|d | j r|r|
|||g @d S d S )Nr r FT)r r r r ro r r r[ r. r r r r r
difference)r" rc rO r r0 ru rY s r# ri zOneToManyDP.process_deletes s &4#75#@#@ &^^-=t,Dc J JN
&
⛜T%> &!( M M ! - $u 5 5 > > - - %udD)U $ / ME M $ 1 1%UG L L L' &t|/B &%():%;%;%F%F *& &
&
&E % 0 $ 1 1$)5$i!" !" !" $(#3 !& !&$($5$5(-y5'%& %& %&9 $A#@
&
&r% c
| j j o | j dk }|D ]}| || j t
j }|r|j D ]=}| ||d d|d | | j r|
|||g >|j D ]?}|r;| j j s/| | s| ||d d|d @|
|| r$|j D ] }| ||d d|d d S )Nr FT)r r r ro r r r r r r r r[ r. r r r s r# rl zOneToManyDP.process_saves/ s * *
2(E11
E 55tx!A G
$] E EE%% udE9e (T-=( ))%UGDDD $_ E' $ : !%u 5 5
)) !5$i $$Y66 !(!2 )) !5$y$ 1 r% c 4 |}|}| | | | j s| | rd S |r't j || j | j j d S t j || j || j | j j || j
o| d S r' ) r r
is_deletedr clearr r r populater r ) r" r0 rY r r rc r sourcedests r# r zOneToManyDP._synchronizeQ s U### < %.%9%9$%?%?
F JtT[$)*E F F F F F M +$4
r% c N t j ||| j | j j S r' r source_modifiedr r r r s r# r zOneToManyDP._pks_changedh ' # udk49+F
r% N) r r r r< rQ rd rg ri rl r r ra r% r# r r = s ' ' 'RA A AF 6< < < |%& %& %&X D .
r% r c B e Zd Zd Zd Zd Zd Zd Zd Zd Z d
d Z
dS ) ManyToOneDPc t | | | j j D ])}|j t
| *d S r' )r r$ r self_and_descendants_dependency_processorsrP DetectKeySwitch)r" r r s r# r$ zManyToOneDP.__init__o s\ $$T4000k6 H HF ) 0 0 1F1F G G G G H Hr% c
B | j rqt j || j j d }t j || j j d } |j ||f||f||f|| f|| f| |f| |fg d S |j ||f||f||f||fg d S r7 r r r r r: r r )
r" r4 r? r@ rA rB r= r> parent_post_updatesparent_pre_updatess
r# r< z%ManyToOneDP.per_property_dependenciest s ",":T[4e# # ",!9T[4d" "
# # *-!:. !45 !34"$67' 7' 8
# # *- .!=1#]3
r% c @ | j r|sit j || j j d } |r"|j || f| |fg d S |j ||f||f|| fg d S t j || j j d }
|j ||
f|
|f|
|fg d S |sC|s"|j ||f||fg d S |j ||fg d S |r |j ||fg d S d S r7 r ) r" r4 r r rZ r= r> rR r] r r s r# rQ z"ManyToOneDP.per_state_dependencies s , I
&0&>8%' '# ! $++ ')< = 0, ? $++ (* 5 ): 6 ')< = &0%=8$& &" ''&(:;+];+\:
I
E ''"J/*k1JK ''*k)B(CDDDDD
I ''- )F(GHHHHH
I
Ir% c | j j s | j j r|D ]}| || j | j }|r| j j r| }n| }|D ]_}|| |dd| j | j
d| }|D ] \ }} }
} | |
d `d S d S )NTr r r ) r r r ro r r sum non_deletedr r r r ) r" rc rO r0 ru todeleterY tr r r r s r# rd zManyToOneDP.presort_deletes s8 < J$,"< J
J
J#9948T%> J|1 9#*;;==#*#6#6#8#8!) J J = $!11 !%)&.!% 2 !K 8 85 I I/0 J JOAq#t % 5 5cD 5 I I I IJ) J J
J
Jr% c |D ]}| |d| j | j j r| || j | j }|r{|j D ]s}| | du rZ| |dd| j | j
d| }|D ] \ }}} }
| | d td S )Nr r FTr r r ) r r r r ro r r r[ r. r r ) r" rc rO r0 ru rY r r r r r s r# rg zManyToOneDP.presort_saves s N NE % %eu49 % M M M|)
N#9948T%> N!( N N >>%00E99 % 5 5 %)-*2%)Y 6 !% < z=DetectKeySwitch.per_property_preprocessors..d s9 ( r% )r r r r2 r3 s r# r5 z*DetectKeySwitch.per_property_preprocessors_ sp 9 & #
$ ; F !!$.....r% c t j || j j }t j || dd }|j ||fg d S r` )r r9 r rG r8 r r )r" r4 r? r= s r# rC z*DetectKeySwitch.per_property_flush_actionsl sT !/T[5LMM *3eUCC
,
!; <=====r% c d S r' ra )r" r4 rO rR s r# r^ z'DetectKeySwitch.per_state_flush_actionsq rj r% c d S r' ra rb s r# rd z DetectKeySwitch.presort_deletest rj r% c D | j s| || d S d S r' r _process_key_switches)r" r4 rO s r# rg z DetectKeySwitch.presort_savesw s5 # 4
& &vs 3 3 3 3 3 4 4r% c b |s,| j r%| || }t | S dS r` )r _key_switchersbool)r" r4 rO rR ds r# rv z DetectKeySwitch.prop_has_changes} s9 D 0 ##C00A77Nur% c J r' ra rb s r# ri z DetectKeySwitch.process_deletes s ur% c D | j sJ | || d S r' r rb s r# rl z DetectKeySwitch.process_saves s/
#### ""6955555r% c | d| fd \ }}| | }|D ]G}||vrA| || r| | 2| | H|S )N pk_switchersc : t t fS r' )r ra r% r# z0DetectKeySwitch._key_switchers.. s SUUCEEN r% )r unionr r )r" r4 rO switched notswitched allstatesrt s r# r z DetectKeySwitch._key_switchers s #
T "$:$:!
!
+ NN;// ' 'A !!$$S!,, ' LLOOOO OOA&&&r% c
X | || }|r|j j D ]}t |j | j j s"|j }| | j
||| j }|t j
ur|| j j r |s}|d }n|}t j | }||v rO| |d| j t' j || j || j | j j || j d S d S )N)rs F)r r identity_map
all_states
issubclassr r rK r- r getr r PASSIVE_NO_RESULTr r} instance_stater r r r r r ) r" deplistrc switchersr0 dict_r related_obj
related_states r# r z%DetectKeySwitch._process_key_switches s^ '' 7;; ! #*7BBDD
!%, 0BCC
..22665$*C 7 :#??? +y( . & % $&-aj &- $.$=k$J$JM$ 11!11 !5$*>
) K ! K I 7 % 0 3! !
r% c v t |j o%t j ||| j | j j S r' )r r r r r r r r s r# r z DetectKeySwitch._pks_changed s6 EI
4#7 udk49+F$
$
r% N)r r r __doc__r5 rC r^ rd rg rv ri rl r r r ra r% r# r r S s / / /> > >
4 4 4 6 6 6 # # #J
r% r c D e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z d
S ) ManyToManyDPc
d |j ||f||f||f||f||f||f||fg d S r' r r )r" r4 r? r@ rA rB r= r> s r# r< z&ManyToManyDP.per_property_dependencies sh z* j)]+ - /
. ,
r% c |sF|r"|j ||f||fg d S |j ||f||fg d S |j ||f||fg d S r' r" ) r" r4 r r rZ r= r> rR r] s r# rQ z#ManyToManyDP.per_state_dependencies s
''!:.\0JK ''!:. z0JK
# # .
0NO
r% c d | j s&|D ]%}| || j | j $d S d S r' )r ro r r )r" rc rO r0 s r# rd z ManyToManyDP.presort_deletes s] #
//48T%>
r% c | j sA|D ]>}| || r&| || j t j }?| j j sd S |D ]}| || j t j }|ry|j D ]q}|
| du rX| |dd| j | j
d| D ] \ }}}} | |d rd S )NFTr r r )r r ro r r r r r r r[ r. r r r r )
r" rc rO r0 ru rY r r r r s
r# rg zManyToManyDP.presort_saves
s^ #
$$Y66 ' = = tx)? G |) F J JE 55tx!A G
J $_ J JE~~e,,55!11 !%)&.!% 2 04{/K/K $e0 0 J JOAq#t & 5 5cD 5 I I I I! J Jr% c
g }g }g }| | }t }|D ] | | j | j }|r| D ]?} | | | f|v r
i }
| | |
d|d s*| |
@| fd| D || | | |||| d S )NFr c 3 K | ]}|fV d S r' ra r r r0 s r# r z/ManyToManyDP.process_deletes..K s' CC!Au:CCCCCCr% )
r r ro r r non_addedr rP r _run_crud) r" rc rO secondary_deletesecondary_insertsecondary_update processedtmpru rY r r0 s @r# ri z ManyToManyDP.process_deletes, sl 44Y?? ee D DE 55tx!: G
D $ . . 0 0 < |
j D ]=} |
| f|v r i } |
| | d|d s(| | >|
fd|
j |
j z D |ro|
j D ]g} i } t j
| j | d| j j t j
| | j | d| j j | | h||
| | |||| d S )NFr r c 3 K | ]}|fV d S r' ra r( s r# r z-ManyToManyDP.process_saves..~ s' OO!Au:OOOOOOr% old_)r r r r r r r ro r r r rP r[ r r r r r r r secondary_synchronize_pairsr* )r" rc rO r+ r, r- r. r/ need_cascade_pksrs ru rY r r0 s @r# rl zManyToManyDP.process_savesT s 44Y?? ee 7 @ 7 @E#'#7 7 D. sH 5N22 S]15 ? ? ??222r% zRDELETE statement on table '%s' expected to delete %d row(s); Only %d were matched.c p g | ]2}|j v |t j d |j z |j k 3S )r2 r7 r9 r< s r# r z*ManyToManyDP._run_crud.. sL 5N22 S]6AE> H H HH222r% zRUPDATE statement on table '%s' expected to update %d row(s); Only %d were matched.) transaction
connectionr r r r and_r execute supports_sane_multi_rowcountrowcountlenr StaleDataError descriptionr insert) r" rc r, r- r+ r? statementresultr s @r# r* zManyToManyDP._run_crud s% *55dkBB
-a 0N -- !% !1 I '' 3CDDF 3355
/S)9%:%:::(7 2 ,-- -a 0N -- !% !1 I '' 3CDDF 3355
/S)9%:%:::(7 2 ,-- < --//I y*: ; ; ; ; ; < |j s5t j dt
j | d|d| j d dS t j
|| j || j j t j
|| j
|| j j dS )NFr r r r T)r r r r[ r r r r r r
populate_dictr r r r3 r s r# r zManyToManyDP._synchronize s
U### =5 Y%6%F%Fu%M%M =
"1%8888)))TYYYP
5 4; 0K
K I 1
tr% c N t j ||| j | j j S r' r r s r# r zManyToManyDP._pks_changed r r% N) r r r r< rQ rd rg ri rl r* r r ra r% r# r r s
8 2
J J JD&
&
&
PF
F
F
P;< ;< ;rP s " " " " " " ! ! ! ! ! ! ! ! ! ! ! ! a? a? a? a? a?& a? a? a?H n
n
n
n
n
% n
n
n
b b b b b b% b b bJr
r
r
r
r
) r
r
r
ju
u
u
u
u
& u
u
u
r {
{ r%