H`Tc@sdZddlmZmZmZddlmZmZmZmZmZ ddl m Z m Z m Z defdYZdefd YZd efd YZd efd YZdefdYZiee 6ee 6ee 6ZdS(sRelationship dependencies. i(tsqltutiltexci(t attributesRtsynct unitofworkR(t ONETOMANYt MANYTOONEt MANYTOMANYtDependencyProcessorcBseZdZedZdZdZdZdZdZ dZ dZ d Z d Z d Zd Zd ZdZdZdZRS(cCs||_|j|_|j|_|j|_|j|_|j|_|j|_|j|_|j|_|j |_ |jrt j |_ n t j |_ |jrt j |_n t j |_|j|_|jjstjd|jndS(Ns|Can't build a DependencyProcessor for relationship %s. No target attributes to populate between parent and child are present(tproptcascadetmappertparentt secondaryt directiont post_updatetpassive_deletestpassive_updatestenable_typechecksRtPASSIVE_NO_INITIALIZEt_passive_delete_flagt PASSIVE_OFFt_passive_update_flagtkeytsynchronize_pairstsa_exct ArgumentError(tselfR ((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyt__init__s*                cCst|j|S(N(t_direction_to_processorR(tclsR ((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pytfrom_relationship/scCs|jjj|jj|S(sreturn True if the given object instance has a parent, according to the ``InstrumentedAttribute`` handled by this ``DependencyProcessor``. (R t class_managertget_implRt hasparent(Rtstate((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyR#3scCs|j|tdS(sestablish actions and dependencies related to a flush. These actions will operate on all relevant states in the aggregate. N(tregister_preprocessortTrue(Rtuow((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pytper_property_preprocessors;scCstj||tt}tj||tt}tj||jj}tj||jj}tj||jj}tj||jj}|j |||||||dS(N( Rt ProcessAlltFalseR&t SaveUpdateAllR tprimary_base_mapperR t DeleteAlltper_property_dependencies(RR't after_savet before_deletet parent_savest child_savestparent_deletest child_deletes((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pytper_property_flush_actionsDs* c Cs|jj}|jj}tj||}tj||}|rftj||tt}t|_n!tj||t t} t| _||j kr||j kst |t f|tfg} t } nt} |stj||jj } d} }| |j krOt}qOn:tj||jj } d} } | |j krOt}nx|D]}|j|jjj||j|r|jntj}|sqVn|rtj||t|}|rtj|||} qn6tj||t |} |rtj|||} n| rg} x|D]\}}||jkrKd}nR|j|\}}|rtj|||tf}ntj|||t f}| j|q'Wnx6| D].\}}|j|| | || |||qWqVWdS(sestablish actions and dependencies related to a flush. These actions will operate on all relevant states individually. This occurs only if there are cycles in the 'aggregated' version of events. N(NN(R R,R RR+R-R)R&tdisabledR*tcyclestAssertionErrort base_mappertNonetmanagerRtimpltget_all_pendingtdictRRRt ProcessStatet DeleteStatetSaveUpdateStatetstatestappendtper_state_dependencies(RR'RBtisdeletetparent_base_mappertchild_base_mapperR2R4R0R/t child_actionstchild_in_cyclesR1R3tparent_in_cyclesR$tsum_t child_statetchildt child_actiontdeletedtlistonlyt childisdelete((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pytper_state_flush_actionscs                  cCstS(N(R*(Rt uowcommitRB((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pytpresort_deletesscCstS(N(R*(RRSRB((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyt presort_savesscCsdS(N((RRSRB((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pytprocess_deletesscCsdS(N((RRSRB((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyt process_savesscCs| s|jrtj}n$|jtkr7tj}n tj}x`|D]5}|j||j|}|rG|j rGt SqGW|o|j j o|j |jkSdS(N(RRRRRtPASSIVE_NO_FETCH_RELATEDRtget_attribute_historyRtemptyR&R t_is_self_referentialR tmappers(RRSRBREtpassivetsthistory((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pytprop_has_changess      cCs|jjr4|dkr4tjd|jfn|dk r|jj|d|j  r|jj|dtrtjdi|j d6|jd6|jj d6|jd6qtjdi|j d6|jd6|jj d6ndS( Ns-Can't flush None value found in collection %stallow_subtypessEAttempting to flush an item of type %(x)s as a member of collection "%(y)s". Expected an object of type %(z)s or a polymorphic subclass of this type. If %(x)s is a subclass of %(z)s, configure mapper "%(zm)s" to load this subtype polymorphically, or set enable_typechecks=False to allow any subtype to be accepted for flush. txtytztzmsAttempting to flush an item of type %(x)s as a member of collection "%(y)s". Expected an object of type %(z)s or a polymorphic subclass of this type.( R tuselistR:Rt FlushErrorR t_canloadRR&tclass_(RR$((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyt_verify_canloads(        cCs tdS(N(tNotImplementedError(RR$RMtassociationrowt clearkeysRS((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyt _synchronize!scCs^|jjsdStt|jgg|jjD]}|j^q,}|jd|ftS(Nt reverse_key(R t_reverse_propertyR:ttupletsortedRtmemotset(RR'tpt process_key((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyt_get_reversed_processed_set%s  ) cCsTxM|D]E}|dk r|j|g|jjD]\}}|^q/PqqWdS(N(R:tissue_post_updateR R(RR$RStrelatedRbtltr((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyt _post_update2s   &cCs tdS(N(Rk(RRSR$((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyt _pks_changed;scCsd|jj|jfS(Ns%s(%s)(t __class__t__name__R (R((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyt__repr__>s(Rt __module__Rt classmethodR R#R(R5RRRTRURVRWR`RjRnRwR|R}R(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyR s"    w      $  t OneToManyDPcBsPeZdZdZdZdZdZdZdZdZ RS(c Cs|jrtj||jjt}tj||jjt} |jj||f||f||f|| f| |f| |fgnO|jj||f||f||f||f||f||f||fgdS(N( RRtIssuePostUpdateR R,R*R&t dependenciestupdate( RR'R1R2R3R4R/R0tchild_post_updatestchild_pre_updates((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyR.Ds0                  c CsH|jrtj||jjt} tj||jjt} |s|rp|jj||f|| fgq|jj||f||f|| fgqD|r|jj|| f| |fgqD|jj|| f| |fgnV|s"|jj||f||f||fgn"|jj||f||fgdS(N( RRRR R,R*R&RR( RR't save_parentt delete_parentRNR/R0RERQRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRDlsB                   c Cs|jj o|jdk }x|D]}|j||j|j}|r$xd|jD]Y}|dk rU|j|t krU|jj r|j |dt q|j |qUqUW|rx?|j D]1}|dk r|j |ddd|jqqWqq$q$WdS(NtallREt operationtdeleteR (R RRRYRRROR:R#R*t delete_orphantregister_objectR&t unchangedR (RRSRBtshould_null_fksR$R_RM((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRTs$   !  c Cs|jd|ft}x|D]}|j||}| sG|jrStj}n tj}|j||j|}|rxB|j D]7}|dk r|j |dt ddd|j qqW|j|j x|jD]}|jjs|j |dtddd|j q|j|tkr|j |dt ddd|j x?|jjd|D]%\} } } } |j | dt q]WqqWn|r|rxH|jD]:}|dk r|j |t|jddd|j qqWqqqWdS( Ntchildren_addedt cancel_deleteRtaddR RERs pk change(RsRtR}RRRRRYRtaddedR:RR&R RROR RR*R#R tcascade_iteratorR( RRSRBRR$t pks_changedR]R_RMtctmtst_tdct_((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRUsR           c Csx|js|jdk rt|jd|ft}x@|D]5}|j||j|j}|r8xy|jD]n}|dk ri|j |t kri|j ||dt |t |jr|r|j |||gqqiqiW|js|jj rmxvt|jj|D]Y}|dk r |j ||dt |t |jrc|rc|j |||gqcq q Wqmq8q8WndS(NRR(RRRsRtRYRRROR:R#R*RnR&R|R RRt difference(RRSRBRR$R_RM((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRVs>         c Cs,x%|D]}|j||jtj}|rx[|jD]P}|j||dt|t|dk r8|jr8|j |||gq8q8WxM|j D]B}|j j r|j | r|j||dt|tqqW|j||r$x0|jD]"}|j||dt|tqWq$qqWdS(N(RYRRRRRnR:R*RR|ROR RR#R&R}R(RRSRBR$R_RM((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRWs(    c Cs|}|}|j||dks>|j rB|j|rBdS|rgtj||j|jjn4tj ||j ||j|jj||j o|dS(N( RjR:Rt is_deletedRtclearR R RtpopulateR R( RR$RMRlRmRSRtsourcetdest((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRn5s   cCstj|||j|jjS(N(Rtsource_modifiedR R R(RRSR$((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyR}Es ( RRR.RDRTRURVRWRnR}(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRBs ( 7  2 .  t ManyToOneDPcBsSeZdZdZdZdZdZdZdZddZ RS( cCs-tj|||jjjt|dS(N(R RR t_dependency_processorsRCtDetectKeySwitch(RR ((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRNsc Cs|jrtj||jjt}tj||jjt} |jj||f||f||f|| f|| f| |fgn4|jj||f||f||f||fgdS(N( RRRR R,R*R&RR( RR'R1R2R3R4R/R0tparent_post_updatestparent_pre_updates((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyR.Rs*               c Cs?|jr|stj||jjt} |rU|jj|| f| |fgq|jj||f||f|| fgq;tj||jjt} |jj|| f| |f| |fgno|s|s|jj||f||fgq;|jj||fgn"|r;|jj||fgndS(N( RRRR R,R*RRR&( RR'RRRNR/R0RERQRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRDvs@                 c Cs|jjs|jjrx|D]}|j||j|j}|r|jjra|j}n |j}x|D]}|dkrqtn|j |dt ddd|j |j j d|}x-|D]%\}} } } |j | dt qWqtWqqWndS(NRERRR (R RRRYRRtsumt non_deletedR:RR&R R R( RRSRBR$R_ttodeleteRMttRRRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRTs(       c Csx|D]}|j|ddd|j|jjr|j||j|j}|rx|jD]}|j|t kr`|j|dt ddd|j|j j d|}x0|D]%\}}} } |j| dt qWq`q`WqqqWdS(NRRR RER( RR R RRYRRROR#R*R&R R( RRSRBR$R_RMRRRRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRUs     c Cs|jr|jj r|jdk rxy|D]n}|j|ddt||r-|jr-|j||j|j }|r|j |||j qq-q-WndS(NR( RR RRRnR:R&RYRRR|R(RRSRBR$R_((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRVs    c Csx|D]}|j||jtj}|r|jrjx0|jD]"}|j||dt|dqAWn|jr|j |||j qqqWdS(NR( RYRRRRRnR:R*RR|R(RRSRBR$R_RM((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRWs    c Cs|dks%|j r)|j|r)dS|dk r~|dk r~|jj| r~tjdtj|||j fdS|s|dkrt j ||j |j j n8|j|t j||j||j |j j |tdS(NsGObject of type %s not in session, %s operation along '%s' won't proceed(R:RRtsessiont_contains_stateRtwarnt mapperutiltstate_class_strR RRR RRjRR R*(RR$RMRlRmRSR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRns$     N( RRRR.RDRTRURVRWR:Rn(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRMs  $ 7    RcBsqeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z RS( sFor many-to-one relationships with no one-to-many backref, searches for parents through the unit of work when a primary key has changed and updates them. Theoretically, this approach could be expanded to support transparent deletion of objects referenced via many-to-one as well, although the current attribute system doesn't do enough bookkeeping for this to be efficient. cCsP|jjr<|jrdStd|jjDkr<dSn|j|tdS(Ncss|]}|jVqdS(N(R(t.0R ((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pys "s(R RpRR*R%(RR'((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyR(s   cCsMtj||jj}tj||tt}|jj||fgdS(N(RR+R R9R)R*RR(RR'R1R/((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyR5(s  cCsdS(N((RR'RBRE((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRR1scCsdS(N((RRSRB((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRT4scCs |js|j||ndS(N(Rt_process_key_switches(RR'RB((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRU7s cCs0| r,|jr,|j||}t|StS(N(Rt_key_switcherstboolR*(RR'RBREtd((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyR`=s cCsts tdS(N(R*R8(RRSRB((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRVDscCs#|jst|j||dS(N(RR8R(RRSRB((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRWGscCs|jd|fd\}}|j|}xL|D]D}||kr7|j||rk|j|q{|j|q7q7W|S(Nt pk_switcherscSsttfS(N(Rt(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pytRs(RstunionR}R(RR'RBtswitchedt notswitchedt allstatesR^((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyROs   c Cs|j||}|r x|jjjD]}t|j|jjsOq+n|j}|j|j j ||d|j }|t j k r+|dk r+t j||j }||kr|j|t|jtj||j||j|jj||jqq+q+WndS(NR](RRt identity_mapt all_statest issubclassRiR R>R"RtgetRRtPASSIVE_NO_RESULTR:tinstance_stateRR*RRRR R R(RtdeplistRSt switchersR$tdict_Ryt related_state((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyR^s(      cCs.t|jo-tj|||j|jjS(N(RRRRR R R(RRSR$((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyR}vs(RRt__doc__R(R5RRRTRUR`RVRWRRR}(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRs         t ManyToManyDPcBsYeZdZdZdZdZdZdZdZdZ dZ RS( c CsS|jj||f||f||f||f||f||f||fgdS(N(RR(RR'R1R2R3R4R/R0((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyR.}s       c Cs||sV|r1|jj||f||fgqx|jj||f||fgn"|jj||f||fgdS(N(RR( RR'RRRNR/R0RERQ((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRDs      cCs:|js6x*|D]}|j||j|jqWndS(N(RRYRR(RRSRBR$((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRTs   c Cs#|jsMxA|D]6}|j||r|j||jtj}qqWn|jjs]dSx|D]}|j||jtj}|rdx|j D]}|j |t kr|j |dt ddd|jx?|jjd|D]%\}}}} |j |dt qWqqWqdqdWdS(NRERRR (RR}RYRRRR RRROR#R*RR&R R R( RRSRBR$R_RMRRRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRUs2       c s6g}g}g}|j|}t}x|D]|j|j|j}|r1x{|jD]m} | dkse|dk r| f|krqeni} |j| | t|dsqen|j | qeW|j fd|jDq1q1W|dk r|j |n|j ||||dS(NRc3s|]}|fVqdS(N((RR(R$(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pys s( RwRtRYRRt non_addedR:RnR*RCRt _run_crud( RRSRBtsecondary_deletetsecondary_inserttsecondary_updatet processedttmpR_RMRl((R$s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRVs:     *  c sBg}g}g}|j|}t}x|D]|j oP|j|}|retj} n tj} |j|j| } | r1xl| j D]a} |dk r| f|krqni} |j | | t |dsqn|j | qWxl| jD]a} |dk r/| f|kr/qni} |j | | t |dsYqn|j | qW|jfd| j | jD|rxk| jD]]} i} tj|j| d|jjtj| |j| d|jj|j | qWqq1q1W|dk r(|j|n|j||||dS(NRRc3s|]}|fVqdS(N((RR(R$(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pys *stold_(RwRtRR}RRRRYRRR:RnR*RCRORRRR R RR tsecondary_synchronize_pairsR( RRSRBRRRRRtneed_cascade_pksR]R_RMRl((R$s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRWsp                c Cs|jj|j}|r|d}|jjtjg|jjD]6}|j|krA|tj |jd|j k^qA}|j ||} | j r| j t|krtjd|jjt|| j fqn|r|d}|jjtjg|jjD]:}|j|kr|tj d|jd|j k^q}|j ||} | j r| j t|krtjd|jjt|| j fqn|r|jj}|j ||ndS(Nittype_sRDELETE statement on table '%s' expected to delete %d row(s); Only %d were matched.RsRUPDATE statement on table '%s' expected to update %d row(s); Only %d were matched.(t transactiont connectionR RRRtand_RRt bindparamttypetexecutetsupports_sane_multi_rowcounttrowcounttlenRtStaleDataErrort descriptionRtinsert( RRSRRRRRlRt statementtresult((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRDs< <  @ cCs|j||dkrtS|dk rr|jj| rr|jsntjdtj |||j fntSt j ||j ||j jt j ||j||j jtS(NsGObject of type %s not in session, %s operation along '%s' won't proceed(RjR:R*RRRORRRRR Rt populate_dictR RR RR&(RR$RMRlRmRSR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyRnps      cCstj|||j|jjS(N(RRR R R(RRSR$((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyR}s ( RRR.RDRTRURVRWRRnR}(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyR{s   " % C , N(RtRRRRRRRRt interfacesRRRtobjectR RRRRR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dependency.pyt s(1 j