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
/
persistence.pyc
|
|---|
ó
EYc @ sZ d Z d d l Z d d l m Z m Z d d l m Z m Z m Z d d l m
Z
m Z m Z m
Z
d d l m Z m Z 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 d Z e d Z d Z! d Z" e# d Z$ e# d Z% d Z& d Z' d Z( e d Z) d Z* d Z+ d Z, d! e- f d" YZ. d# e. f d$ YZ/ d% e. f d& YZ0 d' e. f d( YZ1 d) e. f d* YZ2 d+ e/ e1 f d, YZ3 d- e/ e2 f d. YZ4 d/ e0 e1 f d0 YZ5 d1 e0 e2 f d2 YZ6 d S(3 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ÿÿÿÿN( t groupbyt chaini ( t sqlt utilt exci ( t
attributest syncR t evaluator( t state_strt _attr_as_keyt _entity_descriptor( t
expression( t
_from_objects( t loadingc
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 } t
| d | | |
| d | qÊ W| rÉ| rÉ j }
g j D] } | j ^ qn} 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( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pys <genexpr>5 s c 3 s! | ] } d | f Vq d S( N( R ( R t mapping( R R ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pys <genexpr>; s t bulkt return_defaultst 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 t cached_connectionsR t statest dict_t tablet super_mappert recordst identity_clst pt identity_propsR- ( ( R R sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt _bulk_insert s< ""
c
s` j } t | } j j rH t j j g j n f d } | r§ | r g | D] } | | ^ qj } 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 ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pys <genexpr>[ s ( R# R& ( R R ( R? ( R sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt
_changed_dictY 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 ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pys <genexpr>t s R R ( R R t _primary_key_propkeysRA t setR- 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? sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt _bulk_updateO s4 !%
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( RG ( R R R R R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pys <genexpr>¸ s c s s3 | ]) \ } } } } } | | | | t f Vq d S( N( R) ( R R R R R t update_version_id( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pys <genexpr>¼ s ( t batcht _sort_statest save_objR) R t _organize_states_for_savet appendR% R& t
_pks_by_tableR( RE RF R* t _finalize_insert_update_commandsR ( R R3 t uowtransactionRJ R t states_to_updatet states_to_insertR2 R4 R R t has_identityt
row_switchRK R5 t insertt update( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRN sD
(
c s¤ t | } t t | | | } xy | j j D]h \ } | 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 s< | ]2 \ } } } } | j k r | | | | f Vq d S( N( RQ ( R R R t
sub_mapperR ( R5 ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pys <genexpr>Ô s N( R R$ t _organize_states_for_post_updateR% R& RQ t _collect_post_update_commandst _emit_post_update_statements( R R3 RS t post_update_colsR2 RT R RY ( ( R5 sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt post_updateÄ s
c
C s× t | } t t | | | } | j } xm t t | j D]S } | | } | | j k rk 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 keysRQ t _collect_delete_commandst _emit_delete_statementst dispatcht after_delete(
R R3 RS R2 t states_to_deletet table_to_mapperR5 R t deleteR R R RK ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt
delete_objã s"
c
c sÇ xÀt | | | D]¬\ } } } } t | j } | j pI | j | } d } }
| su | j j | | | n | j j | | | | j rª | j | | | n | rT| | j j
k rT| j j
| } t j | } | j
| s t j d t | | t | f n | j d | t | t | | j | | } n | s`| 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 Re t
before_insertt
before_updatet _validate_polymorphic_identityR t identity_mapR t instance_statet
is_deletedt orm_exct
FlushErrorR t
_log_debugt remove_state_actionst version_id_colt# _get_committed_state_attr_by_columnR# (
R R3 RS R R4 R R RV t instance_keyRW RK t instancet existing( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRO sB
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.
( Rk ( R R3 RS ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR[ G 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( Rk Re t
before_deleteRx R Ry ( R R3 RS R R4 R R RK ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR` T s c c sÐ xÉ| D]Á\ } } } } | | j k r. q n i } i } | j | }
xy t |
j | D]b } | | } |
| }
| d k r q] q] | r² t | t j r² | | |
j <q] | | |
j <q] W| s x4 | j | j
| j
| D] } d | | <qé Wn | s
| rQ| j | j | } | j
j rH| j | j | } q[t } n
t } } | j t k r«| j d k r«| j | j | k r«| j d | | j j <n | | | | | | | | f Vq Wd S( sS Identify sets of values to use in INSERT statements for a
list of states.
N( RQ t _propkey_to_colRC t intersectionR t
isinstanceR t
ClauseElementR- t _insert_cols_as_nonet
differencet _pk_keys_by_tablet issubsetR t eager_defaultst _server_default_colsR) t version_id_generatorRG Rx t _cols_by_table( R5 RU R R R R R R R R t propkey_to_colt propkeyt valuet colt colkeyR R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR( n s@
c # sÜ xÕ| D]Í\ } } } } | | j k r1 q n | j | } i } | j | | r t f d t j j | j | D }
t } nÀ i }
x t j | j D]r } | }
| } t |
t
j rö |
| | <q½ | j | j
j |
| j | t k r½ |
|
| j <q½ q½ W| j j rX| j | j |
} n t } | d k rB| j | j | k rB| ræ|
p| ræxO | j j D]8 } | j | j j
j | t j } | j r¤Pq¤q¤Wq n | j } | |
| j <| s| j |
k rT| j t k rT| j | } | |
| j <qTn |
pK| sTq n | rt f d t j | j | D } n i } x| D]û } | j | j } | j | j
j | t j! } | j rW| j" sd | | f | j k r,| j d | | j <|
j# | j d qk| j" d | | j <| j d |
| j <n | j$ d | | j <| | j d k rt% j& d | | f qqW|
sª| r |
j' | | |
| | | | f Vq q Wd S( st Identify sets of values to use in UPDATE statements for a
list of states.
This function works intricately with the history system
to determine exactly what values should be updated
as well as how the row should be matched within an UPDATE
statement. Includes some tricky scenarios where the primary
key of an object might have been changed.
c 3 s& | ] } | j | f Vq d S( N( R- ( R R ( R R ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pys <genexpr>À s c 3 s+ | ]! } | j j | f Vq d S( N( t _labelt get( R R ( R R ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pys <genexpr>û s t pk_cascadedi sC Can't update table %s using NULL for primary key value on column %sN(( RQ R~ R# RC R R R R) R< R R R t managert implt is_equalR- R R t _server_onupdate_default_colsR
R Rx R t _columntopropertyt valuest get_historyR t PASSIVE_NO_INITIALIZEt addedR R RG t _pk_attr_keys_by_tablet PASSIVE_OFFt deletedt popt unchangedRt Ru RY ( RS R5 RT R R R R RK t pksR R R R R R t propt historyt valt pk_params( ( R R sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRE ¤ s
c c s x | D]ø \ } } } } | j | } i }
t } x¶ | j | D]§ } | | k rz | j | | | d t j |
| j <q@ | | k r@ | j | }
| j |
j j
j | | t j } | j
rç | j
d } | |
| j <t } qç q@ q@ W| r |
| f Vq q Wd S( sr Identify sets of values to use in UPDATE statements for a
list of states within a post_update operation.
t passivei N( RQ RG R t _get_state_attr_by_columnR R R R R R- R R R R R) ( R RS R5 RT R^ R R R R R R t hasdataR R¡ R¢ R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR\ s(
c c sß xØ | D]Ð \ } } } } } | | j k r1 q n i } x] | j | D]N }
| j | | |
| |
j <} | d k rE t j d | |
f qE qE W| d k rÌ | j | j | k rÌ | | | j j <n | | f Vq Wd S( sS Identify values to use in DELETE statements for a list of
states to be deleted.sH Can't delete from table %s using NULL for primary key value on column %sN( RQ Ry R- R Rt Ru Rx R ( R RS R5 Rg R R R R RK R R R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRc C s c s4 j d k o" j j k f d } | j d f | } xÛt | d D]Ç\ \ } }
} } }
d } t |
}
| } | j j } | o° | j j } | o½ } | rè | rè j j
rè | j } n$ j d k r | j j } n | rx´|
D]{ \ } } } } } } | j | j
| | } | rt | | | | | j j d | n | | j 7} t } qWn.| s | } x |
D]g \ } } } } } } | | j | | } t | | | | | j j d | | | j 7} q®Wn g |
D] } | d ^ q#} | pT| oTt | d k } | | j | | } | | j 7} xL |
D]D \ } } } } } } t | | | | | j j d | qW| r | t |
k r,t j d j t |
| f q,qe 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_RQ t clausesRP t bindparamR t typeRx RY ( t clauseR t stmt( R t needs_version_idR5 ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt update_stmti s RY c S s, | d t | d t | d | d f S( Ni i i i ( RC Rl ( t rec( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt <lambda>~ 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( Rx R R t _memoR R$ t dialectt supports_sane_rowcountt supports_sane_multi_rowcountR R R t executeR t
_postfetcht contextt compiled_parameterst rowcountR) t lenRt t StaleDataErrort descriptionR t warnt dialect_description( R RS R2 R R5 RY R R° t cached_stmtR t paramkeyst hasvalueR R7 t rowst statementt assert_singlerowt assert_multirowt allow_multirowR R R R t ct check_rowcountR± t multiparams( ( R R¯ R5 sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRF ` s "
" c C sv | j d | f | j } xTt | d D]@\ \ } } }
} } }
| } | s | ss | j ss | j j r(| r(|
r(t |
}
g |
D] } | d ^ q } | | j | | } | rnx] t |
| j j
D]C \ \ } } } } } } } } } t | | | | | | | | qÛ Wqnq. | rG| j rG| j } n$ | j
d k rk| j | j
} n x |
D]ø \ } } } } } } } } | r´| j | j | | } n | | j | | } | j j } | d k rAx\ t | | j | D]A \ } } | j | } | j | j d k rù| | | j <qùqùWn t | | | | | | | j j
d | qrWq. Wd S( s` Emit INSERT statements corresponding to value lists collected
by _collect_insert_commands().RX c S s3 | d t | d t | d | d | d f S( Ni i i i i ( RC Rl ( R± ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR² ï s
i i N( R³ RX R R R´ t implicit_returningR$ R· t zipR¹ Rº R¸ R Rx R R t inserted_primary_keyRQ R R R- ( R RS R2 R R5 RX R RÁ R t pkeysRÃ R R R7 RÅ R± RË RÉ R R R t
mapper_recR R t last_inserted_paramst resultt primary_keyt pkR R¡ ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR* ä sn %
7"
c s f d } | j d f | } x] t | d D]I \ } } | d }
g | D] \ } } | ^ qZ }
| |
j | |
q= Wd S( se Emit UPDATE statements corresponding to value lists collected
by _collect_post_update_commands().c s\ t j } x@ j D]1 } | j j | t j | j d | j k q W j | S( NR¨ ( R R© RQ Rª RP R« R R¬ RY ( R R ( R R5 ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR° ? s
R_ c S s | d t | d f S( Ni i ( RC ( R± ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR² O s i N( R³ R R· ( R RS R2 R R5 RY R° RÅ R- t grouperR R R RË ( ( R R5 sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR] : s
c sç j d
k o" j j k f d } | j d f | } xt | d D]z\ } } g | D] \ }
} |
^ qx } | | } t | } d }
t } | j j rë | j | | } sß t
} n | j }
n rf| j j r6d }
x] | D]% }
| j | |
} |
| j 7}
q
Wqvt
j d | j j d d | j | | n | j | | | j re |
d k re | |
k re | r½t
j d j | |
f qßt j d j | |
f qe qe Wd
S( s` Emit DELETE statements corresponding to value lists collected
by _collect_delete_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( NR¨ (
R R© RQ Rª RP R« R- R¬ Rx Ri ( R R ( R t need_version_idR5 ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt delete_stmtb s & Ri c S s | d S( Ni ( ( R± ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR² v s iÿÿÿÿi sM Dialect %s does not support deleted rowcount - versioning cannot be verified.t
stackleveli s DELETE statement on table '%s' expected to delete %d row(s); %d were matched. Please set confirm_deleted_rows=False within the mapper configuration to prevent this warning.N( Rx R R R³ R R¼ RG R´ R¶ R· R) R» Rµ R R¿ RÀ t confirm_deleted_rowsR¾ Rt R½ ( R RS R2 R R5 Ri R× RÅ R t recsR t del_objectst expectedt rows_matchedt only_warnRÉ ( ( R RÖ R5 sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRd Z sL
c C s{ xt| D]l\ } } } } } | j r | j g | j D]* } | j sV | j | j k r5 | j ^ q5 } | r | j | j | q n g }
| j r© |
j | j nO | j d k rø | j t k rø | j
j | j k rø |
j | j
j g qø n |
r>| j | | _ t j | j j | | j d | d |
n | s]| j j | | | q | j j | | | q Wd S( sz finalize state on states that have been inserted or updated,
including calling after_insert/after_update events.
t
refresh_statet only_load_propsN( t _readonly_propst unmodified_intersectiont expire_on_flushR- R# t _expire_attributesR t extendt _unloaded_non_objectRx R R RG RA t unloadedRm R
t
load_on_identR t queryRe t after_insertt after_update( R RS R3 R R R R RV R9 t readonlyt
toload_now( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRR s. -
c C sT | j j j } | j j j }
| j j j } | j d k rk | j | j | k rk t | | j g } n t | j
j j } | r g }
n | r | j j
} | d k r xX | D]M } | j rÉ q´ n | | | | j | j <| r´ |
j | j | j q´ q´ Wq n xj | D]b } | j | k r| | j k r| | j | | j | j <| rt|
j | j | j qtqqW| r |
r | j
j j | | |
n |
rî| rî| j | j g |
D]% } | | j k r¿| j | j ^ q¿ n x_ | j | D]P \ } } | d k r*t j | | | qüt j | | | | | | | j qüWd S( s Expire attributes in need of newly persisted database state,
after an INSERT or UPDATE statement has proceeded for that
state.N( R¹ t compiledt prefetcht postfetcht returningRx R R R$ Rl t
class_managerRe t
refresh_flusht returned_defaultsRÓ R R- RP Rä R# t _table_to_equatedR t bulk_populate_inherit_keyst populatet passive_updates( R RS R5 R R4 RÒ R R R t
prefetch_colst postfetch_colst returning_colsRó t load_evt_attrst rowR RÉ t mt
equated_pairs( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR¸ Ö sL
$
!
& c c s | j j r | j j } n | j j | } d } xR t | D]D } | rd | | | j } n | j j } | | j | | f Vq@ Wd S( sß Return an iterator of (state, state.dict, mapper, connection).
The states are sorted according to _sort_states, then paired
with the connection they should be using for the given
unit of work transaction.
N(
R R! t transactionR R RM t objR R R# ( R RS R3 R! R R R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRk s c s t j f d S( Nc s | j d j S( Nt compiled_cache( t execution_optionst _compiled_cache( R ( R ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR² 0 s ( R t PopulateDict( R ( ( R sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR - s c C s[ t | } t d | D } | j | t | d t j d t | d d S( Nc s s$ | ] } | j d k r | Vq d S( N( R- R ( R t s( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pys <genexpr>7 s R- t insert_orderc S s | j d S( Ni ( R- ( t q( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR² : s ( RC t difference_updatet sortedt operatort
attrgetter( R3 t pendingt
persistent( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRM 5 s
t BulkUDc B sq e Z d Z d Z d Z e d Z e 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_eagerloadsRG Ré t _bind_mapperR t _validate_query_state( t selfRé ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt __init__@ 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_RG t eqt getattrRé t sa_exct InvalidRequestError( R t attrt methnamet notsett op( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR E s "c C s
| j j S( N( Ré R ( R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR X 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( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pys <genexpr>c s ( t KeyErrorR t
ArgumentErrort joinR
( t clst lookupt synchronize_sessiont argt klass( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt _factory\ s
c C s6 | j | j | j | j | j d S( N( t _do_pret _do_pre_synchronizet _do_exect _do_post_synchronizet _do_post( R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt exec_h 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
_ColumnEntityRC t clearRY R t columnR¼ R R R t
primary_tablet _only_entity_zeroR t local_tableR t
_autoflush( R t querylibRé t tablest entR ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR/ o s$
c C s d S( N( ( R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR0 s c C s d S( N( ( R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR2 s ( t __name__t
__module__t __doc__R R t propertyR t classmethodR. R4 R t dependenciesR/ R0 R2 ( ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR = 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( ( sO /home/tvault/.virtenv/lib/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]3 \ \ } } } t | | r | | r | ^ q | _ d S( Nc S s t S( N( R) ( R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt eval_condition¨ s sn Could not evaluate current criteria in Python. Specify 'fetch' or False for the synchronize_session parameter.( Ré t _mapper_zerot class_R t EvaluatorCompilert whereclauseR t processRI t UnevaluatableErrorR R R Rq R& t
issubclasst matched_objects( R Ré t
target_clsRH RJ R) RÔ R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR0 s
"( RA RB RC RI R0 ( ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRG 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_columnsR: RÓ R· R t _paramst fetchallt matched_rows( R Ré R R¹ t select_stmt( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR0 ¾ s ( RA RB RC R0 ( ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRT » s t
BulkUpdatec B sJ e Z d Z d Z e d Z d Z d Z d Z d Z RS( s BulkUD which handles UPDATEs.c C s, t t | j | | | _ | | _ d S( N( t superR[ R R t
update_kwargs( R Ré R R] ( ( sO /home/tvault/.virtenv/lib/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 R. t BulkUpdateEvaluatet BulkUpdateFetchR[ RG ( R) Ré R+ R R] ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt factoryÒ s
c C s? | j r7 t | t j r7 t | j | } | j S| Sd S( N( R R R t string_typesR
t __clause_element__( R R- R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt _resolve_string_to_exprÚ s
c C sÖ | j r7 t | t j r7 t | j | } | j j St | t j rP | j St | d rn | j
} n | j r¿ t | t j r¿ y | j j
| } Wn t j k
r´ d SX| j Sn t j d | d S( NRd s Invalid expression type: %r( R R R Rc R
RD R- R t InstrumentedAttributet hasattrRd R t
ColumnElementR Rt t UnmappedColumnErrorR R R ( R R- R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt _resolve_key_to_attrnameá s
c C sÚ g t | j d r$ | j j n | j D]! \ } } | j | | f ^ q+ } | j j d t sv t | } n t j | j
| j j | | j } | j
j j | d | j
j d | j | _ | j j | _ d S( NR& t preserve_parameter_orderR R ( Rg R R& Re R] R RG R# R RY R: R¹ RN Ré R R· RW R RÒ R» ( R R= R> R R° ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR1 õ s !. c C s | j j } | j j | d S( N( Ré R Re t after_bulk_update( R R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR3 s (
RA RB RC R RE Rb Re Rj R1 R3 ( ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR[ Ê s t
BulkDeletec B s8 e Z d Z d Z e d Z d Z d Z RS( s BulkUD which handles DELETEs.c C s t t | j | d S( N( R\ Rm R ( R Ré ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR s c C s( t j i t d 6t d 6t t 6| | S( NR^ R_ ( R R. t BulkDeleteEvaluatet BulkDeleteFetchRm RG ( R) Ré R+ ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRb s
c C s[ t j | j | j j } | j j j | d | j j d | j | _
| j
j | _ d S( NR R ( R Ri R: R¹ RN Ré R R· RW R RÒ R» ( R R× ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR1 s c C s | j j } | j j | d S( N( Ré R Re t after_bulk_delete( R R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR3 & s ( RA RB RC R RE Rb R1 R3 ( ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRm s
R` 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 s i | _ t | j d r* | j j n | j } xQ | D]I \ } } | j | } | d k r: | j t j | | j | <q: q: Wd S( NR& ( t value_evaluatorsRg R R& Rj R RO R t _literal_as_binds( R RH R R- R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRI / s ! c C sê | j j } t } t | j j } x¬ | j D]¡ } t j | t j | } } | j
j | } x% | D] } | j | | | | <qr W| j | t | | j
| t | j | | j | q4 W| j | d S( N( Ré R RC R$ Rq Rb RR R Rr t
instance_dictt
unmodifiedR t _commitRä R t addt _register_altered( R R R3 t evaluated_keysR R R4 t to_evaluateR- ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR2 9 s
( RA RB RC RI R2 ( ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR` + s
Rn c B s e Z d Z d Z RS( sS BulkUD which handles DELETEs using the "evaluate"
method of session resolution.c C s6 | j j j g | j D] } t j | ^ q d S( N( Ré R t _remove_newly_deletedRR R Rr ( R R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR2 V s ( RA RB RC R2 ( ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRn R s Ra c B s e Z d Z d Z RS( sP BulkUD which handles UPDATEs using the "fetch"
method of session resolution.c C sÒ | j j } | j j } t g g | j D] } | j t | ^ q+ D]+ } | | j k rJ t j | j | ^ qJ } g | j
D] } t | ^ q } x | D] } | j | | q§ W| j
| d S( N( Ré R RK RC RY t identity_key_from_primary_keyR$ Rq R Rr R R t
_expire_stateRw ( R R t
target_mapperRÓ t identity_keyR3 R= t attribR ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR2 ` s ,."
( RA RB RC R2 ( ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRa \ s Ro 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 RK RY R{ R$ Rq Rz R Rr ( R R R} RÓ R~ ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyR2 w s ( RA RB RC R2 ( ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyRo s s (7 RC R t itertoolsR R t R R R R R R Rt R t baseR R R
R t sql.baseR R
R; RI RG RN R_ Rj RO R[ R` R( RE R\ Rc R) RF R* R] Rd RR R¸ Rk R RM t objectR RG RT R[ Rm R` Rn Ra Ro ( ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/persistence.pyt <module> sL " 4 2 C ! C
6 z # T S * ; [#D '