/
opt
/
alt
/
python27
/
lib64
/
python2.7
/
site-packages
/
sqlalchemy
/
orm
/
up file
home
� 1��fc @ s@ d Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z e j d � Z d e e f d � � YZ d e f d � � YZ d e f d � � YZ e � Z e j Z Z e j Z Z e j Z Z e e e e e e d � Z d � Z d � Z d � Z d S( 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����Ni ( t base( t collections( t exc( t interfaces( t statei ( t util( t HasMemoizedt DEL_ATTRt ClassManagerc B s� e Z d Z e j Z e j Z e e j e � � Z d2 Z d2 Z d2 Z d2 Z d2 Z d2 Z e e j d d d �d � � � Z e j e j d d d �d � � � Z d � Z e d2 d2 d2 d2 d2 d � Z d � Z d � Z d � Z e d � � Z e j d � � Z e j d � � Z! e j d � � Z" e j d � � Z# e j$ d � � Z d2 d � Z% d2 d � Z& d � Z' d � Z( d � Z) e j$ d � � Z* d � Z+ e j, d � � Z- e j, d � � Z. e j, d � � Z/ e d � Z0 d � Z1 d � Z2 e d � Z3 d � Z4 d � Z5 d! � Z6 d" � Z7 d# � Z8 d$ � Z9 d% � Z: e d& � Z; d' � Z< e d( � � Z= d2 d) � Z> d2 d* � Z? d+ � Z@ d, � ZA d- � ZB d. � ZC e d/ � ZD d0 � ZE eE ZF d1 � ZG RS(3 s, Tracks state information at the class level.s 1.4t messagesW The ClassManager.deferred_scalar_loader attribute is now named expired_attribute_loaderc C s | j S( N( t expired_attribute_loader( t self( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt deferred_scalar_loaderA s c C s | | _ d S( N( R ( R t obj( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR J s c C s6 | | _ i | _ d | _ i | _ i | _ t | _ g g | j j D]! } t | t � rF t | � ^ qF D] } | d k rk | ^ qk | _ x | j D] } | j | � q� W| j j j | | � x? | j D]4 } t | � } | d k r� | j j | j � q� q� W| j � d | j k r2t j d | � n d S( 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.( t class_t infot Nonet new_initt local_attrst originalst Falset _finalizedt __bases__t isinstancet typet manager_of_classt _basest updatet dispatcht _eventst _new_classmanager_instancet __mro__t _updatet managet __dict__R t warn( R R R t mgrt base_t basecls( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt __init__S s. % c C s� | r | | _ n | r( | j | � n | rC t j | � | _ n | rU | | _ n | r� | j su t d | � � | | _ n | j s� | j d k r� | j j t j k r� | j n | j j | _ n | r� | j r� | j � n d S( Ns> class is already instrumented, init_method %s can't be applied( t mappert _add_managert weakreft reft declarative_scanR R t AssertionErrort init_methodR R R( t objectt original_initt _finalize( R t finalizeR) t registryR- R R/ ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt _update_statey s& c C s7 | j r d St | _ | j � t j j | j � d S( N( R t Truet _instrument_initt _instrumentation_factoryR t class_instrumentR ( R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR2 � s c C s t | � S( N( t id( R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt __hash__� s c C s | | k S( N( ( R t other( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt __eq__� s c C s d | j k S( NR) ( R# ( R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt is_mapped� s c C s t | � S( N( t frozenset( R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt _all_key_set� s c C s2 t g | j � D] } | j j r | j ^ q � S( N( R? t valuest implt collectiont key( R t attr( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt _collection_impl_keys� s c C s2 t g | j � D] } | j j r | j ^ q � S( N( R? RA RB t accepts_scalar_loader( R RE ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt _scalar_loader_impls� s c C s& t g | j � D] } | j ^ q � S( N( R? RA RB ( R RE ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt _loader_impls� s c C s t j | j � � d S( N( R t UnmappedClassErrorR ( R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR) � s c c s� i } x� | j j d d !D]� } | j d } xp | j D]e } | j | | � | | j k rb q7 n | | j | } t | t j � r7 | j r7 | | f Vq7 q7 Wq 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`. i i����i N( R R R# t setdefaultR R t InspectionAttrt is_attribute( R t excludet foundt superclst inheritsRD t val( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt _all_sqla_attributes� s c C s9 x2 | j j D] } | | j k r | j | Sq W| Sd S( s5 return an attribute on the class without tripping it.N( R R R# ( R RD t defaultRP ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt _get_class_attr_mro� s c C s | | k o | | j d k S( s\ Return True if the given attribute is fully initialized. i.e. has an impl. N( RB R ( R RD ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt _attr_has_impl� s c C s t | d t �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. R3 ( t register_classR ( R t cls( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt _subclass_manager s c C s2 t | j | | j � | _ | j d | j � d S( NR( ( t _generate_initR R1 R t install_member( R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR7 s c C s | j j | | j � t j S( N( R t first_initR R t InstanceState( R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt _state_constructor s c C s t | j | j | � d S( s0 Mark this instance as the manager for its class.N( t setattrR t MANAGER_ATTR( R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR" s c C s t S( N( t _default_manager_getter( R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt manager_getter s c C s t S( 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 ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt state_getter s c C s t S( N( t _default_dict_getter( R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt dict_getter* s c C s� | r | | j k r9 d Sn | | j | <| j | | � | j � | | | <x9 | j j � D]( } | j | � } | j | | t � q] Wd S( N( R t install_descriptort _reset_memoizationsR t __subclasses__RY t instrument_attributeR6 ( R RD t instt propagatedRX t manager( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRj . s c c sr xk | j j � D]Z } t | � } | d k r | | k r | V| rj x | j t � D] } | VqU Wqj q q Wd S( N( R Ri R R t subclass_managersR6 ( R t recursiveRX R% t m( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRn < s c C s! t j j | j | | | � d S( N( R8 R t attribute_instrumentR ( R RD ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt post_configure_attributeE s c C s� | | k r d S| r, | | j k rC d Sn | j | =| j | � | j � | | =x< | j j � D]+ } t | � } | rd | j | t � qd qd Wd S( N( R t uninstall_descriptorRh R Ri R t uninstrument_attributeR6 ( R RD Rl RX Rm ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRt J s c C s� x$ t | j � D] } | j | � q Wd | _ | _ | _ | j j � x3 t | � D]% } | | j k rX | j | � qX qX W| j | j j k r� t | j | j � n d S( s< remove all instrumentation established by this ClassManager.N( t listR t uninstall_memberR R) R R R t clearR Rt R` R R# t delattr( R RD ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt unregisterZ s c C sB | | j | j f k r+ t d | � � n t | j | | � d S( NsW %r: requested attribute name conflicts with instrumentation attribute of the same name.( t STATE_ATTRR` t KeyErrorR_ R ( R RD Rk ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRg j s c C s t | j | � d S( N( Rx R ( R RD ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRs r s c C sg | | j | j f k r+ t d | � � n | j j | | j j j | t � � t | j | | � d S( NsW %r: requested attribute name conflicts with instrumentation attribute of the same name.( Rz R` R{ R RK R R# t getR R_ ( R RD t implementation( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR[ u s %c C sK | j j | d � } | t k r7 t | j | | � n t | j | � d S( N( R t popR R R_ R Rx ( R RD t original( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRv ~ s c C s t j | � S( N( R t prepare_instrumentation( R RD t collection_class( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt instrument_collection_class� s c C s1 | � } t j | j | � | | � } | | f S( N( R t CollectionAdaptert get_impl( R RD R t factoryt user_datat adapter( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt initialize_collection� s c C s! | r | | k S| | j k Sd S( N( R ( R RD t search( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt is_instrumented� s c C s | | j S( N( RB ( R RD ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR� � s c C s t | j � � S( N( t iterRA ( R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt attributes� s c C sJ | j j | j � } | d k r6 | j | | � } n | j | | � | S( N( R t __new__R R^ t _state_setter( R R t instance( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt new_instance� s c C s5 | d k r! | j | | � } n | j | | � d S( N( R R^ R� ( R R� R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt setup_instance� s c C s t | | j � d S( N( Rx Rz ( R R� ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt teardown_instance� s c C s t | | � S( N( t _SerializeManager( R R t state_dict( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt _serialize� s c C st t | | j � r t S| j | j k rJ | j rJ | 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( t hasattrRz R R t __class__R> RY t _new_state_if_noneR^ R� ( R R� R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR� � s c C s t | | j � S( N( R� Rz ( R R� ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt has_state� s c C s | j | � j | d | �S( t TODOt optimistic( R� t hasparent( R R RD R� ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt has_parent� s c C s t S( s= All ClassManagers are non-zero regardless of attribute state.( R6 ( R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt __bool__� s c C s d | j j | j t | � f S( Ns <%s of %r at %x>( R� t __name__R R: ( R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt __repr__� s N(H R� t __module__t __doc__R t DEFAULT_MANAGER_ATTRR` t DEFAULT_STATE_ATTRRz t staticmethodR t attrsetterR� R R R/ R� R) R- R4 t propertyt deprecatedR t setterR( R R5 R2 R; R= R> R t memoized_attributeR@ RF RH RI t memoized_propertyRS RU RV RY R7 R^ R" t hybridmethodRb Rd Rf Rj Rn Rr Rt Ry Rg Rs R[ Rv R� R� R� R� R� R� R� R� R� R� R� R� R� t __nonzero__R� ( ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR / s� ( ! R� c B s e Z d Z d � Z d � Z RS( s� Provide serialization of a :class:`.ClassManager`. The :class:`.InstanceState` uses ``__init__()`` on serialize and ``__call__()`` on deserialize. c C s, | j | _ | j } | j j | | � d S( N( R Rm R t pickle( R R t dRm ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR( � s c C s� t | j � | _ } | d k r> t j | d | j � � n& | j rd | j j rd | j j � n | d k r� | j | | � n | j j | | � d S( Nsx Cannot deserialize object of type %r - no mapper() has been configured for this class within the current Python process!( R R Rm R R t UnmappedInstanceErrorR> R) t configuredt _check_configureR� R t unpickle( R R Rk R� Rm ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt __call__� s ( R� R� R� R( R� ( ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR� � s t InstrumentationFactoryc B s2 e Z d Z d � Z d � Z d � Z d � Z RS( s' Factory for new ClassManager instances.c C s} | d k s t � t | � d k s* t � | j | � \ } } | d k r` t } | | � } n | j | | � | | _ | S( N( R R. R t _locate_extended_factoryR t _check_conflictsR� ( R R Rm R� ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt create_manager_for_cls s c C s d S( s2 Overridden by a subclass to do an extended lookup.N( NN( R ( R R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR� s c C s d S( s; Overridden by a subclass to test for conflicting factories.N( ( R R R� ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR� s c C s* t | � } | j � | j j | � d S( N( R Ry R t class_uninstrument( R R Rm ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRy s ( R� R� R� R� R� R� Ry ( ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR� � s c C s\ t | � } | d k r* t j | � } n | j d | d | d | d | d | d | � | S( s_ Register class instrumentation. Returns the existing or newly created class manager. R) R4 R- R R/ R3 N( R R R8 R� R5 ( R R3 R) R4 R- R R/ Rm ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRW . s c C s t j | � d S( s! Unregister class instrumentation.N( R8 Ry ( R ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt unregister_classL s c C s t | 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. R� ( R R� R� R6 ( R� RD ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyR� R s c B s | d k r | j } n d } e j | d e �} | | } e j rm e | d | � } e | d d � } n$ e | d d � } e | d d � } e � j � } e | d <| | U| d } | j | _ | | _ | r� | | _ n e j 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) t groupedt im_funct func_defaultst __defaults__t __kwdefaults__R� R( N( R R( R t format_argspec_initR t py2kt getattrt localst copyR� R� t _sa_original_initR� R� ( R t class_managerR1 t func_bodyt func_varst func_textt funcR� t func_kw_defaultst envR( ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyRZ _ s* ( R� R+ t R R R R R R R t symbolR t dictR R0 R� R� R8 t instance_stateRc t instance_dictRe R Ra R6 R RW R� R� RZ ( ( ( sQ /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/instrumentation.pyt <module> s4 � �"%