Ñò
‰„[Jc @ sô d Z d d k l Z l Z d d k i Z d d k l Z l Z l
Z
d d k l Z l
Z
l 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 f d „ ƒ YZ d e f d „ ƒ YZ d S( s¼ Relationship dependencies.
Bridges the ``PropertyLoader`` (i.e. a ``relation()``) and the
``UOWTransaction`` together to allow processing of relation()-based
dependencies at flush time.
iÿÿÿÿ( t sqlt utilN( t
attributest exct sync( t ONETOMANYt MANYTOONEt
MANYTOMANYc C s, h t t 6t t 6t t 6} | | i | ƒ S( N( t OneToManyDPR t ManyToOneDPR t ManyToManyDPR t direction( t propt types( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt create_dependency_processor s
t DependencyProcessorc B s› e Z e Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z e d „ Z
e d „ Z d „ Z d „ Z
d
„ Z d „ Z d „ Z d
„ Z d „ Z RS( c C sÊ | | _ | i | _ | i | _ | i | _ | i | _ | i | _ | i | _ | i | _ | i | _ | i | _ | i
| _
t | i | i | i
ƒ | _ | i i
p t i d | i ƒ ‚ n d S( Nsy Can't build a DependencyProcessor for relation %s. No target attributes to populate between parent and child are present( R t cascadet mappert parentt secondaryR t post_updatet passive_deletest passive_updatest enable_typecheckst keyt
MapperStubt dependency_markert synchronize_pairst sa_exct
ArgumentError( t selfR ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt __init__ s
c C s | i i i | i ƒ S( sg Return the ``InstrumentedAttribute`` handled by this
``DependencyProecssor``.
( R t
class_managert get_implR ( R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt _get_instrumented_attribute1 s c C s | i ƒ i | ƒ S( s¤ return True if the given object instance has a parent,
according to the ``InstrumentedAttribute`` handled by this ``DependencyProcessor``.
( R" t hasparent( R t state( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR# 8 s c C s
t ƒ ‚ d S( sª Tell a ``UOWTransaction`` what mappers are dependent on
which, with regards to the two or three mappers handled by
this ``DependencyProcessor``.
N( t NotImplementedError( R t uowcommit( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt register_dependencies@ s c C s
t ƒ ‚ d S( s Tell a ``UOWTransaction`` about this object as a processor,
which will be executed after that mapper's objects have been
saved or before they've been deleted. The process operation
manages attributes and dependent operations between two mappers.
N( R% ( R R& ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt register_processorsI s c C s; | | j o d S| i t j o | | f S| | f Sd S( s¨ Given an object pair assuming `obj2` is a child of `obj1`,
return a tuple with the dependent object second, or None if
there is no dependency.
N( t NoneR R ( R t state1t state2( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt whose_dependent_on_whoR s
c C s
t ƒ ‚ d S( s1 This method is called during a flush operation to
synchronize data between a parent and child object.
It is called within the context of the various mappers and
sometimes individual objects sorted according to their
insert/update/delete order (topological sort).
N( R% ( R t taskt deplistR& t delete( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt process_dependencies_ s c C s
t ƒ ‚ d S( sØ Used before the flushes' topological sort to traverse
through related objects and ensure every instance which will
require save/update/delete is properly added to the
UOWTransaction.
N( R% ( R R- R. R& R/ ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt preprocess_dependenciesj s c C s¦ | d j o• | i i | d | i ƒ ow | i i | d t ƒo2 t i d | i | i | i i | i f ƒ ‚ q¢ t i d | i | i | i i f ƒ ‚ n d S( Nt allow_subtypess0 Attempting to flush an item of type %s on collection '%s', which is not the expected type %s. Configure mapper '%s' to load this subtype polymorphically, or set enable_typechecks=False to allow subtypes. Mismatched typeloading may cause bi-directional relationships (backrefs) to not function properly.si Attempting to flush an item of type %s on collection '%s', whose mapper does not inherit from that of %s.( R) R t _canloadR t TrueR t
FlushErrort class_R ( R R$ ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt _verify_canloads s + ) c C s
t ƒ ‚ d S( sÀ Called during a flush to synchronize primary key identifier
values between a parent/child object, as well as to an
associationrow in the case of many-to-many.
N( R% ( R R$ t childt associationrowt clearkeysR& ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt _synchronize s c C s? x8 | i i D]* } | i | | | f | i j o t Sq
Wt S( sú Determine if an action has been performed by the 'reverse' property of this property.
this is used to ensure that only one side of a bidirectional relation
issues a certain operation for a parent/child pair.
( R t _reverse_propertyt _dependency_processorR R4 t False( R R& R R8 t actiont r( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt _check_reverse_action‡ s
c C s t | i | | | | f t no_dependenciesR R" R# R' R( R, R0 R1 R7 R; RA RB RJ RK RN ( ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR s
R c B sD e Z d „ Z d „ Z e d „ Z e d „ Z d „ Z d „ Z RS( c C sT | i o0 | i | i | i ƒ | i | i | i ƒ n | i | i | i ƒ d S( N( R t register_dependencyR R R ( R R& ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR' ¸ s
c C sD | i o | i | i | | i ƒ n | i | i | | i ƒ d S( N( R t register_processorR R ( R R& ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR( ¿ s
c C sa | o7| i p | i d j ox| D] } | i | | i d | i ƒ} | oÞ xg | i D]\ } | d j oI | i | ƒ t j o3 | i | | d t | ƒ | i
| | | g ƒ q^ q^ W| i p | i i oX xU | i
D]F } | d j o3 | i | | d t | ƒ | i
| | | g ƒ qà qà Wq2q) q) Wq]n x | D]} | i | | i d t ƒ} | oì xQ | i D]F } | i | | d t | ƒ | d j o | i
| | | g ƒ qwqwWxM | i D]B } | i i o. | i | ƒ o | i | | d t | ƒ qËqËW| i | | ƒ o1 x. | i
D] } | i | | d t | ƒ q.WqYqEqEWd S( Nt allt passive( R R t get_attribute_historyR t deletedR) R# R> R; R4 RJ R R/ t unchangedt addedt
delete_orphanRK ( R R- R. R& R/ R$ t historyR8 ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR0 Å sD
#
2
!
c
C s« | o| i p| i i o | i d j } xä | D]Ø } | i | | i d | i ƒ} | o xi | i D]^ } | d j oK | i | ƒ t j o5 | i i
o | i | d t ƒqÉ | i | ƒ qk qk W| o6 x3 | i
D]$ } | d j o | i | ƒ qÞ qÞ Wqq6 q6 Wq§nŽxŠ| D]‚} | i | | i d t ƒ} | oÝ x/ | i D]$ } | d j o | i | ƒ qSqSWx¨ | i D]™ } | i i
p | i | d t ƒq…| i | ƒ t j oY | i | d t ƒxC | i i d | ƒ D]( \ } }
| i t i | ƒ d t ƒqîWq…q…Wn | i | | ƒ oj | p" | i | | i d | i ƒ} n | o6 x3 | i
D]$ } | d j o | i | ƒ qsqsWq£q!q!Wd S( NRS RT t isdeleteR/ ( R R R/ R RU R RV R) R# R> RY RE R4 RW RX R t cascade_iteratorR t instance_stateRK R ( R R- R. R& R/ t should_null_fksR$ RZ R8 t ct m( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR1 é sZ
#
)
"
c C s– | } | } | d j p | i o | i | ƒ o d S| i | ƒ | o t i | | i | i i ƒ n& t i | | i
| | i | i i ƒ d S( N( R) R t
is_deletedR7 R t clearR R R t populateR ( R R$ R8 R9 R: R& t sourcet dest( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR; s (
c C s t i | | | i | i i ƒ S( N( R t source_modifiedR R R ( R R& R$ ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyRK s ( RM RO R' R( R> R0 R1 R; RK ( ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR · s $ + t DetectKeySwitchc B sP e Z d Z e Z d „ Z d „ Z e d „ Z e d „ Z d „ Z
d „ Z RS( sw a special DP that works for many-to-one relations, fires off for
child items who have changed their referenced key.c C s d S( N( ( R R& ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR' ( s c C s | i | i | | i ƒ d S( N( RR R R ( R R& ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR( + s c C s+ | o | i o | i | | ƒ n d S( N( R t _process_key_switches( R R- R. R& R/ ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR1 . s c C s* | o | i o | i | | ƒ n d S( N( R Rh ( R R- R. R& R/ ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR0 4 s c
s t ‡ ‡ f d † | Dƒ ƒ } | oè xå g } ˆ i i i ƒ D]t } t | i ˆ i i ƒ oU ˆ i | i j oB | i ˆ i d j o+ t
i | i ˆ i ƒ | j o | | q@ q@ ~ D]K } ˆ i | ƒ t
i t
i | i ˆ i ƒ ˆ i | ˆ i ˆ i i ƒ q» Wn d S( Nc 3 s0 x) | ]" } ˆ i ˆ | ƒ o | Vq q Wd S( N( RK ( t .0t s( R R& ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pys = s ( t sett sessiont identity_mapt
all_statest
issubclassR6 R R t dictR) R R] RE R Rc R R R ( R R. R& t switchersRH t elemRj ( ( R R& s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyRh < s 2
c C s t i | | | i | i i ƒ S( N( R Rf R R R ( R R& R$ ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyRK M s ( RM RO t __doc__R4 RP R' R( R> R1 R0 Rh RK ( ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyRg " s R c B sD e Z d „ Z d „ Z d „ Z e d „ Z e d „ Z d „ Z RS( c C s- t i | | ƒ | i i i t | ƒ ƒ d S( N( R R R t _dependency_processorst appendRg ( R R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR Q s c C sT | i o0 | i | i | i ƒ | i | i | i ƒ n | i | i | i ƒ d S( N( R RQ R R R ( R R& ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR' U s
c C sD | i o | i | i | | i ƒ n | i | i | | i ƒ d S( N( R RR R R R ( R R& ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR( \ s
c C s% | o | i o | i i o | i d j op xm | D]a } | i | d d t | ƒ | i | | i d | i ƒ} | o | i | | | i
ƒ ƒ q7 q7 Wq!n~ xz | D]r } | i | | i d t ƒ} | oJ x* | i D] } | i | | d t | ƒ qÝ W| i | | | i
ƒ ƒ q« q« Wd S( NRS RT (
R R RY R R; R) R4 RU R RJ t sumRX R> ( R R- R. R& R/ R$ RZ R8 ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR0 b s ) )
c C sô | i o d S| oÿ | i i p
| i i oá xÞ | D]Ò } | i | | i d | i ƒ} | o§ | i i o | i ƒ } n
| i ƒ } x{ | D]o } | d j o q’ n | i
| d t ƒx? | i i
d | ƒ D]( \ } }
| i
t i | ƒ d t ƒqÕ Wq’ Wq7 q7 WqðnÜ xØ | D]Ð } | i
| ƒ | i i o° | i | | i d | i ƒ} | o‡ x„ | i D]u } | i | ƒ t j oY | i
| d t ƒxC | i i
d | ƒ D]( \ } }
| i
t i | ƒ d t ƒq°WqkqkWqìq q Wd S( NRT R[ R/ ( R R R/ RY RU R R Rv t non_deletedR) RE R4 R R\ R R] RV R# R> ( R R- R. R& R/ R$ RZ t todeleteR8 R_ R` ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR1 t sF
.
c C s— | d j p | i o | i | ƒ o d S| p
| d j o t i | | i | i i ƒ n3 | i | ƒ t i | | i
| | i | i i ƒ d S( N( R) R Ra R Rb R R R R7 Rc R ( R R$ R8 R9 R: R& ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR; – s (
( RM RO R R' R( R> R0 R1 R; ( ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR P s "R
c B sD e Z d „ Z d „ Z e d „ Z e d „ Z d „ Z d „ Z RS( c C s0 | i | i | i ƒ | i | i | i ƒ d S( N( RQ R R R ( R R& ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR' ¡ s c C s | i | i | | i ƒ d S( N( RR R R ( R R& ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR( « s c C s | i i | i ƒ } g } g } g } | oÄ x«| D]µ } | i | | i d | i ƒ}
|
oŠ x‡ |
i ƒ D]u } | d j p | i | | | d ƒ o qm n h } | i | | | t
| ƒ | i | ƒ | i | | | d ƒ qm Wq5 q5 Wnëxç| D]ß} | i | | i ƒ }
|
o
x€ |
i
D]u } | d j p | i | | | d ƒ o q%n h } | i | | | t
| ƒ | i | | | d ƒ | i | ƒ q%Wx„ |
i D]u } | d j p | i | | | d ƒ o q¨n h } | i | | | t
| ƒ | i | | | d ƒ | i | ƒ q¨Wn | i o¨ | i | | ƒ o• |
p | i | | i d t
ƒ}
n xl |
i D]] } h } t i | | i | d | i i ƒ t i | | i | d | i i ƒ | i | ƒ qsWqù qù W| oÓ | i i t i g }
| i i D]< } | i | j o& |
| t i | i d | i ƒj qq~
Œ ƒ } | i | | ƒ } | i ƒ oE | i! t" | ƒ j o/ t# i$ d | i! | i i% t" | ƒ f ƒ ‚ q¶n | o× | i i t i g } | i i D]@ } | i | j o* | | t i d | i d | i ƒj qÝqÝ~ Œ ƒ } | i | | ƒ } | i ƒ oE | i! t" | ƒ j o/ t# i$ d | i! | i i% t" | ƒ f ƒ ‚ q”n | o# | i i& ƒ } | i | | ƒ n d S( NRT t
manytomanyt old_t type_s] Deleted rowcount %d does not match number of secondary table rows deleted from table '%s': %ds] Updated rowcount %d does not match number of secondary table rows updated from table '%s': %d(' t transactiont
connectionR RU R R t non_addedR) RA R; R> Ru RB RX RV R RK RW R t updateR R R t secondary_synchronize_pairsR R/ R t and_R_ t bindparamt typet executet supports_sane_multi_rowcountt rowcountt lenR t ConcurrentModificationErrort descriptiont insert( R R- R. R& R/ R} t secondary_deletet secondary_insertt secondary_updateR$ RZ R8 R9 RH R_ t statementt resultt _[2]( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR0 ® s~
&
&
&
&
""\# *`# *c
C sÖ | pË xÈ | D]¼ } | i | | i d t ƒ} | o” x‘ | i D]‚ } | i i oo | i | ƒ t j oY | i | d t ƒxC | i i
d | ƒ D]( \ } } | i t i | ƒ d t ƒq’ Wq@ q@ Wq q Wn d S( NRT R[ R/ (
RU R R4 RV R RY R# R> RE R R\ R R] (
R R- R. R& R/ R$ RZ R8 R_ R` ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR1 ö s
# c C sa | d j o d S| i | ƒ t i | | i | | i i ƒ t i | | i | | i i ƒ d S( N( R) R7 R t
populate_dictR R R R R€ ( R R$ R8 R9 R: R& ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR; s
c C s t i | | | i | i i ƒ S( N( R Rf R R R ( R R& R$ ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyRK
s ( RM RO R' R( R> R0 R1 R; RK ( ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR
s
H R c B sM e Z d Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( sý Represent a many-to-many dependency within a flush
context.
The UOWTransaction corresponds dependencies to mappers.
MapperStub takes the place of the "association table"
so that a depedendency can be corresponded to it.
c C s+ | | _ | | _ | i | _ g | _ d S( N( R t base_mapperR6 t _inheriting_mappers( R R R R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR s c C s
t | f ƒ S( N( t iter( R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt polymorphic_iterator s c C s d S( N( ( R R& ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt _register_dependencies s c C s d S( N( ( R R& ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt _register_procesors# s c O s d S( N( ( R t argst kwargs( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt _save_obj& s c O s d S( N( ( R R˜ R™ ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt _delete_obj) s c C s | S( N( ( R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt primary_mapper, s (
RM RO Rs R R• R– R— Rš R› Rœ ( ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyR
s ( Rs t
sqlalchemyR R t sqlalchemy.exceptionst
exceptionsR t sqlalchemy.ormR R R t sqlalchemy.orm.interfacesR R R R t objectR R Rg R R
R ( ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/orm/dependency.pyt
s šk.Pm