JezK
Edit File: unitofwork.pyc
� 1��fc @ sq 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 � Z d � Z d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e e f d � � YZ 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 d e f d � � YZ d S(! s� The internals for the unit of work system. The session's flush() process passes objects to a contextual object here, which assembles flush tasks based on mappers and their properties, organizes them in order of dependency, and executes. i ( t attributes( t exc( t utili ( t event( t topologicalc C s' t j d | j j | f d d �d S( NsH "%s" object is being merged into a Session along the backref cascade path for relationship "%s"; in SQLAlchemy 2.0, this reverse cascade will not take place. Set cascade_backrefs to False in either the relationship() or backref() function for the 2.0 behavior; or to set globally for the whole Session, set the future=True flagt codet s9r1( R t warn_deprecated_20t class_t __name__( t statet prop( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt _warn_for_cascade_backrefs s c s� | j � � f d � } � f d � } � f d � } t j | d | d t �t j | d | d t d t �t j | d | d t d t �t j | d | d t d t �d S( s\ Establish event listeners on object attributes which handle cascade-on-set/append. c s� | d k r d S| j } | r� | j r8 | j d � n | j j j � } t j | � } | j j r� | j ry | j s� � | j k r� | j | � r� � | j k r� t | | � n | j | � q� n | S( Ns collection append( t Nonet sessiont _warn_on_eventst _flush_warningt managert mappert _propsR t instance_statet _cascadet save_updatet cascade_backrefst futuret keyt _contains_stateR t _save_or_update_state( R t itemt initiatort sessR t item_state( R ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt append+ s c s� | d k r d S| j } | j j j � } | rZ | j rZ | j | j rP d n d � n | d k r� | t j k r� | t j k r� | j j r� t j | � } | j j | � r� | r� | | j k r� | j | � q� t | _ q� n d S( Ns collection removes related attribute delete( R R R R R R R t uselistR t NEVER_SETt PASSIVE_NO_RESULTR t delete_orphanR t _is_orphant _newt expunget Truet _orphaned_outside_of_session( R R R R R R ( R ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt removeG s" c sV | | k r | S| j } | rR| j r8 | j d � n | j j j � } | d k r� t j | � } | j j r� | j r� | j s� � | j k r� | j | � r� � | j k r� t | | � n | j | � q� n | d k rR| t j k rR| t j k rR| j j rRt j | � } | | j k rO| j j | � rO| j | � qOqRn | S( Ns related attribute set( R R R R R R R R R R R R R R R R R R" R# R$ R& R% R' ( R t newvaluet oldvalueR R R t newvalue_statet oldvalue_state( R ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt set_i s2 t append_wo_mutationt rawR t retvalR* t setN( R R t listenR( ( t descriptorR R R* R/ ( ( R sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt track_cascade_events$ s "* t UOWTransactionc B s� e Z d � Z e d � � Z d � Z d � Z d � Z d � Z e j d � Z d � Z d � Z e e e d d d � Z d � Z d � Z e j d � � Z d � Z d � Z d � Z d � Z d � Z RS( c C sv | | _ i | _ t j t � | _ t j t � | _ i | _ i | _ t � | _ i | _ t j d � � | _ d S( Nc S s t � t � f S( N( R3 ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt <lambda>� t ( R R R t defaultdictR3 t depst mapperst presort_actionst postsort_actionst dependenciest statest post_update_states( t selfR ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt __init__� s c C s t | j � S( N( t boolR@ ( RB ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt has_work� s c C sR | j rN y | j | t j � WqN t j k rJ | j j | g � t SXn t S( sZ Return ``True`` if the given state is expired and was deleted previously. ( t expiredt _load_expiredR t PASSIVE_OFFt orm_exct ObjectDeletedErrorR t _remove_newly_deletedR( t False( RB R ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt was_already_deleted� s c C s | | j k o | j | d S( s[ Return ``True`` if the given state is marked as deleted within this uowtransaction.i ( R@ ( RB R ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt is_deleted� s c C s6 | | j k r | j | S| � | j | <} | Sd S( N( R ( RB R t callable_t ret( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt memo� s c C s( | j | d } | t f | j | <d S( s; Remove pending actions for a state from the uowtransaction.i N( R@ R( ( RB R t isdelete( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt remove_state_actions� s c C s< d | | f } | | j k r� | j | \ } } } | t j @ r8| t j @r8| j | j } | j | | j t j t j Bt j B� } | r� | j r� | j � } n | } | | | f | j | <q8np | j | j } | j | | j | t j Bt j B� } | r | j r | j � } n | } | | | f | j | <| S( sO Facade to attributes.get_state_history(), including caching of results.t history( R t SQL_OKR t implt get_historyt dictRH t LOAD_AGAINST_COMMITTEDt NO_RAISEt uses_objectst as_state( RB R R t passivet hashkeyRT t state_historyt cached_passiveRV ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt get_attribute_history� s0 c C s | t f | j k S( N( R( R= ( RB t processor( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt has_dep s c C s8 | | f } | | j k r4 t | | � | j | <n d S( N( R= t Preprocess( RB Rb t fromparentR ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt register_preprocessor# s c C s� | j j | � sR | j rN | d k rN t j d t j | � | | f � n t S| | j k r� | j j } | | j k r� | j | � n | j | j | � | | f | j | <n) | r� | s� | r� | t f | j | <n t S( NsJ Object of type %s not in session, %s operation along '%s' will not proceed( R R t deletedR R t warnt orm_utilt state_class_strRL R@ R R R< t _per_mapper_flush_actionst addR( ( RB R RR t listonlyt cancel_deletet operationR R ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt register_object( s c C s@ | j j j } | j | \ } } | j | � | j | � d S( N( R R t base_mapperRA Rl t update( RB R t post_update_colsR R@ t cols( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt register_post_updateJ s c C s� t | | j � } t | | j � } | j j | | f � x | j D] } | j | � qD Wx6 | j D]+ } | j rz qe n | j } | j | � qe Wd S( N( t SaveUpdateAllRq t DeleteAllR? Rl t _dependency_processorst per_property_preprocessorst relationshipst viewonlyt _dependency_processor( RB R t savest deletest depR ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRk P s c C s t j d � � S( s return a dynamic mapping of (Mapper, DependencyProcessor) to True or False, indicating if the DependencyProcessor operates on objects of that Mapper. The result is stored in the dictionary persistently once calculated. c S s( | d j j | d j � | d j k S( Ni i ( R t getR R ( t tup( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR8 i R9 ( R t PopulateDict( RB ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt _mapper_for_dep^ s c C s6 | j } g | D]" } | | j j | f r | ^ q S( sm Filter the given list of InstanceStates to those relevant to the given DependencyProcessor. ( R� R R ( RB R R@ t mapper_for_dept s( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt filter_states_for_depl s c c sZ | | f } xG | j j D]9 } x0 | j | D]! } | j | | k r- | Vq- q- Wq Wd S( N( Rq t self_and_descendantsR< R@ ( RB R RR Rm t checktupR ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt states_for_mapper_hierarchyt s c s� xR t rT t } x5 t � j j � � D] } | j � � r% t } q% q% W| s Pq q Wt j � j t � j j � � � � _ } | r�t � f d � | D� � } xt � j � D]� } d | k s� | d j s� | d j s� | j | � r � j j | � q� | d | k rV� j j | � x� | | d D] } � j j | | d f � q/Wq� | d | k r� � j j | � x3 | | d D] } � j j | d | f � q�Wq� q� Wn t g � j j � D] } | j s�| ^ q�� j | � S( s} Generate the full, unsorted collection of PostSortRecs as well as dependency pairs for this UOWTransaction. c 3 s* | ] } | t | j � � � f Vq d S( N( R3 t per_state_flush_actions( t .0t rec( RB ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pys <genexpr>� s i i N( R( RL t listR= t valuest executeR t find_cyclesR? R> t cyclesRX R t disabledt issupersetR* Rl R3 t difference( RB RP t actionR� t convertt edgeR t a( ( RB sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt _generate_actions{ s: % !(.c C s� | j � } t | d d � �} | j r� x� t j | j | � D]; } t | � } x& | rz | j � } | j | | � qU Wq@ Wn- x* t j | j | � D] } | j | � q� Wd S( NR c S s | j S( N( t sort_key( R ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR8 � R9 ( R� t sortedR� R t sort_as_subsetsR? R3 t popt execute_aggregatet sortR� ( RB R> t subsetR/ t nR� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s c C s� | j s d St | j � } t d � | j j � D� � } | j | � } | rc | j j | � n | r| | j j | � n d S( s� Mark processed objects as clean / deleted after a successful flush(). This method is called within the flush() method after the execute() method has succeeded and the transaction has been committed. Nc s s' | ] \ } \ } } | r | Vq d S( N( ( R� R� RR Rm ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pys <genexpr>� s ( R@ R3 t itemsR� R RK t _register_persistent( RB R@ t isdelt other( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt finalize_flush_changes� s N( R t __module__RC t propertyRE RM RN RQ RS R t PASSIVE_NO_INITIALIZERa Rc Rf RL R Rp Ru Rk R t memoized_propertyR� R� R� R� R� R� ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR7 � s, - 4 4 t IterateMappersMixinc B s e Z d � Z RS( c s@ � j r/ t � � f d � � j j j D� � S� j j j Sd S( Nc 3 s+ | ]! } � j | � j f r | Vq d S( N( R� t dependency_processor( R� t m( RB t uow( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pys <genexpr>� s ( Re t iterR� t parentR� R ( RB R� ( ( RB R� sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt _mappers� s ( R R� R� ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s Rd c B s e Z d Z d � Z d � Z RS( R� Re t processedt setup_flush_actionsc C s+ | | _ | | _ t � | _ t | _ d S( N( R� Re R3 R� RL R� ( RB R� Re ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRC � s c C sU t � } t � } xz | j | � D]i } x` | j | j | j � D]E } | j | \ } } | sB | rw | j | � q� | j | � qB qB Wq" W| r� | j j | | � | j j | � n | r� | j j | | � | j j | � n | s� | rM| j rI| j j | | t � s-| j j | | t � rI| j j | � t | _ n t St Sd S( N( R3 R� R< R� R� R@ Rl R� t presort_deletesRr t presort_savesR� t prop_has_changesR( RL t per_property_flush_actions( RB R� t delete_statest save_statesR R RR Rm ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s2 ( R� Re R� R� ( R R� t __slots__RC R� ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRd � s t PostSortRecc B s e Z d Z d � Z d � Z RS( R� c G sR | f | } | | j k r' | j | St j | � | j | <} t | _ | Sd S( N( R> t objectt __new__RL R� ( t clsR� t argsR RP ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� ! s c C s | j | � d S( N( R� ( RB R� t recs( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� * s ( R� ( R R� R� R� R� ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� s t ProcessAllc B s; e Z d Z d � Z d � Z d � Z d � Z d � Z RS( R� RR Re R� c C sQ | | _ d | j j | f | _ | | _ | | _ | j | j j j | � d S( NR� ( R� R� RR Re R; R� Rq Rl ( RB R� R� RR Re ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRC 1 s c C sE | j | � } | j r. | j j | | � n | j j | | � d S( N( t _elementsRR R� t process_deletest process_saves( RB R� R@ ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� > s c C s t g � S( N( R� ( RB R� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� E s c C s d | j j | j | j f S( Ns %s(%s, isdelete=%s)( t __class__R R� RR ( RB ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt __repr__L s c c sg x` | j | � D]O } xF | j | D]7 } | j | \ } } | | j k r$ | r$ | Vq$ q$ Wq Wd S( N( R� R< R@ RR ( RB R� R R RR Rm ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� S s ( R� RR Re R� ( R R� R� RC R� R� R� R� ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� . s t PostUpdateAllc B s/ e Z d Z d � Z e j d � d � � Z RS( R RR R� c C s+ | | _ | | _ d | j | f | _ d S( NR� ( R RR t _sort_keyR� ( RB R� R RR ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRC ^ s s sqlalchemy.orm.persistencec C sr t j j } | j | j \ } } g | D]& } | j | d | j k r) | ^ q) } | j | j | | | � d S( Ni ( R t preloadedt orm_persistenceRA R R@ RR t post_update( RB R� t persistenceR@ Rt R� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� c s 3( R RR R� ( R R� R� RC R t preload_moduleR� ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� [ s Rv c B sA e Z d Z d � Z e j d � d � � Z d � Z d � Z RS( R R� c C s4 | | _ d | j f | _ | | j k s0 t � d S( NRv ( R R� R� Rq t AssertionError( RB R� R ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRC o s s sqlalchemy.orm.persistencec C s2 t j j j | j | j | j t t � | � d S( N( R R� R� t save_objR R� RL ( RB R� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� t s c c s� t | j | j t t � � } | j j } t | | � } x8 | D]0 } t | | � } | j j | | f � | Vq@ Wx= | j | j D]+ } | j | | � } | j | | t � q� Wd S( N( R� R� R RL Rq Rw t SaveUpdateStateR? Rl R; R� R� ( RB R� R@ Rq t delete_allR R� R t states_for_prop( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� | s c C s d | j j | j f S( Ns %s(%s)( R� R R ( RB ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s ( R R� ( R R� R� RC R R� R� R� R� ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRv l s Rw c B sA e Z d Z d � Z e j d � d � � Z d � Z d � Z RS( R R� c C s4 | | _ d | j f | _ | | j k s0 t � d S( NRw ( R R� R� Rq R� ( RB R� R ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRC � s s sqlalchemy.orm.persistencec C s2 t j j j | j | j | j t t � | � d S( N( R R� R� t delete_objR R� R( RL ( RB R� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s c c s� t | j | j t t � � } | j j } t | | � } x8 | D]0 } t | | � } | j j | | f � | Vq@ Wx= | j | j D]+ } | j | | � } | j | | t � q� Wd S( N( R� R� R R( RL Rq Rv t DeleteStateR? Rl R; R� R� ( RB R� R@ Rq t save_allR R� R R� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s c C s d | j j | j f S( Ns %s(%s)( R� R R ( RB ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s ( R R� ( R R� R� RC R R� R� R� R� ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRw � s t ProcessStatec B s) e Z d Z d � Z d � Z d � Z RS( R� RR R R� c C s1 | | _ d | j f | _ | | _ | | _ d S( NR� ( R� R� RR R ( RB R� R� RR R ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRC � s c C s� | j } | j } | j } g | D]9 } | j | k r" | j | k r" | j | k r" | ^ q" } | j | � | j g g | D] } | j ^ q~ } | r� | j | | � n | j | | � d S( N( R� R� RR t difference_updateR R� R� ( RB R� R� t cls_R� RR t rt our_recsR@ ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s &c C s, d | j j | j t j | j � | j f S( Ns %s(%s, %s, delete=%s)( R� R R� Ri t state_strR RR ( RB ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s ( R� RR R R� ( R R� R� RC R� R� ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s R� c B s8 e Z d Z d � Z e j d � d � � Z d � Z RS( R R R� c C s1 | | _ | j j | _ d | j j f | _ d S( NR� ( R R Rq R� R� ( RB R� R ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRC � s s sqlalchemy.orm.persistencec C s� t j j } | j } | j } g | D]* } | j | k r% | j | k r% | ^ q% } | j | � | j | | j g g | D] } | j ^ q{ | � d S( N( R R� R� R� R R� R� R ( RB R� R� R� R� R R� R� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s 7 c C s d | j j t j | j � f S( Ns %s(%s)( R� R Ri R� R ( RB ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s ( R R R� ( R R� R� RC R R� R� R� ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s R� c B s8 e Z d Z d � Z e j d � d � � Z d � Z RS( R R R� c C s1 | | _ | j j | _ d | j j f | _ d S( NR� ( R R Rq R� R� ( RB R� R ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyRC � s s sqlalchemy.orm.persistencec C s� t j j } | j } | j } g | D]* } | j | k r% | j | k r% | ^ q% } | j | � | j g g | D] } | j ^ qr } | j | g | D] } | j | d r� | ^ q� | � d S( Ni ( R R� R� R� R R� R R� R@ ( RB R� R� R� R� R R� R� R@ R� ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s 7 &c C s d | j j t j | j � f S( Ns %s(%s)( R� R Ri R� R ( RB ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� s ( R R R� ( R R� R� RC R R� R� R� ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyR� � s N( t __doc__R9 R R RI R Ri R R R R6 R� R7 R� Rd R� R� R� Rv Rw R� R� R� ( ( ( sL /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/unitofwork.pyt <module> s( u� H 2-%%$