[Jc
@ s d Z d d k Z d d k Z d d k Z d d k l Z e d i Z d d k l Z l
Z
l Z l Z
d d k l Z l Z l Z l
Z d d k l Z l Z l Z d d k l Z l Z l Z d d k l Z l Z l Z l Z l Z l Z l! Z! l" Z" d
d d d
f Z# e i$ Z% e& a' e& a( g Z) e
i* d Z+ e
i, i- Z. e/ Z0 e/ Z1 e/ Z2 e/ Z3 e/ Z4 e/ Z5 e/ Z6 d
e7 f d YZ8 e i9 e8 d Z: d Z; d Z< d Z= d Z> d Z? d Z@ d S( s5 Logic to map Python classes to and from selectables.
Defines the :class:`~sqlalchemy.orm.mapper.Mapper` class, the central configurational
unit which associates a class with a database table.
This is a semi-private module; the main configurational API of the ORM is
available in :class:`~sqlalchemy.orm.`.
iN( t chaint collections( t sqlt utilt logt exc( t
expressiont visitorst operatorsR ( t
attributesR t sync( t MapperPropertyt EXT_CONTINUEt PropComparator( t ExtensionCarriert
_INSTRUMENTORt _class_to_mappert _state_has_identityt
_state_mappert class_mappert instance_strt state_strt Mappert _mapper_registryR t
object_mappert NO_ATTRIBUTEc B s e Z d Z d? d? e d? d? d? d? e e d? d? d? d? d? e d? d? e e d? d? d? e d Z d Z d Z d Z d Z
d Z d Z d Z
e e d Z d
Z d Z d Z d
Z d Z d Z d Z d Z d Z d Z e e d Z e e d Z e d Z d Z d Z e d Z e i! d Z" e i! d Z# d? e d Z$ d? d Z% e d Z& e i! d Z' e i! d Z( d! Z) d" Z* d# Z+ d$ Z, d% Z- d& Z. d' Z/ d( Z0 d? d) Z1 d* Z2 d+ Z3 d, Z4 d- Z5 d. Z6 d/ Z7 d0 Z8 d1 Z9 d2 Z: e d3 Z; d4 Z< d? d5 Z= e i! d6 Z> e d? e d7 Z? d8 Z@ d9 ZA d: ZB d; ZC d? d? d? d? d? d< ZD d= ZE d> ZF RS(@ s Define the correlation of class attributes to database table
columns.
Instances of this class should be constructed via the
:func:`~sqlalchemy.orm.mapper` function.
c C s- t i | t d | _ d | _ | | _ | | _ |
o t i |
| _ n
|
| _ | | _
| | _ | | _ t
| _ | | _ | | _ | | _ | | _ | | _ | p h | _ | | _ g | _ | | _ | | _ | | _ |
| _ g | _ h | _ d | _ t
| _ d | _ | | _ | o: t i! d | o t" i# d n d | f | _$ n | d j o
d | _$ n} t% | t& t' f o= t% | d t( t& t' f o
| | _$ q| d f | _$ n* | d j o t" i# d n
d | _$ t% | i t) i* o' t i+ d | | i i, | _ n | i$ oA t% | i$ d t) i* o' | i$ d | i$ d i, f | _$ n | | _- | o t i! d n | d j o
h | _. n
| | _. | | _/ | | _0 t
| _1 | i2 | i3 | i4 | i5 | i6 t7 a8 | i9 d
d S(
s Construct a new mapper.
Mappers are normally constructed via the :func:`~sqlalchemy.orm.mapper`
function. See for details.
t class_sS select_table option is deprecated. Use with_polymorphic=("*", selectable) instead.sS select_table can't be used with with_polymorphic (they define conflicting settings)t *i s$ Invalid setting for with_polymorphics mapper %s creating an alias for the given selectable. References to the original selectable may be misinterpreted by queries, polymorphic_on, etc. Consider passing an explicit selectable.alias() construct instead.i s polymorphic_fetch option is deprecated. Unloaded columns load as deferred in all cases; loading can be controlled using the "with_polymorphic" option.t constructedN( R N(: R t assert_arg_typet typeR t Nonet
class_managert primary_key_argumentt non_primaryt to_listt order_byt always_refresht version_id_colt concretet Falset singlet inheritst local_tablet inherit_conditiont inherit_foreign_keyst extensiont _init_propertiest allow_null_pkst delete_orphanst batcht eager_defaultst
column_prefixt polymorphic_ont _dependency_processorst _validatorst _clause_adaptert _requires_row_aliasingt _inherits_equated_pairst select_tablet warn_deprecatedt sa_exct
ArgumentErrort with_polymorphict
isinstancet tuplet listt
basestringR t _SelectBaseMixint warnt aliast polymorphic_identityt polymorphic_mapt include_propertiest exclude_propertiest compiledt _configure_inheritancet _configure_extensionst _configure_class_instrumentationt _configure_propertiest _configure_pkst Truet _new_mapperst _log( t selfR R+ t
propertiest primary_keyR" R* R, R- R. R$ R% R& R5 t _polymorphic_mapRG t polymorphic_fetchR' R; R? R0 R2 R4 RI RJ R3 ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt __init__I s !
$'
c C s t | _ | i ot | i t o t | i d t | _ n t | i | i i p, t i
d | i i | i i i f n | i | i i j o> | i o d p d } t i
d | | i i | f n | i
d
j o+ | i i
| _
| i i | _ t | _ n | i
| i i
j o | i o> | i
| _ x | i D] } | i o
t | _ qRqRWq| i p" t i | i i
| i
| _ n t i | i i | i
| i | _ t i | i } t i | i i d | | _ n
| i
| _ | i! o | i o | i i" | _" n
| i | _" | i# d
j o | i i# | _# n x4 | i D]& } t i$ | d t i$ | d qkW| i% t j o1 | i o& | i i% t j o | i i% | _% n | i i& | _& | i i' | _' | i i i( | | i i) | _) | i i* | _* | i! d
j o` | | i& | i! <| i pB x? | i D]- } | i o | i i+ | i | _ Pq\q\WqqnL t | _* | | _) | i
| _ | i! o | | i& | i! t __name__R" R+ R t mapped_tableRQ R) R' t iterate_to_rootR5 R9 R, t sqlutilt join_conditionR t joinR t to_setR- t criterion_as_pairst onclauseR: RG t _identity_classR& t reset_memoizedR$ RH R2 t addt base_mappert _all_tablest corresponding_column( RT t npt mappert fks( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyRL sz
#
"$"
.
c C s t i } | i } | o+ x( t i | D] } | i | q, Wn | i o9 x | i i D]$ } | | j o | i | q^ q^ WnM xI t D]A } t | t o
| } n | | j o | i | q q Wt | _ x | D] } | i i
| q Wd S( s Go through the global_extensions list as well as the list
of ``MapperExtensions`` specified for this ``Mapper`` and
creates a linked list of those extensions.
N( R t
OrderedSetR. R# Rm R* t global_extensionsR@ R R t append( RT t extlistR. t ext_objt ext( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyRM s*
c s4 t i i } i oC | p | i d j o t i d n | _ t t
R. t instrument_classt register_classt _load_scalar_attributest infot getR R( t eventst add_listenert _event_on_initt _event_on_init_failuret _event_on_resurrectR t iterate_attributesR@ t typest FunctionTypet hasattrR R7 ( RT t managert event_registryt keyt methodt nameR ( ( RT s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyRN = sP
c C sY t | _ t | d o
| ` n | i o' | i i | j o t i | i n d S( Nt _compile_failed(
RQ RK R R R" R Rr R t unregister_classR ( RT ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt dispose s
c
s t i i _ i p t i d t i n h _ h _ t i
t g } i D] } | | i
qh ~ } t i
d | D } t i i g } i i | xs | D]k } | i o9 | i | i o& t i | i i | i | s c 3 sH xA | ]: } t | d p | i i j o i | Vq q Wd S( t tableN( R R t _cols_by_tablet _columntoproperty( R t col( RT ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pys s i sJ Mapper %s could not assemble any primary key columns for mapped table '%s't ignore_nonexistent_tabless Identified primary key columns: ($ Re t find_tablesRc t tablesR= R t strt
_pks_by_tableR R t
column_setR R t proxy_setR_ Ro t updateRV t
issupersett ordered_column_sett intersectionR t _readonly_propsR! R Rt Rm t lenR> t descriptionR* R' t reduce_columnsRp RQ RS ( RT t _[1]R t all_colst pk_colsR t tt kt _[2]R RV ( ( RT s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyRP sN
6 &&
0
0
c C ss t i | _ | _ t i | _ t i | _ | i o7 x4 | i i D] \ } } | i
| | t qN Wn | i oh xe | i i i D]M \ } } | | i j o1 | i
| | d t o | i | | t q q Wn x | i i D] } | | i j o q n | i p d | i } | i
| i | d | i i i | o q n x8 | i D]* } | | i j o | i | i } qgqgW| i
| | d t d t q W| i o | i | i j o | i i | i } | p t } | i } n t } | i
| i | i d t o t i d | i n | i
| i t | d | d t d t n d S( Nt localt t initt setparents6 Cannot exclude or override the discriminator column %rt _no_instrument( R t OrderedPropertiest columnsR t OrderedDictt _propst column_dictR R/ t iteritemst _configure_propertyR( R* t _should_excludet _adapt_inherited_propertyRc R4 R R+ t contains_columnRd RQ R5 Rp R= R t ColumnProperty( RT R t propt columnt
column_keyRr R t dont_instrument( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyRO sB
*
+
c C sa | i p | i | | d t d t n4 | | i j o# | i | t d | d t n d S( NR R ( R' R R( R t ConcreteInheritedPropertyRQ ( RT R R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR s
c
C sd | i d | | i i f t | t pQt i | } | d } t i | p t i
d | | f n | i i | d } t | t oE | i | j o | i } n | i i | | i d | q~| d j p t | t od g } xK | D]C } | i i | } | p t i
d | n | i | qWt | } q~t i
d | i | f n t | t oW| i i | i d }
|
d j oY | i d }
t | d o8 t |
d p |
i | i j o | i i | qbnV t | d oE |
i | i j o2 |
| i |
i j o | i |
i i |
n t | d
p- |
| i j p | i d | i j | _ n |
| i | Can't compile synonym '%s': no column on table '%s' named '%s'R R (2 RS t __class__Rb R@ R R R# R t is_columnR= R> R R R R t parentt copyR Rv R Rc Rp R R R R R Rm R5 R R R t ComparablePropertyt SynonymPropertyt
descriptort getattrR t _is_userland_descriptorR( R R R R t
set_parentR" R R` R R t post_instrument_class(
RT R R R R R R t
mapped_columnR t mcR t descRr ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR s
$:-
7
c C s | i o
t o | St i z y t o | i d St a z | i o
t o | SxY t t D]K } t | d t
o t i d | i
n | i p | i qj qj Wt
a | SWd t
a XWn/ d d k } | i d } | | _
n XWd t i Xd S( s Compile this mapper and all other non-compiled mappers.
This method checks the local compiled status as well as for
any new mappers that have been defined, and is safe to call
repeatedly.
NR sr One or more mappers failed to compile. Exception was probably suppressed within a hasattr() call. Message was: %sii ( RK RR t _COMPILE_MUTEXt acquiret _already_compilingt _post_configure_propertiesRQ RB R R R( R= R R t syst exc_infot release( RT Rr R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyRZ n s8
c C s | i d g } | i i D] \ } } | | | f q! ~ } xi | D]a \ } } | i d | | i | j o | i o | i n | i o | i | qJ qJ W| i d t | _ d S( s Call the ``init()`` method on all ``MapperProperties``
attached to this mapper.
This is a deferred configuration step which is intended
to execute once all mappers have been constructed.
s$ _post_configure_properties() starteds initialize prop s% _post_configure_properties() completeN(
RS R R R t _compile_startedR t _compile_finishedR RQ RK ( RT R R R t l( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR s
6
c C s1 x* | i D] \ } } | i | | q
Wd S( s^ Add the given dictionary of properties to this mapper,
using `add_property`.
N( R t add_property( RT t dict_of_propertiesR t value( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt add_properties s
c C s* | | i | <| i | | d | i d S( s; Add an individual MapperProperty to this mapper.
If the mapper has not been compiled yet, just adds the
property to the initial properties dictionary sent to the
constructor. If this Mapper has already been compiled, then
the given MapperProperty is compiled immediately.
R N( R/ R RK ( RT R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR s
c C sq | i oc | i i d | i i d | i o
| i i p
t | i | i o d p d d | n d S( Nt (t |s |non-primaryR s ) ( t _should_log_infot loggerR R Rb R+ R R R" ( RT t msg( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyRS s
Nc C sq | i oc | i i d | i i d | i o
| i i p
t | i | i o d p d d | n d S( NR R s |non-primaryR s ) ( t _should_log_debugR t debugR Rb R+ R R R" ( RT R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt
_log_debug s
Nc C s d t | | i i f S( Ns ( t idR Rb ( RT ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt __repr__ s c C sK d | i i d | i o
| i i p
t | i | i o d p d S( Ns Mapper|R s |non-primaryR ( R Rb R+ R R R" ( RT ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt __str__ s 5c C s~ t } xq | i D]c } xD | i D]9 \ } } t i | i | | d t | o t Sq# W| p
t | i } q W| S( Nt
optimistic( R( Rd R1 R R t
has_parentR t bool( RT t statet oRr R t cls( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt
_is_orphan s
c C s
| | i j S( N( R ( RT R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt has_property s c C s# | i | i | d | d | S( s6 return a MapperProperty associated with the given key.t resolve_synonymst raiseerr( RZ t
_get_property( RT R R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt get_property s
c C s | i i | d } | o4 x1 t | t o | i i | i d } q Wn | d j o* | o# t i d t | | f n | S( Ns Mapper '%s' has no property '%s'( R R R R@ R R R= R R ( RT R R R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR s !#c C s | i | i i S( s1 return an iterator of all MapperProperty objects.( RZ R t
itervalues( RT ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt iterate_properties s
c C s | d j o t | i } n | or g } t i | D] } | t | q> ~ } xE | D]3 } | i | p t i d | | f qa qa Wn g } | oT t t i
| d t } g } | D]! } | i | j o | | q q ~ } n | S( s given a with_polymorphic() argument, return the set of mappers it represents.
Trims the list of mappers to just those represented within the given selectable, if present.
This helps some more legacy-ish mappings.
R s %r does not inherit from %rt include_aliases(
RB t polymorphic_iteratorR R# R t isaR= R R_ Re R RQ R+ ( RT t spect
selectablet mappersR t mR R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _mappers_from_spec
s
0 %9c C su | i } xe | D]] } | | j o q n | i o t i d q | i p | i | i | i } q q W| S( s given a list of mappers (assumed to be within this mapper's inheritance hierarchy),
construct an outerjoin amongst those mapper's mapped tables.
s^ 'with_polymorphic()' requires 'selectable' argument when concrete-inheriting mappers are used.( Rc R' R= R R) t outerjoinR+ R, ( RT R t from_objR
( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _selectable_from_mappers$ s
c C sW | i oE | i o; | i o1 | i d j o! | i i d | i D Sd Sd S( Nc s s x | ] } | i Vq Wd S( N( RG ( R R
( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pys < s ( R) R* R5 RG R t in_R ( RT ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _single_table_criterion5 s
c C s" | i p | g S| i | i S( N( R? R ( RT ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _with_polymorphic_mappersB s
c C sJ | i p | i S| i \ } } | o | S| i | i | | Sd S( N( R? Rc R R ( RT R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _with_polymorphic_selectableH s
c C s | i o: | p | i d } n | t j o | i d } qD n | i | | } | o | | f S| | i | f Sd S( Ni i ( R? R( R R ( RT R R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _with_polymorphic_argsS s
c c s | d j o
| i } n | p x | i D] } | Vq+ Wn x t i t g } | g | D] } | t | i q\ ~ D]G } t | d t o) | i p | i
d | i j o q n | Vq Wd S( sM Return an iterator of MapperProperty objects which will render into a SELECT.R i N( R R R R t unique_listR RB R R( R5 R ( RT R R R Rr ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _iterate_polymorphic_properties` s
8 "c C s t d d S( Nso Public collection of MapperProperty objects is provided by the get_property() and iterate_properties accessors.( t NotImplementedError( RT ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyRU u s c C s g } | i D]% } | | t i d d | i f q ~ } t i g } | D] \ } } | | | j qM ~ t i | f S( s create a "get clause" based on the primary key. this is used
by query.get() and many-to-one lazyloads to load this item
by primary key.
t type_N( RV R t bindparamR R t and_R R ( RT R RV t paramsR R t v( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _get_clausez s <c sd t i f d } xB | i i D]1 } | i o! t i | i h h | d 6 q+ q+ W S( s Create a map of all *equivalent* columns, based on
the determination of column pairs that are equated to
one another based on inherit condition. This is designed
to work with the queries that util.polymorphic_union
comes up with, which often don't include the columns from
the base table directly (including the subclass table columns
only).
The resulting structure is a dictionary of columns mapped
to lists of equivalent columns, i.e.
{
tablea.col1:
set([tableb.col1, tablec.col1]),
tablea.col2:
set([tabled.col2])
}
c s | i t i j o | i j o | i i | i n t i | i f | i <| i j o | i i | i q t i | i f | i Return True if the this mapper inherits from the given mapper.( R* R ( RT R* R
( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR s
c c s' | } x | o | V| i } q Wd S( N( R* ( RT R
( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyRd s
c c sC t | g } x- | o% | i } | V| i | i q Wd S( sK Iterate through the collection including this mapper and
all descendant mappers.
This includes not just the immediately inheriting mappers but
all their inheriting mappers as well.
To iterate through an entire hierarchy, use
``mapper.base_mapper.polymorphic_iterator()``.
N( t dequet popleftt extendR` ( RT t stackt item( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR s c C s
| i i S( sK Return the primary mapper corresponding to this mapper's class key (class).( R Rr ( RT ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR, s c s_ | i } | o, g } | D] } | | i | q ~ } n | i t f d | D f S( s& Return an identity-map key for use in storing/retrieving an
item from the identity map.
row
A ``sqlalchemy.engine.base.RowProxy`` instance or a
dictionary corresponding result-set ``ColumnElement``
instances to their values within a row.
c 3 s x | ] } | Vq Wd S( N( ( R R ( t row( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pys
s ( RV R Rk RA ( RT R5 t adapterR R R ( ( R5 s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt identity_key_from_row s
,c C s | i t t i | f S( s Return an identity-map key for use in storing/retrieving an
item from an identity map.
primary_key
A list of values indicating the identifier.
( Rk RA R R# ( RT RV ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt identity_key_from_primary_key s c C s | i | i | S( s Return the identity key for the given instance, based on
its primary key attributes.
This value is typically also found on the instance state under the
attribute name `key`.
( R8 t primary_key_from_instance( RT R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt identity_key_from_instance s c C s | i | i | S( N( R8 t _primary_key_from_state( RT R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _identity_key_from_state s c C s t i | } | i | S( sO Return the list of primary key values for the given
instance.
( R t instance_stateR; ( RT R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR9 # s c C s. g } | i D] } | | i | | q ~ S( N( RV t _get_state_attr_by_column( RT R R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR; + s c C s y | i | SWn t j
ot | i i | i d } | o5 t i d | i i | i | i t
| f q t i d | | f n Xd S( NsD Column '%s.%s' is not available, due to conflicting property '%s':%ss* No column %s is configured on mapper %s...( R t KeyErrorR R R R R t UnmappedColumnErrorR R t repr( RT R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _get_col_to_prop. s 5c C s | i | i | | S( N( RB R ( RT R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR> 9 s c C s | i | i | | | S( N( RB t setattr( RT R R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _set_state_attr_by_column< s c C s t i | } | i | | S( N( R R= t# _get_committed_state_attr_by_column( RT R' R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _get_committed_attr_by_column? s c C s | i | i | | d | S( Nt passive( RB t getcommitted( RT R R RG ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyRE C s c
s0 i t f d | D i i j o d Sd t f d Y f d } g } y t } xv t t i D]\ } | i j o
t
} n | o5 | i o* | i t
i | i h h | d 6 q q WWn j
o d SXt i | } t i | d t
S( sv assemble a WHERE clause which retrieves a given state by primary key, using a minimized set of tables.
Applies to a joined-table inheritance mapper where the
requested attribute names are only present on joined tables,
not the base table. The WHERE clause attempts to include
only those tables to minimize joins.
c 3 s# x | ] } | i i Vq Wd S( N( R R+ ( R R ( t props( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pys P s t ColumnsNotAvailablec B s e Z RS( ( Rb t
__module__( ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyRJ T s c s | i } | i } | d j p
| d j o d S| i j oZ i | d t } | t i j o
n t i d | d | i i
| _ nk | i j oZ i | d t } | t i j o
n t i d | d | i i
| _ n d S( NRG R ( R R R R RE RQ R t PASSIVE_NORESULTR R R ( R! t leftcolt rightcolt leftvalt rightval( R RT R RJ ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR# W s
%
R! t
use_labelsN( R R_ Rn R+ R t ExceptionR( t reversedRB Rd RQ R) Rv R t cloned_traverseR, R R t select( RT R t attribute_namesR# t allcondst startRr t cond( ( R RT R RJ RI s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _optimized_get_statementF s&
2c
c s t i } | i i d | f g } x | o | d \ } } } y | d j o8 | i } | i | i | | | | d d f nQ | d j oC | i \ }
} } |
| f V| i | i i d | f n Wq* t j
o | i q* Xq* Wd S( s Iterate each element and its mapper in an object graph,
for all relations that meet the given cascade rule.
``type\_``:
The name of the cascade rule (i.e. save-update, delete,
etc.)
``state``:
The lead InstanceState. child items will be processed per
the relations defined for this object's mapper.
the return value are object instances; this provides a strong
reference so that they don't fall out of scope immediately.
t propertyiRr N(
R t IdentitySetR R t nextRv t cascade_iteratorR t
StopIterationt pop(
RT R R t halt_ont visited_instancest
visitablest iteratort item_typet parent_stateR R t instance_mappert corresponding_state( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR^ w s
,
'c C s h } x5 | i i D]$ } x | i D] } | | | | | j o1 | | j o | i+ | | | | i/ | | }! | i? | |
| | |! |! i@ | | |! iA 7} qW|! iB o6 | tC | j o# t iD d | tC | f qX n | o9| iE } x*| D] \ } } } }
} |
i= | i> | | }! |! iF }" |" d j oo xl tG | i | D]S \ }# } | i+ | | d j o. tC |" |# j o | iH | | |" |# q q Wn | i? | |
| | |! |! iI | x> | iJ D]0 } | iK o tL iM | | | | | iK q\
q\
Wqr Wq q W| px| D] \ } } }
} }
| iN iO d | iP D }$ |$ o tQ | |$ n | iR oK | iS oA | i | | _ | i iT | iU | i d | d | iS n | p4 d | i j o | i iV | |
| i q q
d | i j o | i iW | |
| i q
q
Wn d S( sL Issue ``INSERT`` and/or ``UPDATE`` statements for a list of objects.
This is called within the context of a UOWTransaction during a
flush operation.
`_save_obj` issues SQL statements not just for instances mapped
directly by this mapper, but for instances mapped by all
inheriting mappers as well. This is to maintain proper insert
ordering among a polymorphic chain of instances. Therefore
_save_obj is typically called only on a *base mapper*, or a
mapper which does not inherit from any other mapper.
s _save_obj() start, s non-batchedt batchedt
postupdatet post_update_colsR) Nt connection_callablet
before_insertt
before_updatesJ New instance %s with identity key %s conflicts with persistent instance %ssP detected row switch for identity %s. will update %s, remove %s from transactions. _save_obj() table '%s' instance %s identity %si s6 Using polymorphic identity '%s' for insert column '%s'RG i R s? Updated rowcount %d does not match number of objects updated %dc s s x | ] } | i Vq Wd S( N( R ( R t p( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pys s t
refresh_statet only_load_propst after_insertt after_update(X R R R2 t _sort_statest _save_objRQ t mapper_flush_optsR Rv R' R R R< t transactiont
connectionR. Rr Rs R_ t sessiont identity_mapR R= t
is_deletedR t
FlushErrorR t set_row_switchRm R^ Rj R R R R( R R& R5 t shares_lineageRG t defaultR t server_defaultR> R@ R t
ClauseElementt _labelR R t get_state_historyt addedt
get_col_valuet deletedR t clausesR R R R R t executet valuest
_postfetcht last_updated_paramst rowcountt supports_sane_rowcountR t ConcurrentModificationErrort insertt last_inserted_idst enumerateRD t last_inserted_paramsRd R: R
t populatet
unmodifiedR R t
_expire_stateR3 t unloadedt queryt _getRw Rx (% RT t statest uowtransactionRo Rp R) R t tupsRq R
R} Rr t has_identityt instance_keyt row_switchesR t existingRk R R R t pkst isinsertR t value_paramst hasdataR R R t historyt clauset statementt rowsR RV t it readonly( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyRz sd
#
)
%
! $( #
-
!
$
!$
/ 5 % '
,#%
0 $c C s% | i } t | i } | i o. | i | i }
|
o | i |
qV n | i o | i | i n xL | D]D } | i | j o. | | i j o | i | | | | i q{ q{ Wg } g }
| D] } |
| i | q ~
D] } | | i q ~ } | o t
| | n d S( s< Expire attributes in need of newly persisted database state.N( t postfetch_colsRB t
prefetch_colsR5 Rp Rv R& R R RD R ( RT R R} R R t resultproxyR R R t generated_colst poR R R R t deferred_props( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR s
"Fc C s | i o | i d n d | i j oV | i d } g } t | D]+ } | | t | | | | i f qI ~ } nI | i i | } g } t | D] } | | t | | f q ~ } xG | D]? \ } } } d | i j o | i i | | | i q q W| i
}
x0t |
i D] } h } x | D] \ } } } | | i
j o qBn h }
t | p qBn | i | g i |
x. | i
| D] } | i | | |
| i R R& R R R R R R R R t deleteR t supports_sane_multi_rowcountR R R R R ( RT R R Rq R R R R} R Rr Rk R R R R t del_objectsR R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _delete_obj s`
I6 $
'
/ )# % c C s2 x+ | i i | i D] } | i | q Wd S( s Register ``DependencyProcessor`` instances with a
``unitofwork.UOWTransaction``.
This call `register_dependencies` on all attached
``MapperProperty`` instances.
N( R R R6 t register_dependencies( RT t uowcommitt dep( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _register_dependencies s c C s2 x+ | i i | i D] } | i | q Wd S( N( R R R6 t register_processors( RT R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _register_processors s c s i | p o
d n/ | p i t i i i o\ g } D] }
| i |
qj ~ o i n o i q n i f d
g g f d i i
| p
i } n | i d d | i d d | i d d | i d d i
p i
f d } | S( sY Produce a mapper level row processor callable which processes rows into mapped instances.c s t f d D f S( Nc 3 s x | ] } | Vq Wd S( N( ( R R ( R5 ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pys s ( RA ( R5 ( R t identity_class( R5 s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt identity_key s c
s | o? i o i | _ n | i o i i | _ qF n p$ i | \ ( (n | o
} n } | o: g } | D]" } | d | j o | | q q ~ } n x- | D]% \ } }
|
| | | d | | q Wd S( Ni t isnew( t optionst load_optionsR t
_current_patht load_patht _populators( R t dict_R5 R Rv t flagst
populatorsR Rt R t populator( t existing_populatorst new_populatorsRT t contextt pathR6 ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt populate_state s
$
: t
translate_rowt create_instancet populate_instancet
append_resultc
s
o-
| } | t j o
| } q4 n o> | } | d j o# | } | o | | | Sqy n o- i } | d j o i } q n
| } | j o | } t i | } t i | } i o i d t | | n | i
i
j } | }
t } |
oj oc
i oY i
| i | j o9 t i d t | i
| i | f qNn oC } | i } t i | } | i
i
j } t }
t } n[ i o i d | n i o/ xB | d D] } | d j o Pq'q'Wd Sn d | d j o d St } t }
t } o[
| i } | t j o i i } qt i | i }
|
i | n i i } i o i d t | | n t i | } t i | } | | _
i i | _ i | |
p ox | o
i
| _
|
i | R& R R R R' RQ R0 R R t new_instanceR R t setup_instanceR~ t hash_keyt
session_idRm t progresst partialsR t _run_on_loadRv ( R5 R" Rm t
discriminatort _instancet identitykeyR R R R t currentloadt loaded_instancet xR t d_t attrs( R R t polymorphic_instancesR5 RT R Rv t populate_existingR& R R Ru t session_identity_mapR R ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR 6 s
4
$
+N( RV R R5 R t PopulateDictt _configure_subclass_mapperR& R Rk R~ R R. R R R% ( RT R R R6 t polymorphic_fromR. Rv Ru t polymorphic_discriminatorR R R ( ( R R R R R R Ru RT R5 R Rv R R& R R R R R R6 R R s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt _instance_processor s6
(
9c
C s g g } } xz | i i D]i } | i | | | | | \ } } | o | i | i | f n | o | i | i | f q q W| | f S( s@ Produce a collection of attribute level row processor callables.( R R t create_row_processorRv R (
RT R R R5 R6 R R R t newpopt existingpop( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR s
! c s f d } | S( sV Produce a mapper level row processor callable factory for mappers inheriting this one.c sb y i | } Wn# t j
o t d | n X| j o d S| i d S( Ns* No such polymorphic_identity %r is definedR ( RH R? R R R ( R Rr ( RT R R R6 ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt configure_subclass_mapper s
( ( RT R R R6 R ( ( R RT R6 R s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR s N(G Rb RK t __doc__R R( RQ RY RL RM RN R RP RO R R RZ R R R RS R R R R R R R R[ R R R R R t memoized_propertyR R R R RU R R] R R R+ R/ R Rd R R, R7 R8 R: R< R9 R; RB R> RD RF RE RZ R^ R^ Rz R R R R R R R ( ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR A s l R J
< 8 c 2
&
1 "
: c C s
t | _ | S( s Decorate a method as the 'reconstructor' hook.
Designates a method as the "reconstructor", an ``__init__``-like
method that will be called by the ORM after the instance has been
loaded from the database or otherwise reconstituted.
The reconstructor will be invoked with no arguments. Scalar
(non-collection) database-mapped attributes of the instance will
be available for use within the function. Eagerly-loaded
collections are generally not yet available and will usually only
contain the first element. ORM state changes made to objects at
this stage will not be recorded for the next flush() operation, so
the activity within a reconstructor should be conservative.
( RQ R~ ( t fn( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt
reconstructor s c s f d } | S( s Decorate a method as a 'validator' for one or more named properties.
Designates a method as a validator, a method which receives the
name of the attribute as well as a value to be assigned, or in the
case of a collection to be added to the collection. The function
can then raise validation exceptions to halt the process from continuing,
or can modify or replace the value before proceeding. The function
should otherwise return the given value.
c s
| _ | S( N( R ( R ( t names( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt wrap s ( ( R R ( ( R s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt validates s c C s] | i i t } | i d | i j o/ | i i | | i | i i i | | | n d S( s7 Trigger mapper compilation and run init_instance hooks.t
init_instanceN( R R R RZ R. R R R t
original_init( R R t argst kwargst instrumenting_mapper( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR s
c C sY | i i t } d | i j o5 t i | i i | | i | i i i | | | n d S( s Run init_failed hooks.t init_failedN(
R R R R. R t warn_exceptionR R R R ( R R R R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR s c C sQ | i i t } x: t | i | i d D] \ } } | i | | | q* Wd S( Ni ( R R R t zipRV R RD ( R R R R t val( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR s c C s t | d t i d S( NR t sort_key( t sortedR t
attrgetter( R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyRy s c C s> t | } t | } | p t i d t | n t | } t } | i oY | i oN | i | | } | o1 | i
| i | i d d | d | } q n | t j oK | o
| i } n | i | } | i
| i | d | d | } n | o* | d j o t i d t | n d S( s4 initiate a column-based attribute refresh operation.sQ Instance %s is not bound to a Session; attribute refresh operation cannot proceedRv Ru s Instance '%s' has been deleted.N( R t _state_sessionR= t UnboundExecutionErrorR R R( R* R' RZ R t from_statementR R R R< R t ObjectDeletedError( R RV Rr R~ t has_keyR" R R ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyR s$ 5
((A R R t weakrefR t itertoolsR t
__import__R0 t
sqlalchemyR R R R R= t sqlalchemy.sqlR R R Re t sqlalchemy.ormR R
t sqlalchemy.orm.interfacesR R R
t sqlalchemy.orm.utilR R R R R R R R t __all__t WeakKeyDictionaryR R( RR R Ru t symbolR t threadingt RLockR R R R R t RelationPropertyR R R
t objectR t class_loggerR R R R R Ry R ( ( ( s9 /usr/lib/python2.6/site-packages/sqlalchemy/orm/mapper.pyt sT "" :