<#r ^ d Z ddlmZ ddlmZ ddlZddlmZ ddlmZ ddlmZ dd lm
Z
dd
lm Z dd l m
Z
dd l mZ d
dlmZ d
dlmZ d
dlmZ d
dlmZ d
dlmZ d Zd Zd=dZd Zd Zd Zd Zd Z d>dZ d=d Z d Z d Z d?d Z! d?d!Z"d" Z#d# Z$d$ Z%d% Z&d& Z'd' Z(d( Z)d) Z*d* Z+ G d+ d,e, Z- G d- d.e- Z. G d/ d0e- Z/ G d1 d2e- Z0 G d3 d4e- Z1 G d5 d6e.e0 Z2 G d7 d8e.e1 Z3 G d9 d:e/e0 Z4 G d; dz _bulk_insert..7 s @@@euej)@@@ c g | ]\ }}|S r r )r r dict_s r r z _bulk_insert..8 s ;;;.5%;;;r c g | ] }|j
S r r r s r r z _bulk_insert..: 999u
999r c 3 > K | ]\ }}}}}}}}d ||
|||fV d S Nr ) r r
state_dictparamsmpconn value_params has_all_pkshas_all_defaults
connectionmappers r z _bulk_insert..C sk
#
r c 3 $ K | ]
}d |fV d S r" r r mappingr* r+ s r r, z _bulk_insert..Y s, MM$4MMMMMMr T)bulkreturn_defaults render_nulls bookkeepingc g | ] }|j
S r key)r ps r r z _bulk_insert..k s DDDA!%DDDr c g | ]
}| S r r )r r7 r s r r z _bulk_insert..o s <<>$// <._changed_dict.. sO
1E)))Q+-=-= F-=-=-=-=
r )r rA )r+ r rY s `r
_changed_dictz#_bulk_update.._changed_dict~ sO
((**
r c ( g | ]} | S r r )r r rZ r+ s r r z _bulk_update.. s% KKK
fe44KKKr c g | ] }|j
S r r r s r r z _bulk_update.. r r zJconnection_callable / per-instance sharding not supported in bulk_update()c 3 X K | ]$}d |j r|j j nd fV %d S r" )_version_id_propr7 r. s r r, z _bulk_update.. sg
"2" 7 ;<< !
r T)r0 Fr3 )r: r; _primary_key_propkeysr^ r7 unionr? r< r= r> r* r@ rA rB _collect_update_commands_emit_update_statements)
r+ rH rI rJ update_changed_onlyr: rK rM rN rO rZ r* rY s
` @@@r _bulk_updaterd s s $K0==.K
G .2399+FF
" :KKKKK(KKKHH99999HH>>"6
!
-
%// <. sI
;UJ
FJ>
r c 3 0 K | ]\ }}}}}||||d fV dS )TNr )r r r# r+ r* update_version_ids r r, zsave_obj.. sR
%
FJ=
r )batch _sort_statessave_objr; _organize_states_for_saveappendr@ rA
_pks_by_tablerC ra rb rD _finalize_insert_update_commandsr )r: rL uowtransactionrf r states_to_updatestates_to_insertrK r r+ r* has_identity
row_switchri rM insertupdates r rl rl s ++ !+v66 H HE [5'>$ G G G G G0==
#; G GH H
H: H # #vz3DE
# #UE6:$F G G G G$399;;
v , , , )%1ABB) E#3
%
?O
&
r c " t | }t t | || }| j D ]E\ j vrfd|D }t
| ||| }t | ||| FdS )z\Issue UPDATE statements on behalf of a relationship() which
specifies post_update.
c
3 K | ]<\ }}}}|j v ||||j ||j nd fV =d S r" )ro version_id_col#_get_committed_state_attr_by_column)r r r#
sub_mapperr* r+ rM s r r, z post_update.. s
:z:z
000 (4 :::v'<
1000
r N)r; r? _organize_states_for_post_updater@ rA ro _collect_post_update_commands _emit_post_update_statements) r: rL rq post_update_colsrK rr rw r+ rM s @@r post_updater s
1==(fnMM %399;;
v , , ,
>N
/ 8H
%
1
r c t | }t t | || }| j }t t | D ]I}|| }||j vr|j r|j r#t | ||| }t | ||||| J|D ]$\ } }
}} } |j || | %dS )zIssue ``DELETE`` statements for a list of objects.
This is called within the context of a UOWTransaction during a
flush operation.
N)
r; r? _organize_states_for_deleter@ reversedkeysro inheritspassive_deletes_collect_delete_commands_emit_delete_statementsdispatch after_delete)
r: rL rq rK states_to_deletetable_to_mapperrM r+ deleter r# r* ri s
r
delete_objr ; s* 1==#K HH "0O$ 3 3 5 56677
' , , ,
_ !7 ) 0@
@ @
$$VZ????@ @r c # K t | || D ]\ }}}}t |j }|j p| | }dx} }
|s |j ||| n |j ||| |j r| ||| |s||j j v r|j j | } t j | } | | s|
| s7t j dt! | d|dt! | | d|t! | t! | | | | } |s| r0|j )| | r| n|| r| j n||j }
|||||| |
fV dS )aT Make an initial pass across a set of states for INSERT or
UPDATE.
This includes splitting out into distinct lists for
each, calling before_insert/before_update, obtaining
key information for each state including its dictionary,
mapper, the connection to use for the execution per state,
and the identity flag.
Nz
New instance z with identity key z$ conflicts with persistent instance zPdetected row switch for identity %s. will update %s, remove %s from transaction)_connections_for_statesboolr7 _identity_key_from_stater
before_insert
before_update _validate_polymorphic_identityr< identity_mapr instance_statewas_already_deleted
is_deletedorm_exc
FlushErrorr
_log_debugremove_state_actionsrz r{ r )
r: rL rq r r r+ r* rt instance_keyru ri instanceexistings
r rm rm i sX -D^V- - B
B
(ufj EI yJF$C$CE$J$J )--
& E O ) )&*e D D D D O ) )&*e D D D 0 H 1 1&% G G G & 6 CCC%-:<HH!0::H!55h??
&%00:: !,, %U++++\\\9X;N;N;NP &&" ! e$$ h''
33H=== %
J F,A,M & J J (3
e#-8
5%! !
uB
B
r c $ t | || S )zMake an initial pass across a set of states for UPDATE
corresponding to post_update.
This includes obtaining key information for each state
including its dictionary, mapper, the connection to use for
the execution per state.
)r )r: rL rq s r r} r} s #; G GGr c # K t | || D ]R\ }}}}|j ||| |j | |||j }nd}|||||fV SdS )zMake an initial pass across a set of states for DELETE.
This includes calling out before_delete and obtaining
key information for each state including its dictionary,
mapper, the connection to use for the execution per state.
N)r r
before_deleterz r{ )r: rL rq r r r+ r* ri s r r r s -D^V- -
D
D(ufj %%fj%@@@ , & J Juf 3! ! !% eVZ1BCCCCC
D
Dr c # K |D ]\ }}}}| |j vri } i }
|j | } |j | } t | | D ]{}
||
}| |
}||| vr|s|sTt |d st
|t j r*t |d r| n||
|< q|| |j
< ||sE|j | | d |
D D ]}d| |< |r|rP|j
| | }|j j r!|j | | }nd}ndx}}|j dur=|j 6|j |j | v r"| d | |j j
< ||| |||
||fV dS )zSIdentify sets of values to use in INSERT statements for a
list of states.
N__clause_element__c g | ] }|j
S r r6 )r cs r r z,_collect_insert_commands.. s 9 9 9qQU 9 9 9r TF)ro _propkey_to_col _insert_cols_evaluating_noneset intersectionhasattr
isinstancer
ClauseElementr r7 _insert_cols_as_none
difference_pk_keys_by_tableissubsetr: eager_defaults_server_default_colsversion_id_generatorrz _cols_by_table)rM rs r0 r1 r2 r r# r+ r* r$ r' propkey_to_col eval_nonepropkeyvaluecolcolkeyr( r) s r rC rC sz 2B J
J
-z6: , , , /67> >**77
CC ( (G w'E )C}I!5!5l!5
( 344
( eS%677
( u&:;; E,,... S!! #(sw & +E2F## 9 9L 9 9 9::
&
&
"&v 2 2 !259BB6JJK!0
(#)#>u#E#N#N$ $ $( -1 1 {
'u 4 4%1%)>u)EEE060K0K1 1F6(, -
CJ
J
r c # K |D ]\ }}}}||j vr|j | }i } |j | |r]t fdt |j | D }
d} ni }
t |j D ]} | }
| }t |
d st |
t j r*t |
d r|
n|
| |< f|j
| j |
|j | dur
|
|
|j < |j j r!|j | |
} nd} ||j |j | v r|sa|
s_| s]|j D ]A}|j
|j j |t4 j }|j r nB|j }|
o| }||
|j < |s |j |
vr)|j dur | | }||
|j < n |j du r |r
||
|j < n|
s| sjd}d}|rHt fdt |j | D }ni }|D ]}|j | j } |j
| j |t4 j }|j rb|j r d||f| j v r3d}|j d ||j < |
! |j d n1|j d ||j < || v rd}n|j" d ||j < ||j tG j$ d |d
| |
s| r#|
% | ||
||| | |fV |r2|j& | D ]$\ }}tO j( |||||| |j) %dS ) at Identify sets of values to use in UPDATE statements for a
list of states.
This function works intricately with the history system
to determine exactly what values should be updated
as well as how the row should be matched within an UPDATE
statement. Includes some tricky scenarios where the primary
key of an object might have been changed.
c 3 B K | ]}| j | fV d S r" r6 r r r r# s r r, z+_collect_update_commands..X sI (,j.AB r Tr NFc 3 \ K | ]&}| j | fV 'd S r" )_labelgetr s r r, z+_collect_update_commands.. sP (/ 1H1HI r pk_cascadedr zCan't update table , using NULL for primary key value on column )*ro r r r r r _pk_attr_keys_by_tablerV r r r r r managerimplis_equalr7 r: r _server_onupdate_default_colsr rz r _columntopropertyvalues get_historyr PASSIVE_NO_INITIALIZEaddedr r PASSIVE_OFFdeletedpop unchangedr r rw _table_to_equatedr
populatepassive_updates)rq rM rr r0 r r+ r* ri pksr' r$ r) r r r prophistory no_paramsvalr( expect_pk_cascaded pk_paramsm
equated_pairsr r# s @@r ra ra 6 s (
h h
, , , "5) /6 ) ( "> 2 2 j))F 9% @AA F $ F ~..;;%
,
, #7+$W-5"677 ,:3,< < ,
#5*>??#00222 " !%% M'*/88 u 4W =
',F37O!0
(8?(6"" ! $(
)%)>u)EEE
<
# 4 ; ; = = D #mDH 5 : F F z:+K G } 'C "
7<'7I!2F3:
4v---U:: 112CDD"%sw,55)5
#4sw L " & "> 2 2 ? ?1%8 II I
237; -05AA:z'= = A #O 0 )5#6)4 5 5 .2*07
a0@ #*-
37D1111 180B #*- ,..*/K,3,=a,@Icj) SZ(0!,,49EE33@ 1 \ MM) $ $ $
%+$u)EEE0AF6(, -j = ! !r Tc
z j duoj j v fd}| df| }t |d D ]h\ \ } }
} } }
}d}t | }|}d}|
s| }d}nJ|r%| s#j j r| }d}n#j | j }d}|s | j j n | j j
}|o | j j }| o }| rm|D ]i\ }}}} }} }
| |
| | }|r't |||||j j d |d ||j z
}|}jn|s`|}|D ]Z\ }}}} }} }
|| || }|r't |||||j j d |d ||j z
}[nd |D }|p|ot% | d k }|| || }||j z
}|D ]4\ }}}} }} }
|r't |||||j j d |d 5|rA|t% | k r,t' j d
j t% | |fz E r!t- j d |j j z jdS ) z`Emit UPDATE statements corresponding to value lists collected
by _collect_update_commands().Nc t j } j D ]>}| j |t j |j |j k ?rK| j j t j j j j j k | }|S N)type_)
r and_ro clausesrn bindparamr typerz rw clauser stmtr+ needs_version_idrM s r update_stmtz,_emit_update_statements..update_stmt_ s '. C N ! !s}SZsx@@@@
N ! !%=)0 /4
||F## r rw c | d t | d t | d | d | d fS N r
r r recs r z)_emit_update_statements..z 8 F AKK QLL F F
r r FTc g | ]
}|d S r
r r r s r r z+_emit_update_statements.. s 9 9 9#s1v 9 9 9r r MUPDATE statement on table '%s' expected to update %d row(s); %d were matched.MDialect %s does not support updated rowcount - versioning cannot be verified.)rz r _memor r? r1 r: r dialectsupports_sane_rowcount supports_sane_rowcount_returning supports_sane_multi_rowcountexecuter
_postfetchcontextcompiled_parametersrowcountlenr StaleDataError descriptionr warndialect_description) r: rq rK r+ rM rw r4 r cached_stmtr* paramkeyshasvaluer) r( rO rows statementr1 assert_singlerowassert_multirowallow_multirowr r# r$ r' r check_rowcount multiparamsr s `` @r rb rb N sX T) B !V%:5%A A
( ##Xu$5{CCK
W W HY*:K w-- #!1133I "OO #$ # "1 #
"1133I "OO
"
.!11&2GHHI "O #
EJ 5 5#D
@"? *B2B.B [
2
2 &&y'7'7 'E'EvNN & " 5a8$
"!11
24 " @
!1 ' ' $ *:6>>!6 A
# " " * ! ! & I 9! < (
AJ&DD7': : 9 9 9 9 !0 "$>[)9)9Q)> 'z2:: {
" $ " " " * ! ! & I 9! < (
s7||## ,9 (#g,,=> $ I3)/0
gW Wr c
D | d|f|j }t |d D ]\ \ }} }
} } }
|}|r| s| j r |j j s| r|
st
|
}
d |
D }|| || }|rTt |
|j j
D ]9\ \ }}}}}}} } }|rt ||||||||d (t ||| :| s | j r|
}n!|j |
|j }|
D ]\ }}}}}}} } |r*| | | | }n || || }|j j }|Xt ||j | D ]<\ }}|j | } |(||v s| | j
||| j < =|r;|r(t |||||||j j
d |d t ||| dS )z`Emit INSERT statements corresponding to value lists collected
by _collect_insert_commands().rv c | d t | d t | d | d | d fS r r r s r r z)_emit_insert_statements.." r r c g | ]
}|d S r r r s r r z+_emit_insert_statements..9 s 555c3q6555r FNr )r rv r r r implicit_returningr? r zipr
r r _postfetch_bulk_saver1 rz r inserted_primary_keyro r r r7 ) r: rq rK r+ rM rv r4 r r* pkeysr r( r) rO r r r r r# r$
mapper_recr& r' last_inserted_paramsresult primary_keypkr r s r rD rD sS ##Xu$5u|DDK
pL pL DUHk3C ` L !` L #1 ` L
")< ` L ` L ` L 7mmG55W555K":.66y+NNA
L !)"?@@L L " " $#((
L" & * ! ! & 0 ( !
-ZUKKKK $
M (B
M % 5 5 7 7 &2 % 5 5f6K L L .
L .
L ' / /!(( 66 FF 0
; C C!6 F %n A *#&#V%9%%@$ $ 6 6C * ;C @ > < / / )~~dh 7 7 ?35Jtx 0 L
L" & * ! ! & " "N >q A ( !
-ZUKKK].
LEpL pLr c j duoj j v fd}| df| }t |d D ]\ }} d}
t | } |d } j | j j n | j j } | o | j j }
p|
}|sY| }| D ]S\ }}}} }|| || }t ||||||j j d |
|j
z
}
Tnyd | D }|
p| ot | dk }|| || }|
|j
z
}
| D ]-\ }}}} }t ||||||j j d .|rA|
t | k r,t j dj t | |
fz hr!t% j d |j j z dS )
zeEmit UPDATE statements corresponding to value lists collected
by _collect_post_update_commands().Nc t j } j D ]>}| j |t j |j |j k ?rK| j j t j j j j j k | }j |
j }|S r ) r r ro r rn r r r rz rw r1 r s r r z1_emit_post_update_statements..update_stmt s '. C N ! !s}SZsx@@@@
N ! !%=)0 /4
||F## ,''(=>>D r r c < | d t | d fS )N r )r r s r r z._emit_post_update_statements.. s SVSQ[[) r r c g | ]
\ }}}}}| S r r )r r r# r$ r& r$ s r r z0_emit_post_update_statements.. s2 ?E:z4 r r r r )rz r r r r? r r r r r _postfetch_post_updater
r r r
r r r r r r )r: rq rK r+ rM rw r r r7 rO r r* r r r r r r# r$ r$ r r r s `` @r r r s T) B !V%:5%A A
0 !!=%"8+FFI )) G G W w--V
$,
5 5#D
@"? .-@ $ -NEL
#
#Az:z6&z2::9fMM& " I1!4
"
# CJ K
- :S%5%5%:
#:.66y+NNA AJ DEL
Az:z6& " I1!4
s7||## ,9 (#g,,=> $ I3)/0
GG Gr c " j duoj j v fd}| df| }t |d D ]<\ }} d | D }
|| }t |
} d} d}
rx|j j sl|j j r(d} |
D ]"}| || }| |j z
} #nYt j d |j j z | ||
n!| ||
}sd
}
|j } | j
rm| dk rg| | k ra|j j st |
d k rB|
r!t j d j | | fz t j d j | | fz >dS )
z`Emit DELETE statements corresponding to value lists collected
by _collect_delete_commands().Nc t j } j D ]>}| j |t j |j |j k ?rK| j j t j j j j j k | S r )
r r ro r rn r r7 r rz r )r r r+ need_version_idrM s r delete_stmtz,_emit_delete_statements..delete_stmt s '. C N ! !s}SWCH====
N ! !%=)-V5J5O
||F###r r c | d S )Nr r r s r r z)_emit_delete_statements.. s
A r c g | ]\ }}|S r r )r r$ r* s r r z+_emit_delete_statements..! s ==="4&*v===r Fr zMDialect %s does not support deleted rowcount - versioning cannot be verified.Tr zDELETE statement on table '%s' expected to delete %d row(s); %d were matched. Please set confirm_deleted_rows=False within the mapper configuration to prevent this warning.)rz r r r r
r r r r r r r r confirm_deleted_rowsr r r )r: rq rK r+ rM r r2 r r* recs del_objectsexpected rows_matched only_warnr$ r r1 s `` @r r r sX T) B !V%:5%A A
$ $ $ $ $ $ $" !!8U"3[AAI #F,>,> ? ? = =
D===== '
3
{##
& &C & !8
; * / /F"**9f==A AJ.LL/ 7 (<=
""9k::::""9k::A"
! :L
, r!!L(("? ) {##q((
= ((LA B ,= ((LA B o= =r c 6 |D ]\ }}}}|j rC fd|j D }|r j | g }| j r2| j |j |j <|j
du r3|j j j
v r | |j j g |rO| _ t j |j | j | |s |j || n |j || |j
du r-|j &||j j t- j d dS )zzfinalize state on states that have been inserted or updated,
including calling after_insert/after_update events.
c g | ]A}|j r|j r*|j j v s |j s |j s|j j v:|j BS r )expire_on_flushdeferredr7 r )r r8 r s r r z4_finalize_insert_update_commands..i s{ )
"#
01u
/B/B - 0C !"
0C
E 3 3 E 4 3 3r NF)
refresh_stateonly_load_propsz2Instance does not contain a non-NULL version value)_readonly_propsunmodified_intersection_expire_attributesr r extend_unloaded_non_objectr &_server_default_plus_onupdate_propkeysrz r r^ r7 unloadedr r
load_on_identr< queryr after_insert after_updater r )
r: rq rL r# r+ r* rt readonly
toload_nowr s
@r rp rp ` s
@F > >;z6:| ! ? 44 # 3 H
?((X>>>
% *77A
! -+u44&*en<<!!6#:#>"?@@@ #< (H y> >r c | | rd S |j j j }|j j j } j , j j | v rt | j gz }t j j
j } | rg }
|D ][} | j |v rP| j
v rG|| j | j
| j < | r%|
j
| j \| r#|
r! j j
|||
|r)| |j fd|D d S d S )Nc F g | ] }|j v j | j S r r r7 r r r+ s r r z*_postfetch_post_update.. <
000 (+/000r )r r
compiledprefetch postfetchrz r r? r
class_managerr
refresh_flushr7 r rn rD r ) r+ rq rM r r r& r$
prefetch_colspostfetch_colsrX load_evt_attrsr s ` r r. r. s '' N+4M^,6N ) !V%:5%A A A ]++v/D.EE
-6DEEM
G G 5F??qF$< < <5;AE]E&*1-1 2
G %%f&>q&A&EFFF
%33 >>
J
'
r c
|j j j } |j j j }
|j j j j , j j | v rt | j gz } t j j
j } | rg } ro|j j }
|
aD ]^}|j
r
|j j r j | }|r,|
| ||j < | r| |j _| D ][}|j |v rP| j v rG||j | j | j < | r%| j | j \| r#| r! j j
||| |r#|r!|
fd|D |
r'| |j fd|
D j | D ]$\ }}t/ j |||||| j %dS )zExpire attributes in need of newly persisted database state,
after an INSERT or UPDATE statement has proceeded for that
state.Nc * g | ]}|j r|v
|S r )r' )r r returning_colss r r z _postfetch.. s:
?
(+.'@'@ '@'@'@r c F g | ] }|j v j | j S r rQ rR s r r z _postfetch.. rS r )r
rT rU rV returningrz r r? r rW r rX returned_defaultsr' isinsertr r r7 rn rE rD r r r
r r )r+ rq rM r r r& r$ r' isupdaterY rZ rX r[ rowr r r r r r^ s ` @r r r s N+4M^,6N^,6N ) !V%:5%A A A ]++v/D.EE
-6DEEM 8n. ?%
8
8 ? v~'> /33C88 8&)#hE$(O$ 8&--dh777
G G 5F??qF$< < <5;AE]E&*1-1 2
G %%f&>q&A&EFFF
%33 >>
L
'
J
'
# 4U ;
=
"
r c X | j | D ]\ }}t j ||| d S r" )r r
bulk_populate_inherit_keys)r+ r rM r r s r r! r! / sD " 4U ; A A= 'q-@@@@A Ar c # K |j j r
|j j }n |j | }d}t | | D ];}|r || | }|j j }||j ||fV .Q s" T++&6 ,
r )r PopulateDict)r: s `r r; r; N s,
r c | t | }t d |D }| | t || j }nB# t $ r5}t j t j d|z | Y d }~nd }~ww xY wt |t j
d |z S )Nc 3 ( K | ]
}|j |V d S r" r6 )r ss r r, z _sort_states..Y s) ==115+@CD
wH / ? ?@@@
s A
B +BBc e Zd ZdZd Zd Zed Zed Z d Z
d Z d Z e
j d d
Zd Zd Zd
S )BulkUDz;Handle bulk update and deletes via a :class:`_query.Query`.c | d | _ | j | _ | d S )NF)enable_eagerloadsrJ _bind_mapperr+ _validate_query_state)selfrJ s r __init__zBulkUD.__init__q sD ,,U33
j--// ""$$$$$r c < ddd t j fddd t j fdddt j fdd dt j fd
d dt j fd d
dt j ffD ]>\ }}}} |t | j | | st j d|d ?d S )N_limitzlimit()_offsetzoffset() _order_byz
order_by()F _group_byz
group_by() _distinctz
distinct() _from_objz2join(), outerjoin(), select_from(), or from_self()r z1Can't call Query.update() or Query.delete() when z has been called)r} is_eqgetattrrJ r{ r| )r attrmethnamenotsetops r r z BulkUD._validate_query_statev s
y$ 5
D(, 7
,x| <
,x| <
,x| <D
+
&D(FB 2gdj$//88
0019<
r c | j j S r" )rJ r< r s r r< zBulkUD.session s
z!!r c || } || S # t $ r`}t j t j dd t
d |D z | Y d }~d S d }~ww xY w)Nz3Valid strategies for session synchronization are %sz, c 3 4 K | ]}t | V d S r" )repr)r xs r r, z"BulkUD._factory.. s( 0I0IQa0I0I0I0I0I0Ir rs )KeyErrorr rz r{
ArgumentErrorjoinrw )clslookupsynchronize_sessionargklassr s r _factoryzBulkUD._factory s ./E 5#; K$ $ &0I0I&0I0I0I*I*I J JL !$
s
A9AA44A9c | | | | | | d S r" )_do_before_compile_do_pre_do_pre_synchronize_do_exec_do_post_synchronize_do_postr s r exec_z BulkUD.exec_ sc !!! """
!!###
r c r | j || j | _ | j j | _ d S r" )rJ
_execute_crudr+ r& r )r r s r
_execute_stmtzBulkUD._execute_stmt s- j..tT[AA ,
r c t r" )r> r s r r zBulkUD._do_before_compile s !###r zsqlalchemy.orm.queryc n | j }| | | _ t |j d |j rt
}|j D ]T}t ||j s| n(| t |j
Ut | dk rt j
d | | _ n$| d j j | _ |j }|j r| d S d S )Nr r zLThis operation requires only one Table or entity be specified as the target.)rJ QueryContextr
r _entities
_ColumnEntityr clearrw r columnr
r{ r| r
primary_table_only_entity_zeror+ local_tabler<
_autoflush)r querylibrJ tablesentr< s r r zBulkUD._do_pre s9
,,U33 eoa((*@ A A !UUF
=
=!#x'=>> =LLNNNEMM-
";";<<<<6{{a 09
&,ZZ\\"" "'!8!85" " [
- ! ! !r c d S r" r r s r r zBulkUD._do_pre_synchronize r c d S r" r r s r r zBulkUD._do_post_synchronize r r N)__name__
__module__ __qualname____doc__r r propertyr< classmethodr r r r r dependenciesr r r r r r r r n s EE% % %
( " " X" [ - - -$ $ $ T-.. ! ! /. !D
r r c e Zd ZdZd Zd ZdS ) BulkEvaluatezDBulkUD which does the 'evaluate' method of session state resolution.c d S r" r )r evaluator_compilers r _additional_evaluatorsz#BulkEvaluate._additional_evaluators r r c | j }| j t j }|j | |j nd | | nG# t j $ r5}t j
t j d|z | Y d }~nd }~ww xY wfd|j
j D | _ d S )Nc dS )NTr )ri s r eval_conditionz8BulkEvaluate._do_pre_synchronize..eval_condition s 4r ztCould not evaluate current criteria in Python: "%s". Specify 'fetch' or False for the synchronize_session parameter.)from_c g | ]?\ \ }}}}t | t j | j 2 | =|@S r )
issubclassr r expired)r r r( identity_tokenri r
target_clss r r z4BulkEvaluate._do_pre_synchronize.. sx
#z**
-c22:
s##
r )rJ _mapper_zeroclass_r EvaluatorCompiler whereclauseprocessr UnevaluatableErrorr rz r{ r| r< r rA matched_objects)r rJ r r r r s @@r r z BulkEvaluate._do_pre_synchronize s>
''))0
!*!t | j | }| | | dt |t j r)| | | | ||f | ||f |S )NrA )
r r rA r+ r r string_typesr rE _bulk_update_tuplesr QueryableAttributern )r r rW rX descs r _resolved_valueszBulkUpdate._resolved_values/ s t{G,,
DK & &DAq
{
& a!233 *-dk1==DMM$":":1"="=>>>> :#@AA *MM!"7"7":":;;;;MM1a&))))
q!f%%%%
r c g }| j D ]\ }}t |t j r | |j |f **55kBB
JJu !!&)))))r N)r r r r r r r r r r r s< % % * * * * *r r c e Zd ZdZd ZdS )r zSBulkUD which handles DELETEs using the "evaluate"
method of session resolution.c b | j j d | j D d S )Nc 6 g | ]}t j | S r )r r )r ri s r r z;BulkDeleteEvaluate._do_post_synchronize.. s# L L LZ
&s
+
+ L L Lr )rJ r< _remove_newly_deletedr r s r r z'BulkDeleteEvaluate._do_post_synchronize s=
00 L Lt7K L L L
r Nr r r r r r r r r r s- % %
r r c e Zd ZdZd ZdS )r zPBulkUD which handles UPDATEs using the "fetch"
method of session resolution.c | j j | j t fdfd| j D D }| j }t d |D }|D ]4}| |j }|r || 5 | d S )Nc ` g | ]*}|j v t j j | +S r )r r r )r identity_keyr< s r r z8BulkUpdateFetch._do_post_synchronize.. sH
7#777 )'*>|*LMM 877r c T g | ]$} t | %S r ) identity_key_from_primary_keyr? )r r'
target_mappers r r z8BulkUpdateFetch._do_post_synchronize.. sF % % % $ "?? [)) % % %r c 3 K | ] \ }}|V
d S r" r )r rW rX s r r, z7BulkUpdateFetch._do_post_synchronize.. s& **41aQ******r )
rJ r< r r r r r r
_expire_stater# )r rL r attribr to_expirer< r1 s @@r r z$BulkUpdateFetch._do_post_synchronize s *$
//11
% % % % (,'8 % % %
8**6***** 8 8E ++EJ77I
8%%eY777!!&)))))r Nr* r r r r r s- % %* * * * *r r c e Zd ZdZd ZdS )r zPBulkUD which handles DELETEs using the "fetch"
method of session resolution.c | j j }| j }| j D ]`}| t | }||j v r3| t j |j | g ad S r" )
rJ r< r r r0 r? r r) r r )r r< r1 r' r. s r r z$BulkDeleteFetch._do_post_synchronize s *$
//11
,
K )FF[!! L w 333--"1 # 0 >
r Nr* r r r r r s- % % r r )F)FFF)T)6r itertoolsr r r} r r r r r r
baser r r{ r r r sql.baser rR rd rl r r rm r} r rC ra r~ r rb rD r r rp r. r r! r r; rk objectr r r r r r r r r r r r r= s $ $ $ $ $ $ $ $ $ $ $ $M M M`B
B
B
JS S S Sl*
*
*
Z+@ +@ +@\N
N
N
b H H HD D D6
U
U
U
U
r 38v v v vr5@ 5@ 5@p$! $! $!\ ~ ~ ~ ~P ~L ~L ~L ~LBp p pfZ Z ZzC C CL&
&
&
R]
]
]
@A A A
4 4 44 .e
e
e
e
e
V e
e
e
P*
*
*
*
*
6 *
*
*
Z Y1 Y1 Y1 Y1 Y1 Y1 Y1 Y1x 1 1 1 1 1 1 1 1F&* &* &* &* &* z &* &* &*R
z
* * * * *i * * *< i r