H`Tc@s:dZddlmZmZddlmZmZmZddlmZ m Z ddlmZddlm Z m Z mZ mZmZmZddlmZdd lmZdd lmZdd l mZmZdd lmZd dlZeeeeeeedZejjdededefdYZej ejjde!dedefdYZ"ej ejjde!de!defdYZ#de$fdYZ%defdYZ&ej ej'jddej'jdede&fdYZ(ej ej'jde!ej'jdd d!e&fd"YZ)d#e$fd$YZ*ej'jdd%d&e&fd'YZ+ej ej'jdd(d)e&fd*YZ,ej ej'jdd+ej'jded,e&fd-YZ-d.Z.dS(/sWsqlalchemy.orm.interfaces.LoaderStrategy implementations, and related MapperOptions.i(texctinspect(tutiltlogtevent(Rtvisitors(tsqli(t attributest interfacesRtloadingt unitofworkR(t InstanceState(t _none_set(t properties(tLoaderStrategytStrategizedProperty(t_state_sessioniNc ! s|j} ttj| jdg} g} |rL| jrL| jtn| j| j j kr| j j | j\| jfdn|r| jt j n| j ddr| jfdnx|jD]}| |jj| jkrtj|j| jd| dd|d|d | d |o_| jp_| jtjkd |d |d |d| d| p| j d| j|  }x| D]}||| qWqqWdS(Ntdefaultcstj||jS(N(torm_utilt_validator_eventstkey(tdesctprop(toptstfn(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyt5stbackrefcstj|S(N(Rtbackref_listeners(RR(tuselistR(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRBst parent_tokenRtcompare_functiont useobjectt extensiont trackparentt typecallablet callable_tactive_historyt impl_classtsend_modified_eventstdoc(tparent_propertytlistRtto_listR t single_parenttappendtsingle_parent_validatorRtparentt validatorsR ttrack_cascade_eventstpoptNonetself_and_descendantst_propstgetRtregister_attribute_impltclass_t directionRt ONETOMANYtviewonlyR'(tstrategytmapperRRR"RR#tproxy_propertyR$R%tkwRt attribute_extt listen_hookstmRthook((RRRRs_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyt_register_attributesJ     t instrumenttdeferredtUninstrumentedColumnLoadercBs,eZdZdZddZdZRS(sRepresent the a non-instrumented MapperProperty. The polymorphic_on argument of mapper() often results in this, if the argument is against the with_polymorphic selectable. cCs)tt|j||jj|_dS(N(tsuperRFt__init__R(tcolumns(tselfR.((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRHlsc Ks;x4|jD])}|r&|j|}n|j|q WdS(N(RIR,( RJtcontexttentitytpathtloadopttadaptertcolumn_collectiontkwargstc((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyt setup_querypscCsdS(N(NNN(R2(RJRKRMRNR<trowRO((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pytcreate_row_processorxsN(t__name__t __module__t__doc__RHR2RSRU(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRFds  t ColumnLoadercBs2eZdZdZdZdZdZRS(s8Provide loading behavior for a :class:`.ColumnProperty`.cCs>tt|j||jj|_t|jd|_dS(Ntcomposite_class(RGRYRHR(RIthasattrt is_composite(RJR.((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRHsc Ks;x4|jD])}|r&|j|}n|j|q WdS(N(RIR,( RJRKRLRMRNRORPRQRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRSsc Csst|_|jdj}|jjpJ|jdjpJ|jt|jk}t ||dt d|j d|dS(NiRRR$( tTruetis_class_levelRIttypeR(R$t primary_keytversion_id_coltsetRCtFalsetcompare_values(RJR<tcoltypeR$((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pytinit_class_attributes   c s|jxz|jD]S|r/|jndk r|krfd}|ddfSqWfd}|ddfSdS(Ncs||eZdZdZdZdZddZdZRS(sAProvide loading behavior for a deferred :class:`.ColumnProperty`.cCsYtt|j|t|jdr7tdn|jj|_|jj|_dS(NRZs8Deferred loading for composite types not implemented yet(RGRmRHR[R(tNotImplementedErrorRItgroup(RJR.((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRHs c s|jd}|r#|j|}n|j||kr`|jjtj||||||S|jstj|j t }|ddfSfd} | ddfSdS(Nics|j|dS(N(t_reset(RgRhRT(R(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pytreset_col_for_deferreds( RIRR(t_get_strategy_by_clsRYRUR^R t_row_processort class_managertLoadDeferredColumnsR2( RJRKRMRNR<RTRORitset_deferred_for_local_stateRq((Rs_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRUs     c CsBt|_t||dtd|jdjjd|jdtdS(NRRiR#texpire_missing(R]R^RCRcRIR_Rdt_load_for_state(RJR<((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRfs   cKs|r3d|jkr3t|jj|jjsu|r`|jr`|jjdt|jksu|r|j |kr|j j t j ||||||ndS(Nt undefer_pkst undefer_group(t local_optsRbRIt intersectionR.R`RoR5RcRR(RrRYRS(RJRKRLRMRNROtonly_load_propsRQ((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRSs c CsQ|jstjS|tj@s$tjS|jj}|jrg|jD]B}t |t rCt |j t rC|j|jkrC|j^qC}n |jg}g|D]}||j kr|^q}t|}|dkrtjdtj||jfn|j|} tj| |jd|d|dkrJtj|ntjS(NsfParent instance %s is not bound to a Session; deferred load operation of attribute '%s' cannot proceedR}t refresh_state(RRt ATTR_EMPTYtSQL_OKtPASSIVE_NO_RESULTtmanagerR<Rotiterate_propertiest isinstanceRR;Rmt unmodifiedRR2torm_exctDetachedInstanceErrorRt state_strtqueryR t load_on_identtObjectDeletedErrort ATTR_WAS_SET( RJRgtpassivet localparenttpttoloadtkRotsessionR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRxs0     $ (   N( RVRWRXRHRURfR2RSRx(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRms    RucBs&eZdZdZejdZRS(s7serializable loader object used by DeferredColumnLoadercCs ||_dS(N(R(RJR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRH%scCs?|j}|jj}|j|}|jt}|j||S(N(RRR<R4t _strategiesRmRx(RJRgRRRRR;((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyt__call__(s     (RVRWRXRHRt PASSIVE_OFFR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRu"s tAbstractRelationshipLoadercBseZdZdZRS(s0LoaderStratgies which deal with related objects.cCsGtt|j||jj|_|jj|_|jj|_dS(N(RGRRHR(R<ttargetR(RJR.((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRH4s(RVRWRXRH(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyR1stlazytnoloadtNoLoadercBs eZdZdZdZRS(sYProvide loading behavior for a :class:`.RelationshipProperty` with "lazy=None". c Cs8t|_t||dtd|jjd|jjdS(NRRR"(R]R^RCR(Rtcollection_class(RJR<((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRfDs    csfd}|ddfS(Ncs|jjdS(N(t _initializeR(RgRhRT(RJ(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pytinvoke_no_loadQs(R2(RJRKRMRNR<RTROR((RJs_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRUNs(RVRWRXRfRU(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyR;s tselectt LazyLoadercBsweZdZdZdZeed d dZed dZdZ dZ e j ddZ d ZRS( s|Provide loading behavior for a :class:`.RelationshipProperty` with "lazy=True", that is loads when first accessed. cCs:tt|j||jj}|j\|_|_|_|jdt \|_ |_ |_ |j jd||j|j o|jjdj|jdt d|jj|_|jr6x[t|jD]J}||jjkrx/|jj|D]}|j||j|=stuse_mapper_path(t_clonet correlateR2t _from_objR<R"t_set_select_fromRct_adapt_col_listt _set_entitiestdistinct_target_keyR]t _distinctRbRR`t _order_byRt_limitt_offsett with_labelsRRt AliasedClass( RJRRRRt orig_entityRt target_colsR2tttembed_qR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyR$s,          cCsog}t|j}x{t|D]m\}\}}|dkrv||ddj}|j|rm|n|} n|} |j| |jfq%Wt|dkrt|dd} nt|dkr|} nM| jj|j rt j |dddt } nt j |j dt } |j j} g| D]"} t| |j j| j^q:}||| fS(NiiiiR+(R)tpairst enumerateR<R"R,RRRR.RR8R]R(R#R$R%(RJRRRR=tiR<Rt prev_mappert to_appendRR t local_colsRRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRRs.      ,cCs2x+t|D]\}\}}|dk} |t|dk} |t|dk} |t|dk} | rt||} | r||jk r| j|} qnB| r||jk rt||j|} nt|j|} | r|j|| dt}q |j| d| dt}q W|S(Niiitfrom_joinpointtaliased(R>RR$R<tof_typeRLtjoinR](RJRRRR RR?R<Rtfirsttmiddletsecond_to_lasttlasttattr((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRs"  cCs=|j|}|j|j}|jr9|j|_n|S(N(RRt _with_optionst_populate_existing(RJRRRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRs  cCsP|jjrL|jd}|jjtj|jj}|j|}n|S(Ni(R(RR.t_target_adaptertcopy_and_processRR*(RJRt eagerjointeager_order_by((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRs   t_SubqCollectionscBs8eZdZdZdZdZdZdZRS(sGiven a :class:`.Query` used to emit the "subquery load", provide a load interface that executes the query at the first moment a value is needed. cCs ||_dS(N(tsubq(RJRS((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRHscCs/|jdkr|jn|jj||S(N(t_dataR2t_loadR5(RJRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyR5s cCs/tdtj|jdD|_dS(Ncss8|].\}}|g|D]}|d^qfVqdS(iN((R*Rtvtvv((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pys scSs|dS(Ni((tx((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRs(Rt itertoolstgroupbyRSRT(RJ((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRUs cCs |jdkr|jndS(N(RTR2RU(RJRgRhRT((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRsN( RVRWRXR2RTRHR5RUR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRRs    c Cs |jj|jjjs/tjd|n||j}|j|j d}|dkradS|jj }|j|j d} | dkr|j |} |j |j d| n|rg|D]} |j| ^q}n|jr|j| |S|j| |SdS(NsJ'%s' does not support object population - eager loading cannot be applied.Rt collections(NNN(R.RtRtimpltsupports_populationtsa_exctInvalidRequestErrorR(R5RR2R#RRRbRIRt_create_collection_loadert_create_scalar_loader( RJRKRMRNR<RTRORSRBR[RR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRUs$     # cs(fd}|ddjfS(NcsRjtgD]}||^qd}|jjj|||dS(N((R5ttupleRRtset_committed_value(RgRhRTRit collection(RJR[RB(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pytload_collection_from_subqs   (R2R(RJR[RBRe((RJR[RBs_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyR`scs(fd}|ddjfS(NcsjtgD]}||^qd}t|dkrUtjdn|d}|jjj|||dS(NisLMultiple rows returned with uselist=False for eagerly-loaded attribute '%s' i(N( R5RbR2RRRRRRc(RgRhRTRiRdtscalar(RJR[RB(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pytload_scalar_from_subqs    (R2R(RJR[RBRg((RJR[RBs_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRasN(RVRWRHRfR2RSR RRRRRtobjectRRRUR`Ra(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRs   J  . 6 "  " tjoinedt JoinedLoadercBszeZdZdZdZd d edZdZdZ dZ dZ dZ d Z d Zd ZRS( scProvide loading behavior for a :class:`.RelationshipProperty` using joined eager loading. cCs)tt|j||jj|_dS(N(RGRjRHR(R(RJR.((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRH+scCs|jjtj|dS(N(R(RrRRf(RJR<((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRf/s c  Ks|jjsdS||j}d} |r;|j||nt} | tk rt|j||||| \} }} n|j|jds|j r|j d|j krdSq|j |j rdSn|j ||||||||\} }} }|j|jdd}|dk r(|j} nd} ||j }xH|j jd| D]1}|j|||| d|j d| d|qQW|dk rdt|jkrtjd ndS( s@Add a left outer join to the statement that's being constructed.NRiRtmappersRRPtchained_from_outerjoinsDetected unaliased columns when generating joined load. Make sure to use aliased=True or flat=True when using joined loading with with_polymorphic().(RRR(R2t_init_user_defined_eager_procRct$_setup_query_on_user_defined_adapterR RRR R R<t_generate_row_adapterR5twith_polymorphic_mapperst_iterate_polymorphic_propertiestsetupRbtsecondary_columnsR^R_(RJRKRLRMRNRORPRRlRQtwith_polymorphictuser_defined_adaptertclausestadd_to_collectionRtvalue((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRS3sP             c Cs2d|jkrtS|jj}|j|jdt}|tk rG|S|jd}|d\}}|dk rt|tr|j j |}nt j |d|j j}nf|j|jdr|j|jd}tj|jd|j j}n|jjj|j d}|j|jd||S(Nteager_from_aliast user_defined_eager_row_processoriRR(R{RcRMR.R5RR2RtstrRRRt ColumnAdapterR<RR Rt ORMAdapterRLRt_polymorphic_adaptersRb( RJRNRKRMRORt root_mapperRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRmys<        cCs|j|j|}|rI|rI|j|}|j|jd|n%|rn|}|j|jd|n|j}|||fS(NRz(t_get_entity_clausesRtwrapRbRtprimary_columns(RJRKRLRMRORuRw((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRns      c  Cs>|j|jdd} | r*| j} ntj|jdtdt} tj| d|jj dt} | j dk s~t |j j tjkrt|_n|dk r|jjd|j jn |j j} | st}n|jj|j|||||| | |f |j} |j|jd| | || |fS(NRtflatR+Rtadapt_requiredt innerjointeager_row_processor(R5RR2RLRR8R<R]R}Rt aliased_classtAssertionErrorR(R8RRtmulti_row_eager_loadersR{Rtcreate_eager_joinsR,t_create_eager_joinRsRb(RJRKRLRMRNRORPRRlRtto_adaptRvRRw((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRos8       '      c  Cs|dkr|j} n|} |jo0|jj} d} ||jkr| r|jrtj|j|j \} } | dk r| | } }qn| dkr||j } }n|jj | |}|r2t |ddrt |j |j |j}q;t tj|j|j dt|j |j}n |j}|j dk sPt|ont|tjon|j}|r|r|dkrtj|j|j |dt}tj|j||jdt}|j|_n.|rt}ntj||j |d| }||j| <|j |_|jjdkr| rx^tj |jj!D]D}| j"j#j$|rP|r|j%|}n|j&j'|qPqPWn|jj(r|j)|jj*t+j,|jj(7_)ndS(NRR+tnestedtisouter(-R2R<RRt_should_nest_selectablet eager_joinst from_clauseRtfind_join_sourcet selectablet setdefaultR$RRR(RR8R.R]RRRtJoinRRFtrightRctlefttonclauseRNtstop_onRt _find_columnst primaryjoint mapped_tableRRtcontains_columnRIRR,RRQRORR*(RJRKRLRMRORRvRRlRtshould_nest_selectablet entity_keytindextclausetdefault_towrapttowrapRt join_to_outertinnerRPRi((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRs                    cCs|r|j||nt}|tk rl|}|jrT|rT|j|j}q|jr|j}qn%|j|jd}|dkrtSy|jj|||SWnt k rtSXdS(NR( RmRcRORR5RR2R<tidentity_key_from_rowtKeyError(RJRKRTRORMRNRut decorator((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyt_create_eager_adapterds    c Cs|jj|jjjs/tjd|n||j}|j|||||}|t k r|j} t j |j |||j |} |j s|j|| | S|j|| | Sn(|jjtj||||||SdS(NsJ'%s' does not support object population - eager loading cannot be applied.(R.RtRR\R]R^R_R(RRcR tinstance_processorR<RRaR`RrRRU( RJRKRMRNR<RTROtour_patht eager_adapterRt _instance((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyRU~s,        csIfd}fd}fd}||d|fS(NcsKtj||}tj|d}|j|f<||dS(Ntappend_without_event(Rtinit_state_collectionRtUniqueAppender(RgRhRTRdt result_list(RKRR(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyt#load_collection_from_joined_new_rows   csv|fjkr+j|f}n:tj||}tj|d}|j|f<||dS(NR(RRRR(RgRhRTRRd(RRRK(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyt(load_collection_from_joined_existing_rows cs|ddS(N(R2(RgRhRT(R(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyt load_collection_from_joined_execs(R2(RJRKRRRRR((RKRRs_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/strategies.pyR`s csFfd}fd}fd}||d|fS(Ncs|d| sd.  ?1o 4q