H`Tc@sJdZddlmZmZddlmZddlmZmZmZdZde fdYZ d e fd YZ d e fd YZ d e fdYZ de e fdYZde fdYZde fdYZde fdYZde fdYZde fdYZde fdYZdS(sThe internals for the unit of work system. The session's flush() process passes objects to a contextual object here, which assembles flush tasks based on mappers and their properties, organizes them in order of dependency, and executes. i(tutiltevent(t topologicali(t attributest persistenceRcs|jfd}fd}fd}tj|d|dtdttj|d|dtdttj|d|dtdtd S( s\Establish event listeners on object attributes which handle cascade-on-set/append. cs|dkrdS|j}|r|jr8|jdn|jjj}tj|}|j j r|j s~|j kr|j | r|j|qn|S(Nscollection append(tNonetsessiont_warn_on_eventst_flush_warningtmanagertmappert_propsRtinstance_statet_cascadet save_updatetcascade_backrefstkeyt_contains_statet_save_or_update_state(tstatetitemt initiatortsesstpropt item_state(R(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pytappends    cs|dkrdS|j}|r|jjj}|jrZ|j|jrPdndntj |}|j j r||j kr|jj |r|j|qndS(Nscollection removesrelated attribute delete(RRR R R RRtuselistRR R t delete_orphant_newt _is_orphantexpunge(RRRRRR(R(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pytremove0s     c s-||kr|S|j}|r)|jr8|jdn|jjj}|dk rtj|}|j j r|j s|j kr|j | r|j|qn|dk r)|tjk r)|tjk r)|j jr)tj|}||jkr&|jj|r&|j|q&q)n|S(Nsrelated attribute set(RRRR R R RRR R RRRRRt NEVER_SETtPASSIVE_NO_RESULTRRRR(RtnewvaluetoldvalueRRRtnewvalue_statetoldvalue_state(R(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pytset_Fs,       RtrawtretvalRtsetN(RRtlistentTrue(t descriptorRRRR&((Rs_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyttrack_cascade_eventss  tUOWTransactioncBseZdZedZdZdZdZej dZ dZ dZ e e e dddZd Zd Zejd Zd Zd ZdZdZdZRS(cCsv||_i|_tjt|_tjt|_i|_i|_t|_ i|_ tjd|_ dS(NcSsttfS(N(R)(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyts( RRRt defaultdictR)tdepstmapperstpresort_actionstpostsort_actionst dependencieststatestpost_update_states(tselfR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt__init__ls      cCs t|jS(N(tboolR6(R8((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pythas_workscCs||jko|j|dS(sWreturn true if the given state is marked as deleted within this uowtransaction.i(R6(R8R((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt is_deletedscCs6||jkr|j|S||j|<}|SdS(N(R(R8Rt callable_tret((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pytmemos cCs(|j|d}|tf|j|DsiiN(R+RYtlistR3tvaluestexecuteRt find_cyclesR5R4tcyclesRFRtdisabledt issupersetRR[R)t difference(R8R>tactionRtconverttedgeRnta((R8s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt_generate_actions+s<     !(cCs|j}|jraxvtj|j|D]/}x&|rY|j}|j||q4Wq+Wn-x*tj|j|D]}|j|qwWdS(N( RRRtsort_as_subsetsR5tpoptexecute_aggregatetsortR~(R8R4R&tnR{((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR~^s       cCsat|j}td|jjD}|j|}|jj||jj|dS(smark processed objects as clean / deleted after a successful flush(). this method is called within the flush() method after the execute() method has succeeded and the transaction has been committed. css'|]\}\}}|r|VqdS(N((RzRtR@R\((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pys sN(R)R6titemsRRt_remove_newly_deletedt_register_newly_persistent(R8R6tisdeltother((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pytfinalize_flush_changesvs N(t__name__t __module__R9tpropertyR;R<R?RARtPASSIVE_NO_INITIALIZERORQRTRYRR_RdRZRtmemoized_propertyRrRuRxRR~R(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR.ks& -   )       3 tIterateMappersMixincBseZdZRS(cs@jr/tfdjjjDSjjjSdS(Nc3s+|]!}j|jfr|VqdS(N(Rrtdependency_processor(Rztm(tuowR8(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pys s(RStiterRtparentRvR (R8R((R8Rs_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt_mapperss  (RRR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRsRRcBseZdZdZRS(cCs+||_||_t|_t|_dS(N(RRSR)t processedRYtsetup_flush_actions(R8RRS((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR9s   cCsUt}t}xz|j|D]i}x`|j|j|jD]E}|j|\}}|sB|rw|j|q|j|qBqBWq"W|r|jj|||jj |n|r|jj |||jj |n|s|rM|j rI|jj ||t s-|jj ||trI|jj|t |_ nt StSdS(N(R)RR2RRR6R[Rtpresort_deletesRat presort_savesRtprop_has_changesR+RYtper_property_flush_actions(R8Rt delete_statest save_statesR RR@R\((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR~s2        (RRR9R~(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRRs t PostSortReccBs)eZeZdZdZdZRS(cGsI|f|}||jkr'|j|Stj||j|<}|SdS(N(R4tobjectt__new__(tclsRtargsRR>((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs   cCs|j|dS(N(R~(R8Rtrecs((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRscCs0d|jjdjd|jjDfS(Ns%s(%s)t,css|]}t|VqdS(N(tstr(Rztx((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pys s(t __class__Rtjoint__dict__R}(R8((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt__repr__s (RRRYRRRR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs t ProcessAllcBs5eZdZdZdZdZdZRS(cCs9||_||_||_|j|jjj|dS(N(RtdeleteRSR1RR`R[(R8RRRRS((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR9s    cCsE|j|}|jr.|jj||n|jj||dS(N(t _elementsRRtprocess_deletest process_saves(R8RR6((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR~s cCs tgS(N(R(R8R((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRyscCsd|jj|j|jfS(Ns%s(%s, delete=%s)(RRRR(R8((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs ccsgx`|j|D]O}xF|j|D]7}|j|\}}||jkr$| r$|Vq$q$WqWdS(N(RR2R6R(R8RR RR@R\((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs (RRR9R~RyRR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs     tIssuePostUpdatecBseZdZdZRS(cCs||_||_dS(N(R R@(R8RR R@((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR9s cCsf|j|j\}}g|D]&}|j|d|jkr|^q}tj|j|||dS(Ni(R7R R6R@Rt post_update(R8RR6RcRt((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR~s3(RRR9R~(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs RecBs#eZdZdZdZRS(cCs"||_||jkstdS(N(R R`tAssertionError(R8RR ((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR9s cCs,tj|j|j|jtt|dS(N(Rtsave_objR RxRY(R8R((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR~ s c cst|j|jtt}|jj}t||}x;|D]3}t|||}|jj||f|Vq@Wx=|j |jD]+}|j ||}|j ||tqWdS(N( R|RxR RYR`RftSaveUpdateStateR5R[R1RuRy( R8RR6R`t delete_allRRRntstates_for_prop((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRys    (RRR9R~Ry(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRes  RfcBs#eZdZdZdZRS(cCs"||_||jkstdS(N(R R`R(R8RR ((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR9#s cCs,tj|j|j|jtt|dS(N(Rt delete_objR RxR+RY(R8R((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR~'s c cst|j|jtt}|jj}t||}x;|D]3}t|||}|jj ||f|Vq@Wx=|j |jD]+}|j ||}|j ||tqWdS(N( R|RxR R+RYR`Ret DeleteStateR5R[R1RuRy( R8RR6R`tsave_allRRRnR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRy.s    (RRR9R~Ry(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRf"s  t ProcessStatecBs#eZdZdZdZRS(cCs||_||_||_dS(N(RRR(R8RRRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR9@s  c Cs|j}|j}|j}g|D]9}|j|kr"|j|kr"|j|kr"|^q"}|j||jgg|D]}|j^q~}|r|j||n|j||dS(N(RRRtdifference_updateRRR( R8RRtcls_RRtrtour_recsR6((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyREs     &cCs,d|jj|jtj|j|jfS(Ns%s(%s, %s, delete=%s)(RRRRWt state_strRR(R8((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRTs  (RRR9RR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR?s  RcBs#eZdZdZdZRS(cCs||_||_dS(N(RR (R8RRR ((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR9^s cCs|j}|j}g|D]*}|j|kr|j|kr|^q}|j|tj||jgg|D]}|j^qo|dS(N(RR RRRR(R8RRRR RR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRbs      cCs d|jjtj|jfS(Ns%s(%s)(RRRWRR(R8((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRns (RRR9RR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR]s  RcBs#eZdZdZdZRS(cCs||_||_dS(N(RR (R8RRR ((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR9vs c Cs|j}|j}g|D]*}|j|kr|j|kr|^q}|j||jgg|D]}|j^qf}tj|g|D]}|j|dr|^q|dS(Ni(RR RRRRR6( R8RRRR RRR6Rt((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRzs    & 'cCs d|jjtj|jfS(Ns%s(%s)(RRRWRR(R8((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRs (RRR9RR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRus  N(t__doc__tRRRRRRWR-RR.RRRRRRReRfRRR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyts  V )%