H`Tc@s&dZddlZddlmZddlmZmZmZm Z ddlm Z m Z mZ m Z ddlmZmZmZdd lmZdd lmZed Zd Zd ZdZdZdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'de(fdYZ)d e)fd!YZ*d"e)fd#YZ+d$e)fd%YZ,d&e)fd'YZ-d(e*e,fd)YZ.d*e*e-fd+YZ/d,e+e,fd-YZ0d.e+e-fd/YZ1dS(0sprivate module containing functions used to emit INSERT, UPDATE and DELETE statements on behalf of a :class:`.Mapper` and its descending mappers. The functions here are called only by the unit of work functions in unitofwork.py. iN(tgroupbyi(tsqltutiltexctschemai(t attributestsyncRt evaluator(t _state_mappert state_strt _attr_as_key(t expression(tloadingc Cs| rE|j rEx-t|D]}t||g|dtqWdSt|||\}}t|}x|jjD]z\}} t||||} t ||||} | rt |||| || n| ryt |||| || qyqyWt ||||dS(s;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. tsingleN( tbatcht _sort_statestsave_objtTruet_organize_states_for_savet_cached_connection_dictt_sorted_tablestitemst_collect_insert_commandst_collect_update_commandst_emit_update_statementst_emit_insert_statementst _finalize_insert_update_commands( t base_mappertstatestuowtransactionR tstatetstates_to_inserttstates_to_updatetcached_connectionsttabletmappertinserttupdate((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs0         c Cs|t|}t|||}xW|jjD]F\}}t|||||}|r.t||||||q.q.WdS(s\Issue UPDATE statements on behalf of a relationship() which specifies post_update. N(Rt _organize_states_for_post_updateRRt_collect_post_update_commandst_emit_post_update_statements( RRRtpost_update_colsR!R R"R#R%((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt post_updateGs     c Cst|}t|||}|j}xXtt|jD]>}t||||}||}t||||||q@Wx3|D]+\} } }} } |jj || | qWdS(sIssue ``DELETE`` statements for a list of objects. This is called within the context of a UOWTransaction during a flush operation. N( Rt_organize_states_for_deleteRtreversedtlisttkeyst_collect_delete_commandst_emit_delete_statementstdispatcht after_delete( RRRR!tstates_to_deletettable_to_mapperR"tdeleteR#Rt state_dictt has_identityt connection((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt delete_obj]s       c Csg}g}xt|||D]\}}}}t|j} |jpU|j|} d} | s}|jj|||n|jj||||jr|j|||n| r\| |j j kr\|j j | } t j | } |j | s$tjdt|| t| fn|jd| t|t| |j| | } n| r| r|j||||| | | fq|j||||| | | fqW||fS(sTMake 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. sJNew instance %s with identity key %s conflicts with persistent instance %ssPdetected row switch for identity %s. will update %s, remove %s from transactionN(t_connections_for_statestbooltkeyt_identity_key_from_statetNoneR1t before_insertt before_updatet_validate_polymorphic_identitytsessiont identity_mapRtinstance_statet is_deletedtorm_exct FlushErrorR t _log_debugtremove_state_actionstappend(RRRRR Rtdict_R#R8R7t instance_keyt row_switchtinstancetexisting((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR|sH       cCstt|||S(sMake 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:(RRR((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR&s cCsng}xat|||D]M\}}}}|jj||||j|||t|j|fqW|S(sMake 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. (R:R1t before_deleteRJR;R<(RRRR3RRKR#R8((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR+sc Csg}x|D]\}}}}} } } ||jkr=q n|j|} i} i}t}t}x|j|D]}||jkr|jtk r|jd}|| |jR<t_columntopropertytgettdefaulttserver_defaultRteager_defaultst isinstanceRt ClauseElementRJ(RRR"RR$RR6R#R8R7RLRMtpkstparamst value_paramst has_all_pksthas_all_defaultstcoltvaltproptvalue((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRsB         c Csg}x|D]\}}}}} } } ||jkr=q n|j|} i} i}t}}x|j|D]}||jkr|j| p|| r| jp||| |j<|j|}|j|j j j ||t j }|jr |jd| |j RWt unchangedRFRGRJ(RRR"R R%RR6R#R8R7RLRMR]R^R_thasdatathasnullRbRdthistoryRcRe((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs                                      cCs*g}x|D]\}}}} ||jkr4q n|j|} i} t} x|j|D]} | | kr|j||| | | jRFRGRStctcontains_column( RRR"R3R5RR6R#R7R8R^RbRe((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR/s& c s]jdk o!jjjfd}|jdf|}d}x|D]\} } } } } | r| j|j| | }n|| j|| }t|| | ||jj d| ||j 7}q^W| j j r3|t |krYtjdjt ||fqYn&rYtjd|j jddndS( s`Emit UPDATE statements corresponding to value lists collected by _collect_update_commands().cstj}x@jD]1}|jj|tj|jd|jkqWr|jjjtjjjdjjknj |}j j r|j }n$jdk r|j j}n|S(Nttype_(Rtand_RQtclausesRJt bindparamRittypeRSR%RRZtreturn_defaultsR>(tclauseRbtstmt(R#R"tneeds_version_id(s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt update_stmts     R%isMUPDATE statement on table '%s' expected to update %d row(s); %d were matched.sMDialect %s does not support updated rowcount - versioning cannot be verified.t stackleveli N(RSR>RwRxt_memotexecuteRot _postfetchtcontexttcompiled_parameterstrowcounttdialecttsupports_sane_rowcounttlenRFtStaleDataErrort descriptionRtwarntdialect_description(RRR!R#R"R%Rt statementtrowsRR6R^R8R_Rw((R#R"Rs`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs@      "  cCsi|jd|f|j}xGt|dD]3\\}}} } } } | sf|j sf|jj r| r| rt| } g| D]} | d^q}||j||}xt| |j j D]C\\}}}}}}} } }t ||||||||qWq.| r1|jr1|j }n$|j dk rU|j |j }nx | D]\}}}}}}} } |r|j|j||}n||j||}|j j}|dk r4xet||j|D]J\}}|j|}|j|jdkr|j||||qqWnt |||||||j j d|q\Wq.WdS(s`Emit INSERT statements corresponding to value lists collected by _collect_insert_commands().R$cSs9|dt|djt|d|d|dfS(Niiiii(R-R.R;(trec((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt*s iiN(RR$RRZRtimplicit_returningR-RtzipRRRR~RSR>Rotinserted_primary_keyRQRVRWR<t_set_state_attr_by_column(RRR!R#R"R$RR8tpkeysthasvalueR`RatrecordsRt multiparamsRwRR6R^t mapper_rectconnR_tlast_inserted_paramstresultt primary_keytpkRbRd((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR!sl%      7"         csfd}|jdf|}xft|dD]R\}} |d} g| D]\} } } }| ^qZ}|| j||q=WdS(seEmit UPDATE statements corresponding to value lists collected by _collect_post_update_commands().cs\tj}x@jD]1}|jj|tj|jd|jkqWj|S(NRy( RRzRQR{RJR|RiR}R%(RRb(R#R"(s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR{s  R*cSs|dt|djfS(Nii(R-R.(R((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRsiN(RRR(RRR!R#R"R%RRR<tgrouperR8RR6R^RR((R#R"s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR(vs  % c sjd k o!jjjfd}x|jD]s\}}|jdf|} ||}t|} d} t} |jj r|j | |} st } n| j } nr@|jj rd} x]|D]%}|j | |} | | j 7} qWqPtjd|jjdd|j | |n|j | ||jrF| dkrF| | krF| rtjdj| | fqtjdj| | fqFqFWd S( s`Emit DELETE statements corresponding to value lists collected by _collect_delete_commands().cstj}x@jD]1}|jj|tj|jd|jkqWr|jjjtjjjdjjknj |S(NRy( RRzRQR{RJR|R<R}RSR5(RRb(R#tneed_version_idR"(s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt delete_stmts  &  R5iisMDialect %s does not support deleted rowcount - versioning cannot be verified.Ri sDELETE 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.N(RSR>RwRxRRRRURtsupports_sane_multi_rowcountRRRRRRRtconfirm_deleted_rowsRRFR(RRR!R#R"R5RR8t del_objectsRtexpectedt rows_matchedt only_warnRwR^((R"RR#s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR0sF         c Csx||D]|\}}}}}} } |jr|jg|jD]*} | js`| j|jkr?| j^q?} | r|j|j| qng} |jr| j|jnY|j dk r |j t kr |j |j }|j|jkr | j|jgq n| rR|j||_tj|jj||jd|d| n|sq|jj|||q |jj|||q WdS(szfinalize state on states that have been inserted or updated, including calling after_insert/after_update events. t refresh_statetonly_load_propsN(t_readonly_propstunmodified_intersectiontexpire_on_flushR<Rht_expire_attributesRZtextendt_unloaded_non_objectRSR>RTRURVtunloadedR=R t load_on_identRBtqueryR1t after_insertt after_update(RRRR RR6R#R8R7RLRMtptreadonlyt toload_nowRd((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs4  -  c Cs|jj}|jj} |jj} |jdk rLt||jg}n| r|jj} | dk rx:| D]/} | jrqqn|j ||| | | qqWqnxL|D]D} | j |kr| |j kr|j ||| || j qqW| rA|j |j g| D]%} | |j kr|j | j ^qnx=|j|D].\}}tj|||||||jqOWdS(sExpire attributes in need of newly persisted database state, after an INSERT or UPDATE statement has proceeded for that state.N(Rt prefetch_colstpostfetch_colstreturning_colsRSR>R-treturned_defaultsRRR<RVRRht_table_to_equatedRtpopulatetpassive_updates(R#RR"RRKRR^R_RRRtrowRbRwtmt equated_pairs((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs2       $ $  &ccs|jjr|jj}n d}d}xmt|D]_}|rX|||j}n|ss|jj|}nt|}||j||fVq4WdS(sReturn 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( RBtconnection_callableR>Rtobjt transactionR8RRh(RRRRR8RR#((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR::s    cstjfdS(Ncs|jdjS(Ntcompiled_cache(texecution_optionst_compiled_cache(R(R(s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR[s (Rt PopulateDict(R((Rs`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRXscCs[t|}td|D}|j|t|dtjdt|ddS(Ncss$|]}|jdk r|VqdS(N(R<R>(t.0ts((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pys bsR<t insert_ordercSs |jdS(Ni(R<(tq((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRes(tsettdifference_updatetsortedtoperatort attrgetter(Rtpendingt persistent((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR`s   tBulkUDcBsYeZdZdZedZedZdZdZ dZ dZ RS(s5Handle bulk update and deletes via a :class:`.Query`.cCs|jt|_dS(N(tenable_eagerloadsRUR(tselfR((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt__init__kscCs |jjS(N(RRB(R((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRBnscGs\y||}Wn=tk rMtjddjtd|Dn X||SdS(Ns3Valid strategies for session synchronization are %ss, css|]}t|VqdS(N(trepr(Rtx((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pys ys(tKeyErrortsa_exct ArgumentErrortjoinR(tclstlookuptsynchronize_sessiontargtklass((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt_factoryrs cCs6|j|j|j|j|jdS(N(t_do_pret_do_pre_synchronizet_do_exect_do_post_synchronizet_do_post(R((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pytexec_~s     cCs|j}|j|_}t|jjdksQt|jjdtj rl|j dj j |_ n|jjd|_ |j }|jr|jndS(NiisLThis operation requires only one Table or entity be specified as the target.(Rt_compile_contextRRRtfromsR[RtTablet_only_entity_zeroR#t local_tablet primary_tableRBt _autoflush(RRRRB((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs   cCsdS(N((R((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRscCsdS(N((R((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs( t__name__t __module__t__doc__RtpropertyRBt classmethodRRRRR(((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRhs    t BulkEvaluatecBs eZdZdZdZRS(sDBulkUD which does the 'evaluate' method of session state resolution.cCsdS(N((Rtevaluator_compiler((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt_additional_evaluatorsscCs|j}|jj}yMtj|}|jdk rN|j|j}n d}|j|Wn#tj k rt j dnXg|j j jD]3\\}}}t||r||r|^q|_dS(NcSstS(N(R(R((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyteval_conditionssnCould not evaluate current criteria in Python. Specify 'fetch' or False for the synchronize_session parameter.(Rt _mapper_zerotclass_RtEvaluatorCompilert whereclauseR>tprocessRtUnevaluatableErrorRtInvalidRequestErrorRBRCRt issubclasstmatched_objects(RRt target_clsRRRRR((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs    "(RRRRR(((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs t BulkFetchcBseZdZdZRS(sABulkUD which does the 'fetch' method of session state resolution.cCsR|j}|j}|jjj|jj}|j|d|jj |_ dS(NR^( RRBRRtwith_only_columnsRRRt_paramstfetchallt matched_rows(RRRBt select_stmt((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs   (RRRR(((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRst BulkUpdatecBs8eZdZdZedZdZdZRS(sBulkUD which handles UPDATEs.cCs3tt|j||jjd||_dS(NR%(tsuperRRRt_no_select_modifiersRo(RRRo((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRscCs+tjitd6td6tt6|||S(Ntevaluatetfetch(RRtBulkUpdateEvaluatetBulkUpdateFetchRRU(RRRRo((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pytfactorys  cCsXtj|j|jj|j}|jjj|d|jj |_ |j j |_ dS(NR^( RR%RRRRoRRBRR RR(RR((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs   cCs |jj}|jj|dS(N(RRBR1tafter_bulk_update(RRB((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs (RRRRRRRR(((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs   t BulkDeletecBs8eZdZdZedZdZdZRS(sBulkUD which handles DELETEs.cCs*tt|j||jjddS(NR5(RRRRR(RR((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRscCs(tjitd6td6tt6||S(NRR(RRtBulkDeleteEvaluatetBulkDeleteFetchRRU(RRR((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs  cCsRtj|j|jj}|jjj|d|jj|_ |j j |_ dS(NR^( RR5RRRRRBRR RR(RR((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs  cCs |jj}|jj|dS(N(RRBR1tafter_bulk_delete(RRB((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs (RRRRRRRR(((s`/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs   RcBs eZdZdZdZRS(sSBulkUD which handles UPDATEs using the "evaluate" method of session resolution.cCsXi|_xH|jjD]7\}}t|}|jtj||j|sF "" -   I   3 { % " D U  O - *   6# $