Ñò
‰„[Jc @ sü d Z d d k l Z l Z l Z d d k l Z l Z d d k l Z d d k l
Z
e Z e Z
d e i f d „ ƒ YZ d e f d „ ƒ YZ e i e ƒ d
e f d „ ƒ YZ d e f d
„ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d S( sd The internals for the Unit Of Work system.
Includes hooks into the attributes package enabling the routing of
change events to Unit Of Work objects, as well as the flush()
mechanism which creates a dependency structure that executes change
operations.
A Unit of Work is essentially a system of maintaining a graph of
in-memory objects and their modified state. Objects are maintained as
unique against their primary key identity using an *identity map*
pattern. The Unit of Work then maintains lists of objects that are
new, dirty, or deleted and provides the capability to flush all those
changes at once.
iÿÿÿÿ( t utilt logt topological( t
attributest
interfaces( R ( t
_state_mappert UOWEventHandlerc B s2 e Z d Z d „ Z d „ Z d „ Z d „ Z RS( sd An event handler added to all relation attributes which handles
session cascade operations.
c C s
| | _ d S( N( t key( t selfR ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt __init__% s c C s^ t | ƒ } | oG t | ƒ i | i ƒ } | i i o | | j o | i | ƒ qZ n | S( N( t _state_sessionR t get_propertyR t cascadet save_updatet add( R t statet itemt initiatort sesst prop( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt append( s c C s} t | ƒ } | of t | ƒ i | i ƒ } | i i o= | | i j o- | i i t i
| ƒ ƒ o | i | ƒ qy n d S( N( R
R R R R t
delete_orphant newt mappert
_is_orphanR t instance_statet expunge( R R R R R R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt remove1 s
c C sÇ | | j o | St | ƒ } | ož t | ƒ i | i ƒ } | d j o+ | i i o | | j o | i | ƒ n | i i o= | | i j o- | i
i t i
| ƒ ƒ o | i | ƒ qà n | S( N( R
R R R t NoneR R
R R R R R R R R ( R R t newvaluet oldvalueR R R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt set; s
' ( t __name__t
__module__t __doc__R R R R ( ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyR s
t UOWTransactionc B s› e Z d Z d „ Z e d „ Z e e e d d „ Z d „ Z d „ Z
e d „ Z d „ Z d „ Z
d „ Z d
„ Z e d „ ƒ Z d „ Z d
„ Z RS( sg Handles the details of organizing and executing transaction
tasks during a UnitOfWork object's flush() operation.
The central operation is to form a graph of nodes represented by the
``UOWTask`` class, which is then traversed by a ``UOWExecutor`` object
that issues SQL and instance-synchronizing operations via the related
packages.
c C sC | | _ | i | _ t ƒ | _ h | _ h | _ t ƒ | _ d S( N( t sessiont _mapper_flush_optst mapper_flush_optsR t dependenciest tasksR t
processors( R R$ ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyR T s c C sÎ d | | f } | | i j oU | i | \ } } | o7 | o/ t i | | d t ƒ} | | f | i | %s)i i N( t class_R ( t .0t d( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pys . s s Dependency sort:
( R t sort_with_cyclesR' R( Re RI R R< t _sort_circular_dependenciesR R7 R8 R9 t joint str(
R t _[1]t tt nodesRa R t cyclesRB t _[2]t i( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyR[ s" D 7
N( R R! R" R RW R3 R- R RC RG RH R< RP RV R` R^ t propertyRf Rj R[ ( ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyR# J s
RK c B s e Z d Z d d „ Z e i d „ ƒ Z e d „ ƒ Z d „ Z
e e d „ Z d „ Z
d „ Z d „ Z d „ Z e d
„ ƒ Z e d „ ƒ Z e d „ ƒ Z e d
„ ƒ Z e d „ ƒ Z e d „ ƒ Z e d „ ƒ Z e d „ ƒ Z d „ Z d „ Z RS( sC A collection of mapped states corresponding to a particular mapper.c C s€ | | _ | d j o | | _ h | | 6| _ n | | _ | | i | <| | _ h | _ g | _ t ƒ | _ t ƒ | _ d S( N(
t uowtransactionR RI t _inheriting_tasksR RE t dependent_tasksR R' t cyclical_dependencies( R Ry R RI ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyR 8 s
c C s t | i i ƒ ƒ S( N( RY R t polymorphic_iterator( R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt inheriting_mappersR s c c sF x? | i D]4 } | i i i | d ƒ } | d j o | Vq
q
Wd S( sì Return an iterator of UOWTask objects corresponding to the
inheritance sequence of this UOWTask's mapper.
e.g. if mapper B and mapper C inherit from mapper A, and
mapper D inherits from B:
mapperA -> mapperB -> mapperD
-> mapperC
the inheritance sequence starting at mapper A is a depth-first
traversal:
[mapperA, mapperB, mapperD, mapperC]
this method will therefore return
[UOWTask(mapperA), UOWTask(mapperB), UOWTask(mapperD),
UOWTask(mapperC)]
The concept of "polymporphic iteration" is adapted into
several property-based iterators which return object
instances, UOWTaskElements and UOWDependencyProcessors in an
order corresponding to this sequence of parent UOWTasks. This
is used to issue operations related to inheritance-chains of
mappers in the proper order based on dependencies between
those mappers.
N( R~ RI Rz t getR ( R R Rs ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt polymorphic_tasksV s
c C s | i o | i S( sx return True if this UOWTask is 'empty', meaning it has no child items.
used only for debugging output.
( RE R' ( R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt is_emptyy s c C sL | | i j o t | ƒ | i | <} n | i | } | i | | ƒ d S( N( RE t UOWTaskElementt update( R R R4 R5 t rec( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyR s
c C s/ | i i | g | i d t d t | ƒ ƒd S( s» issue a 'post update' UPDATE statement via this object's mapper immediately.
this operation is used only with relations that specify the `post_update=True`
flag.
R@ RA N( R t _save_objRy RW R ( R R RA ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyR= ‰ s
c C s1 x* | i D] } | | i j o t Sq
Wt Sd S( sU return True if the given object is contained within this UOWTask or inheriting tasks.N( R€ RE RW R- ( R R RB ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt __contains__• s
c C s- y | i | i SWn t j
o t SXd S( sO return True if the given object is marked as to be deleted within this UOWTask.N( RE R5 RJ R- ( R R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyRH ž s c s t ‡ f d † ƒ } | S( su return a property that will adapt the collection returned by the
given callable into a polymorphic traversal.c 3 s4 x- | i D]" } x ˆ | ƒ D] } | Vq Wq
Wd S( N( R€ ( R RB R„ ( t fn( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt
collectionª s
( Rx ( R‡ Rˆ ( ( R‡ s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt _polymorphic_collection¦ s c C s
| i i ƒ S( N( RE RX ( R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyRf ± s c C s | i S( N( Rf ( R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt polymorphic_elementsµ s c C s0 g } | i D] } | i p | | q q ~ S( N( RŠ R5 ( R Rr R„ ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt polymorphic_tosave_elements¹ s c C s0 g } | i D] } | i o | | q q ~ S( N( RŠ R5 ( R Rr R„ ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt polymorphic_todelete_elements½ s c C sT g } | i D]? } | i d j o) | i o | i t j o | | i q q ~ S( N( RŠ R R R4 R5 R- ( R Rr R„ ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt polymorphic_tosave_objectsÁ s c C sT g } | i D]? } | i d j o) | i o | i t j o | | i q q ~ S( N( RŠ R R R4 R5 RW ( R Rr R„ ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt polymorphic_todelete_objectsÈ s c C s | i S( N( R' ( R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt polymorphic_dependenciesÏ s c C s | i S( N( R| ( R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/unitofwork.pyt! polymorphic_cyclical_dependenciesÓ s c & s h ‰ ‡ ‡ f d † } t ˆ ƒ ‰ ‡ ‡ f d † } h } g } xv ˆ D]n } xe | i D]Z } | | ƒ p | i | ƒ n x3 | i i D]% } | i | g ƒ }
|
i | ƒ qŠ WqY WqI Wh } g } xúˆ D]ò} xé| i D]Þ}
xÕ|
i D]Ê} | i } |
| | <|
| j o qî n xš| |
D]Ž} | i i p | | ƒ o q&n | i | i } } | i
} | i | ˆ d t ƒ\ } } } | o | o | o q&n ˆ i
| i ƒ } | | | } xç | D]ß } | d j o qÑn | | j o! | i | d t ƒ| | | s *é
ÿ + O