+ hj HRt^RIHt^RIHt^RIHt^RIHt^RIHt^RIHt^RIH t ^RIH t ^R IH t ^R IH t ^R I Ht^R I Ht^R I Ht^RI Ht^RI Ht^RI Ht^RIHt^RIHt^RIHt^RIHt^RIHt^RI Ht^RI Ht^RIHt^RIHt ^RI!H"t"^RI!H#t#^RI!H$t$^RI!H%t%^RI!H&t&^RI!H't'^RI(H)t)^R I(H*t*^R!I(H+t+^R"I,H-t-^R#I,H.t.^R$I,H/t/^R%IH0t0^R&I1H2t2] 'dI^R'I3H4t4^R(I3H5t5^R)I3H6t6^R*I7H8t8^R+I9H:t:^R,I9H;t;^R-I9HH?t?^R0IH@t@^R1IHAtA^R2IBHCtC] !R3]DR47tE] R5R6R7R6/R8R9ll4tF] R5R6R7R6/R:R;ll4tFR5RlltF] R?R6R@RA/RBRCll4tG] R?R6R@RA/RDREll4tGR?Rr?rArBr6r7s&&&$$$$$rI _bulk_insertrOJs rKc<V^8dQhRRRRRRRRR RR RR R R RRR/ #)r9r:r;r<r=r>r/r?r@rArBr6Optional[dml.Insert]r7rDrEzcursor.CursorResult[Any]rG)rHs"rIrJrJYsb # #  #J #, #  #  # #. #< # #rKcR#rMrGrNs&&&$$$$$rIrOrOXs #rKNc<V^8dQhRRRRRRRRR RR RR R R RRR/ #)r9r:r;r<r=r>r/r?r@rArBr6rQr7rDrEz"Optional[cursor.CursorResult[Any]]rG)rHs"rIrJrJfsmUU UJU,U  U  UU.U<U(UrKc aaSPpVPP'd \R4hV'd\'d'\ \ \\,,V4pV'd3VU u.uFqV P3NK p p V U U u.uFwrV NK pp p MVU u.uFqPNK pp Mr\'d-\ \ \\\3,,V4pV'd \V4pMVU u.uFp \V 4NK pp \SV4VPV4oRp VP P#4UUu.uFwrVSP$9gKW3NK pppV'dRpM\'V4^8dRpMRpVFwppVeEVP)4Uu.uF)pVP*V^,9gKVP*NK+ upMRpVV3Rl\,P.!VVV3RlV4RVVVR74p\,P0!VRVVVVVVR7pVfKVP2'dV fTp KVP4'gKV'gQhV P7V4p K V'doV'dgSP8pSP:Uu.uFpVP*NK ppX F/wrT\=VUu.uF pV V,NK up4R3V nK1 Ve V fQhV #R#uup iuup p iuup iuup iuuppiuupiuupiuupi) zJconnection_callable / per-instance sharding not supported in bulk_insert()NTFc 3J<"TFwppppppppRVVS S VVV3xK R#5irMrG) .0state state_dictparamsmpconn value_params has_all_pkshas_all_defaults connectionr:s & rI _bulk_insert..sQ (  #  &s #c30<"TF pRVSS3xK R#5irMrGrVmappingr_r:s& rIr`rasMH$4Hs)bulkrArBinclude_bulk_keys) bookkeepingr6r7rG) base_mappersessionconnection_callableNotImplementedErrorr rrr0r4dictrstrrlist_expand_compositesr__sorted_tablesitems _pks_by_tablelen_get_embedded_bindparamskeyr_collect_insert_commands_emit_insert_statements _returning returns_rowssplice_horizontally_identity_class_identity_key_propstuple)r:r<r>r?rArBr6r7rhrWstatesdict_m return_resulttablerZmappers_to_runrg super_mapperbextra_bp_namesrecordsr identity_clspidentity_propsrur_sf&&$$$$$ @rIrOrOfs$$K""666! -   =H]2%67BH 7?@xeejj)xF@4:;F.5FH;H089u H9H =HT#s(^4h?H H~H*22AQH268,$// r/r?r@update_changed_onlyrrCrrErFrG)rHs"rIrJrJsX    J ,     '     rKcR#rMrGr:r<r>r?rrrs&&&$$$$rI _bulk_updaters rKc8V^8dQhRRRRRRRRR RR R R RR R/#)r9r:rr<r=r>r/r?r@rrOptional[dml.Update]rrEz_result.Result[Any]rG)rHs"rIrJrJ sX    J ,     .    rKcR#rMrGrs&&&$$$$rIrr srKc8V^8dQhRRRRRRRRR RR R R RR R/#)r9r:rr<r=r>r/r?r@rrrrrEzOptional[_result.Result[Any]]rG)rHs"rIrJrJsbY%Y% Y%JY%,Y%  Y%  Y%.Y% Y%#Y%rKc  aaaSPpSPoSP'd'SPP0P S4oV3RlpV'd<V'dVU u.uF q!SV 4NK pp MAVU u.uFqP NK pp M&VU u.uFp \ V 4NK pp \ SV4VPP'd \R4hVPV4oVeEVP4U u.uF)p V PV^,9gKV PNK+ up MRp VPP4FtwrSPV4'dV SP9dK/\ P"!RV VV3RlV4RVV R7p\ P$!VRVV VRVVR7Kv Ve\&P(!4#R#uup iuup iuup iuup i) c<VPP4UUu/uF wr#W!P9g VS9gKW#bK" upp#uuppirM)rlrqcommitted_state)r:rWkv search_keyss&& rI _changed_dict#_bulk_update.._changed_dict(sP ((* *)))Q+-= AD*   s A A zJconnection_callable / per-instance sharding not supported in bulk_update()Nc3<"TF;pRTSSSP'dVSPP,MR3xK= R#5irM)_version_id_proprurcs& rIr`_bulk_update..SsQ  (G"222  7 7 ; ;<!  (s A(AT)rerrfF)rgrrrG)rh_primary_key_propkeysrruunionrlrorirjrkr_rtrprqisarrr_collect_update_commands_emit_update_statements_result null_result)r:r<r>r?rrrrhrrWrrrrrrr_rsf&&$$$$ @@rIrrs$$K..K ..22399+F   BJK( fe4(HKH089u H9H%-.XDGX.68,""666! -  %// NO!(((--.>?@rKc  VPV4pV'g\P!W4#VUu.uF7p\VP VP WP 4R44NK9 up#uupi)F)rr%_get_multi_crud_kv_pairsrlrr:rq)rrrr value_dicts&&& rIr$ORMDMLState._get_multi_crud_kv_pairss44Y?!:: *  * **"))96F6F6H%  *    s=A4c V'gQR4hVPV4pV'g\P!WV4#\VP VP VVV44#)z0no test coverage for needs_to_be_cacheable=False)rr%rrnrr:)rrrrrs&&&& rIrORMDMLState._get_crud_kv_pairsst " > = > !44Y?!44(=   & &%%%    rKc  &VPPR,pVPpVP'dVPpMVP P pRVRVP RVPRVPRVP/#) parententitynametypeexprentityr) rrr:is_aliased_classrclass___name__r local_table)rrext_infor: _label_names&& rIget_entity_description"ORMDMLState.get_entity_descriptionsz??//?  $ $ $"--K --00K K FMM HOO hoo V''   rKc RpRpVPUu.uF qDV!V43NK upUUu.uF?wrERVPRVPRV!WE4RVPRVP/NKA upp#uupiuuppi)c:VPPRR4#)rN)rr)cs&rI _ent_for_colCORMDMLState.get_returning_column_descriptions.._ent_for_cols>>%%nd; ;rKcVfV#VPPRR4pV'gV#\VPW 4#)Nr)rrgetattrr)rentrs&& rI _attr_for_colDORMDMLState.get_returning_column_descriptions.._attr_for_col s;{**;=Iszz988rKrrraliasedr)_all_selected_columnsrurrr)rrrrrrs&& rI!get_returning_column_descriptions-ORMDMLState.get_returning_column_descriptionss < 9$/8.M.M.MLO$.M    a-3//#**      s A6AA;use_supplemental_colsc ZVP'Ed\VPVRR7pVP!R/VPBpVP!VP !pW`n\P!Wa4;Vn pVPV4VP4pRVnVPUu.uF qfKVNK p pV 'gV PVP4V'dVP!VPRV /pV#VP !V !pV#uupi)a<establish ORM column handlers for an INSERT, UPDATE, or DELETE which uses explicit returning(). called within compilation level create_for_statement. The _return_orm_returning() method then receives the Result after the statement was executed, and applies ORM loading to the state that we first established here. F)_adapt_on_namessupplemental_colsrG)rxrr7_execution_optionsoptions _with_optionsselect_statementrcreate_for_statementr!setup_dml_returning_compile_state _generateprimary_columnsextend primary_keyrA returning) selfcompilerorm_level_statementdml_level_statement dml_mapperrfsfscrcols_to_returns &&&&&$ rI_setup_orm_returning ORMDMLState._setup_orm_returnings.(  ) ) )#..# %B %%O(;(N(NOB0>>?B$& !,AA"O D #c  1 1* ="5"?"?"A -/  *),)<)<N)E55n    "  (    4A##A#F  rKrc ]tRtRt!RR]4t]RRRRRRRR/R R ll4t]R 4t]R 4t ]R 4t ]R4t ]R4t ]R4t ]R4t]R4t]R4t]R4t]R4tRtR#)BulkUDCompileStateic]tRtRt$RtR]R&RtR]R&RtR]R &RtR]R &Rt R]R &R t R]R &Rt R]R&] t RtRtRtRtR]R&RtR#))BulkUDCompileState.default_update_optionsiautor( _dml_strategyr*_synchronize_sessionFr@_can_use_returning_is_delete_using_is_update_fromT _autoflushNOptional[Mapper[Any]]_subject_mapper_populate_existingrG)rrrrr(r r)r*r+r,r-r/r&_resolved_values_eval_condition _matched_rows_identity_tokenr0r"rGrKrIdefault_update_optionsr&sn-3 *3;A8A#(D(!&$& %% D15.5% #(D(rKr5 is_multitableFis_update_fromis_delete_usingis_executemanyc4V^8dQhRRRRRRRRRRR RR R/# r9dialectrr:rr6r@r7r8r9rErG)rHs"rIrJBulkUDCompileState.__annotate__sP $ $ $ $  $  $ $ $  $rKc \4hrM)rk)rr<r:r6r7r8r9s&&&$$$$rIcan_use_returning$BulkUDCompileState.can_use_returnings "##rKc  (\PPR0RmVVP4wppW%R&VPR,pV'd%VP VR&VRVP /, pR TPP9d TR R /, pMw\T\4'gFTPR 8Xd TR R/, pMDTPR8Xd\P!R4hMTPR 8Xd TR R/, pTPp T eLT R9d\P!R4hTPR8XdT R8Xd\P!R4hT'Eg^TP 'dTP!4TPR8XdyTPR 8XdTP#TTTTTT4pM}TPR8XdTP%TTTTTT4pMUTPR8XdTP'TTTTTT4pM-TPR8XdTPR 8Xd TRR/, pTP)RTPRTP*RTP,RTPRTP./4pT'g\0P2pMTP5\0P24pT\6P8!T4P5RT/43# \ d QR 4hi;i)_sa_orm_update_optionssynchronize_sessionr8r7 dml_strategyclauserr:r/0statement had 'orm' plugin but no plugin_subjectrr( core_onlyr'ormreHCan't use "bulk" ORM insert strategy without passing separate parametersevaluatefetchzSValid strategies for session synchronization are 'auto', 'evaluate', 'fetch', FalsezkThe 'fetch' synchronization strategy is not available for 'bulk' ORM updates (i.e. multiple parameter sets)r)r?> autoflushrDidentity_tokenr7r8populate_existingrC)r'rJrKF)r$r5from_execution_optionsrrr:KeyErrorrrrrnr(sa_excInvalidRequestErrorr) ArgumentErrorr-_do_pre_synchronize_auto_do_pre_synchronize_evaluate_do_pre_synchronize_fetch _annotater+r,r*r _orm_load_exec_optionsrr immutabledict) rrirrYr7r is_pre_eventupdate_optionsrsyncs &&&&&&& rIorm_pre_session_exec'BulkUDCompileState.orm_pre_session_execs4  5 5 L L $    ( (   $-x  M&778HIN+9+@+@x(#4n6K6K"LL !=!= =  < +N+N%~'F'F$n&D&D"N$@$@')J)J I&%$+$B$B!$5$;$;22%!    0 1 7 7)>:   I M LL L5 Ms K>>Lc ^VR,pVPR8XdIVPR8XdVPWWg4MZVPR8XdVPWWg4M6VPR8Xd&VPR8XdVP WWg4V#VP VVVVVV4#)rBrHrJrKre)r(r)_do_post_synchronize_evaluate_do_post_synchronize_fetch"_do_post_synchronize_bulk_evaluater)rrirrYr7rrr[s&&&&&&& rIorm_setup_cursor_result*BulkUDCompileState.orm_setup_cursor_result+s$++CD  ' '5 022j@11 44?.. ) )V 322j@66VM((         rKc aaRpSP'd SPMRoRSP3V9d`T\;QJd*.V3RlVRSP3,4FNK 5M#!V3RlVRSP3,44, pSPPeVSPP3, pS'd3\;QJd.V3RlV4FNK 5M!V3RlV44pV#)a]Apply extra criteria filtering. For all distinct single-table-inheritance mappers represented in the table being updated or deleted, produce additional WHERE criteria such that only the appropriate subtypes are selected from the total results. Additionally, add WHERE criteria originating from LoaderCriteriaOptions collected from the statement. Nadditional_entity_criteriac3<"TF:pVP'gVPSJgK'VPS4xK< R#5irM)include_aliasesr_resolve_where_criteria)rVaers& rIr`@BulkUDCompileState._adjust_for_extra_criteria..lsE!B%%%h)> 5**844sA AAc3F<"TFpSPV4xK R#5irM)traverse)rVcritadapters& rIr`rkxsO;4 0 0 6 6;s!rG)r_adapterr:r}_single_table_criterion)rglobal_attributesr return_critros&&f @rI_adjust_for_extra_criteria-BulkUDCompileState._adjust_for_extra_criteriaWs '/'@'@'@(##d ) OO   55!+18??C!55!+18??C! K ?? 2 2 > HOOCCE EK %O;O%%O;OOKrKc .VPVPPJd'VPVPP4pMVPVP4pVUu.uF qT!V4NK up# \d.u#i;iuupi)areturn rows that indicate PK cols in mapper.primary_key position for RETURNING rows. Prior to 2.0.36, this method seemed to be written for some kind of inheritance scenario but the scenario was unused for actual joined inheritance, and the function instead seemed to perform some kind of partial translation that would remove non-PK cols if the PK cols happened to be first in the row, but not otherwise. The joined inheritance walk feature here seems to have never been used as it was always skipped by the "local_table" check. As of 2.0.36 the function strips away non-PK cols and provides the PK cols for the table in mapper PK order. )rrh _tuple_getterrrP)rrr:rowspk_keysrows&&&& rI_interpret_returning_rows,BulkUDCompileState._interpret_returning_rows|s$ !!););)G)GG !..v/A/A/M/MN ..v/A/AB)-- --  I   .sA A? A?,B? BBc :VPpVPpVUu.uFVpVPPV4'gK&VP'dK:VP 4WUP 3NKX ppVPpVe.VUUU u.uFwrp VPV8XgKWV 3NK pppp .p VFOwrp V!V4p V RJgV \PJgK*V PVVV V \PJ34KQ V #uupiuup ppi)NT) r/r2r:rexpiredobjrlr4rMr_EXPIRED_OBJECTappend) rr[r~r:eval_conditionrWraw_datarMrrrevaled_conditions &&& rI _get_matched_objects_on_criteria3BulkUDCompileState._get_matched_objects_on_criterias+//'77  ||' -05  -UYY[% ,  (77  %*2)1%C''>9$U#)1  !) C-c2  !D(#y'@'@@ (I,E,EE "*" A s#DD DD,Dc VPpVPp\P!V4pRpVP'dWbP, p/pVP F(pVP 'gKVPV4K* V'dW`PWs4, pV'dVP!V!p V #Rp T p V #)cR#)TrG)rs&rIr2JBulkUDCompileState._eval_condition_from_statement.._eval_conditionsrKrG) r/rr_EvaluatorCompiler_where_criteriar_is_criteria_optionget_global_criteriartprocess) rr[rr: target_clsevaluator_compilerrnrroptrr2s &&& rI_eval_condition_from_statement1BulkUDCompileState._eval_condition_from_statements//]] &99*E  $ $ $ -- -D**C&&&''(9:+  223DM MD /77>N  -NrKc VPWb4pVRVRR/,# \PdMi;iTRR/, pTPTTTTTT4#)asetup auto sync strategy "auto" checks if we can use "evaluate" first, then falls back to "fetch" evaluate is vastly more efficient for the common case where session is empty, only has a few objects, and the UPDATE statement can potentially match thousands/millions of rows. OTOH more complex criteria that fails to work with "evaluate" we would hope usually correlates with fewer net rows. r2r)rJrK)rrUnevaluatableErrorrV)rrirrYr7rr[rs&&&&&&& rIrT+BulkUDCompileState._do_pre_synchronize_autos2  ??N"!>& % ++    17;;,,         s  88c VPWb4pTRT/,# \Pd$p\P!RT,4ThRp?ii;i)z{Could not evaluate current criteria in Python: "%s". Specify 'fetch' or False for the synchronize_session execution option.Nr2)rrrrQrR) rrirrYr7rr[rerrs &&&&&&& rIrU/BulkUDCompileState._do_pre_synchronize_evaluatesp  ??N ~!   ++ ,,8:=>   sAAAc VP'd.#VP'd\VP4#VP'd$\VPP 44#.#rM) _multi_values_ordered_valuesrn_valuesrq)rr:rs&&&rI_get_resolved_values'BulkUDCompileState._get_resolved_values-s[  " " "I  & & & 112 2     ))//12 2IrKc D.pVF{wrEV'dT\V\P4'd4VPV,pVP VP V34K`\P!RV,4h V# \ PdKi;i)zCAttribute name not found, can't be synchronized back to objects: %r) rr ColumnElement_columntopropertyrruorm_excUnmappedColumnErrorrQrR)rr:resolved_valuesvaluesrrrs&&& rI_resolved_keys_as_propnames.BulkUDCompileState._resolved_keys_as_propnames8s#DA*Q (@(@AA1!33A6DMM488Q-00079:;$ 22sBBBc ^aaa a SPo \S PS P3,!P S 4P !VP !pVPVnRo RV VV V3RllpVPVVVVVR7p V P4p SRV RS /,#)Nc V^8dQhRRRR/#)r9 orm_contextr-rErrG)rHs"rIrJBBulkUDCompileState._do_pre_synchronize_fetch..__annotate__ls  O  rKc<VPP!R/VPBpSPVPSSP SP VPR7pSeSV8wd\P!R4hM2VP'dV'g\P!R4hVoV'd\P!4#R#))r7r8r9NzjFor synchronize_session='fetch', can't mix multiple backends where some support RETURNING and others don'tzFor synchronize_session='fetch', can't use multiple parameter sets in ORM mode, which this backend does not support with RETURNINGrG) riget_bindrr?r<r,r+r9rQrRrr)rbindper_bind_resultr?rr:r[s& rIskip_for_returningHBulkUDCompileState._do_pre_synchronize_fetch..skip_for_returningls&&//M+2L2LMD"33 -== . ? ?*99 4O!,$7 44 8 +++O00- %4!**,,rK)r7r _add_eventr3r*) r/rrselect_identity_token select_fromrrrexecutefetchall) rrirrYr7rr[ select_stmtrr matched_rowsr?r:s f&&&&&f @@rIrV,BulkUDCompileState._do_pre_synchronize_fetchJs // V''6+G+G*II K [ W -- /  '0&?&? #!  B  /)) ! (  \ "3!   rKrGN)rrrrr"r5r!r?r]rcrtr{rrrTrUrrrVr"rGrKrIr$r$s0 ) ) $ $ $ % $!& $ % $ $F F P) ) V""H . .D$$L8- - ^  2"N N rKr$rHinsertca]tRtRt$!RR]4tRtR]R&]R4t ]RR l4t ]R V3R ll4t ]R 4t R t RtRtV;t#) BulkORMInserticl]tRtRt$RtR]R&RtR]R&RtR]R&R tR ]R &R t R]R &Rt R]R&Rt R #)$BulkORMInsert.default_insert_optionsir'r(r(Fr@ _render_nulls_return_defaultsNr.r/Tr-r0rG) rrrrr(r rrr/r-r0r"rGrKrIdefault_insert_optionsrsB-3 *3# t#!&$&15.5 D#(D(rKrNzOptional[FromStatement]rc \\PPR0R mVVP4wppW%R&VPR,pV'd%VP VR&VRVP /, pT'gFTPR8Xd TRR /, pMDTPR 8Xd\P!R 4hMTPR8Xd TRR /, pTPR 8wd9T'g\PpMTP\P4pT'g#TP'dTP4TPRTP/4pT\P !T4PRT/43# \ d QR4hi;i)_sa_orm_insert_optionsrDrErr:r/rFr'r(rHrerIraw>rLrDrBrN)rrrOrrr:rPr(rQrRr rXrr-rWrrY) rrirrYr7rrZinsert_optionsrs &&&&&&& rIr]"BulkORMInsert.orm_pre_session_execs  0 0 G G $ N   ( (    $-x  M&778HIN+9+@+@x(#4n6K6K"LL++v5?E"::--70028 ++v5?F";;  ' '5 0 %$+$B$B!$5$;$;22%! 9 9 9    '' ^99 :    0 1 7 7)>:   O M LL L5 Ms FF+c4V^8dQhRRRRRRRRR R R R R R/#)r9rir.rz dml.InsertrYr3r7r)rr,r[r1rE_result.ResultrG)rHs"rIrJBulkORMInsert.__annotate__sYV V V V & V 6 V ' V V  V rKc  VPRVP4pVPR 9d\P!R4hVPR8Xd TP Y#;'g/VR7pV#VPR8XdVP p VPe,V P'd\P!RV 24hV fQhVPfQh\T \R\V\4'dV.MT4VPRVPVP VVR 7pM9VPR8XdTP Y#;'g/VR7pM \#4h\%VP&4'gV#VP('d?VPR \*P,4p V R R /, p VP/R V /4pVP1VVVVVV4#)rrrerHzHValid strategies for ORM insert strategy are 'raw', 'orm', 'bulk', 'auto)r7z`bulk INSERT with a 'post values' clause (typically upsert) not supported for multi-table mapper Iterable[Dict[str, Any]]F)r?rArBr6r7rr0T)rrerHr')rrr(rQrSrr/_post_values_clause_multiple_persistence_tablesrR _transactionrOrrrlrrAssertionErrorr@rxr0rrrr) rrirrYr7rr[rrr:rs &&&&&&& rIorm_execute_statement#BulkORMInsert.orm_execute_statements+.. $c&@&@   ' '0  &&2   ' '5 0\\<>)HHK++,<= --11.%H 6 !  ' ' 1 U "  & &x 8 rKc aV3RlVP44UUUu/uFwr4pVe VPMTVbK uppp#uupppi)c3b<"TF$wrSPPV4W3xK& R#5irM)rr)rVrrr:s& rIr`;BulkORMInsert._resolved_keys_as_col_keys..`s(4ODAa!'4Os,/)rqru)rr:resolved_value_dictcolrrs&f& rI_resolved_keys_as_col_keys(BulkORMInsert._resolved_keys_as_col_keys\sR4G4M4M4O  CGGAq 0   sAc \\PVP4;r4VP VVVVRR7pW0nR#)FrrN)rrInsertrr )rrr:rrs&&& rIr#BulkORMInsert._setup_for_orm_insertesD*.szz4>>*JJ --   "' . #rKc <\\PVP4;r#VPpVR,VR,reVP 4pWRnVP'dFVPP4UUu/uFwrxVP VJgKWxbK uppVnVPVVVVRR7pVPe=VPPP'd\P!R4hW nR#uuppi)zestablish an INSERT statement within the context of bulk insert. This method will be within the "conn.execute()" call that is invoked by persistence._emit_insert_statement(). _emit_insert_table_emit_insert_mapperTrNzCan't use RETURNING * with bulk ORM INSERT. Please use a different INSERT form, such as INSERT..VALUES or INSERT with a Core Connection)rrrrr_cloner_dict_parametersrqr rrrrQ CompileError) rrrranemit_insert_tableemit_insert_mapperrvals && rIr$BulkORMInsert._setup_for_bulk_insertqs+/szz4>>*JJ  # # # $ $ %. $$& +  !% 5 5 ; ; =% =HC99 11 =%D ! --   )"& .   # # /''77@@@%%3  #1%s D!D)rr)rrrrr"rrr r!r]rrrrrr" __classcell__rs@rIrrs))15-4A A FV V p,   #,#,#rKrupdatec a]tRtRt]R4tRtRt]RV3Rll4t]RRR RR RR R/R R ll4t ]R4t ]R4t ]R4t ]R4t RtV;t#) BulkORMUpdateic VPV4pVPPRR4pVP'*pV'dVR8XdVP W4V#VR8Xg#VR8Xd6RVP P9d\ P!WAV3/VBV#V'dVR9dVPW4V#)rD unspecifiedrerGr)rHr) __new__rrr_setup_for_bulk_updaterr%__init___setup_for_orm_update)rrrrrrDrs&&&, rIr"BulkORMUpdate.create_for_statements{{3 --11 M  ~~%  .  ' ' <  K '},ioo&B&BB  # #DX D D \-CC  & &y ; rKc TpVP'*pVPPR,pVP;VnpVP Wq4VnVP VVVVR7VP'd\VP 4VnVP4pVPPR,VJdVPVnVP'dVP Vn M#VP'dVP VnVPVPV4p V 'dVP!V !p\P !WV3/VBRp V'gRp MVPP#RR4p VPP#RR4p V RJd5V R8H;'d(VP%VP&WpP(R7p V R8Xd/V 'd'Rp VP*!VPP,!pV'dVP/VVVVV R 7pWnR#) rrprocess_criteria_for_toplevelFNrCr?rK)r6Tr)rrrr:rr1_init_global_attributesrrlrrrrtrrwherer%rrr?r<r6rArr r) rrrrrrrr:new_stmtnew_critrrCr?s &&&, rIr#BulkORMUpdate._setup_for_orm_updates%'~~%??//?'. f $ 9 9& L $$  *2 %     $()>)>$?D !##% >> & &~ 6& @#//HN  $ $ $'+'<'*EE rKc aV'gR#VPpVPUu.uFqfPNK ppVPpVEF oVP V3RlV4VP 4p VP V 4p V 'gKE\S4PV4p V Pp V PPV 4p V FpW9gK SV,W&K V PPPV RV 4V PV \!V 44V PV 4PV 4pV'gEKV P#W4EK# R#uupi)Nc36<"TFpSV,xK R#5irMrG)rVruparams& rIr`CBulkORMUpdate._do_post_synchronize_bulk_evaluate..s/wsws)r/r|ru identity_mapidentity_key_from_primary_keyr4fast_get_stater differencerl unmodifiedrmanagerdispatchrefresh_commitrn_expire_attributes)rrirYrr[r:propryr  identity_keyrWevaluated_keysr to_evaluateru to_expirers&&&&& @rIrb0BulkORMUpdate._do_post_synchronize_bulk_evaluates; //(.(B(BC(B88(BC++ E!??/w/..L!// =E Z227;NJJE**77GK">   + + -  //    NN . .q 1=L M_%9Sc% _ M  "  ! ! # NsBc pVPpVPpV'd@VPW5V4pVUu.uF p\V4VP3,NK" p pM VP p V Uu.uFq^RVR,3NK upU U u.uFAwrVPeWP8XgK%VP \V 4V R7NKC up p U u.uF(p WP9gKVPV ,NK* p p V 'gR#TPTTTVPP^,V Uu.uF0pV\P!V4\P!V43NK2 upVP4VP!44R#uupiuupiuup p iuup iuupi)r1NrM)r/returned_defaults_rowsr{r}r4r3r!rnr r3r r4r instance_state instance_dictr5r6)rrirrr[ target_mapperr<pk_rowsrzrrrMr+objsrs&&&&& rIra(BulkORMUpdate._do_post_synchronize_fetchs'66 !'!>!> !33'=G #"Cc n<<>>>" L *77L5A44@S2YB(L4 ! 4/K"119!%C%CC ;;%#1<4 !  ! 333 /G  . . !    //    NN . .q 1    C --c2,,S1     "  ! ! # 54 ! 0 s)&F0F# "F(3 F(F.0F.6F3c  VPpVPp \P!V 4p VP W4p VP W4p /p V F>wrV P \P!\PV44pVW&K@ \V P44pV UUu0uFwppVkK ppp\4pVUu0uF>pVPV9gKVVP 9gK)VPV9gK<VkK@ ppVUu0uF3pVVP 9gKVP V,PkK5 upP#V4pVUu.uF,pVP V,PVP3NK. ppVEFwpppTP%VUUu/uFwppVVV,bK upp4VP'VP(V4VP*P-V4pVFpVV9gK W,!V4VV&K VP.P0P3VRV4VP5V\V44VP-V4P#V4pV'dVP'VV4VP7V4EK VP9V4R# \PdEKi;iuuppiuupiuupiuupiuuppi)zUapply values to objects derived from an update statement, e.g. UPDATE..SET N)r/rrrrrrrrrrrrnrrrurr#rr)rlr$rr%r&r'r(add_register_altered) rrir[reffective_paramsr7r5r6r:rrrresolved_keys_as_propnamesvalue_evaluatorsruvalue _evaluatorr,rrattribr~r to_prefetchr.prefetch_transferrrWr col_to_propc_keyr-s &&&&&&&& rIr31BulkORMUpdate._apply_update_set_values_to_objects.s  //]] &99*E226E%(%D%D & "4JC 3/77$$U%@%@%H )3 %5.3356 :; :1! :;# "uu(( V--- ^+ A"  $ #F,,, ,F $ $Q ' + +#  *^ $ ?J >IV % %a ( , ,aee 4k  "1 C LL/@.?* U !1%!88.?   $ $UZZ ;**77GK"%> & &~ 6& @#//HN11  " "F  ~~x0H ?B? %"& "*"7"7";";%t# %1155   E )$w.**$$"&"4"4$,$9$9$=$=)5% +  $( !//1K1KLH 00#!&; 1H" rKc4V^8dQhRRRRRRRRR R R R R R/#)r9rir.rz dml.DeleterYr3r7r)rr,r[r1rErrG)rHs"rIrJBulkORMDelete.__annotate__sP    &  6  '     rKc <VPRVP4pVPR8Xd\P!R4hVPR9d\P !R4h\ SV`WW4WV4#)rBrezBulk ORM DELETE not supported right now. Statement may be invoked at the Core level using session.connection().execute(stmt, parameters)zGValid strategies for ORM DELETE strategy are 'orm', 'auto', 'core_only')rHr'rG)rr5r(rQrRrSrr) rrirrYr7rr[r[rs &&&&&&& rIr#BulkORMDelete.orm_execute_statements+.. $c&@&@   ' '6 1,,A   ' '/K K&&  w, >  rKr6Fr7r8r9c4V^8dQhRRRRRRRRRRR RR R/#r;rG)rHs"rIrJrWsP&&&&  &  &&& &rKc VP;'dVPPpV'gR#V'd VP#V'd7VP'g%\P !RVP R24hR#)Frz" does not support RETURNING with DELETE..USING; for synchronize_session='fetch', please add the additional execution option 'is_delete_using=True' to the statement to indicate that a separate SELECT should be used for this backend.T)delete_returningrrdelete_returning_multifromrQrrrs&&&$$$$ rIr?BulkORMDelete.can_use_returnings  $ $ N N););)N)N  55 5 7#E#E#E %%GLL>*EE rKc ,VPVVPP44p.pVFFwrxrV 'd(VPWPP4K5VP V4KH V'dVP V4R#R#rM)rr r2_expire _modifiedr_remove_newly_deleted) rrirrr[r7 to_deleter rWris_partially_expireds &&&&& rIr`+BulkORMDelete._do_post_synchronize_evaluate.s>>   + + -   5D 1Ae# e%9%9%C%CD  ' 6E   ) )) 4 rKc VPpVPpV'd@VPW5V4pVUu.uF p\V4VP3,NK" p pM VP p V FvpV^Rp VR,p VP \V 4V R7p WP9gK?VP\P!VPV ,4.4Kx R#uupi)r1r:Nr;) r/r<r{r}r4r3r!rnr rbr r=) rrirrr[r?r<r@rzrrrMr+s &&&&& rIra(BulkORMDelete._do_post_synchronize_fetchBs'66 !'!>!> !33'=G #"Cc n<<>>>" L *77LCa)K WN)FF[!-GL333--"11#00> s&C*)r:r) rrrrr!rrr?r`rar"rrs@rIrSrSsYYv  >& $ & % &!&& %&&P55&$$rKrS)O__doc__ __future__rtypingrrrrrrr r r r r rrrrrbaserrrrrrQrenginerrrsqlrrrrrrsql.baser r!r"sql.dmlr#r$r%r& util.typingr'_typingr(r)r*r:r+rir,r-r.r/rWr0r1r2engine.interfacesr3objectr4rOrrorr$ plugin_forrrrSrGrKrIrvs@ # ,"1!&,#$$$!,33'( +$#9 T   *- ?B     #14 #?B #  #U15U?CUp  *- #'     14 #'   Y%15Y%#'Y%x %@)@FS S l)@#K@#*@#F)c*&c**c*L)_&_*_rK