U
|
¸ý°d8ñ ã @ s¨ d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlZddlm Z dd lm
|
Z dd
|
lm Z dd lm Z dd lmZ d d lm
|
Z d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ dDddZ dd Z dd Z d d Z d d Z d d! Z!dddd"d#d$d%Z"ddd"d&d'd(Z#d)d* Z$d+d, Z%d-dd-d.d/d0Z&d-ddd1d2d3Z'd4d5 Z(d6d7 Z)d8d9 Z*d:d; Z+d<d= Z,d>d? Z-d@dA Z.dBdC Z/dS )Ezëprivate module containing functions used to emit INSERT, UPDATE
|
and DELETE statements on behalf of a :class:`_orm.Mapper` and its descending
|
mappers.
|
|
The functions here are called only by the unit of work functions
|
in unitofwork.py.
|
|
é )Ú annotations)Úchain)Úgroupby)Ú zip_longestNé )Ú
|
attributes)Úexc)Úloading)Úsync)Ú state_stré )Úfuture)Úsql)Úutil)Úcursor)Ú operators)ÚBooleanClauseList)Ú LABEL_STYLE_TABLENAME_PLUS_COLFc C s |s0| j s0t| |D ]}t| |g|dd qdS g }g }t| ||D ]B\}}}} }
|
} } |
|
s^| rt| |||| | f¡ qD| |||| f¡ qD| j ¡ D ]J\} }| |jkr¦qt| |}t || |}t
|
| ||| | t | ||| | qt | |t dd |D dd |D dS )a; Issue ``INSERT`` and/or ``UPDATE`` statements for a list
|
of objects.
|
|
This is called within the context of a UOWTransaction during a
|
flush operation, given a list of states to be flushed. The
|
base mapper in an inheritance hierarchy handles the inserts/
|
updates for all descendant mappers.
|
|
T)ÚsingleNc s s$ | ] \}}}}||||d fV qdS )FN© )Ú.0ÚstateÚ
|
state_dictÚmapperÚ
|
connectionr r úQd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/orm/persistence.pyÚ <genexpr>i s
|
ÿzsave_obj.<locals>.<genexpr>c s s& | ] \}}}}}||||d fV qdS )TNr )r r r r r Úupdate_version_idr r r r m s ú)ÚbatchÚ _sort_statesÚsave_objÚ_organize_states_for_saveÚappendÚ_sorted_tablesÚitemsÚ _pks_by_tableÚ_collect_insert_commandsÚ_collect_update_commandsÚ_emit_update_statementsÚ_emit_insert_statementsÚ _finalize_insert_update_commandsr )Ú base_mapperÚstatesÚuowtransactionr r Ústates_to_updateÚstates_to_insertÚdict_r r Ú has_identityÚ
|
row_switchr ÚtableÚinsertÚupdater r r r ( sn
|
|
|
ø ÿ
|
|
ÿûûþøûýr c sh t t| ||}| j ¡ D ]H\ jkr.q fdd|D }t| |||}t| | | qdS )z\Issue UPDATE statements on behalf of a relationship() which
|
specifies post_update.
|
|
c
|
3 sH | ]@\}}}}|j kr|||| jd k r: || j¡nd fV qd S ©N)r% Úversion_id_colÚ#_get_committed_state_attr_by_column)r r r Z
|
sub_mapperr ©r r3 r r r s
|
|
õý ÿ÷z post_update.<locals>.<genexpr>N)ÚlistÚ _organize_states_for_post_updater# r$ r% Ú _collect_post_update_commandsÚ _emit_post_update_statements)r+ r, r- Úpost_update_colsr. r5 r r9 r Ú post_update{ s.
|
ÿ
|
ô ÿûr? c C s t t| ||}| j}tt | ¡ D ]F}|| }||jkr@q&n|jrN|jrNq&t| |||}t | |||| q&|D ] \}} }}
|
} |j
|
||
|
|¡ qrdS )zIssue ``DELETE`` statements for a list of objects.
|
|
This is called within the context of a UOWTransaction during a
|
flush operation.
|
|
N) r: Ú_organize_states_for_deleter# ÚreversedÚkeysr% ZinheritsZpassive_deletesÚ_collect_delete_commandsÚ_emit_delete_statementsÚdispatchZ after_delete) r+ r, r- Ústates_to_deleteZtable_to_mapperr3 r Údeleter r r r r r r Ú
|
delete_obj¦ s>
|
ÿ
|
ÿûúrH c c sJ t | ||D ]6\}}}}t|j}|jp2| |¡}d } }
|
|sR|j |||¡ n|j |||¡ |jrv| |||¡ |sô||jj krô|jj | } t
|
| ¡} | | ¡sô| | ¡sÎt dt||t| f ¡ n&| d|t|t| ¡ | | ¡ | } |sþ| r0|jdk r0| | r| n|| r&| jn||j¡}
|
|||||| |
|
fV q 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.
|
|
NzJNew instance %s with identity key %s conflicts with persistent instance %szPdetected row switch for identity %s. will update %s, remove %s from transaction)Ú_connections_for_statesÚboolÚkeyÚ_identity_key_from_staterE Z before_insertZ before_updateZ _validate_polymorphic_identityÚsessionZ identity_mapr Zinstance_stateZwas_already_deletedÚ
|
is_deletedr Úwarnr Z
|
_log_debugZremove_state_actionsr7 r8 Údict) r+ r, r- r r0 r r r1 Z instance_keyr2 r ÚinstanceÚexistingr r r r! Ñ s` ÿ
|
ÿ
|
þ
|
|
|
þÿú
|
|
ýùr! c C s t | ||S )z÷Make 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.
|
|
)rI )r+ r, r- r r r r; " s r; c c s^ t | ||D ]L\}}}}|j |||¡ |jdk rD| |||j¡}nd}|||||fV q dS )zôMake 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)rI rE Z before_deleter7 r8 )r+ r, r- r r0 r r r r r r r@ . s ÿ
|
ÿr@ r )ÚbulkÚreturn_defaultsÚ render_nullsÚinclude_bulk_keysc # sÈ |D ]¼\} }}| |j kr qi } i }
|
|j| } |j| } t| ¡D ]l} | }| | }|dkrt|| krt|stqHqH|sªt|dst|tjrªt|dr | ¡ n||
|
|< qH|| |j
|
< qH|sè|j | | ¡ dd |
|
D ¡D ] }d| |< qÚ|rò|r,|j | | ¡}|j |j| ¡r&|j| | ¡}nd}nd }}|jdk rp|jdk rp|j|j| krp| d¡| |jj
|
< |r¬|jr| |j|j¡ |r¬| fdd|D ¡ | | |||
|
||fV qdS ) zSIdentify sets of values to use in INSERT statements for a
|
list of states.
|
|
NÚ__clause_element__c S s g | ]
|
}|j qS r ©rK ©r Úcr r r Ú
|
<listcomp>y s z,_collect_insert_commands.<locals>.<listcomp>TFc 3 s | ]}| | fV qd S r6 r ©r Úk©r r r r s z+_collect_insert_commands.<locals>.<genexpr>)r% Ú_propkey_to_colZ _insert_cols_evaluating_noneÚsetÚ intersectionÚhasattrÚ
|
isinstancer Ú ClauseElementrW rK Z_insert_cols_as_noneÚ
|
differenceZ_pk_keys_by_tableÚissubsetr+ Ú_prefer_eager_defaultsÚdialectZ_server_default_col_keysÚversion_id_generatorr7 Ú_cols_by_tableZ_set_polymorphic_identityÚ
|
setdefaultZ_polymorphic_attr_keyZpolymorphic_identityr5 )r3 r/ rS rT rU rV r r r ÚparamsÚ value_paramsÚpropkey_to_colZ eval_noneÚpropkeyÚvalueÚcolZcolkeyÚ has_all_pksÚhas_all_defaultsr r^ r r& F s
|
|
|
ÿ
|
þÿ
|
ý
|
ÿ þÿ
|
|
ÿÿþÿþýÿ ÿør& )rS Úuse_orm_update_stmtrV c # s |D ]\}}}} ||j kr q|j | }
|
|dk r:|j} ni } |j| |r| fddt ¡ |j| ¡D } d} n¨i } t |j¡D ]n}| } | }t|dsºt |t
|
j rÖt|drÌ| ¡ n|| |< q|j | j ||j| ¡dk r|| |j< q|jjdkr |j| | ¡} nd} | dk rþ|j|j| krþ|s| s| s|j ¡ D ].}|j |j j |tj¡}|j r\ qq\q|j}| o | }| | |j < |s¾|j| krà|j dk rà| | ¡}|| |j< n |j dkr |r | | |j< n| s | s qd}d}|r@ fddt |j| ¡D }nÌi }|
|
D ]Â}|j| j}|j | j |tj ¡}|j rÖ|j rd||f| jkr¶d}|j d ||j < | !|jd¡ n |j d ||j < || kræd}n|j"d ||j < ||j dkrHt# $d
|
||f ¡qH|r*| %fd d |D ¡ | s6| rX| %|¡ || ||| | |fV q|r|j&| D ]"\}}t' (|||||| |j)¡ qfqdS ) 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.
|
|
Nc s i | ]} | j | qS r rX ©r ro ©rn r r r Ú
|
<dictcomp>× s ÿ z,_collect_update_commands.<locals>.<dictcomp>TrW Fc s i | ]} | j |¡qS r )Ú_labelÚgetru rv r r rw + s ÿ Z pk_cascadedr zCCan't update table %s using NULL for primary key value on column %sc 3 s | ]}| | fV qd S r6 r r\ r^ r r r Q s z+_collect_update_commands.<locals>.<genexpr>)*r% Z_valuesr_ r` ra re Z_pk_attr_keys_by_tableZcommitted_staterb rc r rd rW ÚmanagerÚimplZis_equalrK r+ Úeager_defaultsZ!_server_onupdate_default_col_keysrf r7 rj Ú_columntopropertyÚvaluesÚ get_historyr ÚPASSIVE_NO_INITIALIZEÚaddedrx ri Ú PASSIVE_OFFZdeletedÚpopZ unchangedÚorm_excÚ
|
FlushErrorr5 Ú_table_to_equatedr
|
ÚpopulateÚpassive_updates)r- r3 r. rS rt rV r r r r Úpksrm rl rs ro rp rq ÚpropÚhistoryZ no_paramsÚvalrr Zexpect_pk_cascadedZ pk_paramsÚmÚ equated_pairsr rv r r' « s ú
|
|
|
ÿþþÿ ÿÿ
|
ý ÿýÿ ÿþÿþ ÿ
|
|
ÿÿþ
|
ÿþ ÿÿÿþ
|
ÿÿ
|
ø
|
ùr' c c s, |D ] \}}}}} |j | }
|
i } d} |j| D ]|} | |
|
krX|j||| tjd| | j< q0| |ksj| jdk r0|j| }|j|j j
|
||tj ¡}|j r0|j d }|| | j < d} q0| r| dk r|j|j| kr|j} | | | j< t|j r| j | kr|jdk r| | ¡}|| | j < ||||| fV qdS )zrIdentify sets of values to use in UPDATE statements for a
|
list of states within a post_update operation.
|
|
F)ZpassiveNr T)r% rj Z_get_state_attr_by_columnr r rx Zonupdater} rz rK r{ r r r r7 rJ ri )r+ r- r3 r. r> r r r r r r rl Zhasdatarq r r rp r r r r r< q sZ ú
|
ÿ
|
ÿ
|
|
ÿþ
|
ÿþý
|
|
r< c c s |D ]\}}}}}||j kr qi } |j | D ]6}
|
| |||
|
¡ | |
|
j< } | dkr,t d||
|
f ¡q,|dk r|j|j| kr|| |jj< | |fV qdS )zSIdentify values to use in DELETE statements for a list of
|
states to be deleted.NzHCan't delete from table %s using NULL for primary key value on column %s)r% r8 rK r r
r7 rj ) r+ r- r3 rF r r r r r rl rq rp r r r rC © s@ ú
|
ÿþÿþÿÿþ rC T)Ú bookkeepingrt Úenable_check_rowcountc s j dk o j j kd| ji}d fdd } |dk rH| |}
|
n| df| ¡}
|
t|dd D ]\\} } } }}}d}t|}|
|
}|dk r¢| d ¡}d
|
}|s¾|j j }d }|rô|sô j j
|
d krôj rô| j j rô|j j }d } jr | j ¡}d }| j j}|o | j j}| o. }| rª|D ]j\}}} } }}}| j| |¡||d }|rt |||||jjd |d |j
|
||j7 }|o |} q:n |s |o¸|} |D ]Z\}}} } }}}| j|||d }|r t |||||jjd |d |j
|
||j7 }q¾nd d |D } |oF|pF|oFt| dk} | j|| |d }||j7 }|D ]N\}}} } }}}|rft |||||jjd |d |jjs¬|jnd
|
qf| ræ|t|krüt dj t||f ¡qfrft d|j j ¡ qfdS )z`Emit UPDATE statements corresponding to value lists collected
|
by _collect_update_commands().NÚcompiled_cachec s t tj¡} j D ] }| |tj|j|j dk¡ qr^| j
|
tj j
|
j j
|
j dk¡ | d k rr| |¡}n ¡ |¡}|S ©N)Útype_) r Ú_construct_rawr Úand_r% Ú_append_inplacer Ú bindparamrx Útyper7 Úwherer5 )Z existing_stmtÚclausesrq Ústmt©r Zneeds_version_idr3 r r Ú update_stmtå s$ ÿþÿÿ z,_emit_update_statements.<locals>.update_stmtr5 c S s* | d t | d t| d | d | d fS ©Né r é é é ©r` rJ ©Úrecr r r Ú<lambda> s
|
|
ûz)_emit_update_statements.<locals>.<lambda>r )Z_emit_update_tableZ_emit_update_mapperFT©Úexecution_optionsc S s g | ] }|d qS ©r r ©r r¥ r r r r[ s z+_emit_update_statements.<locals>.<listcomp>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.)N)!r7 rj Ú_compiled_cacheÚ_memor r: Ú _annotaterT r% r+ r| Úimplicit_returningrh Zupdate_returningZ _server_onupdate_default_colsÚ!_version_id_has_server_side_valueÚsupports_sane_rowcountÚ supports_sane_multi_rowcountÚexecuter~ Ú
|
_postfetchÚcontextÚcompiled_parametersÚreturned_defaultsÚrowcountÚlenÚ executemanyr ÚStaleDataErrorÚ descriptionr rO Údialect_description) r+ r- r r3 r5 r rt r r¨ r Ú cached_stmtr Z paramkeysÚhasvaluers rr ÚrecordsÚrowsÚ statementrT Úassert_singlerowÚassert_multirowÚallow_executemanyr r rl rm rZ Úcheck_rowcountÚ multiparamsr r r r( Ð sB
|
þ
|
|
þý þÿÿþ
|
ýùø
|
ÿ þ
|
÷ý
|
ö
|
|
|
÷ ÿ
|
ö þ ÿ
|
÷
|
ÿ
|
ôþÿþÿr( )r Úuse_orm_insert_stmtr¨ c % C s° |dk r,|}t j} t|j}
|
|
|
r&|jp(|} n$d}
|
|} | d|f|j¡}d| ji} |rdt j | |¡}n| }d} t |dd D ]\\} }}}}}|}|dk rª|
|
||d¡}|rÐ|sÐ| | j |¡rÐ|j rÐ| j jsx|
|
sx|rx|sxt|}dd |D }| j|||d
|
}|rt||jjD ]X\\}}}}}}}}} |rft||||||| |d|jjs^|jnd
|
n t||| q qzt|}|
|
s|sút|d krú| rª| j jsº| sÀ| j jrÀd } n8|
|
rô| rÒd } nd} t d| j j d| d¡nd} nd} |dkr4|s4| | j |¡r4|j |j | d|i}|j dk rR|j |j |d}n| rj|j |j!d|i}| r~dd |D }| j|||d
|
}|dk r²| dkr¨|} n
|
| "|¡} |rt#||jj|j$|j%pÐdD ]¦\\}}}}}}}}} } } | dkrt& 'd| ¡t| |j(| D ]0\}!}"|j)|" }#| *|#j+¡dkr|!||#j+< q|rlt||||||| |d|
|
n t||| qÔqz|
|
rt,|D ]ü\}}}}} }}}|r¾| j| -|¡||d
|
}n| j|||d
|
}|j.}$|$dkrît& 'd|f ¡t|$|j(| D ]:\}!}"|j)|" }#|"|ks,| *|#j+¡dkrþ|!||#j+< qþ|r|rzt|||||||jjd |d|jjsr|jnd
|
n t||| qqz|dk r¬| dkr¨t/ 0¡ S | S dS )z`Emit INSERT statements corresponding to value lists collected
|
by _collect_insert_commands().NFr4 r c S s* | d t | d t| d | d | d fS r r£ r¤ r r r r¦ å s
|
|
ûz)_emit_insert_statements.<locals>.<lambda>)Z_emit_insert_tableZ_emit_insert_mapperc S s g | ] }|d qS r© r rª r r r r[ s z+_emit_insert_statements.<locals>.<listcomp>r§ r Tz+ with RETURNING and sort by parameter orderz with RETURNINGz<Can't use explicit RETURNING for bulk INSERT operation with z backend; executemanyz! is not enabled for this dialect.Úsort_by_parameter_order)rÊ c S s g | ] }|d qS r© r rª r r r r[ k s r zÈMulti-row INSERT statement for %s did not produce the correct number of INSERTed rows for RETURNING. Ensure there are no triggers or special driver issues preventing INSERT from functioning properly.z¾Single-row INSERT statement for %s did not produce a new primary key result being invoked. Ensure there are no triggers or special driver issues preventing INSERT from functioning properly.r )1r Ú
|
EMPTY_DICTrJ Z
|
_returningZ_sort_by_parameter_orderr® r4 r Z
|
merge_withr r¯ rg rh r° Zinsert_returningr: r´ Úzipr¶ r· rµ r» r¸ Ú_postfetch_bulk_saverº Z4insert_executemany_returning_sort_by_parameter_orderZ insert_executemany_returningÚsa_excÚInvalidRequestErrorr¾ rT Z_server_default_colsr7 Ú primary_keyZsplice_verticallyr Zinserted_primary_key_rowsZreturned_defaults_rowsr r
r% r} ry rK ÚAssertionErrorr~ Úinserted_primary_keyÚ_cursorZnull_dml_result)%r+ r- r r3 r4 r rÉ r¨ r¿ Zexec_optZ returning_is_required_anywayZdeterministic_results_reqdZ return_resultr Ú_rÀ rr rs rÁ rà rÈ Úresultr r rl Ú
|
mapper_recÚconnrm Zlast_inserted_paramsZdo_executemanyÚdtrÒ r¸ Úpkrq r rÐ r r r r) ¸ sþ
|
þý
|
ÿþý þÿ þü ÿûø ÷ ô óò ÿ ôÿ
|
ôÿ
|
ÿÿþüûÿ
|
ÿ ÿþÿþ þÿÿ ÿ
|
|
|
|
üò
|
ûÿ þ
|
ö
|
÷ýý
|
ûÿ ÿ
|
ÿþ
|
ÿ
|
ô
|
|
r) c s² d| j i} jdk o" j j k fdd}| df|¡} jrV| j¡}t|dd D ]F\}} d}
|
t| } |d } | jj } | o| jj
|
} p| }|sô| }| D ]D\}}}} }| j |||d }t ||||||j jd |
|
|j7 }
|
q¬nrd
|
d | D }| p| ot|d k}| j |||d }|
|
|j7 }
|
| D ],\}}}} }t ||||||j jd q8|r|
|
t| kr¬t d jt| |
|
f ¡qdrdt d|jj ¡ qddS )zeEmit UPDATE statements corresponding to value lists collected
|
by _collect_post_update_commands().r Nc sp t tj¡} j D ] }| |tj|j|j dk¡ qr^| j
|
tj j
|
j j
|
j dk¡ ¡ | ¡}|S r ) r r r r r% r r r rx r r7 r5 r )r rq r r r r r s ÿþÿÿz1_emit_post_update_statements.<locals>.update_stmtr? c S s | d t | d fS )Né r )r` r¤ r r r r¦ ' ó z._emit_post_update_statements.<locals>.<lambda>r r§ c S s g | ]\}}}}}|qS r r )r r r rÖ r× rl r r r r[ H s ÿz0_emit_post_update_statements.<locals>.<listcomp>r r« r¬ )r r7 rj r® r± rT r r: rh r² r³ r´ Ú_postfetch_post_updater¶ r· r¹ rº r r¼ r½ r rO r¾ )r+ r- r r3 r5 r¨ r rà rK rÁ r r rÄ rÅ rÆ rÇ r r rÖ rl rZ rÈ r r r r= ú s
|
|
þ þþ
|
ÿ
|
ù þÿ ÿ
|
|
ù
|
þÿþÿr= c s` j dk o j j k fdd}| df|¡}t|dd D ]\}}dd |D } d | ji}
|
t| } d
|
} d } rÜ|jjsÜ|jjr¸d } | D ] }|j |||
|
d }| |j
|
7 } qqút d|jj ¡ |j || |
|
d n |j || |
|
d }sôd} |j
|
} | jrH| d
|
krH| | krH|jjs&t| dkrH| rDt dj| | f ¡ qHt dj| | f ¡qHdS )z`Emit DELETE statements corresponding to value lists collected
|
by _collect_delete_commands().Nc sl t tj¡} j D ] }| |tj|j|j dk¡ qr^| j
|
tj j
|
j j
|
j dk¡ ¡ | ¡S r ) r r r r r% r r r rK r r7 rG r )r rq ©r Zneed_version_idr3 r r Ú delete_stmt| s ÿ ÿÿÿz,_emit_delete_statements.<locals>.delete_stmtrG c S s | d S )Nr r r¤ r r r r¦ rÛ z)_emit_delete_statements.<locals>.<lambda>c S s g | ] \}}|qS r r )r rl r r r r r[ s z+_emit_delete_statements.<locals>.<listcomp>r éÿÿÿÿFr r§ 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.)r7 rj r® r r rº rh r³ r² r´ r¹ r rO r¾ Zconfirm_deleted_rowsr½ r r¼ )r+ r- r r3 rG rÞ rà r ZrecsZ del_objectsr¨ ÚexpectedZ rows_matchedZ only_warnrl rZ r rÝ r rD q s~
|
þ
|
ÿþ ÿþÿ ÿ ÿÿþýû
|
ú
|
üÿ
|
üÿrD c
|
s, |D ] \ }}}}|j rF fdd|j D ¡}|rF j|¡ g }| jdkrh| j |j¡¡ |j dk r|j
|
dkr|j j j kr| |j j g¡ |rÒ| ¡ _ t |¡ t¡} tj|j| j |d |sè|j || ¡ n|j || ¡ |j
|
dkr|j dk r||j j dkrt d¡qdS )zzfinalize state on states that have been inserted or updated,
|
including calling after_insert/after_update events.
|
|
c sB g | ]:}|j r |jr8|j jks8|j s|js|j jkr|jqS r )Zexpire_on_flushÚdeferredrK rP )r Úp©r r r r[ Þ s ÷z4_finalize_insert_update_commands.<locals>.<listcomp>TNF)Z refresh_stateZonly_load_propsz2Instance does not contain a non-NULL version value)Z_readonly_propsZunmodified_intersectionÚ_expire_attributesrP r| ÚextendZ_unloaded_non_objectra Z&_server_default_plus_onupdate_propkeysr7 ri Z_version_id_proprK ZunloadedrL r ÚselectZset_label_styler r Z load_on_identrM rE Z after_insertZ after_updater r
)
|
r+ r- r, r r r r1 ÚreadonlyZ
|
toload_nowr r rã r r* Õ sZ
|
þÿ
|
ÿÿÿþ
|
ÿû ÿþÿr* c sê | |¡rd S |jjj}|jjj} jd k rL j j| krLt| jg }t j j
|
j } | rbg }
|
|D ]D} | j |krf| j krf|| j | j | j < | rf|
|
j | j ¡ qf| rÆ|
|
rÆ j j
|
|||
|
¡ |ræ| |j fdd|D ¡ d S )Nc s" g | ]}| j kr j | jqS r ©r} rK rY ©r r r r[ B s
|
þz*_postfetch_post_update.<locals>.<listcomp>)rN r¶ ÚcompiledÚprefetchÚ postfetchr7 rj r: rJ Ú class_managerrE Ú refresh_flushrK r} r" rä rP ) r r- r3 r r0 rÕ rl Ú prefetch_colsÚpostfetch_colsrî Úload_evt_attrsrZ r ré r rÜ ! s<
|
|
|
ÿþ ÿ
|
þþrÜ c
|
|
s |j jj}
|
|j jj} |j jj jdk rH j j| krHt|
|
jg }
|
t j j
|
j } | r^g } r¼| }|dk r¼t |D ]B\}}|j r|j jrqx j |¡}|rx|||j< | rx| |j¡ qx|
|
D ]D}|j|krÀ| jkrÀ||j | j| j< | rÀ| j| j¡ qÀ| r$| r$ j j
|
||| ¡ |rH|rH| fdd|D ¡ | rj| |j fdd| D ¡ j| D ]"\}}t |||||| j¡ qtdS )zExpire attributes in need of newly persisted database state,
|
after an INSERT or UPDATE statement has proceeded for that
|
state.Nc s g | ]}|j r| kr|qS r )rÐ )r rq )Úreturning_colsr r r[ s þz _postfetch.<locals>.<listcomp>c s" g | ]}| j kr j | jqS r rè rY ré r r r[ s
|
þ)r¶ rê rë rì Zeffective_returningr7 rj r: rJ rí rE rî rÌ rÐ Zisinsertr} ry rK r" rå rä rP r r
|
r r )r r- r3 r r0 rÕ rl rm Zisupdater¸ rï rð rî rñ ÚrowZ row_valuerq r rZ r r r )r rò r rµ J sp
|
|
|
ÿþ
|
ÿ
|
þÿ
|
þþ ùrµ c C s& | j | D ]\}}t |||¡ q
|
d S r6 )r r
|
Zbulk_populate_inherit_keys)r r0 r3 r r r r r rÍ « s rÍ c c s` |j jr|j j}n|j | ¡}d}t| |D ].}|rB|| | ¡ }|jj}||j||fV q,dS )zßReturn an iterator of (state, state.dict, mapper, connection).
|
|
The states are sorted according to _sort_states, then paired
|
with the connection they should be using for the given
|
unit of work transaction.
|
|
N) rM Úconnection_callableZ transactionr r Úobjrz r rP )r+ r- r, rô r r r r r r rI ° s
|
rI c
|
C s| t |}dd |D }| |¡ zt|| jd}W n2 tk
|
rd } zt d| ¡|W 5 d }~X Y nX t|t d¡d| S )Nc S s h | ]}|j d k r|qS r6 rX )r Úsr r r Ú <setcomp>Ì s
|
z _sort_states.<locals>.<setcomp>rX z^Could not sort objects by primary key; primary key values must be sortable in Python (was: %s)Z insert_order) r` Údifference_updateÚsortedZ_persistent_sortkey_fnÚ TypeErrorrÎ rÏ ÚoperatorÚ
|
attrgetter)r r, ÚpendingÚ
|
persistentZpersistent_sortedÚerrr r r r Ê s(
|
ÿ
|
ÿÿýÿÿr )F)0Ú__doc__Ú
|
__future__r Ú itertoolsr r r rû Ú r r r r r
|
Úbaser rÎ r r r Zenginer rÓ r Z sql.elementsr Zsql.selectabler r r? rH r! r; r@ r& r' r< rC r( r) r= rD r* rÜ rµ rÍ rI r r r r r Ú<module>
|
sn
|
S++Q ù jù G8.÷ p÷ DwdL)a
|
