File: //opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyc
�
���ec @@ s� d Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m
Z
d d l m Z d d
l m Z d d l
m Z d d l
m Z d
d l m Z d
d l m Z d
d l m
Z
d
d l m Z d
d l m Z d
d l m Z d
d l m Z d
d l m
Z d
d l m Z d
d l m Z e
j � Z d � Z e
j d � e! d � � Z" e
j# d d d d e! �e
j d � e! d � � � Z$ d � Z% e& e& e& e& e' e
j( e
j( d � Z) e& e& e& e& e& e' e
j( e
j( d � Z* e& e& e& e& e& d! � Z+ e& e& e& d" � Z, d# � Z- e& e& e& e& d$ � Z. d% � Z/ d& � Z0 d' � Z1 d( � Z2 d) � Z3 d* e4 f d+ � � YZ5 d, � Z6 d- S(. s� private module containing functions used to convert database
rows into object instances and associated state.
the functions here are called primarily by Query, Mapper,
as well as some of the attribute loading strategies.
i ( t absolute_importi ( t
attributes( t exc( t
path_registry( t strategy_options( t _DEFER_FOR_STATE( t _RAISE_FOR_STATE( t _SET_DEFERRED_EXPIRED( t _none_set( t state_stri ( t future( t util( t result_tuple( t ChunkedIteratorResult( t FrozenResult( t SimpleResultMetaData( t LABEL_STYLE_TABLENAME_PLUS_COL( t SelectStatec
@ s� t � � _ i � _ � j } | j } � j j oV t | j � d k oV | j d j � yq t
t g � j j D] } | j � � � ^ qo � � \ � } } � j
r� � j s� � j r� t j d � � n Wn. t k
r� t j � � � j � Wd QXn Xd � } d � } � j j rkg � j j D]< } � j
r;| n$ | j sV| j sV| j r\t n d ^ q&}
nb g � j j D]O } � j
r�| n7 | j r�| j r�| | j j � n | j r�t n d ^ qx}
t | | d |
�} � � � � f d � } � j j d t! � r3t
| d � � � � f d
� } n t" | | d � d � d
� j# j$ �}
|
j% j& t' d | d � � � |
_% � j j( r�d � } d | f |
_) n � j
r�|
j
� j
� n |
S( s� Return a :class:`.Result` given an ORM query context.
:param cursor: a :class:`.CursorResult`, generated by a statement
which came from :class:`.ORMCompileState`
:param context: a :class:`.QueryContext` object
:return: a :class:`.Result` object representing ORM results
.. versionchanged:: 1.4 The instances() function now uses
:class:`.Result` objects and has an all new interface.
i i s� Can't use yield_per with eager loaders that require uniquing or row buffering, e.g. joinedload() against collections or subqueryload(). Consider the selectinload() strategy for better flexibility in loading objects.Nc S@ s t j d � � d S( Ns@ Can't use the ORM yield_per feature in conjunction with unique()( t sa_exct InvalidRequestError( t entry( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt
_no_unique[ s c @ s � f d � } | S( Nc @ s t j d � � � d S( Nsk Can't apply uniqueness to row tuple containing value of type %r; this datatype produces non-hashable values( R R ( t obj( t datatype( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt goa s ( ( R R ( ( R sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt
_not_hashable` s t _unique_filtersc 3@ s� x� t r� | } i � _ | r: � j | � } | sF PqF n � j � } � rx � d } g | D] } | | � ^ q] } n8 g | D]+ } t g � D] } | | � ^ q� � ^ q } x- � j j � D] \ } } | j � | � q� W| V| s Pq q Wd S( Ni ( t Truet partialst fetchmanyt
_raw_all_rowst tuplet post_load_pathst itemst invoke( t sizet yield_pert fetcht proct rowt rowst patht post_load( t contextt cursort processt
single_entity( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt chunks� s"
"8 t prebuffer_rowsc @ s
t � � S( N( t iter( R# ( t _prebuffered( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR/ � s t source_supports_scalarst rawt dynamic_yield_pert filteredt is_single_entityc S@ s t j d � � d S( Ns~ The unique() method must be invoked on this Result, as it contains results that include joined eager loads against collections( R R ( R ( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt require_unique� s (* t
_new_runidt runidR t
compile_statet _has_mapper_entitiest load_optionst _only_return_tuplest lent _entitiest supports_single_entityt listt zipt
row_processorR$ t loaders_require_bufferingt loaders_require_uniquingR R t ExceptionR t safe_reraiset closet _legacy_uniquingt use_id_for_hasht _non_hashable_valuet _null_column_typet idt Nonet columnt typeR t execution_optionst gett FalseR
R+ t _is_server_sidet _attributest uniont dictt multi_row_eager_loaderst _unique_filter_state( R, R+ R; R6 t query_entityt labelst extraR R t entt unique_filterst row_metadataR/ t resultR8 ( ( R2 R+ R, R- R. sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt instances( s^
7
O_ s sqlalchemy.orm.contextc C@ s� t j j } | r | j � n | j j | d t �} | j } z1t | _ g t | j � D]$ \ } } t
| | j � r\ | ^ q\ } g | j D] }
|
j ^ q� } t
| g | j D] }
|
j ^ q� � } g }
x� | j � D] } xc | D][ } | | d k r� | j t j | | � t j | | � d | d i d i �| | <q� q� W|
j | | � � q� W| j |
� SWd | | _ Xd S( sz Merge a :class:`_engine.FrozenResult` back into a :class:`_orm.Session`,
returning a new :class:`_engine.Result` object with :term:`persistent`
objects.
See the section :ref:`do_orm_execute_re_executing` for an example.
.. seealso::
:ref:`do_orm_execute_re_executing`
:meth:`_engine.Result.freeze`
:class:`_engine.FrozenResult`
t legacyt loadt
_recursivet _resolve_conflict_mapN( R t preloadedt orm_contextt
_autoflusht ORMSelectCompileStatet _create_entities_collectionRT t autoflusht enumerateR@ t
isinstancet
_MapperEntityt _label_nameR t _extra_entitiest rewrite_rowsRO t _mergeR t instance_statet
instance_dictt appendt
with_new_rows( t sessiont statementt
frozen_resultRd t querycontextt ctxRl t it et mapped_entitiesR^ t keyst keyed_tupleRa t newrow( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt merge_frozen_result� s6
%
s :func:`_orm.merge_result`t alternativesy The function as well as the method on :class:`_orm.Query` is superseded by the :func:`_orm.merge_frozen_result` function.t becomes_legacyc C@ sd t j j } | j } | r( | j � n t | t � rO | } t | j � } n d } | j
j | d t �} | j
} z�t | _
| o� t | j � d k } | rt | j d | j � r g | D]< } | j t j | � t j | � d | d i d i �^ q� }
q5t | � }
n g t | j � D]$ \ } } t | | j � r(| ^ q(}
g }
g | j D] } | j ^ qb} t | g | j D] } | j ^ q�� } x� | D]� } t | � } xc |
D][ } | | d k r�| j t j | | � t j | | � d | d i d i �| | <q�q�W|
j | | � � q�W| rH| j |
� St |
� SWd | | _
Xd S( s� Merge a result into the given :class:`.Query` object's Session.
See :meth:`_orm.Query.merge_result` for top-level documentation on this
function.
Rc i i Rd Re Rf N( R Rg Rh Rx Ri Rn R R1 t dataRO Rj Rk R Rl RT R? R@ Ro Rs R Rt Ru RB Rm Rp R Rq Rv t with_data( t queryt iteratorRd R{ Rx Rz R| Rl R. t instanceRa R} R~ R R^ R� R� R' R� ( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt merge_result sR
I %
c C@ s� | j j | � } | d k r� t j | � } | j rP | j j | � rP t j S| j r� | t j
@sm t j S| t j @s~ | Sy | j
| | � Wq� t j k
r� | j | g � d SXn | Sd Sd S( sq Look up the given key in the given session's identity map,
check the object for expired state if found.
N( t identity_mapRS RO R Rt t inheritst mappert isat PASSIVE_CLASS_MISMATCHt expiredt SQL_OKt PASSIVE_NO_RESULTt RELATED_OBJECT_OKt
_load_expiredt orm_exct ObjectDeletedErrort _remove_newly_deleted( Rx R� t keyt passiveR� t state( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt get_from_identityb s"
c
C@ sm | d k r# | d }
| d } n
d }
} t | | |
d | d | d | d | d | d | d | d
| �S( s. Load the given identity key from the database.i i R= t
refresh_statet with_for_updatet only_load_propst identity_tokent no_autoflusht bind_argumentsRR N( RO t load_on_pk_identity( Rx Ry R� R= R� R� R� R� R� RR t identR� ( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt
load_on_ident� s
c C@ s� | } | j � } | j s" t � d d l m }
m } | d k rP |
j } n | j t j
k rn | j } n | j } | d k r�| j d } | j
\ } } d | k r,t g t | j | � D]% \ } } | d k r� | | j ^ q� � } t j | | � } t | � t | � k r,t j d � q,n t j | i t d 6� f | _ t g t | | j � D] \ } } | | j | f ^ qa� } n d } | d k r�t } | | _ n* | j d k r�t } | j | _ n t } | r| j r| i | j j d 67} | j | j � } n t! | | d | d | d | d
| �\ } } | | _ d | _" | rn| i t d 67} n t j# j$ |
i | d 6� }
| j% | d
| d |
d | �j& � j' � } y | j( � SWn t) j* k
r�d SXd S( s6 Load the given primary key identity from the database.i ( t QueryContextt ORMCompileStatet plugin_subjectso fully NULL primary key identity cannot load any object. This condition may raise an error in a future release.t
_orm_adaptt
_current_patht
version_checkR� R� R� Ri t _sa_orm_load_optionst paramsRR R� N(+ t _clonet _is_lambda_elementt AssertionErrorR+ R� R� RO t default_load_optionst _compile_optionsR t default_select_compile_optionst default_compile_optionst _propagate_attrst _get_clauset setRC t primary_keyR� t sql_utilt adapt_criterion_to_nullR? R t warnt _deep_annotateR t _where_criteriaRX t _for_update_argRT R= t load_patht parentt optionst _set_get_optionst _order_byt
EMPTY_DICTt
merge_witht executet uniquet scalarst oneR� t
NoResultFound( Rx Ry t primary_key_identityR= R� R� R� R� R� R� RR R� t qR� R� t compile_optionsR� R� t _get_paramst colt valuet nonest id_valR� R� R� t new_compile_optionsRa ( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR� � sz
"
8 c C@ s� i } i } | r | | d <n | r2 | | d <n | rO | | d <t | d <n | rh t | � | d <n | r{ | | d <n | r� | | 7} n | r� | | 7} n | | f S( Nt _version_checkt _populate_existingt _refresh_statet _for_refresh_statet _only_load_propst _refresh_identity_token( R t frozenset( t compile_optt load_optt populate_existingR� R� R� R� R� R= ( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR� " s$
c K@ s
| r | j | � }
n | j }
i } | j | j d | � | o_ t | � d k o_ | d j } xZ |
D]R }
| r� |
j | k r� qi n |
j | | | | d | d | d | d | | �qi W| d k r| | j k r| r� | j
| } n | } | j | � n d S( Nt memoized_setupsi i����R� t column_collectiont memoized_populatorst check_for_adapt( t _iterate_polymorphic_propertiest _polymorphic_propertiesR� R R? t is_aliased_classR� t setupRO t polymorphic_ont columnsRv ( R; R� R[ R) t adapterR� t with_polymorphicR� t polymorphic_discriminatort kwt poly_propertiest quick_populatorsR� R� t pd( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt _setup_entity_queryB s4
%
c C@ s t j d t | � f � d S( Nsm Loading context for %s has changed within a load/refresh handler, suggesting a row refresh operation took place. If this event handler is expected to be emitting row refresh operations within an existing load or refresh operation, set restore_load_context=True when establishing the listener to ensure the context remains unchanged when the event handler completes.( R R� R ( R� ( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt _warn_for_runid_changed| s c
@ s* � j � � j }
d � f } | j |
j | d � } | d k r�� j }
�
d k ry |
j � f d � �
D� � }
n | j � j d t � } g } i g d 6g d 6g d 6g d 6g d 6g d 6g d
6} � d k r � j } | r g | D] } | j | ^ q� } n | j
| � � n d � i | d 6| d 6� d
6} xO|
D]G} | | k r�| | } | t k r�| d j | j
| j f � q�| t k r�| d j | j
t f � q�| t k r�| d j | j
| j f � q�d } | r | j | } | d k r | j | t � } q n | s;| j | t � } n | r^| d j | j
| f � q�| j � | | � | | | � qF| j | � qFW| j |
j | | � n | d } d � | j � D� �
x1 | d D]% } | j � | | � | | �
� q�W� j � � j j j r&� j j | n | � � j j � � j pG� j � t � j j j! � � t � j j j" � � t � j j j# � � � r�� j j j# � n t j$ � t j% � � j j& � � j' � � j( � � j) � � r&� j* } | d k r | r | j | } n | j | � � q&d � n � r| d k rd | j f } | � j k r�� j | j+ d t, f f k r�� j- � j | j. d | � } n � j- d | � } | r| | k r�
d k s�t/ � t0 � | | � } t1 j2 � � | j3 | | | � qn t1 j4 � � �
� � � rK� j
� � d k r[� j5 � � � q[n d � | d
� � j6 rpt j7 � n t j � � � � � � � � � � � �
� � �
� � � � � � � � � � � f d � } � j8 r&| r&� r&� � � � f d � } t9 | � | � | | | | | � } n | S( s] Produce a mapper level row processor callable
which processes rows into mapped instances.t gettersc 3@ s | ] } � j | Vq d S( N( t _props( t .0t k( R� ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pys <genexpr>� s R� t newt quickt deferredt expiret delayedt existingt eagert cached_populatorst todot primary_key_getterc S@ s% i | ] \ } } t | � | � q S( ( RB ( R� R� R� ( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pys
<dictcomp> s t loadert selectinload_polymorphict entitiesc
@ s� � rB � } | j � } � | � } | j � k } t } t } n � � | � � f } � j | � } | d k r� � | � } � | � } | j � k } | } t } � rM� rM| rMt � | | | � � qMnx � | d � r� d St } t } t } � j j � } � | � } � | � } | | _ � | _
� | _ � j | | � � } � | k rht } n | st| r�| r�� s�| r�� | _
� | _ n t � | | | | � | | �
� | r�| j } | rF� r| j j j | � � | j | k rt | � qn � r�� � j | � | j | k rCt | � qCq�n> � r�| j j j | � �
� | j � k r�t | � q�n | s�| j r�� r��
r�| j | �
� q�| j | � � q�n � r�� j | t � q�n� | j }
| � j k } | s|
s�
d r�t � | | | | � |
�
� } | r�� r�| j } | j j j | � | � | j | k r�t | � q�n | j | | � q�n � r�� j r�� j | t � n | S( Ni R� ( R R: R RT RS RO t _validate_version_idt
class_managert new_instanceR� R� t
session_idt _add_unpresentR= R� t _populate_fullt managert dispatchRd R� Rx t refresht modifiedt _committ _commit_allt add_statet unloadedR t _populate_partialt invoke_all_eagers( R' R� R� t dict_t isnewt currentloadt loaded_instancet identitykeyt effective_populate_existingt existing_runidR t to_load( R+ t identity_classR� Ru Rt t is_not_primary_keyt load_evtR� t loaded_as_persistentR� R� t persistent_evtR� t
populatorsR* R� t propagated_loader_optionst refresh_evtt refresh_identity_keyR� R: R t session_identity_mapR� t version_id_getter( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt _instances s�
c @ s1 � � | � � f } � | d � s) | Sd Sd S( Ni ( RO ( R' R ( R R� R R� ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt ensure_no_pk s N(: t _identity_classR; RS R RO t _prop_sett intersectionR R� R� t
_tuple_getterR Rv R� t _deferred_column_loaderR RT R t _raise_column_loadert _gettert create_row_processorR� R! R t current_pathR) Rx R� R� t always_refresht boolR R Rd R
R Rt Ru t hash_keyR: R� R� t version_id_colt strategyR t _should_selectin_loadt
local_optsR� t _load_subclass_via_int PostLoadt callable_for_pathR� t for_contextt _identity_key_from_statet allow_partial_pkst
issupersett polymorphic_mapt _decorate_polymorphic_switch( R[ R� R+ Ra R) R� R� R� R� t _polymorphic_fromR; t
getter_keyR� t propsR� R� R� t pk_colst ct propR� t gettert adapted_colR3 R� t selectin_load_viat callable_R% R& ( ( R+ R R� Ru Rt R R R� R R� R� R R� R R* R� R R! R" R� R: R R# R� R$ sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt _instance_processor� s
#
W� c @ ss | j } t | j j � d k � | j rE | j | � \ � � � n | j \ � � � � � � � f d � } | S( Ni c
@ s� | j } � f | j � f } � j | � } | j j | _ | j i | j d 67_ | j ru | j d t � } n | j
j | t d g | D]0 \ } } � r� | j
d d n
| j
d ^ q� � � j � j � j � d S( NR� R� t primary_keysi i ( R� t
_with_optionsR� R; R� R� R� R� RR R Rx R� RX R� R� R� t all(
R+ R) t statest load_onlyt effective_entityt
orig_queryR� t q2R� t
load_attrs( t disable_optt
enable_optR� t zero_idx( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt do_load; s ( R� R? t base_mapperR� R� t _subclass_load_via_int _subclass_load_via_in_mapper( R+ R) t entityR� RW ( ( RT RU R� RV sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR7 1 s c
C@ s� | r| j | _ x( | d D] \ } }
|
| � | | <q W| r� xx | d D]5 \ } } | j | d � | rN | j j | � qN qN Wn4 x1 | d D]% \ } } | r� | j j | � q� q� Wx( | d D] \ } } | | | | � q� Wx� | d D] \ } } | | | | � q� Wn� | | j k r�| | _ x7 | d D]+ \ } }
| | k r:|
| � | | <q:q:WxV | d D] \ } } | | | | � qtWn+ x( | d D] \ } } | | | | � q�Wd S( NR� R� R� R� R� ( R: t popRO t expired_attributest addR� (
R+ R' R� R R R� R R� R R� RF t set_callablet populator( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR T s2 c
C@ s� | sP | j | } xN| d D]+ \ } }
| | k r |
| | | � q q Wn| } | | j | <x7 | d D]+ \ } } | | k rn | | � | | <qn qn WxP | d D]D \ } } | | k r� | j | d � | r� | j j | � q� q� q� Wx7 | d D]+ \ } }
| | k r� |
| | | � q� q� Wx7 | d D]+ \ } }
| | k r5|
| | | � q5q5Wx7 | d D]+ \ } }
| | k ro|
| | | � qoqoW| S( NR� R� R� R� R� R� ( R R\ RO R] R^ (
R+ R' R� R R R� R R R R� R` RF R_ ( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR � s2
c C@ se | j | | | j � | | � k ra t j d t | � | j | | | j � | | � f � � n d S( NsW Instance '%s' has version id '%s' which does not match database-loaded version id '%s'.( t _get_state_attr_by_columnR3 R� t StaleDataErrorR ( R� R� R R' RF ( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR � s c @ s� | d k r | � n � j � � d k r. � S� rD � j � � n � � � � � �
f d � } t j | � � �
j � � � � � � � � � f d � }
|
S( Nc @ s{ y � j | } Wn! t k
r4 t d | � � nC X| � k rE d S| j � � sX t St � | � � � � d � �Sd S( Ns* No such polymorphic_identity %r is definedR@ ( R> t KeyErrorR� RO R� RT RJ ( t
discriminatort
sub_mapper( R� R+ R� R) R[ Ra ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt configure_subclass_mapper� s"
c @ s� � | � } | d k r� � | } | r2 | | � S| t k r� � | � } | ry t j d | � � j | � f � � q� d Sq� � | � Sn2 � | � } | r� t j d | � f � � n d Sd S( Ns� Row with identity key %s can't be loaded into an object; the polymorphic discriminator column '%s' refers to %s, which is not a sub-mapper of the requested %ssj Row with identity key %s can't be loaded into an object; the polymorphic discriminator column '%s' is NULL( RO RT R R R> ( R' Rd R% R ( R& RF t instance_fnR� t polymorphic_instancesR� ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt polymorphic_instance� s,
( RO R� R� R t PopulateDictR- ( Rg R+ R[ R� Ra R) R� R� R& Rf Ri ( ( R� R+ R& RF Rg R� R) Rh R� R[ Ra sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR? � s &R8 c B@ s\ e Z d Z d
Z d � Z d � Z d � Z e d � � Z e d � � Z e d � � Z
RS( s4 Track loaders and states for "post load" operations.t loadersRN t load_keysc C@ s% i | _ t j � | _ d | _ d S( N( Rk R t OrderedDictRN RO Rl ( t self( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt __init__ s c C@ s | | j | <d S( N( RN ( Rn R� t overwrite( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR % s c C@ s� | j s
d St j j | � } x� | j j � D]} \ } } } } } g | j j � D]- \ } } | j j j | � rT | | f ^ qT }
|
r/ | | | |
| j
| | � q/ q/ W| j j � d S( N( RN R t PathRegistryt coerceRk t valuesR! R R� R� Rl t clear( Rn R+ R) t tokent limit_to_mapperR� t argR� R� Rp RN ( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR" , s %'#c C@ s7 | j j | j � } | d k r3 | r3 | | _ n | S( N( R RS R) RO Rl ( t clsR+ R) R� t pl( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR: : s c C@ s) | j | j k o( | | j | j j k S( N( R) R Rk ( Rn R+ R) R� ( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt path_existsA s c O@ s\ | j | j k r% | j | j } n t � } | j | j <| | | | | f | j | <d S( N( R) R R8 Rk ( Rx R+ R) Rv Ru t loader_callableRw R� Ry ( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR9 H s ( Rk RN Rl ( t __name__t
__module__t __doc__t __slots__Ro R R" t classmethodR: Rz R9 ( ( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR8 s c
C@ s9 | j } | s+ t j d t | � � � n t | j � } t } t | t j @� p\ | j j } | r� | j
| j j � � } n | j
r| j r| j | | � } | d
k rd d l m } | | | � j t j | � j d � � }
t | |
d
d | d | d | �} qn | t k r| r3| j } nc g | j D] } | j | j ^ q=}
| j j
|
� r�t j d t | � � � n | j | � } t j | � r�| j s�t j! | � r�t" j# d t | � � d
St | t$ j% | � j& t' � | d | d | d | �} n | r5| d
k r5t j( | � � n d
S( s4 initiate a column-based attribute refresh operation.sQ Instance %s is not bound to a Session; attribute refresh operation cannot proceedi ( t
FromStatementt *R� R� R� s_ Instance %s cannot be refreshed - it's not persistent and does not contain a full primary key.sw Instance %s to be refreshed doesn't contain a full primary key - can't be refreshed (and shouldn't be expired, either).N() Rx R� t DetachedInstanceErrorR R1 R� RT R t NO_AUTOFLUSHt
autocommitR) t attrsR� R� t concretet _optimized_get_statementRO R� R� R� R t Loadt undeferR� R� t _columntopropertyR] R R R; R t issubsetR< R= R t warn_limitedR
t selectt set_label_styleR R� ( R� R� t attribute_namesR� Rx t has_keyRa R� Ry R� t stmtt identity_keyR� t pk_attrs( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt load_scalar_attributesS s` &
N(7 R~ t
__future__R t R R R� R R t baseR R R R R R R R
t engineR t
engine.resultR
R R t sqlR� t sql.selectableR R t counterR9 Rb t preload_moduleR R� t
deprecated_20R� R� RO RT R� R� R� R� R� R� RJ R7 R R R R? t objectR8 R� ( ( ( sG /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt <module> s� � ; P & t 1 � � # : " Y8