JezK
Edit File: dependency.pyc
� 1��fc @ sC 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 e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ i e e 6e e 6e e 6Z d S( s Relationship dependencies. i ( t attributes( t exc( t sync( t unitofwork( t util( t MANYTOMANY( t MANYTOONE( t ONETOMANYi ( t sqlt DependencyProcessorc B s� e Z d � Z e d � � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z e d � Z d � Z d � Z RS( c C s | | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j | _ | j r� t j | _ n t j | _ | j r� t j | _ n t j | _ d | j j | j f | _ | j | _ | j j s t j d | j � � n d S( Ns %s_%ss| Can't build a DependencyProcessor for relationship %s. No target attributes to populate between parent and child are present( t propt cascadet mappert parentt secondaryt directiont post_updatet passive_deletest passive_updatest enable_typechecksR t PASSIVE_NO_INITIALIZEt _passive_delete_flagt PASSIVE_OFFt _passive_update_flagt _sort_keyt keyt sort_keyt synchronize_pairst sa_exct ArgumentError( t selfR ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt __init__ s, c C s t | j | � S( N( t _direction_to_processorR ( t clsR ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt from_relationship7 s c C s | j j j | j � j | � S( s� return True if the given object instance has a parent, according to the ``InstrumentedAttribute`` handled by this ``DependencyProcessor``. ( R t class_managert get_implR t hasparent( R t state( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR% ; s c C s | j | t � d S( s� establish actions and dependencies related to a flush. These actions will operate on all relevant states in the aggregate. N( t register_preprocessort True( R t uow( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt per_property_preprocessorsC s c C s� t j | | t t � } t j | | t t � } t j | | j j � } t j | | j j � } t j | | j j � } t j | | j j � } | j | | | | | | | � d S( N( R t ProcessAllt FalseR( t SaveUpdateAllR t primary_base_mapperR t DeleteAllt per_property_dependencies( R R) t after_savet before_deletet parent_savest child_savest parent_deletest child_deletes( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt per_property_flush_actionsL s$ c C s� | j j } t j | | � } t j | | � } | rZ t j | | t t � } t | _ n! t j | | t t � } t | _ | | j k r� | | j k s� t � | t f | t f g } t } n t } | s t j | | j j � } d } } | | j k rCt } qCn: t j | | j j � } d } } | | j k rCt } n x�| D]�} | j | j j j | | j | r{| j n t j � } | s�qJn | r�t j | | t | � } | rt j | | � } qn3 t j | | t | � } | rt j | | � } n | r�g } x� | D]} \ } } | | j k r9d } nL | j | \ } } | rmt j | | � t f } n t j | | � t f } | j | � qWn x6 | D]. \ } } | j | | | | | | | | � q�WqJWd S( s� establish actions and dependencies related to a flush. These actions will operate on all relevant states individually. This occurs only if there are cycles in the 'aggregated' version of events. N( NN( R R. R R- R/ R+ R( t disabledR, t cyclest AssertionErrorR t base_mappert Nonet managerR t implt get_all_pendingt dictR R R t ProcessStatet DeleteStatet SaveUpdateStatet statest appendt per_state_dependencies( R R) RD t isdeletet child_base_mapperR4 R6 R2 R1 t child_actionst child_in_cyclesR3 R5 t parent_in_cyclesR& t sum_t child_statet childt child_actiont deletedt listonlyt childisdelete( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt per_state_flush_actionsh sx c C s t S( N( R, ( R t uowcommitRD ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt presort_deletes� s c C s t S( N( R, ( R RT RD ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt presort_saves� s c C s d S( N( ( R RT RD ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt process_deletes� s c C s d S( N( ( R RT RD ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt process_saves� s c C s� | s | j r t j } n$ | j t k r7 t j } n t j } x` | D]5 } | j | | j | � } | rG | j � rG t SqG W| o� | j j o� | j | j k Sd S( N( R R R R R t PASSIVE_NO_FETCH_RELATEDR t get_attribute_historyR t emptyR( R t _is_self_referentialR t mappers( R RT RD RG t passivet st history( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt prop_has_changes� s c C s� | j j r4 | d k r4 t j d | j f � � n� | d k r� | j j | d | j � r� | j j | d t �r� t j d i | j d 6| j d 6| j j d 6| j d 6� � q� t j d i | j d 6| j d 6| j j d 6� � n d S( Ns- Can't flush None value found in collection %st allow_subtypessE Attempting to flush an item of type %(x)s as a member of collection "%(y)s". Expected an object of type %(z)s or a polymorphic subclass of this type. If %(x)s is a subclass of %(z)s, configure mapper "%(zm)s" to load this subtype polymorphically, or set enable_typechecks=False to allow any subtype to be accepted for flush. t xt yt zt zms� Attempting to flush an item of type %(x)s as a member of collection "%(y)s". Expected an object of type %(z)s or a polymorphic subclass of this type.( R t uselistR< R t FlushErrorR t _canloadR R( t class_( R R& ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt _verify_canload� s( c C s t � � d S( N( t NotImplementedError( R R& RN t associationrowt clearkeysRT ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt _synchronize( s c C s^ | j j s d St t | j g g | j j D] } | j ^ q, � � } | j d | f t � S( Nt reverse_key( R t _reverse_propertyR< t tuplet sortedR t memot set( R R) t pt process_key( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt _get_reversed_processed_set+ s 5c C s[ xT | D]L } | s | d k r | j | g | j j D] \ } } | ^ q6 � Pq q Wd S( N( R< t register_post_updateR R ( R R& RT t relatedt is_m2o_deleteRc t lt r( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt _post_update4 s )c C s t � � d S( N( Rl ( R RT R& ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt _pks_changed< s c C s d | j j | j f S( Ns %s(%s)( t __class__t __name__R ( R ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt __repr__? s ( R� t __module__R t classmethodR" R% R* R7 RS RU RV RW RX Ra Rk Ro Rx R, R~ R R� ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR s" p ) t OneToManyDPc B sP e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C s� | j r� t j | | j j t � } t j | | j j t � } | j j | | f | | f | | f | | f | | f | | f g � nO | j j | | f | | f | | f | | f | | f | | f | | f g � d S( N( R R t PostUpdateAllR R. R, R( t dependenciest update( R R) R3 R4 R5 R6 R1 R2 t child_post_updatest child_pre_updates( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR0 D s( c C sH | j r� t j | | j j t � } t j | | j j t � } | s� | rp | j j | | f | | f g � q� | j j | | f | | f | | f g � qD| r� | j j | | f | | f g � qD| j j | | f | | f g � nV | s"| j j | | f | | f | | f g � n" | j j | | f | | f g � d S( N( R R R� R R. R, R( R� R� ( R R) t save_parentt delete_parentRO R1 R2 RG RR R� R� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRF m s8 c C s | j j o | j d k } x� | D]� } | j | | j | j � } | r$ xd | j D]Y } | d k rU | j | � t k rU | j j r� | j | d t �q� | j | � qU qU W| r� x? | j D]1 } | d k r� | j | d d d | j �q� q� Wq� q$ q$ Wd S( Nt allRG t operationt deleteR ( R R� R RZ R R RP R< R% R, t delete_orphant register_objectR( t unchangedR ( R RT RD t should_null_fksR& R` RN ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRU � s ! c C s | j d | f t � } | j j o2 | j d k } x�| D]�} | j | | � } | sd | j rp t j } n t j } | j | | j | � } | r�xB | j D]7 } | d k r� | j | d t d d d | j �q� q� W| j | j � x� | j D]� } | j j s6| r�| j | d t d d d | j �q�q� | j | � t k r� | j | d t d d d | j �x? | j j d | � D]% \ } } } } | j | d t �q�Wq� q� Wn | r< | rxH | j D]: } | d k r�| j | t | j d d d | j �q�q�Wqq< q< Wd S( Nt children_addedR� t cancel_deleteR� t addR RG R� s pk change( Rt Ru R R� R R R R R R RZ R t addedR< R� R( R R� RP R, R% R t cascade_iteratorR� ( R RT RD R� R� R& t pks_changedR^ R` RN t ct mt st_t dct_( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRV � sZ ! c C sx | j s | j d k rt| j d | f t � } x@| D]5} | j | | j | j � } | r8 xy | j D]n } | d k ri | j | � t k ri | j | | d t | t � | j r� | r� | j | | | g � q� qi qi W| j s� | j j rmxv t | j � j | � D]Y } | d k r | j | | d t | t � | j rc| rc| j | | | g � qcq q Wqmq8 q8 Wn d S( NR� R� ( R R Rt Ru RZ R R RP R< R% R, Ro R( R~ R R� R� t difference( R RT RD R� R& R` RN ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRW s, c C sO | j j o | j d k } x+| D]#} | j | | j t j � } | r$ x[ | j D]P } | j | | d t | t � | d k rU | j rU | j | | | g � qU qU WxS | j D]H } | r� | j j r� | j | � r� | j | | d t | t � q� q� W| j | | � rGx0 | j D]" } | j | | d t | t � qWqGq$ q$ Wd S( NR� ( R R� R RZ R R R R� Ro R< R, R R~ RP R% R( R R� ( R RT RD R� R& R` RN ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRX 5 s* c C s� | } | } | j | � | d k s> | j rB | j | � rB d S| rg t j | | j | j j � n4 t j | | j | | j | j j | | j o� | � d S( N( Rk R< R t is_deletedR t clearR R R t populateR R ( R R& RN Rm Rn RT R� t sourcet dest( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRo W s c C s t j | | | j | j j � S( N( R t source_modifiedR R R ( R RT R& ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR n s ( R� R� R0 RF RU RV RW RX Ro R ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR� C s ) C > , " t ManyToOneDPc B sS e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d d � Z RS( c C sA t j | | � x* | j j D] } | j j t | � � q Wd S( N( R R R t self_and_descendantst _dependency_processorsRE t DetectKeySwitch( R R R ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR u s c C s� | j r� t j | | j j t � } t j | | j j t � } | j j | | f | | f | | f | | f | | f | | f | | f g � n4 | j j | | f | | f | | f | | f g � d S( N( R R R� R R. R, R( R� R� ( R R) R3 R4 R5 R6 R1 R2 t parent_post_updatest parent_pre_updates( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR0 z s$ c C s? | j r� | s� t j | | j j t � } | rU | j j | | f | | f g � q� | j j | | f | | f | | f g � q;t j | | j j t � } | j j | | f | | f | | f g � no | s| s� | j j | | f | | f g � q;| j j | | f g � n" | r;| j j | | f g � n d S( N( R R R� R R. R, R� R� R( ( R R) R� R� RO R1 R2 RG RR R� R� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRF � s2 c C s | j j s | j j rx� | D]� } | j | | j | j � } | r | j j ra | j � } n | j � } x� | D] } | d k r� qt n | j | d t d d d | j �| j j d | � } x- | D]% \ } } } } | j | d t �q� Wqt Wq q Wn d S( NRG R� R� R ( R R� R� RZ R R t sumt non_deletedR< R� R( R R R� ( R RT RD R& R` t todeleteRN t tR� R� R� R� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRU � s& c C s� x� | D]� } | j | d d d | j �| j j r | j | | j | j � } | r� x� | j D]� } | j | � t k r` | j | d t d d d | j �| j j d | � } x0 | D]% \ } } } } | j | d t �q� Wq` q` Wq� q q Wd S( NR� R� R RG R� ( R� R R R� RZ R R RP R% R, R( R R� ( R RT RD R& R` RN R� R� R� R� R� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRV � s c C s� | j r� | j j r� | j d k r� x | D]t } | j | d d t | � | r- | j r- | j | | j | j � } | r� | j | | | j � d t �q� q- q- Wn d S( NR� R{ ( R R R� R Ro R< R( RZ R R R~ R� ( R RT RD R& R` ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRW s c C s� x� | D]� } | j | | j t j � } | r | j rj xX | j D]" } | j | | d t | d � qA Wn( | j r� | j | d d t | d � n | j r� | j | | | j � � q� q q Wd S( NR� R� ( RZ R R R R� Ro R< R, RP R( R R~ R� ( R RT RD R& R` RN ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRX s c C s� | d k s% | j r) | j | � r) d S| d k r~ | d k r~ | j j | � r~ t j d t j | � | | j f � d S| s� | d k r� t j | | j | j j � n8 | j | � t j | | j | | j | j j | t � d S( NsG Object of type %s not in session, %s operation along '%s' won't proceed( R< R R� t sessiont _contains_stateR t warnt mapperutilt state_class_strR R R� R R Rk R� R R, ( R R& RN Rm Rn RT R� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRo 0 s* N( R� R� R R0 RF RU RV RW RX R< Ro ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR� t s ( : R� c B sq e Z d Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s� For many-to-one relationships with no one-to-many backref, searches for parents through the unit of work when a primary key has changed and updates them. Theoretically, this approach could be expanded to support transparent deletion of objects referenced via many-to-one as well, although the current attribute system doesn't do enough bookkeeping for this to be efficient. c C sP | j j r< | j r d St d � | j j D� k r< d Sn | j | t � d S( Nc s s | ] } | j Vq d S( N( R ( t .0R ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pys <genexpr>k s ( R Rq R R, R' ( R R) ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR* e s c C sM t j | | j j � } t j | | t t � } | j j | | f g � d S( N( R R- R R; R+ R, R� R� ( R R) R3 R1 ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR7 r s c C s d S( N( ( R R) RD RG ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRS w s c C s d S( N( ( R RT RD ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRU z s c C s | j s | j | | � n d S( N( R t _process_key_switches( R R) RD ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRV } s c C s0 | r, | j r, | j | | � } t | � St S( N( R t _key_switcherst boolR, ( R R) RD RG t d( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRa � s c C s t s t � d S( N( R, R: ( R RT RD ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRW � s c C s# | j s t � | j | | � d S( N( R R: R� ( R RT RD ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRX � s c C s� | j d | f d � � \ } } | j | � } xL | D]D } | | k r7 | j | | � rk | j | � q{ | j | � q7 q7 W| S( Nt pk_switchersc S s t � t � f S( N( Ru ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt <lambda>� t ( Rt t unionR R� ( R R) RD t switchedt notswitchedt allstatesR_ ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR� � s c C s5 | j | | � } | r1x| j j j � D]� } t | j | j j � sO q+ n | j } | j | j � j | | d | j �} | t j k r+ | d k r+ | j j r� | s� q+ n | d } n | } t j | � } | | k r*| j | t | j � t j | | j | | j | j j | | j � q*q+ q+ Wn d S( NR^ i ( R� R� t identity_mapt all_statest issubclassRj R R@ R$ R t getR R t PASSIVE_NO_RESULTR< R Rg t instance_stateR� R, R R R� R R ( R t deplistRT t switchersR& t dict_Rz t related_objt related_state( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR� � s6 c C s. t | j � o- t j | | | j | j j � S( N( R� R R R� R R R ( R RT R& ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR � s ( R� R� t __doc__R* R7 RS RU RV Ra RW RX R� R� R ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR� Y s %t ManyToManyDPc B sY e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C sS | j j | | f | | f | | f | | f | | f | | f | | f g � d S( N( R� R� ( R R) R3 R4 R5 R6 R1 R2 ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR0 � s c C s| | sV | r1 | j j | | f | | f g � qx | j j | | f | | f g � n" | j j | | f | | f g � d S( N( R� R� ( R R) R� R� RO R1 R2 RG RR ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRF � s c C s: | j s6 x* | D] } | j | | j | j � q Wn d S( N( R RZ R R ( R RT RD R& ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRU s c C s# | j sM xA | D]6 } | j | | � r | j | | j t j � } q q Wn | j j s] d Sx� | D]� } | j | | j t j � } | rd x� | j D] } | j | � t k r� | j | d t d d d | j �x? | j j d | � D]% \ } } } } | j | d t �q� Wq� q� Wqd qd Wd S( NRG R� R� R ( R R RZ R R R R R� R RP R% R, R� R( R R R� ( R RT RD R& R` RN R� R� R� R� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRV s* c s6 g } g } g } | j | � } t � } x� | D]� � | j � | j | j � } | r1 x{ | j � D]m } | d k se | d k r� � | f | k r� qe n i } | j � | | t | d � s� qe n | j | � qe W| j � f d � | j � D� � q1 q1 W| d k r | j | � n | j | | | | � d S( NR� c 3 s | ] } | � f Vq d S( N( ( R� R� ( R& ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pys <genexpr>Q s ( Rx Ru RZ R R t non_addedR< Ro R, RE R� t _run_crud( R RT RD t secondary_deletet secondary_insertt secondary_updatet processedt tmpR` RN Rm ( ( R& sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRW 2 s8 * c sB g } g } g } | j | � } t � } x�| D]�� | j oP | j | � � } | re t j } n t j } | j � | j | � } | r1 xl | j D]a } | d k r� � | f | k r� q� n i } | j � | | t | d � s� q� n | j | � q� Wxl | j D]a } | d k r/� | f | k r/qn i } | j � | | t | d � sYqn | j | � qW| j � f d � | j | j D� � | rxk | j D]] } i } t j � | j | d | j j � t j | | j | d | j j � | j | � q�Wqq1 q1 W| d k r(| j | � n | j | | | | � d S( NR� R� c 3 s | ] } | � f Vq d S( N( ( R� R� ( R& ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pys <genexpr>� s t old_( Rx Ru R R R R R RZ R R� R< Ro R, RE RP R� R� R R R R R t secondary_synchronize_pairsR� ( R RT RD R� R� R� R� R� t need_cascade_pksR^ R` RN Rm ( ( R& sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRX Z sn ' c C s� | j j | j � } | r� | d } | j j � j t j g | j j D]6 } | j | k rG | t j | j d | j �k ^ qG � � } | j | | � } | j � r� | j t | � k r� t j d | j j t | � | j f � � q� n | r�| d } | j j � j t j g | j j D]: } | j | k r | t j d | j d | j �k ^ q � � } | j | | � } | j � r�| j t | � k r�t j d | j j t | � | j f � � q�n | r�| j j � } | j | | � n d S( Ni t type_sR DELETE statement on table '%s' expected to delete %d row(s); Only %d were matched.R� sR UPDATE statement on table '%s' expected to update %d row(s); Only %d were matched.( t transactiont connectionR R R� t whereR t and_R� R t bindparamt typet executet supports_sane_multi_rowcountt rowcountt lenR t StaleDataErrort descriptionR� t insert( R RT R� R� R� R� Rm R� t statementt result( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR� � sD < @ c C s� | j | � | d k r t S| d k rr | j j | � rr | j sn t j d t j | � | | j f � n t St j | | j | | j j � t j | | j | | j j � t S( NsG Object of type %s not in session, %s operation along '%s' won't proceed( Rk R< R, R� R� RP R R� R� R� R R t populate_dictR R R R� R( ( R R& RN Rm Rn RT R� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyRo � s" c C s t j | | | j | j j � S( N( R R� R R R ( R RT R& ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR s ( R� R� R0 RF RU RV RW RX R� Ro R ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyR� � s " ( H = !N( R� R� R R R R R R� t interfacesR R R R R t objectR R� R� R� R� R ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/dependency.pyt <module> s. � +� 2�u� 9