ó H`¾Tc@sdZddlmZmZmZddlmZddlmZmZmZ m Z m Z mZ m Z ddlmZeje jjddƒd e jfd „ƒYƒƒZd ejfd „ƒYZd efd„ƒYZdeefd„ƒYZd„Zdefd„ƒYZdS(s‚Dynamic collection API. Dynamic collections act like Query() objects for read operations and support basic add/delete mutation. i(tlogtutiltexc(t operatorsi(t attributestobject_sessionRt strategiest object_mapperRt properties(tQuerytlazytdynamict DynaLoadercBseZd„ZRS(cCst|_|js+tjd|jƒ‚ntj||dtdtdtd|jj d|jj d|jj d|jj ƒdS( NstOn relationship %s, 'dynamic' loaders cannot be used with many-to-one/one-to-one relationships and/or uselist=False.t useobjecttuselistt impl_classt target_mappertorder_byt query_classtbackref( tTruetis_class_levelRRtInvalidRequestErrortparent_propertyRt_register_attributetDynamicAttributeImpltmapperRRtback_populates(tselfR((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytinit_class_attributes     (t__name__t __module__R(((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR sRcBseZeZeZeZeZdd„Z e j d„Z de j d„Zejd„ƒZejd„ƒZdd„Zdd„Zd„Ze j ded„Zdd „Zd „Zd „Ze j d „Ze j d „Ze j d„Ze j d„Ze j d„Ze j d„ZRS(c Kswtt|ƒj|||||||_||_|sFt|_n-t|jƒkrd||_nt |ƒ|_dS(N( tsuperRt__init__RRt AppenderQueryRt AppenderMixintmrotmixin_user_query( Rtclass_tkeyt typecallabletdispatchRRRtkw((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR!5s    cCs7|tj@s#|j|tjƒjS|j||ƒSdS(N(RtSQL_OKt_get_collection_historytPASSIVE_NO_INITIALIZEt added_itemsR(Rtstatetdict_tpassive((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytgetCs cCs=|tj@s |j||ƒjS|j||ƒ}|jSdS(N(RR+R,R.tadded_plus_unchanged(RR/R0t user_dataR1thistory((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytget_collectionJs    cCstj|tjƒS(N(RtEventt OP_APPEND(R((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt _append_tokenSscCstj|tjƒS(N(RR7t OP_REMOVE(R((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt _remove_tokenWscCs˜|dkr!|j||ƒ}n|j|ƒx/|jjD]!}||||pV|jƒ}q;W|jr”|dk r”|jtj |ƒ|t ƒndS(N( tNonet_modified_eventt add_addedR)tappendR9t trackparentt sethasparentRtinstance_stateR(RR/R0tvaluet initiatortcollection_historytfn((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytfire_append_event[s  cCs–|dkr!|j||ƒ}n|j|ƒ|jrb|dk rb|jtj|ƒ|tƒnx-|jj D]}||||pŠ|j ƒqoWdS(N( R<R=t add_removedR@RARRBtFalseR)tremoveR;(RR/R0RCRDRERF((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytfire_remove_evenths  cCs_|j|jkr.t||ƒ|j|jòscCsW|j}|dkr@t|jjtj|jƒtjƒj ƒSt|j |ƒƒSdS(N( R…R<titerRzR,RRBRyR-R.t_clone(RR„((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt__iter__ôs    cCsZ|j}|dkr@|jjtj|jƒtjƒj|ƒS|j |ƒj |ƒSdS(N( R…R<RzR,RRBRyR-tindexedR‰t __getitem__(RtindexR„((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRŒýs    cCsW|j}|dkr@t|jjtj|jƒtjƒj ƒS|j |ƒj ƒSdS(N( R…R<tlenRzR,RRBRyR-R.R‰tcount(RR„((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRs    cCs³|j}|dkr[t|ƒ}|dkr[tjdtj|ƒ|jjfƒ‚q[n|j r‚|j |jj d|ƒ}n|j |jj ƒ}|j |_ |j |_ |S(NsŒParent instance %s is not bound to a Session, and no contextual session is established; lazy load operation of attribute '%s' cannot proceedR…(RyR<Rtorm_exctDetachedInstanceErrorRƒt instance_strRzR'RRtqueryR~R(RR„RyR“((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR‰s    %   cCsFx?|D]7}|jjtj|jƒtj|jƒ|dƒqWdS(N(RzR?RRBRyt instance_dictR<(Rtiteratortitem((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pytextend's  cCs5|jjtj|jƒtj|jƒ|dƒdS(N(RzR?RRBRyR”R<(RR–((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR?-s cCs5|jjtj|jƒtj|jƒ|dƒdS(N(RzRJRRBRyR”R<(RR–((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRJ2s N(RRR<RR!R…tpropertyRŠRŒRR‰R—R?RJ(((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR#Ös     R"cBseZdZRS(sBA dynamic query that supports basic collection storage operations.(RRt__doc__(((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR"8scCs*d|j}t|t|fi|d6ƒS(sAReturn a new class with AppenderQuery functionality layered over.tAppenderR(RttypeR#(tclstname((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR%<s RMcBs\eZdZdd„Zed„ƒZed„ƒZd„Zd„Z d„Z d„Z RS( sDOverrides AttributeHistory to receive append/remove events directly.cCsŽ|rTt||ƒjtƒ}tj|ƒ|_|j|_|j|_t|_ n6tjƒ|_tjƒ|_tjƒ|_t|_ dS(N( R"RRIRtOrderedIdentitySettunchanged_itemsR.t deleted_itemsRt_reconcile_collection(RRzR/Rntcoll((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR!Es   cCst|jj|jƒƒS(N(RTR.RWRŸ(R((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR3RscCs%t|jj|jƒj|jƒƒS(N(RTR.RWRŸR (R((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRkVs cCsŠ|jrH|jj|jƒ}|jj|jƒ}|jj|ƒ}n|j|j|j}}}tjt|ƒt|ƒt|ƒƒS(N( R¡R.RYRŸR RXRtHistoryRT(Rtaddedtdeletedt unchanged((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRh[s   cCst|jƒ|S(N(RTR.(RR((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR‹jscCs|jj|ƒdS(N(R.tadd(RRC((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR>mscCs6||jkr"|jj|ƒn|jj|ƒdS(N(R.RJR R§(RRC((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRHpsN( RRR™R<R!R˜R3RkRhR‹R>RH(((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRMBs    N(R™tRRRtsqlRRRRƒRRRRR“R t class_loggertRelationshipPropertyt strategy_fortAbstractRelationshipLoaderR t AttributeImplRtobjectR#R"R%RM(((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt s4§b