/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm
Edit: /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyo (46786B)
4]c @ s d Z d d l m Z d d l m Z d d l 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 Z d Z e d Z d Z d Z d Z d Z d Z e e e d Z e d Z d Z d Z! e" d Z# e" d Z$ d Z% d! Z& d" Z' d# Z( d$ Z) d% Z* d& Z+ d' Z, d( Z- d) e. f d* YZ/ d+ e/ f d, YZ0 d- e/ f d. YZ1 d/ e/ f d0 YZ2 d1 e/ f d2 YZ3 d3 e0 e2 f d4 YZ4 d5 e0 e3 f d6 YZ5 d7 e1 e2 f d8 YZ6 d9 e1 e3 f d: YZ7 d S(; s private module containing functions used to emit INSERT, UPDATE
and DELETE statements on behalf of a :class:`.Mapper` and its descending
mappers.
The functions here are called only by the unit of work functions
in unitofwork.py.
i( t chain( t groupbyNi ( t
attributes( t evaluator( t exc( t loading( t sync( t _entity_descriptor( t state_stri ( t sql( t util( t
expression( t
_from_objectsc s j } t | } | j j r0 t d n | r | r g | D] } | | j f ^ qC } g | D] \ } }
|
^ qe } q g | D] } | j ^ q } n t | } | j | x | j j D] \ } } j
| s q n f d t | f d | D d t d | d | D }
t
| d | | | |
d | q W| r| r j } g j D] } | j ^ qt} xC | D]8 \ } }
| t g | D] } |
| ^ q f | _ qWn d S( NsJ connection_callable / per-instance sharding not supported in bulk_insert()c 3 sE | ]; \ } } } } } } } } d | | | | | f Vq d S( N( t None( t .0t statet
state_dictt paramst mpt connt value_paramst has_all_pkst has_all_defaults( t
connectiont mapper( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pys
D s c 3 s! | ] } d | f Vq d S( N( R
( R t mapping( R R ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pys Y s t bulkt return_defaultst render_nullst bookkeeping( t base_mappert _cached_connection_dictt sessiont connection_callablet NotImplementedErrort dictt listR t _sorted_tablest itemst isat _collect_insert_commandst Truet _emit_insert_statementsR
t _identity_classt _identity_key_propst keyt tuple( R t mappingst session_transactiont isstatesR R R t cached_connectionsR t statest dict_t tablet super_mappert recordst identity_clst pt identity_propsR- ( ( R R sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt _bulk_insert# sH ""
c
sZ j } t | } j j rB j j h j n f d } | r | r g | D] } | | ^ qd } q g | D] } | j ^ q } n t | } | j j r t
d n | j | x| | j j
D]k \ } }
j |
sq n t d | f d | D d t } t | d | |
| | d t q Wd S( Nc s& t f d j j D S( Nc 3 s< | ]2 \ } } | j k s* | k r | | f Vq d S( N( t committed_state( R t kt v( t search_keysR ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pys s ( R# R& ( R R ( R? ( R sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt
_changed_dict~ s sJ connection_callable / per-instance sharding not supported in bulk_update()c 3 s= | ]3 } d | j r. | j j n d f Vq d S( N( R
t _version_id_propR- ( R R ( R R ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pys s R R ( R R t _primary_key_propkeysRA R- t unionR# R$ R R! R" R R% R& R' t _collect_update_commandsR
R) t _emit_update_statementst False( R R/ R0 R1 t update_changed_onlyR R2 R@ R R5 R6 R7 ( ( R R R? sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt _bulk_updates s@ %
c C s | rE | j rE x- t | D] } t | | g | d t q Wd Sg } g } t | } xs t | | | D]_ \ } } } }
} } }
| s | r | j | | | |
|
f qp | j | | | |
f qp Wx | j j D]t \ } } | | j k rq n t
| | } t | | | } t | | | | | | t
| | | | | | q Wt | | t d | D d | D d S( s; Issue ``INSERT`` and/or ``UPDATE`` statements for a list
of objects.
This is called within the context of a UOWTransaction during a
flush operation, given a list of states to be flushed. The
base mapper in an inheritance hierarchy handles the inserts/
updates for all descendant mappers.
t singleNc s s0 | ]& \ } } } } | | | | t f Vq d S( N( RF ( R R R R R ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pys s c s s3 | ]) \ } } } } } | | | | t f Vq d S( N( R) ( R R R R R t update_version_id( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pys s
( t batcht _sort_statest save_objR) R t _organize_states_for_savet appendR% R& t
_pks_by_tableR( RD RE R* t _finalize_insert_update_commandsR ( R R3 t uowtransactionRI R t states_to_updatet states_to_insertR2 R4 R R t has_identityt
row_switchRJ R5 t insertt update( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRM sR + c s t | } t t | | | } x| | j j D]k \ j k rU q4 n f d | D } t | | | | } t | | | | q4 Wd S( s\ Issue UPDATE statements on behalf of a relationship() which
specifies post_update.
c 3 sf | ]\ \ } } } } | j k r | | | | j d k rW j | | j n d f Vq d S( N( RP t version_id_colR
t# _get_committed_state_attr_by_column( R R R t
sub_mapperR ( R R5 ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pys s N( R R$ t _organize_states_for_post_updateR% R& RP t _collect_post_update_commandst _emit_post_update_statements( R R3 RR t post_update_colsR2 RS RX ( ( R R5 sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt post_update s"
c
C s t | } t t | | | } | j } x t t | j D]k } | | } | | j k rk qF n | j r | j r qF n t | | | | } t
| | | | | | qF Wx3 | D]+ \ } }
} } } | j j | | | q Wd S( s Issue ``DELETE`` statements for a list of objects.
This is called within the context of a UOWTransaction during a
flush operation.
N(
R R$ t _organize_states_for_deleteR% t reversedt keysRP t inheritst passive_deletest _collect_delete_commandst _emit_delete_statementst dispatcht after_delete(
R R3 RR R2 t states_to_deletet table_to_mapperR5 R t deleteR R R RJ ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt
delete_obj; s,
c
c s xt | | | D]\ } } } } t | j } | j pI | j | } d } }
| su | j j | | | n | j j | | | | j r | j | | | n | rf| | j j
k rf| j j
| } t j | } | j
| sf| j | s+t j d t | | t | f n | j d | t | t | | j | | } qfn | sr| r| j d k r| j | r| n | | r| j n | | j }
n | | | | | | |
f Vq Wd S( sT Make an initial pass across a set of states for INSERT or
UPDATE.
This includes splitting out into distinct lists for
each, calling before_insert/before_update, obtaining
key information for each state including its dictionary,
mapper, the connection to use for the execution per state,
and the identity flag.
sJ New instance %s with identity key %s conflicts with persistent instance %ssP detected row switch for identity %s. will update %s, remove %s from transactionN( t _connections_for_statest boolR- t _identity_key_from_stateR
Rh t
before_insertt
before_updatet _validate_polymorphic_identityR t identity_mapR t instance_statet was_already_deletedt
is_deletedt orm_exct
FlushErrorR t
_log_debugt remove_state_actionsRY RZ R# (
R R3 RR R R4 R R RU t instance_keyRV RJ t instancet existing( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRN i sL
"
c C s t | | | S( s Make an initial pass across a set of states for UPDATE
corresponding to post_update.
This includes obtaining key information for each state
including its dictionary, mapper, the connection to use for
the execution per state.
( Rn ( R R3 RR ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyR\ s c c s x t | | | D]l \ } } } } | j j | | | | j d k re | j | | | j } n d } | | | | | f Vq Wd S( s Make an initial pass across a set of states for DELETE.
This includes calling out before_delete and obtaining
key information for each state including its dictionary,
mapper, the connection to use for the execution per state.
N( Rn Rh t
before_deleteRY R
RZ ( R R3 RR R R4 R R RJ ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRa s c c s- x&| D] \ } } } } | | j k r. q n i } i }
| j | } | j | } x t | j | D] }
| |
} | |
} | d k r | | k r | r qj qj | r t | d s t | t j r t | d r | j
n | |
| Z s R c 3 s+ | ]! } | j j | f Vq d S( N( t _labelt get( R R ( R R ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pys s t pk_cascadedi sC Can't update table %s using NULL for primary key value on column %sN(- RP R R# R R R t _pk_attr_keys_by_tableR) R< R R R R R t managert implt is_equalR- R R t _server_onupdate_default_colsR R
RY R t _columntopropertyt valuest get_historyR t PASSIVE_NO_INITIALIZEt addedR R RF t PASSIVE_OFFt deletedt popt unchangedRx Ry RX t _table_to_equatedR t populatet passive_updates( RR R5 RS R R R R RJ t pksR R R R R R t propt historyt no_paramst valR t expect_pk_cascadedt pk_paramst mt
equated_pairs( ( R R sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRD 7 s
c c s x| D]\ } } } } } | j | }
i } t } x | j | D] }
|
|
k r} | j | | |
d t j | |
j | j j } | oK } | rx| D] \ } } } } } } }
| j | j | | } | rt | | | | | j j d | t n | | j 7} | } q[WnL| ss| } x=| D]v \ } } } } } } }
| | j | | } | r_t | | | | | j j d | t n | | j 7} qWn g | D] } | d ^ qz} | p| ot | d k } | | j | | } | | j 7} x[ | D]S \ } } } } } } }
| rt | | | | | j j d | t qqW| rr| t | k rt j d j t | | f qqe re t j d | j j qe qe Wd S(
s` Emit UPDATE statements corresponding to value lists collected
by _collect_update_commands().c s t j } x@ j D]1 } | j j | t j | j d | j k q W r | j j j t j j j d j j k n j | } | S( Nt type_(
R t and_RP t clausesRO t bindparamR t typeRY RX ( t clauseR t stmt( R t needs_version_idR5 ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt update_stmt` s & RX c S s3 | d t | d t | d | d | d f S( Ni i i i i ( R Ro ( t rec( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt { s
i i i sM UPDATE statement on table '%s' expected to update %d row(s); %d were matched.sM Dialect %s does not support updated rowcount - versioning cannot be verified.N( RY R
R t _memoR R$ RF R R) R R t dialectt supports_sane_rowcountt supports_sane_rowcount_returningt supports_sane_multi_rowcountt executeR t
_postfetcht contextt compiled_parameterst rowcountt lenRx t StaleDataErrort descriptionR
t warnt dialect_description( R RR R2 R R5 RX R R t cached_stmtR t paramkeyst hasvalueR R R7 t rowst statementR t assert_singlerowt assert_multirowt allow_multirowR R R R R t check_rowcountR t multiparams( ( R R R5 sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRE O s
%
"
"
"
"c C s | j d | f | j } xt | d D]\ \ } } }
} } }
| } | s | ss | j ss | j j rD| rD|
rDt |
}
g |
D] } | d ^ q } | | j | | } | rxy t |
| j j
D]_ \ \ } } } } } } } } } | r*t | | | | | | | | t q t
| | | q Wqq. | rc| j rc| j } n$ | j d k r| j | j } n x=|
D]5\ } } } } } } } } | r| j | j | | } n | | j | | } | j j } | d k ruxt t | | j | D]Y \ } } | j | } | d k r| | k s^| j | j d k r| | | j \ s R- c S s | j d S( Ni ( R- ( t q( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyR _ R s^ Could not sort objects by primary key; primary key values must be sortable in Python (was: %s)t insert_order( R t difference_updatet sortedt TypeErrort sa_exct InvalidRequestErrort operatort
attrgetter( R3 t pendingt
persistentt persistent_sortedt err( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRL Z s
t BulkUDc B s e Z d Z d Z d Z e d Z e d Z d Z d Z
d Z e j
d d Z d
Z d Z RS( s5 Handle bulk update and deletes via a :class:`.Query`.c C s2 | j t | _ | j j | _ | j d S( N( t enable_eagerloadsRF R t _bind_mapperR t _validate_query_state( t selfR ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt __init__n s c C s x d d d t j f d d d t j f d d t t j f d d t t j f d d
t t j f d d d t j f f D]F \ } } } } | t | j | | ss t j d
| f qs qs Wd S( Nt _limits limit()t _offsets offset()t _order_bys
order_by()t _group_bys
group_by()t _distincts
distinct()t _from_objs2 join(), outerjoin(), select_from(), or from_self()sC Can't call Query.update() or Query.delete() when %s has been called( ( R
R t is_RF t eqt getattrR R R ( R) t attrt methnamet notsett op( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyR( s s c C s
| j j S( N( R R ( R) ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyR s c G s\ y | | } Wn= t k
rM t j d d j t d | D n X| | Sd S( Ns3 Valid strategies for session synchronization are %ss , c s s | ] } t | Vq d S( N( t repr( R t x( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pys s ( t KeyErrorR t
ArgumentErrort joinR ( t clst lookupt synchronize_sessiont argt klass( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt _factory s
'c C s@ | j | j | j | j | j | j d S( N( t _do_before_compilet _do_pret _do_pre_synchronizet _do_exect _do_post_synchronizet _do_post( R) ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt exec_ s
c C s. | j j | | j | _ | j j | _ d S( N( R t
_execute_crudR R R ( R) R ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt
_execute_stmt s c C s
t d S( N( R" ( R) ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRC s s sqlalchemy.orm.queryc C s | j } | j | | _ t | j d | j r t } xG | j D]< } t | | j sm | j PqG | j t | j
qG Wt | d k r t j
d q | j | _ n | j d j j | _ | j } | j r | j n d S( Ni i sL This operation requires only one Table or entity be specified as the target.( R t QueryContextR R t _entitiest
_ColumnEntityR t clearRX R t columnR R R R t
primary_tablet _only_entity_zeroR t local_tableR t
_autoflush( R) t querylibR t tablest entR ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRD s$
c C s d S( N( ( R) ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRE s c C s d S( N( ( R) ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRG s ( t __name__t
__module__t __doc__R* R( t propertyR t classmethodRB RI RK RC R
t dependenciesRD RE RG ( ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyR% k s # t BulkEvaluatec B s e Z d Z d Z d Z RS( sD BulkUD which does the 'evaluate' method of session state resolution.c C s d S( N( ( R) t evaluator_compiler( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt _additional_evaluators s c
C s | j } | j j } yM t j | } | j d k rN | j | j } n d } | j | Wn) t j k
r } t
j d | n Xg | j j
j D]6 \ \ } } } } t | | r | | r | ^ q | _ d S( Nc S s t S( N( R) ( R ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt eval_condition s st Could not evaluate current criteria in Python: "%s". Specify 'fetch' or False for the synchronize_session parameter.( R t _mapper_zerot class_R t EvaluatorCompilert whereclauseR
t processR` t UnevaluatableErrorR R R Rt R& t
issubclasst matched_objects(
R) R t
target_clsR_ Ra R$ R= R t identity_tokenR ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRE s %( RX RY RZ R` RE ( ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyR^ s t BulkFetchc B s e Z d Z d Z RS( sA BulkUD which does the 'fetch' method of session state resolution.c C sd | j } | j } | j } | j j | j j } | j | d | j d | j j
| _ d S( NR R ( R R t _compile_contextR t with_only_columnsRQ R R R t _paramst fetchallt matched_rows( R) R R R t select_stmt( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRE s ( RX RY RZ RE ( ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRl s t
BulkUpdatec B s_ e Z d Z d Z e d Z d Z e d Z e d Z d Z
d Z RS( s BulkUD which handles UPDATEs.c C s, t t | j | | | _ | | _ d S( N( t superRs R* R t
update_kwargs( R) R R Ru ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyR*
s c C s. t j i t d 6t d 6t t 6| | | | S( Nt evaluatet fetch( R% RB t BulkUpdateEvaluatet BulkUpdateFetchRs RF ( R= R R? R Ru ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt factory s c C sZ | j j j rV xD | j j j D]0 } | | j | } | d k r | | _ q q Wn d S( N( R Rh t before_compile_updateR
( R) t fnt new_query( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRC s
c C s g } x t | j d r* | j j n | j D] \ } } | j r t | t j r t | j | } | j | j | q t | t
j r | j | j | q | j | | f q1 | j | | f q1 W| S( NR& (
R R R& R R R
t string_typesR R t _bulk_update_tuplesR t QueryableAttributeRO ( R) R R= R> t desc( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt _resolved_values$ s ! c C s g } x | j D] \ } } t | t j rJ | j | j | f q n t | d rh | j } n | j r t | t j
r y | j j | } Wn t j
k
r q X| j | j | f q t j d | q W| S( NR s Invalid expression type: %r( R R R R RO R- R R R R t
ColumnElementR Rx t UnmappedColumnErrorR R ( R) R R= R> R4 ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt" _resolved_values_keys_as_propnames8 s c C sb | j } | j j d t s- t | } n t j | j | j j | | j } | j
| d S( Nt preserve_parameter_order( R Ru R RF R# R RX RQ R Re RK ( R) R R ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRF O s c C s | j j } | j j | d S( N( R R Rh t after_bulk_update( R) R ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRH ^ s ( RX RY RZ R* R\ Rz RC R[ R R RF RH ( ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRs s t
BulkDeletec B sA e Z d Z d Z e d Z d Z d Z d Z RS( s BulkUD which handles DELETEs.c C s t t | j | d S( N( Rt R R* ( R) R ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyR* f s c C s( t j i t d 6t d 6t t 6| | S( NRv Rw ( R% RB t BulkDeleteEvaluatet BulkDeleteFetchR RF ( R= R R? ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRz i s c C sZ | j j j rV xD | j j j D]0 } | | j | } | d k r | | _ q q Wn d S( N( R Rh t before_compile_deleteR
( R) R| R} ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRC u s
c C s, t j | j | j j } | j | d S( N( R Rl RQ R Re RK ( R) R ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRF | s c C s | j j } | j j | d S( N( R R Rh t after_bulk_delete( R) R ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRH s ( RX RY RZ R* R\ Rz RC RF RH ( ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyR c s Rx c B s e Z d Z d Z d Z RS( sS BulkUD which handles UPDATEs using the "evaluate"
method of session resolution.c C sL i | _ | j } x3 | D]+ \ } } | j t j | | j | ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pys s ( R R Rb R Rq t identity_key_from_primary_keyR$ Rt R Ru R R R# t
_expire_stateR (
R) R t
target_mapperR t identity_keyR3 R t attribR t to_expire( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRG s ,.
( RX RY RZ RG ( ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRy s R c B s e Z d Z d Z RS( sP BulkUD which handles DELETEs using the "fetch"
method of session resolution.c C sz | j j } | j j } xX | j D]M } | j t | } | | j k r% | j t j | j | g q% q% Wd S( N(
R R Rb Rq R R$ Rt R R Ru ( R) R R R R ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyRG s ( RX RY RZ RG ( ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyR s (8 RZ t itertoolsR R R R R R R Rx R R t baseR R R R R
R t sql.baseR R; RH RF RM R` Rm RN R\ Ra R( RD R] Rf R) RE R* R^ Rg RQ R R R Rn R RL t objectR% R^ Rl Rs R Rx R Ry R ( ( ( sM /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/orm/persistence.pyt sb P E V - . Q U 8 . { s ^ F ) ` e(\#(