Ñò
Š„[Jc @ s¯ d Z d d k Z d d k Z d d k l Z d d k l Z l Z d d k l Z e i
d e i e i Bƒ Z
d e i f d „ ƒ YZ d e i f d
„ ƒ YZ e e _ d S( s Default implementations of per-dialect sqlalchemy.engine classes.
These are semi-private implementation classes which are only of importance
to database dialect authors; dialects will usually use the classes here
as the base class for their own corresponding classes.
iÿÿÿÿN( t base( t compilert
expression( t excs- \s*(?:UPDATE|INSERT|CREATE|DELETE|DROP|ALTER)t DefaultDialectc B s e Z d Z d Z e i Z e i Z e i Z
e i Z e
i Z e Z e Z d Z e Z e Z e Z e Z h Z d Z e Z e Z e e d d d d d „ Z d „ Z d „ Z d „ Z! d „ Z" d
„ Z# d „ Z$ d „ Z% d
„ Z& d „ Z' d d „ Z( d d „ Z) d „ Z* RS( s! Default implementation of Dialectt defaulti' t nameds utf-8c K sü | | _ | | _ | | _ t | _ d | _ | | _ | d j o
| | _ n0 | i d j o | i i | _ n
| i | _ | i d j | _ | i
| ƒ | _ | o0 | | i j o t
i d | | i f ƒ ‚ n | | _ t | d | ƒ | _ d S( Nt qmarkt formatt numericsQ Label length of %d is greater than this dialect's maximum identifier length of %dt description_encoding( R s formatR ( t convert_unicodet assert_unicodet encodingt Falset
positionalt Nonet _ischemat dbapit
paramstylet default_paramstylet preparert identifier_preparert max_identifier_lengthR t
ArgumentErrort label_lengtht getattrR
( t selfR R R
R R R t kwargs( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt __init__, s"
c C s$ t | ƒ t j o
| ƒ } n | S( sê Provide a database-specific ``TypeEngine`` object, given
the generic object which comes from the types module.
Subclasses will usually use the ``adapt_type()`` method in the
types module to make this job easy.( t type( R t typeobj( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt type_descriptorB s
c C s: t | ƒ | i j o t i d | | i f ƒ ‚ n d S( Ns7 Identifier '%s' exceeds maximum length of %d characters( t lenR R t IdentifierError( R t ident( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt validate_identifierM s c C s d S( sa Implementations might want to put logic here for turning
autocommit on/off, etc.
N( ( R t
connection( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt do_beginQ s c C s | i ƒ d S( sa Implementations might want to put logic here for turning
autocommit on/off, etc.
N( t rollback( R R% ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt do_rollbackX s c C s | i ƒ d S( sa Implementations might want to put logic here for turning
autocommit on/off, etc.
N( t commit( R R% ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt do_commit_ s c C s d t i d d ƒ S( s³ Create a random two-phase transaction ID.
This id will be passed to do_begin_twophase(), do_rollback_twophase(),
do_commit_twophase(). Its format is unspecified.s _sa_%032xi i i€ l ( t randomt randint( R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt
create_xidf s c C s | i t i | ƒ ƒ d S( N( t executeR t SavepointClause( R R% t name( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt do_savepointn s c C s | i t i | ƒ ƒ d S( N( R. R t RollbackToSavepointClause( R R% R0 ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt do_rollback_to_savepointq s c C s | i t i | ƒ ƒ d S( N( R. R t ReleaseSavepointClause( R R% R0 ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt do_release_savepointt s c C s | i | | ƒ d S( N( t executemany( R t cursort statementt
parameterst context( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt do_executemanyw s c C s | i | | ƒ d S( N( R. ( R R7 R8 R9 R: ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt
do_executez s c C s t S( N( R ( R t e( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt
is_disconnect} s N(+ t __name__t
__module__t __doc__R0 R t SchemaGeneratort schemageneratort
SchemaDroppert
schemadroppert DefaultCompilert statement_compilert IdentifierPreparerR R t
DefaultRunnert
defaultrunnert Truet supports_alterR t supports_unicode_statementsR t supports_sane_rowcountt supports_sane_multi_rowcountt preexecute_pk_sequencest supports_pk_autoincrementt dbapi_type_mapR t supports_default_valuest supports_empty_insertR R R R$ R& R( R* R- R1 R3 R5 R; R< R> ( ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyR sB t DefaultExecutionContextc B s e Z d d d d „ Z e d „ ƒ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d „ Z d „ Z
d
„ Z d „ Z d „ Z d
„ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( c sÐ | ˆ _ | ˆ _ ˆ _ ˆ ˆ _ | i ˆ _ ˆ d j o©ˆ i p t i d ˆ ƒ ‚ n t d „ ‡ ‡ f d † ˆ i
Dƒ Dƒ ƒ ˆ _ ˆ i ˆ _ | i
p" t ˆ ƒ i ˆ i i ƒ ˆ _ n t ˆ ƒ ˆ _ ˆ i ˆ _ ˆ i ˆ _ ˆ i i ˆ _ t ˆ i t i ƒ o# ˆ i p ˆ i ˆ i ƒ ˆ _ n | p ˆ i ƒ g ˆ _ t ˆ _ nC g } | D] } | ˆ i | ƒ qc~ ˆ _ t | ƒ d j ˆ _ ˆ i ƒ ˆ _ ˆ i p
ˆ i o ˆ i! ƒ n ˆ i" ˆ i ƒ ˆ _# né | d j o¥ d ˆ _ ˆ i$ | ƒ ˆ _# t | ƒ d j ˆ _ t | t ƒ o' | i
o | i ˆ i i ƒ ˆ _ n
| ˆ _ t ˆ _ ˆ _ ˆ i ƒ ˆ _ ˆ i | ƒ ˆ _ n7 d ˆ _ t ˆ _ ˆ _ ˆ _ ˆ _ ˆ i ƒ ˆ _ d S( Ns Not an executable clause: %sc s s6 x/ | ]( \ } } | d j o | | f Vq q Wd S( N( R ( t .0t keyt value( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pys s c 3 s2 x+ | ]$ } ˆ i | | i ˆ i ƒ f Vq Wd S( N( t
bind_namest bind_processort dialect( RV t bindparam( t compiledR ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pys ‘ s i (% R[ t _connectiont root_connectionR] t engineR t can_executeR R t dictRY t
processorst
result_mapRM t unicodet encodeR
R8 t isinsertt isupdatet _autocommitt should_autocommitt
isinstanceR t _TextClauset should_autocommit_textt construct_paramst compiled_parametersR R6 R! t
create_cursorR7 t* _DefaultExecutionContext__process_defaultst1 _DefaultExecutionContext__convert_compiled_paramsR9 t+ _DefaultExecutionContext__encode_param_keys( R R[ R% R] R8 R9 t _[1]t m( ( R] R s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyR ‚ sT
" #
-
c C s
| i i ƒ S( N( R^ t _branch( R ( ( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyR% Á s c sˆ ˆ i i p
ˆ i i o, | o | Sˆ i i o d g Sh g Sn? ‡ f d † } g } | D] } | | | ƒ q` ~ p h g Sd S( s’ apply string encoding to the keys of dictionary-based bind parameters.
This is only used executing textual, non-compiled SQL expressions.c s2 t ˆ t ƒ p ˆ St ‡ ‡ f d † ˆ Dƒ ƒ S( Nc 3 s2 x+ | ]$ } | i ˆ i i ƒ ˆ | f Vq Wd S( N( Rf R[ R
( RV t k( R t d( s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pys × s ( Rk Rb ( Rx ( R ( Rx s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt procÒ s N( ( R[ R RM ( R t paramsRy Rt Rx ( ( R s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt __encode_param_keysÅ s
c C s† | i } g } | i i o| xc| D]m } g } xQ | i i D]C } | | j o | i | | | | ƒ ƒ q< | i | | ƒ q< W| i | ƒ q# Wnë | i i } xÚ | D]Ò } h } | oj | i i } x£ | D]O } | | j o% | | | | ƒ | | i | ƒ / s N( Rb R] RY R[ R R| t dialect_implt get_dbapi_typeR R R} R7 t
setinputsizest ExceptionR^ t _handle_dbapi_exceptiont valuesRf R
( R t typest
inputsizesRW t
typeenginet dbtypeR= ( ( R s= /usr/lib/python2.6/site-packages/sqlalchemy/engine/default.pyt set_input_sizes( s8
!
!
! c C sÅ | i oº t | i i ƒ o£ | i i | ƒ } | i } xx | D]p } | | _ x^ | i i D]P } | i o | i | ƒ } n | i | ƒ } | d j o | | | i
s jö