Ñò
‰„[Jc @ s0 d Z d d k l Z l Z d d k i Z d d k l Z l Z l Z
l Z d d k l
Z
d d k l Z l Z d d k l Z l Z d e i f d „ ƒ YZ e i e ƒ d
e i f d „ ƒ YZ d e f d
„ ƒ YZ d e f d „ ƒ YZ d e e
f d „ ƒ YZ d „ Z d e f d „ ƒ YZ d S( s‚ Dynamic collection API.
Dynamic collections act like Query() objects for read operations and support
basic add/delete mutation.
iÿÿÿÿ( t logt utilN( t
attributest object_sessionR t
strategies( t Query( t _state_has_identityt has_identity( R t collectionst
DynaLoaderc B s e Z d „ Z d „ Z RS( c
C sM t | _ t i | | d t d t d | i i d | i i d | i i ƒd S( Nt useobjectt
impl_classt
target_mappert order_byt query_class( t Truet is_class_levelR t _register_attributet DynamicAttributeImplt parent_propertyt mapperR
R ( t selfR ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt init_class_attribute s c C s d S( N( NN( t None( R t
selectcontextt pathR t rowt adapter( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt create_row_processor% s ( t __name__t
__module__R R ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR s R c B s¤ e Z e Z e Z d
d „ Z e d „ Z d
e d „ Z d „ Z
d „ Z d „ Z d „ Z
d
d „ Z d „ Z e d „ Z e d
„ Z e d „ Z e d „ Z RS( c K sx t t | ƒ i | | | | | | _ | | _ | p
t | _ n0 t | i ƒ j o
| | _ n t | ƒ | _ d S( N(
t superR t __init__R R
t
AppenderQueryR t
AppenderMixint mrot mixin_user_query( R t class_t keyt typecallableR R
R t kwargs( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR . s
c C s2 | o | i | d t ƒi S| i | | ƒ Sd S( Nt passive( t _get_collection_historyR t added_itemsR ( R t statet dict_R) ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt get: s c C sE | o | i | d | ƒi S| i | d | ƒ} | i | i Sd S( NR) ( R* R+ t unchanged_items( R R, R- t user_dataR) t history( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt get_collection@ s c C sˆ | i | | ƒ } | i i | ƒ x+ | i D] } | i | | | p | ƒ q, W| i o* | d j o | i t i | ƒ t ƒ n d S( N(
t _modified_eventR+ t appendt
extensionst trackparentR t sethasparentR t instance_stateR ( R R, R- t valuet initiatort collection_historyt ext( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt fire_append_eventG s
c C sˆ | i | | ƒ } | i i | ƒ | i o* | d j o | i t i | ƒ t ƒ n x+ | i D] } | i
| | | p | ƒ q` Wd S( N( R3 t
deleted_itemsR4 R6 R R7 R R8 t FalseR5 t remove( R R, R- R9 R: R; R< ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt fire_remove_eventQ s
c C sm | i | i j o t | | ƒ | i | i ( R R, R- R) t c( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt get_history| s c C sY | i | i j o | i | i } n t | | ƒ } | p t | | d | ƒS| Sd S( Nt apply_to( R& RB RC ( R R, R) RS ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR* € s c C s+ | | j o | i | | | | ƒ n d S( N( R= ( R R, R- R9 R: R) ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR4 ‹ s
c C s+ | | j o | i | | | | ƒ n d S( N( RA ( R R, R- R9 R: R) ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR@ s
N( R R R t uses_objectsR? t accepts_scalar_loaderR R R. R2 R= RA R3 RH RG RQ RT R* R4 R@ ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR * s
RK c B sJ e Z d Z d „ Z d „ Z d d „ Z d d „ Z d „ Z d „ Z RS( s9 the dynamic analogue to orm.collections.CollectionAdapterc C s | | _ | | _ | | _ d S( N( t attrR, t data( R RX t owner_stateRY ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR – s c C s
t | i ƒ S( N( t iterRY ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt __iter__› s c C s& | i i | i | i i | | ƒ d S( N( RX R4 R, t dict( R t itemR: ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt append_with_eventž s c C s& | i i | i | i i | | ƒ d S( N( RX R@ R, R] ( R R^ R: ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt remove_with_event¡ s c C s d S( N( ( R R^ ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt append_without_event¤ s c C s d S( N( ( R R^ ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt remove_without_event§ s N(
R R t __doc__R R\ R R_ R` Ra Rb ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyRK “ s R" c B st e Z d
Z d „ Z d „ Z d „ Z e e d „ ƒ Z d „ Z d „ Z d „ Z
d
d „ Z d „ Z d „ Z
RS( c C s2 t i | | i d ƒ | i ƒ | _ | | _ d S( N( R R R R t objt instanceRX ( R RX R, ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR s c C sk t | i ƒ } | d j o2 | i o( | i o | i | j o | i ƒ n t | i ƒ p d S| Sd S( N( R Re R t autoflusht flushR ( R t sess( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt __session² s 1c C s
| i ƒ S( N( t _AppenderMixin__session( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt session» s c C s d S( N( R ( t st x( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt ½ s c C s\ | i ƒ } | d j o, t | i i t i | i ƒ d t ƒi ƒ St | i
| ƒ ƒ Sd S( NR) ( Rj R R[ RX R* R R8 Re R R+ t _clone( R Rh ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR\ ¿ s
c C sb | i ƒ } | d j o/ | i i t i | i ƒ d t ƒi i | ƒ S| i
| ƒ i | ƒ Sd S( NR) ( Rj R RX R* R R8 Re R R+ t __getitem__Ro ( R t indexRh ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyRp È s
c C s\ | i ƒ } | d j o, t | i i t i | i ƒ d t ƒi ƒ S| i
| ƒ i ƒ Sd S( NR) ( Rj R t lenRX R* R R8 Re R R+ Ro t count( R Rh ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyRs Ñ s
c C sß | i } | d j oI t | ƒ } | d j o, t i d t i | ƒ | i i f ƒ ‚ q_ n | i o | i | i i
d | ƒ} n | i | i i
ƒ } | i | | i i ƒ } | i i
o | i
| i i
ƒ } n | S( NsŒ Parent instance %s is not bound to a Session, and no contextual session is established; lazy load operation of attribute '%s' cannot proceedRk ( Re R R t sa_exct UnboundExecutionErrort
mapperutilt instance_strRX R& R R t queryt with_parentR
( R Rh Re Rx ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyRo Ú s
'
c C s5 | i i t i | i ƒ t i | i ƒ | d ƒ d S( N( RX R4 R R8 Re t
instance_dictR ( R R^ ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR4 ò s c C s5 | i i t i | i ƒ t i | i ƒ | d ƒ d S( N( RX R@ R R8 Re Rz R ( R R^ ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR@ õ s N( R R R R R Rj Rk t propertyR\ Rp Rs Ro R4 R@ ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR" ª s R! c B s e Z d Z RS( sB A dynamic query that supports basic collection storage operations.( R R Rc ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR! ù s c C s* d | i } t | t | f h | d 6ƒ S( sA Return a new class with AppenderQuery functionality layered over.t AppenderR ( R t typeR" ( t clst name( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR$ ý s
RC c B s e Z d Z d d „ Z RS( sD Overrides AttributeHistory to receive append/remove events directly.c C s³ | o t i | i ƒ } | i } t | | ƒ i t ƒ } g } t i | ƒ D] } | | j o | | qN qN ~ | _ | i | _ | i | _ n g | _ g | _ g | _ d S( N( R t IdentitySetR> R+ R! Rf R? R/ ( R RX R, RU t deletedt addedt collt _[1]t o( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyR s > N( R R Rc R R ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyRC s ( Rc t
sqlalchemyR R t sqlalchemy.exceptionst
exceptionsRt t sqlalchemy.ormR R Rv R t sqlalchemy.orm.queryR t sqlalchemy.orm.utilR R R t AbstractRelationLoaderR t class_loggert
AttributeImplR t objectRK R" R! R$ RC ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/orm/dynamic.pyt s "
iO