ó H`¾Tc@sdZddlmZddlmZmZmZmZm Z ddlm Z m Z m Z ddlmZddlmZddlZd Zd „ZegZd efd „ƒYZeƒe_Zee_d efd„ƒYZdefd„ƒYZd„Zd„Zd„ZdS(sžExtensible class instrumentation. The :mod:`sqlalchemy.ext.instrumentation` package provides for alternate systems of class instrumentation within the ORM. Class instrumentation refers to how the ORM places attributes on the class which maintain data and track changes to that data, as well as event hooks installed on the class. .. note:: The extension package is provided for the benefit of integration with other object management packages, which already perform their own instrumentation. It is not intended for general use. For examples of how the instrumentation extension is used, see the example :ref:`examples_instrumentation`. .. versionchanged:: 0.8 The :mod:`sqlalchemy.orm.instrumentation` was split out so that all functionality having to do with non-standard instrumentation was moved out to :mod:`sqlalchemy.ext.instrumentation`. When imported, the module installs itself within :mod:`sqlalchemy.orm.instrumentation` so that it takes effect, including recognition of ``__sa_instrumentation_manager__`` on mapped classes, as well :data:`.instrumentation_finders` being used to determine class instrumentation resolution. i(tinstrumentation(t ClassManagertInstrumentationFactoryt_default_state_gettert_default_dict_gettert_default_manager_getter(t attributest collectionstbase(tutil(texciÿÿÿÿNt__sa_instrumentation_manager__cCst|tdƒS(s;Find user-specified instrumentation management for a class.N(tgetattrtINSTRUMENTATION_MANAGERtNone(tcls((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyt%find_native_user_instrumentation_hookAstExtendedInstrumentationRegistrycBs€eZdZejƒZejƒZejƒZeZ d„Z d„Z d„Z d„Z d„Zd„Zd„Zd„ZRS( s„Extends :class:`.InstrumentationFactory` with additional bookkeeping, to accommodate multiple types of class managers. cCsMxFtD]:}||ƒ}|dk r|j||ƒ}||fSqWdSdS(N(NN(tinstrumentation_findersRt_extended_class_manager(tselftclass_tfindertfactorytmanager((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyt_locate_extended_factoryas    cCsG|j|ƒj|gƒ}|rCtd|jt|ƒfƒ‚ndS(NsRmultiple instrumentation implementations specified in %s inheritance hierarchy: %r(t!_collect_management_factories_fort differencet TypeErrort__name__tlist(RRRtexisting_factories((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyt_check_conflictsjs  cCs“||ƒ}t|tƒs-t||ƒ}n|tkrV|j rVt|_tƒn|jƒ|j|<|jƒ|j |<|j ƒ|j |<|S(N( t isinstanceRt_ClassInstrumentationAdaptert _extendedtTruet_install_instrumented_lookupstmanager_gettert_manager_finderst state_gettert_state_finderst dict_gettert _dict_finders(RRRR((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRss   cCs¨tj|ƒ}tƒ}x||D]t}|j|ƒ}|dk rS|j|jƒqx0tD]"}||ƒ}|dk rZPqZqZWd}|j|ƒqW|jdƒ|S(scReturn a collection of factories in play or specified for a hierarchy. Traverses the entire inheritance graph of a cls and returns a collection of instrumentation factories for those classes. Factories are extracted from active ClassManagers, if available, otherwise instrumentation_finders is consulted. N( R tclass_hierarchytsettmanager_of_classRtaddRRtdiscard(RRt hierarchyt factoriestmemberRRR((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyR„s        cCsJ||jkr0|j|=|j|=|j|=ntt|ƒj|ƒdS(N(R'R)R+tsuperRt unregister(RR((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyR5Ÿs    cCs)|dkrdS|jj|tƒ|ƒS(N(RR'tgetR(RR((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyR.¦s cCs7|dkrtdƒ‚n|jj|jtƒ|ƒS(NsNone has no persistent state.(RtAttributeErrorR)R6t __class__R(Rtinstance((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pytstate_of«s  cCs7|dkrtdƒ‚n|jj|jtƒ|ƒS(NsNone has no persistent state.(RR7R+R6R8R(RR9((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pytdict_of±s  (Rt __module__t__doc__tweakreftWeakKeyDictionaryR'R)R+tFalseR#RR RRR5R.R:R;(((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRVs        tInstrumentationManagercBs§eZdZd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z d „Z d „Zd „Zd„Zd„Zd„Zd„ZRS(s User-defined class instrumentation extension. :class:`.InstrumentationManager` can be subclassed in order to change how class instrumentation proceeds. This class exists for the purposes of integration with other object management frameworks which would like to entirely modify the instrumentation methodology of the ORM, and is not intended for regular usage. For interception of class instrumentation events, see :class:`.InstrumentationEvents`. The API for this class should be considered as semi-stable, and may change slightly with new releases. .. versionchanged:: 0.8 :class:`.InstrumentationManager` was moved from :mod:`sqlalchemy.orm.instrumentation` to :mod:`sqlalchemy.ext.instrumentation`. cCsdS(N((RR((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyt__init__×scCst|d|ƒdS(Nt_default_class_manager(tsetattr(RRR((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pytmanageÚscCst|dƒdS(NRC(tdelattr(RRR((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pytdisposeÝscCs d„}|S(NcSs|jS(N(RC(R((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyR6ás((RRR6((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyR&às cCsdS(N((RRtkeytinst((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pytinstrument_attributeåscCsdS(N((RRRHRI((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pytpost_configure_attributeèscCst|||ƒdS(N(RD(RRRHRI((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pytinstall_descriptorëscCst||ƒdS(N(RF(RRRH((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pytuninstall_descriptorîscCst|||ƒdS(N(RD(RRRHtimplementation((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pytinstall_memberñscCst||ƒdS(N(RF(RRRH((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pytuninstall_memberôscCs tj|ƒS(N(Rtprepare_instrumentation(RRRHtcollection_class((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pytinstrument_collection_class÷scCs|jS(N(t__dict__(RRR9((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pytget_instance_dictúscCsdS(N((RRR9((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pytinitialize_instance_dictýscCst|d|ƒdS(Nt_default_state(RD(RRR9tstate((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyt install_statescCst|dƒdS(NRW(RF(RRR9((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyt remove_statescCsd„S(NcSs t|dƒS(NRW(R (R9((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyts((RR((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyR(scs‡‡fd†S(Ncsˆjˆ|ƒS(N(RU(RI(RR(sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyR[ s((RR((RRsd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyR* s(RR<R=RBRERGR&RJRKRLRMRORPRSRURVRYRZR(R*(((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRA½s$                R"cBsÂeZdZd„Zd„Zd„Zd„Zed„Zd„Z d„Z d„Z d „Z d „Z d „Zd „Zdd „Zd„Zdd„Zd„Zd„Zd„Zd„ZRS(s?Adapts a user-defined InstrumentationManager to a ClassManager.cCsG||_|jj|ƒ|_|jj|ƒ|_tj||ƒdS(N(t_adaptedR(t _get_stateR*t _get_dictRRB(RRtoverride((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRBs cCs|jj|j|ƒdS(N(R\RER(R((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyREscCs|jj|jƒdS(N(R\RGR(R((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRGscCs|jj|jƒS(N(R\R&R(R((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyR&scCs<tj||||ƒ|s8|jj|j||ƒndS(N(RRJR\R(RRHRIt propagated((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRJ scCs7tt|ƒj|ƒ|jj|j|||ƒdS(N(R4R"RKR\R(RRH((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRK%scCs|jj|j||ƒdS(N(R\RLR(RRHRI((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRL)scCs|jj|j|ƒdS(N(R\RMR(RRH((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRM,scCs|jj|j||ƒdS(N(R\ROR(RRHRN((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRO/scCs|jj|j|ƒdS(N(R\RPR(RRH((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRP2scCs|jj|j||ƒS(N(R\RSR(RRHRR((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRS5s cCsEt|jddƒ}|r+||||ƒStj||||ƒSdS(Ntinitialize_collection(R R\RRRa(RRHRXRtdelegate((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRa9s  cCs)|jj|jƒ}|j||ƒ|S(N(Rt__new__tsetup_instance(RRXR9((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyt new_instanceAscCs$|j|ƒrtS|j|ƒSdS(s‚Install a default InstanceState if none is present. A private convenience method used by the __init__ decorator. N(t has_stateR@Rd(RR9((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyt_new_state_if_noneFscCsT|jj|j|ƒ|dkr7|j||ƒ}n|jj|j||ƒ|S(N(R\RVRRt_state_constructorRY(RR9RX((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRdPs  cCs|jj|j|ƒdS(N(R\RZR(RR9((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pytteardown_instanceZscCs1y|j|ƒWntjk r(tSXtSdS(N(R]torm_exctNO_STATER@R$(RR9((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRf]s cCs|jS(N(R](R((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyR(escCs|jS(N(R^(R((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyR*hsN(RR<R=RBRERGR&R@RJRKRLRMRORPRSRaRReRgRdRiRfR(R*(((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyR" s(                cCs,ttdtjdtjdtjƒƒdS(sºReplace global class/object management functions with ExtendedInstrumentationRegistry implementations, which allow multiple types of class managers to be present, at the cost of performance. This function is called only by ExtendedInstrumentationRegistry and unit tests specific to this behavior. The _reinstall_default_lookups() function can be called after this one to re-establish the default functions. tinstance_statet instance_dictR.N(t_install_lookupstdictt_instrumentation_factoryR:R;R.(((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyR%ls   cCs#ttdtdtdtƒƒdS(sRestore simplified lookups.RlRmR.N(RnRoRRR(((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyt_reinstall_default_lookups‚s cCsg|da|da|datt_t_t_tt_t_t_tt_t_t_dS(NRlRmR.(RlRmR.torm_baseRtorm_instrumentation(tlookups((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyRns    (R=tormRRstorm.instrumentationRRRRRRRRRrtR R RjR>R RRRRptobjectRAR"R%RqRn(((sd/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/ext/instrumentation.pyts"(   c P_