Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
triliodata-4-0-patch / contego deb
Repository URL to install this package:
|
Version:
4.0.108 ▾
|
contego
/
home
/
tvault
/
.virtenv
/
lib
/
python2.7
/
site-packages
/
sqlalchemy
/
orm
/
loading.pyc
|
|---|
ó
EYc @@ sG d Z d d l m Z d d l m Z d d l m Z m Z d d l m Z d d l m
Z
d d l m Z m Z d d l
m Z m Z d d
l m Z d d l Z e j Z d Z e j d
e d Z d Z d d d d Z d d d d Z d d d d d Z d Z d Z d Z d Z d Z! 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 utili ( t
attributest exc( t strategy_options( t _none_sett state_str( t _SET_DEFERRED_EXPIREDt _DEFER_FOR_STATE( R Nc #@ s t | _ g | j D] } | j ^ q t k } t | j d k oY | j d j } | r | rq t } q f d } n yNt t g | j D] } | j | | | ^ q \ } } | sÞ t
j d | }
n xï t rÏi | _
| j r| j | j } | s$Pq$n | j } | rV| d } g | D] }
| |
^ q;} n8 g | D]+ }
|
g | D] } | |
^ qm ^ q]} | r©t
j | | } n x | D] }
|
Vq°W| j sá Pqá qá WWn* t k
rý} | j t
j | n Xd S( s$ Return an ORM result as an iterator.i i c @ s t d t | D S( Nc s@ s! | ] \ } } | | Vq d S( N( ( t .0t xt fn( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pys <genexpr>. s ( t tuplet zip( t row( t
filter_fns( sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt filter_fn- s t resultN( t
_new_runidt runidt _entitiesR t idt lent supports_single_entityt listR
t
row_processorR t lightweight_named_tuplet Truet partialst
_yield_pert fetchmanyt fetchallt unique_listt Exceptiont closet raise_from_cause( t queryt cursort contextt entt filteredt
single_entityR t query_entityt processt labelst keyed_tuplet fetcht procR t rowst err( ( R sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt instances sH 4
"5
s sqlalchemy.orm.queryc C@ s× | j } | r | j n | j } z¡t | _ t | j d k } | rº t | j d | j r« g | D]6 } | j t j
| t j | d | d i ^ ql } q»t | } ng t
| j D]$ \ } }
t |
| j rÊ | ^ qÊ } g } g | j D] } | j ^ q}
t j d |
} x | D]
} t | } x] | D]U } | | d k rK| j t j
| | t j | | d | d i | | <qKqKW| j | | q2Wt | SWd | | _ Xd S( s: Merge a result into this :class:`.Query` object's Session.i i t loadt
_recursiveR N( t sessiont
_autoflusht autoflusht FalseR R t
isinstancet
_MapperEntityt _mergeR t instance_statet
instance_dictR t enumeratet _label_nameR R t Nonet appendt iter( t querylibR$ t iteratorR3 R5 R7 R) t instanceR t it et mapped_entitiesR' t keysR- R t newrow( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt merge_resultY s8
C
c C@ s¦ | j j | } | d k r t j | } | j r | t j @sJ 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_mapt getR@ R R< t expiredt SQL_OKt PASSIVE_NO_RESULTt RELATED_OBJECT_OKt
_load_expiredt orm_exct ObjectDeletedErrort _remove_newly_deleted( R5 t keyt passiveRE t state( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt get_from_identity s
c C@ sí | d k r | d } n d } | d k rD | j } | j n | j } | d k rD| j } | j \ } } d | k rÜ t g t | j | D]% \ }
} | d k r | |
j ^ q } t j
| | } n | j | t t
} | | _ t g t | | j D] \ }
} | | j |
f ^ q } | | _ n | d k rht } | j | } n* | j d k rt } | j | _ n t
} | j d t | d | d | d | d | _ y | j SWn t j k
rèd SXd S( s. Load the given identity key from the database.i t populate_existingt
version_checkt only_load_propst
refresh_stateN( R@ t _clonet _get_conditiont _mapper_zerot _get_clauset setR
t primary_keyRV t sql_utilt adapt_criterion_to_nullt
_adapt_clauseR R8 t
_criteriont dictt _paramst
with_lockmodet _for_update_argt _get_optionst boolt _order_byt oneRS t
NoResultFound( R$ RV R] t lockmodeR\ t identt qt mapperRa t _get_paramst colt valuet nonest id_valRc t paramsR[ ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt
load_on_ident¡ sN
> 8 c K@ sß | r | j | }
n | j }
i } | j | j d | xT |
D]L } | re | j | k re qD n | j | | | | d | d | d | | qD W| d k rÛ | | j k rÛ | rÅ | j | }
n | }
| j |
n d S( Nt memoized_setupsR\ t column_collectiont memoized_populators(
t _iterate_polymorphic_propertiest _polymorphic_propertiesRb R RV t setupR@ t polymorphic_ont columnsRA ( R& Rt R* t patht adapterR} t with_polymorphicR\ t polymorphic_discriminatort kwt poly_propertiest quick_populatorsRw t pd( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt _setup_entity_queryà s:
c @ s% j
r2 g
D] } j | ^ q
n j t j t j }
d k r |
j f d D }
n | j j
d t } xÿ |
D]÷ } | | k r{| | }
|
t k rè d j
| j | j f q|
t k r d j
| j t f q r' j |
}
n | j |
t } | r\ d j
| j | f q| j | | q | j | | q W j
rÒ j j j rÉ j j | n | n j j j pí j t j j j t j j j t
j! t
j" j j# j$ j% rz j d k r j& qn d j' rt j( n t j
f d } j) r!| r! r!t* | | | | } n | S( s` Produce a mapper level row processor callable
which processes rows into mapped instances.c 3@ s | ] } j | Vq d S( N( t _props( R t k( Rt ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pys <genexpr>' s R| t newt expiret quickc @ sÁ rB } | j } | } | j k } t } t } n t g
D] } | | ^ qO f } j | } | d k rã | } | } | j k } | } t } rR| rRt | | | qRno | d r÷ d St } t } t } j j } | } | } | | _
| _ j | | | s^ r2| r
r
| _
| _ n t | | | | | | r½| rÉ rÉ| j j j | n" rë| j j j | n sú| j r/ r r| j | q,| j | q/q½n | j } | j k } | sa| sa d r½t | | | | | }
| r½ r§| j j j | |
n | j | |
q½n | S( Ni t eager( t objR R R8 R RM R@ t _validate_version_idt
class_managert new_instanceRV t
session_idt _add_unpresentt load_optionst load_patht _populate_fullt managert dispatchR3 t refresht modifiedt _committ _commit_allt unloadedR t _populate_partial( R RX RE t dict_t isnewt currentloadt loaded_instancet columnt identitykeyR¢ t to_load( R
R& t identity_classR= R< t is_not_primary_keyt load_evtR Rt R\ t pk_colsRZ t
populatorst propagate_optionst refresh_evtt refresh_identity_keyR] R R t session_identity_mapR[ ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt _instanceh st &
N(+ Rc R t _identity_classt collectionst defaultdictR t _prop_setR@ t intersectionRM R R R RA RV t _deferred_column_loaderR R8 t _gettert create_row_processorR° R$ t
_current_pathR R5 RL RZ t always_refreshRm R R R3 R R< R= t hash_keyR[ R t _identity_key_from_statet allow_partial_pkst
issupersett polymorphic_mapt _decorate_polymorphic_switch( Rt R& R R R
R\ R] R t _polymorphic_fromt ct propsR t propRv t getterR´ ( ( R
R& R« R= R< R¬ R R Rt R\ R® RZ R¯ R° R± R² R] R R R³ R[ sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt _instance_processor
sl #
( Klc C@ sF | 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É WxV | d D] \ } } | | | | qô Wn+ x( | d D] \ } } | | | | q"Wd S( NR R R t delayedt existing( R t popR@ t expired_attributest add( R& R RX R¤ R¥ R§ RZ R¯ RV RÉ t set_callablet populator( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR Þ s$ 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Í R@ RÎ RÏ ( R& R RX R¤ R¥ R¢ R¯ Rª RV RÑ RÉ RÐ ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyR£ ú s2
c C@ s | j } | d k r d S| r/ | j | } n | j | | | j | | k r 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 version_id_colR@ R t _get_state_attr_by_columnRS t StaleDataErrorR ( Rt RX R¤ R R
RÒ ( ( sK /home/tvault/.virtenv/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 | f d } | S( Nc @ se y j | } Wn! t k
r4 t d | n- X| k rE d St | d Sd S( Ns* No such polymorphic_identity %r is definedRÅ ( RÃ t KeyErrort AssertionErrorR@ RÊ ( t
discriminatort
sub_mapper( R
R& Rt R R ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt configure_subclass_mapper< s
c @ s= | } | d k r3 | } | r3 | | Sn | S( N( R@ ( R R× R´ ( t instance_fnt polymorphic_instancesR ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt polymorphic_instanceO s
( R@ R R R t PopulateDict( RÚ R& Rt R R R R
RÙ RÜ ( ( R
R& RÚ Rt R RÛ R R sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyRÄ / s c
C@ sÑ | j } | s+ t j d t | n t | j } t } | j r¿ | j r¿ | j | | } | d k r¿ t | j | j
t j | j d j | d d | d | } q¿ n | t k r©| rÝ | j } nc g | j D] } | j | j ^ qç } | j j | r1t j d t | n | j | } t j | rY| j sht j | rt j d t | d St | j | | d | d | } n | rÍ| d k rÍt 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 proceedt *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( R5 RS t DetachedInstanceErrorR Rm RV R8 t inheritst concretet _optimized_get_statementR@ R{ R$ t optionsR t Loadt undefert from_statementRc t _columntopropertyRÎ R¹ t sa_exct InvalidRequestErrorRÀ R t issubsetRÁ RÂ R t warn_limitedRT (
Rt RX t attribute_namesR5 t has_keyR t statementt identity_keyRv t pk_attrs( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt load_scalar_attributesY sR #
(" t __doc__t
__future__R t R R R RS t sqlRd R R R t baseR R Rè R¶ t counterR R2 t dependenciesR RK RY R@ R{ R RÊ R R£ R RÄ Rñ ( ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/loading.pyt <module> s4 ; * @ + Í ! *