ó
‹EYc@sîdZd
dl
mZmZmZmZ
ddl
mZ
d
dl
mZ
ejƒZ	de
f
d„ƒYZdef
d	„ƒYZ
d
ef
d„ƒYZeƒZejZZejZZejZZd„Zd
„Zd„Zd„ZdS(sœDefines SQLAlchemy's system of class instrumentation.

This module is usually not directly visible to user applications, but
defines a large part of the ORM's interactivity.

instrumentation.py deals with registration of end-user classes
for state tracking.   It interacts closely with state.py
and attributes.py which establish per-instance and per-class-attribute
instrumentation, respectively.

The class instrumentation system can be customized on a per-class
or global basis using the :mod:`sqlalchemy.ext.instrumentation`
module, which provides the means to build and specify
alternate instrumentation forms.

.. versionchanged: 0.8
   The instrumentation extension system was moved out of the
   ORM and into the external :mod:`sqlalchemy.ext.instrumentation`
   package.  When that package is imported, it installs
   itself within sqlalchemy.orm so that its more comprehensive
   resolution mechanics take effect.

i
(texctcollectionst
interfaceststatei(
tutil(
tbasetClassManagercBs*eZ
dZejZejZee	j
eƒ
ƒ
Zd+Z
ejZd+Zd
„Zd„Zd„Zed„ƒ
Zed„ƒ
Zed„ƒ
Zed„ƒ
Ze	jd„ƒ
Zd+d	„
Zd
„Zd„Zd„Zd
„Z e	jd„ƒ
Z!d„Z"d„Z#e	j$d„ƒ
Z%e	j$d„ƒ
Z&e	j$d„ƒ
Z'e(d„
Z)d„Z*d„Z+e(d„
Z,d„Z-d„Z.d„Z/d„Z0d„Z1d„Z2d„Z3e(d„
Z4d „Z5ed!„ƒ
Z6d+d"„
Z7d+d#„
Z8d$„Z9d%„Z:d&„Z;d'„Z<e(d(„
Z=d)„Z>e>Z?d*„Z@RS(,s,tracks state information at the class level.cCs7
|
|_i|_
d|_i|_i|_gg|jjD]!}t|tƒr=t	|ƒ
^q=D]}|dk	rb|^qb|_
x|j
D]}|j|ƒ

qW|jj
j|
|ƒ
x?|
jD]4}t	|ƒ
}|dk	rÄ|jj|jƒ

qÄqÄW|jƒ
|jƒ
d
|
jkr3
tjd|
ƒ

ndS(Nt__del__s¦__del__() method on class %s will cause unreachable cycles and memory leaks, as SQLAlchemy instrumentation often creates reference cycles.  Please remove this method.(tclass_tinfotNonetnew_inittlocal_attrst	originalst	__bases__t
isinstancettypetmanager_of_classt_basestupdatetdispatcht_eventst_new_classmanager_instancet__mro__t_updatetmanaget_instrument_initt__dict__Rtwarn(tselfRRtmgrtbasecls((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt__init__7s,
	
	
	
	
	


%









	c

Cs
t|ƒ
S(
N(
tid(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt__hash__Xs
cCs
|
|kS(
N((Rtother((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt__eq__[s
c

Cs
d
|jkS(Ntmapper(
R(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt	is_mapped^sc

Cs
t|ƒ
S(
N(
t	frozenset(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt_all_key_setbsc
Cs2tg|j
ƒD]}
|
jjr|
j^qƒ
S(
N(R'tvaluestimplt
collectiontkey(Rtattr((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt_collection_impl_keysfs
c
Cs2tg|j
ƒD]}
|
jjr|
j^qƒ
S(
N(R'R)R*taccepts_scalar_loader(RR-((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt_scalar_loader_implsks

c

Cstj
|jƒ
‚
dS(
N(RtUnmappedClassErrorR(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR%qsccs|
d
krt
ƒ}
nxq|jjD]c}xZt
|jƒ
j|
ƒ
D]@}|
j|ƒ

|j|}t|tj	ƒrD||fV
qDqDWq%Wd
S(s
return an iterator of all classbound attributes that are
        implement :class:`.InspectionAttr`.

        This includes :class:`.QueryableAttribute` as well as extension
        types such as :class:`.hybrid_property` and
        :class:`.AssociationProxy`.

        N(
R
tsetRRRt
differencetaddRRtInspectionAttr(RtexcludetsuperclsR,tval((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt_all_sqla_attributesvs	








cCs|
|ko||
jd
k	S(s\Return True if the given attribute is fully initialized.

        i.e. has an impl.
        N(R*R
(RR,((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt_attr_has_implˆscCs.t|
ƒ
}|d
kr*tj|
ƒ
}n|S(sÏ
Create a new ClassManager for a subclass of this ClassManager's
        class.

        This is called automatically when attributes are instrumented so that
        the attributes can be propagated to subclasses against their own
        class-local manager, without the need for mappers etc. to have already
        pre-configured managers for the full class hierarchy.   Mappers
        can post-configure the auto-generated ClassManager when needed.

        N(RR
t_instrumentation_factorytcreate_manager_for_cls(Rtclstmanager((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt_subclass_managers


c

Cs;|jj
|_t|j|ƒ|_|jd
|jƒ
dS(NR (RR t
original_initt_generate_initRtinstall_member(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR s

c

Cs&|jr"|j
d
ƒ

d|_ndS(NR (Rtuninstall_memberR
(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt_uninstrument_initªs
	


c

Cs|jj
||jƒ
tjS(
N(Rt
first_initRRt
InstanceState(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt_state_constructor¯s
c

Cst|j
|j|ƒ
d
S(s0Mark this instance as the manager for its class.N(tsetattrRtMANAGER_ATTR(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR´sc

Cst|j
|jƒ
d
S(s)Dissasociate this manager from its class.N(tdelattrRRI(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pytdispose¹sc


CstS(
N(
t_default_manager_getter(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pytmanager_getter¾sc


CstS(
sÍReturn a (instance) -> InstanceState callable.

        "state getter" callables should raise either KeyError or
        AttributeError if no InstanceState could be found for the
        instance.
        (
t_default_state_getter(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pytstate_getterÂs	c


CstS(
N(
t_default_dict_getter(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pytdict_getterÍscCs|r|
|jkr9dSn||j|
<|j
|
|ƒ
tj|ƒ

|||
<x9|jjƒD](}|j|ƒ
}|j|
|tƒ
q`WdS(
N(	Rtinstall_descriptort_memoized_key_collectiontexpire_instanceRt__subclasses__R?tinstrument_attributetTrue(RR,tinstt
propagatedR=R>((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRVÑs










ccsrxk|jj
ƒD]Z}t|ƒ
}|dk	r||k	r|V
|
rjx|jtƒ
D]}|V
qUWqjqqWdS(
N(RRURR
tsubclass_managersRW(Rt	recursiveR=Rt
m((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRZßs






cCs!tj
j|j|
||
ƒ
dS(
N(R;Rtattribute_instrumentR(RR,((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pytpost_configure_attributeès
	
cCsš|
|krdS|r,|
|jkrCdSn|j|
=|j
|
ƒ

tj|ƒ

||
=x<|jjƒD]+}t|ƒ
}|rg|j|
tƒ
qgqgWdS(
N(	Rtuninstall_descriptorRSRTRRURtuninstrument_attributeRW(RR,RYR=R>((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR`ìs














c
Csa|jƒ
d
|_|_|jjƒ
x3t|ƒ
D]%}
|
|jkr4|j|
ƒ

q4q4Wd
S(s<remove all instrumentation established by this ClassManager.N(	RDR
R%RR	tcleartlistRR`(RR,((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt
unregisterüs




cCsB|
|j|j
fkr+td
|
ƒ
‚
nt|j|
|ƒ
dS(NsW%r: requested attribute name conflicts with instrumentation attribute of the same name.(t
STATE_ATTRRItKeyErrorRHR(RR,RX((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRR
s



cCst|j
|
ƒ
dS(
N(RJR(RR,((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR_
s
cCsd|
|j|j
fkr+td
|
ƒ
‚
n|jj|
t|j|
dƒƒ
t|j|
|ƒ
dS(NsW%r: requested attribute name conflicts with instrumentation attribute of the same name.(	RdRIReR
t
setdefaulttgetattrRR
RH(RR,timplementation((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRB
s




"
cCs;|jj
|
dƒ}|dk	r7t|j|
|ƒ
ndS(
N(R
tpopR
RHR(RR,toriginal((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRC
s


cCs
tj
|ƒ
S(
N(R
tprepare_instrumentation(RR,tcollection_class((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pytinstrument_collection_class
s
cCs1|ƒ}tj
|j|
ƒ
||ƒ}||fS(
N(R
tCollectionAdaptertget_impl(RR,Rtfactoryt	user_datatadapter((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pytinitialize_collection"
s
	


cCs!|r|
|kS|
|jkSdS(
N(
R(RR,tsearch((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pytis_instrumented(
s


cCs||
jS(
N(
R*(RR,((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRo.
s
c

Cst|j
ƒƒ
S(
N(titerR)(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt
attributes1
scCsJ|jj
|jƒ
}|
dkr6|j||ƒ}
n|j||
ƒ
|S(
N(Rt__new__R
RGt
_state_setter(RRtinstance((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pytnew_instance7
s





cCs5|dkr!|j
|
|ƒ}n|j|
|ƒ
dS(
N(R
RGRy(RRzR((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pytsetup_instance>
s


cCst|
|j
ƒ
dS(
N(RJRd(RRz((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pytteardown_instanceC
s
cCs
t|
|ƒS(
N(
t_SerializeManager(RRt
state_dict((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt
_serializeF
s
cCstt|
|j
ƒrtS|j|
jk	rJ|jrJ|j|
jƒ
j|
ƒ
S|j|
|ƒ}|j	|
|ƒ
|Sd
S(sƒInstall a default InstanceState if none is present.

        A private convenience method used by the __init__ decorator.

        N(
thasattrRdtFalseRt	__class__R&R?t_new_state_if_noneRGRy(RRzR((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR„I
s


	


cCst|
|j
ƒS(
N(RRd(RRz((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt	has_state_
s
cCs|j|ƒ
j
|
d
|ƒ

S(tTODOt
optimistic(Rot	hasparent(RRR,R‡((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt
has_parentb
sc


CstS(
s=All ClassManagers are non-zero regardless of attribute state.(
RW(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt__bool__f
sc

Cs d
|jj
|jt|ƒ
fS(Ns<%s of %r at %x>(Rƒt__name__RR!(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt__repr__l
s

N(AR‹t
__module__t__doc__RtDEFAULT_MANAGER_ATTRRItDEFAULT_STATE_ATTRRdtstaticmethodRt
attrsetterRyR
tdeferred_scalar_loadertobjectR R@RpR"R$tpropertyR&RSR(R.R0tmemoized_propertyR%R9R:R?RRDRGRRKthybridmethodRMRORQR‚RVRZR^R`RcRRR_RBRCRmRsRuRoRwR{R|R}R€R„R…R‰RŠt__nonzero__RŒ(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR)sd
	
			!					
																			R~c
Bs eZ
dZd
„Zd„ZRS(s¡Provide serialization of a :class:`.ClassManager`.

    The :class:`.InstanceState` uses ``__init__()`` on serialize
    and ``__call__()`` on deserialize.

    cCs,|
j|_|
j
}|jj|
|ƒ
dS(
N(RR>Rtpickle(RRt
dR>((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR y
s

	
cCsšt|j
ƒ
|
_}|dkr>tj|d
|j
ƒ‚
n&|jrd|jjrd|jj	ƒ
n|dk	rƒ|j
||
ƒ
n|jj|
|ƒ
dS(NsxCannot deserialize object of type %r - no mapper() has been configured for this class within the current Python process!(
RRR>R
RtUnmappedInstanceErrorR&R%t
configuredt_configure_allR|Rtunpickle(RRRXRR>((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt__call__~
s








(R‹RRŽR RŸ(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR~q
s	tInstrumentationFactoryc
Bs2eZ
dZd
„Zd„Zd„Zd„ZRS(s'Factory for new ClassManager instances.cCs|
dk	st
‚
t|
ƒ
dks*t
‚
|j|
ƒ
\}}|dkr`t}||
ƒ
}n|j|
|ƒ
||_|jj|
ƒ

|S(
N(	R
tAssertionErrorRt_locate_extended_factoryRt_check_conflictsRpRtclass_instrument(RRR>Rp((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR<–
s



	
cCsdS(s2Overridden by a subclass to do an extended lookup.N(NN(
R
(RR((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR¢©
sc
Csd
S(s;Overridden by a subclass to test for conflicting factories.N((RRRp((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR£­
scCsYt|
ƒ
}|j
ƒ
|jƒ
|jj|
ƒ

tj|
jkrUt|
tjƒ
ndS(
N(	RRcRKRtclass_uninstrumentRRIRRJ(RRR>((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRc±
s







(R‹RRŽR<R¢R£Rc(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR “
s

			c
Cs.t|ƒ
}
|
d
kr*tj|ƒ
}
n|
S(s_Register class instrumentation.

    Returns the existing or newly created class manager.

    N(RR
R;R<(RR>((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pytregister_classÇ
s


c

Cstj
|ƒ

d
S(s!Unregister class instrumentation.N(R;Rc(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pytunregister_classÔ
scCst|j
ƒ
j|
d
tƒ

S(sïReturn True if the given attribute on the given instance is
    instrumented by the attributes package.

    This function may be used regardless of instrumentation
    applied directly to the class, i.e. no descriptors are required.

    Rt(RRƒRuRW(RzR,((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRuÚ
s
cBsó|j}|st
‚
d
}ej|deƒ

}||}ejrje|d|ƒ}e|ddƒ}n$e|ddƒ}e|ddƒ}eƒj	ƒ}	||	fdU|	d}
|j
|
_
|rÓ||
_nejrï|rï||
_n|
S(	s>Build an __init__ decorator that triggers ClassManager events.sâdef __init__(%(apply_pos)s):
    new_state = class_manager._new_state_if_none(%(self_arg)s)
    if new_state:
        return new_state._initialize_instance(%(apply_kw)s)
    else:
        return original__init__(%(apply_kw)s)
tgroupedtim_funct
func_defaultst__defaults__t__kwdefaults__NR (
R R¡Rtformat_argspec_initR‚tpy2kRgR
tlocalstcopyRŽR«R¬(Rt
class_managertoriginal__init__t	func_bodyt	func_varst	func_texttfuncRªtfunc_kw_defaultstenvR ((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRAæ
s&	



	









N(RŽtRR
RRRRt!group_expirable_memoized_propertyRStdictRR”R~R R;tinstance_stateRNt
instance_dictRPRRLR¦R§RuRA(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt<module>s "

ÿI"(