JezK
Edit File: dynamic.pyc
� 1��fc @ s� d 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 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 e j j d d � d e j f d � � Y� � Z d e j f d � � YZ d e f d � � YZ d e f d � � YZ d e e f d � � YZ d � Z d e f d � � YZ d S( s� Dynamic collection API. Dynamic collections act like Query() objects for read operations and support basic add/delete mutation. i ( t attributes( t exc( t interfaces( t object_mapper( t object_session( t relationships( t strategies( t util( t Queryi ( t log( t resultt lazyt dynamict DynaLoaderc B s e Z d � Z RS( c C s� t | _ | j s+ t j d | j � � n5 | j j t j t j f k r` t j d | j � n t j | j | d t d t d | j j d | j j d | j j �d S( Nst On relationship %s, 'dynamic' loaders cannot be used with many-to-one/one-to-one relationships and/or uselist=False.s� On relationship %s, 'dynamic' loaders cannot be used with many-to-one/one-to-one relationships and/or uselist=False. This warning will be an exception in a future release.t useobjectt impl_classt target_mappert order_byt query_class( t Truet is_class_levelt uselistR t InvalidRequestErrort parent_propertyt directionR t ONETOMANYt MANYTOMANYR t warnR t _register_attributet DynamicAttributeImplt mapperR R ( t selfR ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt init_class_attribute! s& ( t __name__t __module__R ( ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR s R c B s% e Z e Z e Z e Z e Z e Z d Z d d � Z e j d � Z d e j d � Z e j d � � Z e j d � � Z d d � Z d d � Z d � Z d e j d e e d � Z d � Z d � Z e j d � Z e j d � Z e j d � Z e j d � Z e j d � Z e j d � Z RS( c K s� t t | � j | | | | | � | | _ | rC t | � | _ n | sU t | _ n- t | j � k rs | | _ n t | � | _ d S( N( t superR t __init__R t tupleR t AppenderQueryR t AppenderMixint mrot mixin_user_query( R t class_t keyt typecallablet dispatchR R R t kw( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR$ G s c C s7 | t j @s# | j | t j � j S| j | | � Sd S( N( R t SQL_OKt _get_collection_historyt PASSIVE_NO_INITIALIZEt added_itemsR ( R t statet dict_t passive( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt get_ s c C sJ | t j @s% | j | | � j } n | j | | � } | j } t | � S( N( R R/ R0 R2 t added_plus_unchangedt DynamicCollectionAdapter( R R3 R4 t user_dataR5 t datat history( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt get_collectiong s c C s t j | t j � S( N( R t Eventt OP_APPEND( R ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt _append_tokenu s c C s t j | t j � S( N( R R= t OP_REMOVE( R ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt _remove_tokeny s c C s� | d k r! | j | | � } n | j | � x/ | j j D]! } | | | | pV | j � } q; W| j r� | d k r� | j t j | � | t � n d S( N( t Nonet _modified_eventt add_addedR- t appendR? t trackparentt sethasparentR t instance_stateR ( R R3 R4 t valuet initiatort collection_historyt fn( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt fire_append_event} s c C s� | d k r! | j | | � } n | j | � | j rb | d k rb | j t j | � | t � n x- | j j D] } | | | | p� | j � qo Wd S( N( RB RC t add_removedRF RG R RH t FalseR- t removeRA ( R R3 R4 RI RJ RK RL ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt fire_remove_event� s c C s_ | j | j k r. t | | � | j | j <n | j | | t j � t | | j <| j | j S( N( R+ t committed_statet CollectionHistoryRC R t NEVER_SETR ( R R3 R4 ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRC � s c C sM | r | j | j k r d S| r2 | d k r2 d S| } t | � } | j rk t j | j | | � � } n | j | | � } | j s� | j } n | j | j � } t j } | j | � } | | � j | � } | j | � } x9 | D]1 } | | k r� | j | | | d d | �q� q� Wx* | D]" } | j | | | d d | �q#Wd S( NRK ( t parent_tokenRB t listt has_identityR t IdentitySetR6 RC R2 t uniont intersectiont differenceRM RQ ( R R3 R4 RI RJ R5 t check_oldt popt _adaptt iterablet new_valuest old_collectionRK t idsett constantst additionst removalst member( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt set� s@ c O s t � � d S( N( t NotImplementedError( R t argst kwargs( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt delete� s c C s t d � � d S( Ns7 Dynamic attributes don't support collection population.( Rh ( R R3 R4 RI ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt set_committed_value� s c C s | j | | � } | j � S( N( R0 t as_history( R R3 R4 R5 t c( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt get_history� s c C s; | j | | � } g | j D] } t j | � | f ^ q S( N( R0 t all_itemsR RH ( R R3 R4 R5 Rn t x( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt get_all_pending� s c C se | j | j k r% | j | j } n t | | � } | j r] | t j @r] t | | d | �S| Sd S( Nt apply_to( R+ RR RS RW R t INIT_OK( R R3 R5 Rn ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR0 � s c C s) | | k r% | j | | | | � n d S( N( RM ( R R3 R4 RI RJ R5 ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRE � s c C s) | | k r% | j | | | | � n d S( N( RQ ( R R3 R4 RI RJ R5 ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRP � s c C s | j | | | | d | �d S( NR5 ( RP ( R R3 R4 RI RJ R5 ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR] s ( N(! R! R" R t uses_objectsRO t default_accepts_scalar_loadert supports_populationt collectionR R RB R$ R t PASSIVE_OFFR6 R1 R< R t memoized_propertyR? RA RM RQ RC Rg Rk Rl Ro Rr R0 RE RP R] ( ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR ? s8 - R8 c B sA e Z d Z d � Z d � Z d � Z d � Z d � Z e Z RS( s9 simplified CollectionAdapter for internal API consistencyc C s | | _ d S( N( R: ( R R: ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR$ s c C s t | j � S( N( t iterR: ( R ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt __iter__ s c C s d S( N( ( R ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt _reset_empty s c C s t | j � S( N( t lenR: ( R ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt __len__ s c C s t S( N( R ( R ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt __bool__ s ( R! R" t __doc__R$ R| R} R R� t __nonzero__( ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR8 s R' c B st e Z d Z d � Z d � Z e e d � � Z d � Z d � Z d � Z d d � Z d � Z d � Z d � Z RS( c C s� t t | � j | j d � | j � | _ } | | _ t | � } | j | j j } | j d k r� | j j � | j f | _ n | j | d t �f | _ | j j r� | j j | _ n d S( Nt alias_secondary( R# R' R$ R RB t objt instancet attrR t _propsR+ t secondaryR t __clause_element__t _from_objt _with_parentRO t _where_criteriaR t _order_by_clauses( R R� R3 R� R t prop( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR$ " s c C sg t | j � } | d k rI | j rI | j rI | j | k rI | j � n t j | j � s_ d S| Sd S( N( R R� RB t autoflusht flusht orm_utilRW ( R t sess( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt session= s c C s d S( N( RB ( t sRq ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt <lambda>K t c C s� | j } | d k r� t j | j � } | j rM t j d t j | � � n t j t j | j j j g � t | j j t j | j � t j � j � d t �j � S| j | � j � Sd S( Ns� Instance %s is detached, dynamic relationship cannot return a correct result. This warning will become a DetachedInstanceError in a future release.t _source_supports_scalars( R� RB R RH R� t detachedR R R� t state_strR t IteratorResultt SimpleResultMetaDataR� R* R! R{ R0 R1 R2 R t scalarst _generatet _iter( R R� R3 ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR� M s c C sZ | j } | d k r@ | j j t j | j � t j � j | � S| j | � j | � Sd S( N( R� RB R� R0 R RH R� R1 t indexedR� t __getitem__( R t indexR� ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR� f s c C sW | j } | d k r@ t | j j t j | j � t j � j � S| j | � j � Sd S( N( R� RB R~ R� R0 R RH R� R1 R2 R� t count( R R� ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR� p s c C s� | j } | d k r[ t | � } | d k r[ t j d t j | � | j j f � � q[ n | j r� | j | j j d | �} n | j | j j � } | j | _ | 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� ( R� RB R t orm_exct DetachedInstanceErrorR� t instance_strR� R+ R R t queryR� R� R� ( R R� R� R� ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR� | s % c C sF x? | D]7 } | j j t j | j � t j | j � | d � q Wd S( N( R� RE R RH R� t instance_dictRB ( R t iteratort item( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt extend� s c C s5 | j j t j | j � t j | j � | d � d S( N( R� RE R RH R� R� RB ( R R� ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRE � s c C s5 | j j t j | j � t j | j � | d � d S( N( R� RP R RH R� R� RB ( R R� ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRP � s N( R! R" RB R R$ R� t propertyR� R� R� R� R� RE RP ( ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR' s R& c B s e Z d Z RS( sB A dynamic query that supports basic collection storage operations.( R! R" R� ( ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR& � s c C s* d | j } t | t | f i | d 6� S( sA Return a new class with AppenderQuery functionality layered over.t AppenderR ( R! t typeR' ( t clst name( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR) � s RS c B s\ e Z d Z d d � Z e d � � Z e d � � Z d � Z d � Z d � Z d � Z RS( sD Overrides AttributeHistory to receive append/remove events directly.c C s� | rT t | | � j t � } t j | � | _ | j | _ | j | _ t | _ n6 t j � | _ t j � | _ t j � | _ t | _ d S( N( R& R� RO R t OrderedIdentitySett unchanged_itemsR2 t deleted_itemsR t _reconcile_collection( R R� R3 Rs t coll( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR$ � s c C s t | j j | j � � S( N( RV R2 RY R� ( R ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR7 � s c C s% t | j j | j � j | j � � S( N( RV R2 RY R� R� ( R ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRp � s c C s� | j rH | j j | j � } | j j | j � } | j j | � } n | j | j | j } } } t j t | � t | � t | � � S( N( R� R2 R[ R� R� RZ R t HistoryRV ( R t addedt deletedt unchanged( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRm � s c C s t | j � | S( N( RV R2 ( R R� ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyR� � s c C s | j j | � d S( N( R2 t add( R RI ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRD � s c C s6 | | j k r" | j j | � n | j j | � d S( N( R2 RP R� R� ( R RI ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRN � s N( R! R" R� RB R$ R� R7 Rp Rm R� RD RN ( ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyRS � s N( R� R� R R R� R R R R R R R� R� R R t engineR t class_loggert RelationshipPropertyt strategy_fort AbstractRelationshipLoaderR t AttributeImplR t objectR8 R' R& R) RS ( ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dynamic.pyt <module> s, ��