Ñò
‰„[Jc @ sÀ d d k l Z d d k Z d d k l Z d d k l Z l Z l Z l Z l
Z
l Z d d k l
Z
d d k l Z d e f d „ ƒ YZ d e f d
„ ƒ YZ d e f d „ ƒ YZ d S(
iÿÿÿÿ( t EMPTY_SETN( t util( t PASSIVE_NORESULTt PASSIVE_OFFt NEVER_SETt NO_VALUEt manager_of_classt ATTR_WAS_SET( t
attributes( t
interfacest
InstanceStatec B sd e Z d Z d Z d Z d Z e Z e Z d Z
d Z d 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 e d
„ Z d „ Z d „ Z d „ Z d „ Z d „ Z! d „ Z" e d „ ƒ Z# e d „ ƒ Z$ d d „ Z% d „ Z& d „ Z' d „ Z( e d „ Z) d „ Z* d d „ Z+ RS( s/ tracks state information at the instance level.c C sg | i | _ | | _ t i | | i ƒ | _ t | _ h | _ t | _
h | _ h | _ h | _
d S( N( t __class__t class_t managert weakreft reft _cleanupt objt Falset modifiedt callablest expiredt committed_statet pendingt parents( t selfR R
( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt __init__ s c C s | i o
| ` n d S( N( t
session_id( R ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt detach s
c C s | i o
| ` n | ` d S( N( R R ( R ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt dispose$ s
c C s2 | i ƒ } | o | i | ƒ n | i ƒ d S( N( t _instance_dictt removeR ( R R t
instance_dict( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyR ) s c C s d S( N( t None( R ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyR / s c C s/ | i ƒ } | d j o t i | ƒ Sh Sd S( N( R R! R R ( R t o( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt dict2 s
c C s" | i o | i d p
| i f S( Ni ( t keyt insert_order( R ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt sort_key: s c C s | i S( N( R ( R ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt check_modified> s c
O s÷ | d | d | d } } } | i } x' | i i D] } | | | | | ƒ q6 W| i oD | i t j o4 t | _ t i | i ƒ | i ƒ | _ h | _
n y | i i | d | Ž SWn4 x' | i i D] } | | | | | ƒ qÏ W‚ n Xd S( Ni i i (
R
t eventst on_initt mutable_attributesR t MutableAttrInstanceStateR R R R t mutable_dictt
original_initt on_init_failure( t mixedt kwargsR t instancet argsR
t fn( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt initialize_instanceB s
c K s" | i i | ƒ i | | i | S( N( R
t get_implt get_historyR# ( R R$ R0 ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyR6 X s c C s | i i | ƒ S( N( R
R5 ( R R$ ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyR5 [ s c C s/ | | i j o t ƒ | i | s R R R R R R c 3 s: x3 | ], } | ˆ i j o | ˆ i | f Vq q Wd S( N( RD ( RE RF ( R ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pys † s R$ t load_optionst expired_attributesR, t load_path( s committed_states pendings parentss modifieds expireds callables( s keys load_optionss expired_attributess mutable_dict( R t updateRI R t serialize_path( R t d( ( R s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt __getstate__y s
c s" t i ˆ d | i ƒ | _ ˆ d i | _ t | i ƒ | _ ˆ i d h ƒ | _ ˆ i d h ƒ | _
ˆ i d h ƒ | _ ˆ i d t ƒ | _
ˆ i d t ƒ | _ ˆ i d h ƒ | _ | i
o ˆ d | _ n | i i ‡ f d † d Dƒ ƒ d
ˆ j o t i ˆ d
ƒ | _ n d S( NR1 R R R R R R c 3 s4 x- | ]& } | ˆ j o | ˆ | f Vq q Wd S( N( ( RE RF ( t state( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pys ž s R$ RG RH R, RI ( s keys load_optionss expired_attributess mutable_dict( R R R R R R R R
R; R R R R R R R t _strong_objRD RJ R t deserialize_pathRI ( R RN ( ( RN s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt __setstate__Ž s
c C s# | i i | ƒ i | | i ƒ d S( N( R
R5 t
initializeR# ( R R$ ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyRR ¦ s c C s$ | i i | d ƒ | | i | Ï s ( R] R
t iterkeys( R ( ( R s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt unloadedÆ s c C st t | i ƒ | _ | d j o{ | i i ƒ } t | _ | i oF | p+ | i ƒ } | o | i i
| ƒ qƒ q‡ | i i
| ƒ n t | _ t } n t } | i } xÄ | D]¼ } | i | i
} | p | i p
| | j o/ | i i | ƒ | i o | | i | R$ R= ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt expire_attributesÒ s8
c C s' | i | d ƒ | i i | d ƒ d S( s@ remove the given attribute and any callables associated with it.N( RS R! R ( R R$ R> ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt resetô s c C s d S( N( R! ( R ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyR ú s c C s
| i ƒ S( N( R ( R ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt _is_really_noneý s c C s | i | i j } | ož | t j oB | o% | i | j o | | i } qd qh | i | | ƒ } n | o) | d t t f j o | i | ƒ } n | o | | i | i R[ t should_copyt previousR9 t needs_committedR ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt modified_event s$
c C sÉ | i } x_ | D]W } | | j o1 | | i j o! | | i i | | | i ƒ q | i i | d ƒ q Wt | _ xN | i i
| ƒ D]: } | | j o' | i i | ƒ | i i | d ƒ q‡ q‡ Wd S( s8 Commit attributes.
This is used by a partial-attribute load operation to mark committed
those attributes which were refreshed from the database.
Attributes marked as "expired" can potentially remain "expired" after
this step if a value was not populated in state.dict.
N(
R
R* R= t commit_to_stateR RS R! R R RH t intersectionR R ( R R> Ra RY R$ ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt commit s
!
c C sê h | _ h | _ | i oD x- | i i | ƒ D] } | i i | d ƒ q/ W| i i | ƒ n xE | i i D]7 } | | j o$ | i | i
i | | | i ƒ qm qm W| o | i o | i
i | ƒ n t | _ | _ d | _ d S( s commit all attributes unconditionally.
This is used after a flush() or a full load/refresh
to remove all pending state from the instance.
- all attributes are marked as "committed"
- the "strong dirty reference" is removed
- the "modified" flag is set to False
- any "expired" markers/callables are removed.
Attributes marked as "expired" can potentially remain "expired" after this step
if a value was not populated in state.dict.
N( R R RH Rr R RS R! t difference_updateR
R* R= Rq R Rc Rd R R RO ( R R> R R$ ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt
commit_all2 s
(N( (, t __name__t
__module__t __doc__R! R R$ t runidR RH RG RI R% R, RO R R R R R t propertyR# R& R' R4 R6 R5 R8 R R@ RC RM RQ RR RU R\ RV R` Ri Rj R Rk Rp Rs Ru ( ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyR
sL " R+ c B sh e Z d „ Z d d „ Z d „ Z e e e ƒ Z e d „ ƒ Z d „ Z d „ Z
d „ Z d „ Z RS( c C s h | _ t i | | | ƒ d S( N( R, R
R ( R R R
( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyR V s c C sv | i i d t ƒ o t S| d j o
| i } n x: | i i D]( } | i | i i | | ƒ o t SqB Wt Sd S( NR (
RD R; R Rb R! R# R
R* R= t check_mutable_modified( R R> R$ ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt
_get_modifiedZ s
c C s | | i d ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pys q s ( R# R] R
R_ ( R ( ( R R> s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyRV k s c C s) | i o | i | _ | i ƒ Sd Sd S( s do a check modified/resurrect.
This would be called in the extremely rare
race condition that the weakref returned None but
the cleanup handler had not yet established the
__resurrect callable as its replacement.
N( R t$ _MutableAttrInstanceState__resurrectR R! ( R ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyRk v s
c C s* | i i | d ƒ t i | | | ƒ d S( N( R, RS R! R
Rj ( R R$ R> ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyRj … s c C sU | i | i ƒ o | i | _ n/ | i ƒ } | o | i | ƒ n | i ƒ d S( sx weakref callback.
This method may be called by an asynchronous
gc.
If the state shows pending changes, the weakref
is replaced by the __resurrect callable which will
re-establish an object reference on next access,
else removes this InstanceState from the owning
identity map, if any.
N( R| R, R R R R R ( R R R ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyR ‰ s
c C ss | i i d | ƒ } t i | | i ƒ | _ | | _ | i i | i ƒ | i i
i d | | ƒ | i | ƒ | S( s= A substitute for the obj() weakref function which resurrects.RN t on_resurrect(
R
t new_instanceR R R R RO RD RJ R, R( RB RC ( R R ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt __resurrectž s
N(
Rv Rw R R! R| R~ Rz R RV Rk Rj R R ( ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyR+ U s R7 c B s) e Z d Z d „ Z d „ Z d „ Z RS( s A writable placeholder for an unloaded collection.
Stores items appended to and removed from a collection that has not yet
been loaded. When the collection is loaded, the changes stored in
PendingCollection are applied to it to produce the final result.
c C s" t i ƒ | _ t i ƒ | _ d S( N( R t IdentitySett
deleted_itemst OrderedIdentitySett added_items( R ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyR » s c C s8 | | i j o | i i | ƒ n | i i | ƒ d S( N( R„ R R† Rf ( R R} ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt append¿ s c C s8 | | i j o | i i | ƒ n | i i | ƒ d S( N( R† R R„ Rf ( R R} ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyR Ä s ( Rv Rw Rx R R‡ R ( ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyR7 ³ s ( t sqlalchemy.utilR R t
sqlalchemyR t sqlalchemy.orm.attributesR R R R R R t sqlalchemy.ormR R t objectR
R+ R7 ( ( ( s8 /usr/lib/python2.6/site-packages/sqlalchemy/orm/state.pyt s .ÿ N^