[Jc @ s' d Z d d d d d d d d d d
d d d
d d d d d d g Z d d k Z d d k Z d d k l Z l Z l Z l Z l Z d d k
l Z d e f d YZ
d
e f d YZ d e f d YZ d e f d YZ d e f d YZ d e f d YZ d
e f d YZ d e f d YZ d e f d YZ d e f d! YZ d" Z d e f d# YZ d e f d$ YZ d e f d% YZ d e f d& YZ d e f d' YZ d e i f d( YZ d e i f d) YZ d* Z d S(+ s Basic components for SQL execution and interfacing with DB-API.
Defines the basic components used to interface DB-API modules with
higher-level statement-construction, connection-management, execution
and result contexts.
t BufferedColumnResultProxyt BufferedColumnRowt BufferedRowResultProxyt Compiledt Connectablet
Connectiont
DefaultRunnert Dialectt Enginet ExecutionContextt NestedTransactiont ResultProxyt RootTransactiont RowProxyt SchemaIteratort StringIOt Transactiont TwoPhaseTransactiont connection_memoizeiN( t exct schemat utilt typest log( t
expressionc B s e Z d Z d Z d Z d Z d d Z d d Z d d Z d Z
d Z d Z d
Z
d Z d Z d
Z d Z d Z d Z e e d Z e e d Z d Z d d Z d d Z d Z RS( sC Define the behavior of a specific database and DB-API combination.
Any aspect of metadata definition, SQL query generation,
execution, result-set handling, or anything else which varies
between databases is defined under the general category of the
Dialect. The Dialect acts as a factory for other
database-specific object implementations including
ExecutionContext, Compiled, DefaultGenerator, and TypeEngine.
All Dialects implement the following attributes:
name
identifying name for the dialect (i.e. 'sqlite')
positional
True if the paramstyle for this Dialect is positional.
paramstyle
the paramstyle to be used (some DB-APIs support multiple
paramstyles).
convert_unicode
True if Unicode conversion should be applied to all ``str``
types.
encoding
type of encoding to use for unicode, usually defaults to
'utf-8'.
schemagenerator
a :class:`~sqlalchemy.schema.SchemaVisitor` class which generates
schemas.
schemadropper
a :class:`~sqlalchemy.schema.SchemaVisitor` class which drops schemas.
defaultrunner
a :class:`~sqlalchemy.schema.SchemaVisitor` class which executes
defaults.
statement_compiler
a :class:`~sqlalchemy.engine.base.Compiled` class used to compile SQL
statements
preparer
a :class:`~sqlalchemy.sql.compiler.IdentifierPreparer` class used to
quote identifiers.
supports_alter
``True`` if the database supports ``ALTER TABLE``.
max_identifier_length
The maximum length of identifier names.
supports_unicode_statements
Indicate whether the DB-API can receive SQL statements as Python unicode strings
supports_sane_rowcount
Indicate whether the dialect properly implements rowcount for ``UPDATE`` and ``DELETE`` statements.
supports_sane_multi_rowcount
Indicate whether the dialect properly implements rowcount for ``UPDATE`` and ``DELETE`` statements
when executed via executemany.
preexecute_pk_sequences
Indicate if the dialect should pre-execute sequences on primary key
columns during an INSERT, if it's desired that the new row's primary key
be available after execution.
supports_pk_autoincrement
Indicates if the dialect should allow the database to passively assign
a primary key column value.
dbapi_type_map
A mapping of DB-API type objects present in this Dialect's
DB-API implmentation mapped to TypeEngine implementations used
by the dialect.
This is used to apply types to result sets based on the DB-API
types present in cursor.description; it only takes effect for
result sets against textual statements where no explicit
typemap was present.
supports_default_values
Indicates if the construct ``INSERT INTO tablename DEFAULT VALUES`` is supported
description_encoding
type of encoding to use for unicode when working with metadata
descriptions. If set to ``None`` no encoding will be done.
This usually defaults to 'utf-8'.
c C s
t d S( s Build DB-API compatible connection arguments.
Given a :class:`~sqlalchemy.engine.url.URL` object, returns a tuple
consisting of a `*args`/`**kwargs` suitable to send directly
to the dbapi's connect function.
N( t NotImplementedError( t selft url( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt create_connect_argsu s c C s
t d S( sF Transform a generic type to a database-specific type.
Transforms the given :class:`~sqlalchemy.types.TypeEngine` instance
from generic to database-specific.
Subclasses will usually use the
:func:`~sqlalchemy.types.adapt_type` method in the types module to
make this job easy.
N( R ( R t typeobj( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt type_descriptor s c C s
t d S( s0 Return a tuple of the database's version number.N( R ( R t
connection( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt server_version_info s c C s
t d S( sP Load table description from the database.
Given a :class:`~sqlalchemy.engine.Connection` and a
:class:`~sqlalchemy.schema.Table` object, reflect its columns and
properties from the database. If include_columns (a list or
set) is specified, limit the autoload to the given column
names.
N( R ( R R t tablet include_columns( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt reflecttable s
c C s
t d S( s& Check the existence of a particular table in the database.
Given a :class:`~sqlalchemy.engine.Connection` object and a string
`table_name`, return True if the given table (possibly within
the specified `schema`) exists in the database, False
otherwise.
N( R ( R R t
table_nameR ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt has_table s c C s
t d S( s Check the existence of a particular sequence in the database.
Given a :class:`~sqlalchemy.engine.Connection` object and a string
`sequence_name`, return True if the given sequence exists in
the database, False otherwise.
N( R ( R R t
sequence_nameR ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt has_sequence s c C s
t d S( sg Return the string name of the currently selected schema given a :class:`~sqlalchemy.engine.Connection`.N( R ( R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt get_default_schema_name s c C s
t d S( sM Provide an implementation of *connection.begin()*, given a DB-API connection.N( R ( R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt do_begin s c C s
t d S( sP Provide an implementation of *connection.rollback()*, given a DB-API connection.N( R ( R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt do_rollback s c C s
t d S( s Create a two-phase transaction ID.
This id will be passed to do_begin_twophase(),
do_rollback_twophase(), do_commit_twophase(). Its format is
unspecified.
N( R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt
create_xid s c C s
t d S( sN Provide an implementation of *connection.commit()*, given a DB-API connection.N( R ( R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt do_commit s c C s
t d S( sB Create a savepoint with the given name on a SQLAlchemy connection.N( R ( R R t name( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt do_savepoint s c C s
t d S( s9 Rollback a SQL Alchemy connection to the named savepoint.N( R ( R R R- ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt do_rollback_to_savepoint s c C s
t d S( s8 Release the named savepoint on a SQL Alchemy connection.N( R ( R R R- ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt do_release_savepoint s c C s
t d S( s6 Begin a two phase transaction on the given connection.N( R ( R R t xid( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt do_begin_twophase s c C s
t d S( s8 Prepare a two phase transaction on the given connection.N( R ( R R R1 ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt do_prepare_twophase s c C s
t d S( s9 Rollback a two phase transaction on the given connection.N( R ( R R R1 t is_preparedt recover( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt do_rollback_twophase s c C s
t d S( s7 Commit a two phase transaction on the given connection.N( R ( R R R1 R4 R5 ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt do_commit_twophase s c C s
t d S( s^ Recover list of uncommited prepared two phase transaction identifiers on the given connection.N( R ( R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt do_recover_twophase s c C s
t d S( sI Provide an implementation of *cursor.executemany(statement, parameters)*.N( R ( R t cursort statementt
parameterst context( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt do_executemany s c C s
t d S( sE Provide an implementation of *cursor.execute(statement, parameters)*.N( R ( R R9 R: R; R< ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt
do_execute s c C s
t d S( sE Return True if the given DB-API error indicates an invalid connectionN( R ( R t e( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt
is_disconnect s N( t __name__t
__module__t __doc__R R R t NoneR# R% R' R( R) R* R+ R, R. R/ R0 R2 R3 t Truet FalseR6 R7 R8 R= R> R@ ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s. [
c B sh e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
d Z d
Z RS( s A messenger object for a Dialect that corresponds to a single execution.
ExecutionContext should have these datamembers:
connection
Connection object which can be freely used by default value
generators to execute SQL. This Connection should reference the
same underlying connection/transactional resources of
root_connection.
root_connection
Connection object which is the source of this ExecutionContext. This
Connection may have close_with_result=True set, in which case it can
only be used once.
dialect
dialect which created this ExecutionContext.
cursor
DB-API cursor procured from the connection,
compiled
if passed to constructor, sqlalchemy.engine.base.Compiled object
being executed,
statement
string version of the statement to be executed. Is either
passed to the constructor, or must be created from the
sql.Compiled object by the time pre_exec() has completed.
parameters
bind parameters passed to the execute() method. For compiled
statements, this is a dictionary or list of dictionaries. For
textual statements, it should be in a format suitable for the
dialect's paramstyle (i.e. dict or list of dicts for non
positional, list or list of lists/tuples for positional).
isinsert
True if the statement is an INSERT.
isupdate
True if the statement is an UPDATE.
should_autocommit
True if the statement is a "committable" statement
postfetch_cols
a list of Column objects for which a server-side default
or inline SQL expression value was fired off. applies to inserts and updates.
c C s
t d S( s Return a new cursor generated from this ExecutionContext's connection.
Some dialects may wish to change the behavior of
connection.cursor(), such as postgres which may return a PG
"server side" cursor.
N( R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt
create_cursor@ s c C s
t d S( s Called before an execution of a compiled statement.
If a compiled statement was passed to this ExecutionContext,
the `statement` and `parameters` datamembers must be
initialized after this statement is complete.
N( R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt pre_execJ s c C s
t d S( s Called after the execution of a compiled statement.
If a compiled statement was passed to this ExecutionContext,
the `last_insert_ids`, `last_inserted_params`, etc.
datamembers should be available after this method completes.
N( R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt post_execT s c C s
t d S( sg Return a result object corresponding to this ExecutionContext.
Returns a ResultProxy.
N( R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt result^ s c C s
t d S( sH Receive a DBAPI exception which occured upon execute, result fetch, etc.N( R ( R R? ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt handle_dbapi_exceptionf s c C s
t d S( s[ Parse the given textual statement and return True if it refers to a "committable" statementN( R ( R R: ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt should_autocommit_textk s c C s
t d S( sS Return the list of the primary key values for the last insert statement executed.
This does not apply to straight textual clauses; only to
``sql.Insert`` objects compiled against a ``schema.Table``
object. The order of items in the list is the same as that of
the Table's 'primary_key' attribute.
N( R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt last_inserted_idsp s c C s
t d S( s Return a dictionary of the full parameter dictionary for the last compiled INSERT statement.
Includes any ColumnDefaults or Sequences that were pre-executed.
N( R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt last_inserted_params{ s c C s
t d S( s Return a dictionary of the full parameter dictionary for the last compiled UPDATE statement.
Includes any ColumnDefaults that were pre-executed.
N( R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt last_updated_params s c C s
t d S( sj Return True if the last INSERT or UPDATE row contained
inlined or database-side defaults.
N( R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt lastrow_has_defaults s (
RA RB RC RG RH RI RJ RK RL RM RN RO RP ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR
s 4
c B sb e Z d Z d d d Z d Z d Z e i d d Z d Z
d Z d Z RS(
s Represent a compiled SQL expression.
The ``__str__`` method of the ``Compiled`` object should produce
the actual text of the statement. ``Compiled`` objects are
specific to their underlying database dialect, and also may
or may not be specific to the columns referenced within a
particular set of bind parameters. In no case should the
``Compiled`` object be dependent on the actual values of those
bind parameters, even though it may reference those values as
defaults.
c C s4 | | _ | | _ | | _ | | _ | i | _ d S( s~ Construct a new ``Compiled`` object.
dialect
``Dialect`` to compile against.
statement
``ClauseElement`` to be compiled.
column_keys
a list of column names to be compiled into an INSERT or UPDATE
statement.
bind
Optional Engine or Connection to compile this statement against.
N( t dialectR: t column_keyst bindt supports_executiont can_execute( R RQ R: RR RS ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __init__ s
c C s
t d S( s; Produce the internal string representation of this element.N( R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt compile s c C s
t d S( s6 Return the string text of the generated SQL statement.N( R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __str__ s sA Deprecated. Use construct_params(). (supports Unicode key names.)c K s
| i | S( N( t construct_params( R t params( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt
get_params s c C s
t d S( s Return the bind params for this compiled object.
`params` is a dict of string/object pairs whos
values will override bind values compiled in
to the statement.
N( R ( R RZ ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRY s c O s< | i } | d j o t i d n | i | | | S( s Execute this compiled object.s> This Compiled object is not bound to any Engine or Connection.N( RS RD R t UnboundExecutionErrort _execute_compiled( R t multiparamsRZ R? ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt execute s
c O s | i | | i S( sB Execute this compiled object and return the result's scalar value.( R_ t scalar( R R^ RZ ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR` s N(
RA RB RC RD RV RW RX R t
deprecatedR[ RY R_ R` ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s c B sA e Z d Z d Z d Z d Z d Z d d d Z RS( s Interface for an object which supports execution of SQL constructs.
The two implementations of ``Connectable`` are :class:`Connection` and
:class:`Engine`.
c C s
t d S( sC Return a Connection object which may be part of an ongoing context.N( R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt contextual_connect s c K s
t d S( s; Create a table or index given an appropriate schema object.N( R ( R t entityt kwargs( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt create s c K s
t d S( s9 Drop a table or index given an appropriate schema object.N( R ( R Rc Rd ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt drop s c O s
t d S( N( R ( R t objectR^ RZ ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR_ s c C s
t d S( N( R ( R t elemR^ RZ ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _execute_clauseelement s N( RA RB RC Rb Re Rf R_ RD Ri ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s c B sZ e Z d Z d4 e e d Z d Z e d Z e d Z e d Z
e d Z e d Z e d Z
d Z d
Z d4 d Z d Z d
Z d Z d4 d Z d Z e d Z e d Z d Z d Z d Z d Z d4 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- d) Z. d* Z/ d+ Z0 d, Z1 d4 d- Z2 d4 d. Z3 h e) e4 i5 6e+ e4 i6 6e, e7 6e* e8 i9 6e/ e8 i: 6e- e; 6Z< d/ Z= d0 Z> d4 d1 Z? d2 Z@ d3 ZA RS(5 st Provides high-level functionality for a wrapped DB-API connection.
Provides execution support for string-based SQL statements as well
as ClauseElement, Compiled and DefaultGenerator objects. Provides
a begin method to return Transaction objects.
The Connection object is **not** thread-safe.
.. index::
single: thread safety; Connection
c C sP | | _ | p
| i | _ d | _ | | _ d | _ | | _ t | _ d S( s Construct a new Connection.
Connection objects are typically constructed by an
:class:`~sqlalchemy.engine.Engine`, see the ``connect()`` and
``contextual_connect()`` methods of Engine.
i N(
t enginet raw_connectiont _Connection__connectionRD t _Connection__transactiont _Connection__close_with_resultt _Connection__savepoint_seqt _Connection__branchRF t _Connection__invalid( R Rj R t close_with_resultt _branch( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRV s
c C s | i i | i | i d t S( s> Return a new Connection which references this Connection's
engine and connection; but does not have close_with_result enabled,
and also whose close() method does nothing.
This is used to execute "sub" statements within a single execution,
usually an INSERT statement.
Rs ( Rj R Rl RE ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRs s c C s
| i i S( s Dialect used by this Connection.( Rj RQ ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRQ % s c C s | i o
d | i j S( s) return True if this connection is closed.Rl ( Rq t __dict__( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt closed+ s c C s | i S( s/ return True if this connection was invalidated.( Rq ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt invalidated1 s c C s y | i SWnr t j
of | i oF | i d j o t i d n | i i | _ t | _ | i St i d n Xd S( s< The underlying DB-API connection managed by this Connection.s8 Can't reconnect until invalid transaction is rolled backs This Connection is closedN(
Rl t AttributeErrorRq Rm RD R t InvalidRequestErrorRj Rk RF ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR 7 s
c C s | i S( s Indicates if this Connection should be closed when a corresponding
ResultProxy is closed; this is essentially an auto-release mode.
( Rn ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt should_close_with_resultF s c C s
| i i S( s: A collection of per-DB-API connection instance properties.( R t info( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRz N s c C s | S( s Returns self.
This ``Connectable`` interface method returns self, allowing
Connections to be used interchangably with Engines in most
situations that require a bind.
( ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt connectS s c K s | S( s Returns self.
This ``Connectable`` interface method returns self, allowing
Connections to be used interchangably with Engines in most
situations that require a bind.
( ( R Rd ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRb ] s c C sQ | i o t i d n | i i o | i i | n | ` t | _ d S( s Invalidate the underlying DBAPI connection associated with this Connection.
The underlying DB-API connection is literally closed (if
possible), and is discarded. Its source connection pool will
typically lazily create a new connection to replace it.
Upon the next usage, this Connection will attempt to reconnect
to the pool with a new connection.
Transactions in progress remain in an "opened" state (even though
the actual transaction is gone); these must be explicitly
rolled back before a reconnect on this Connection can proceed. This
is to prevent applications from accidentally continuing their transactional
operations in a non-transactional state.
s This Connection is closedN( Ru R Rx Rl t is_validt
invalidateRE Rq ( R t exception( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR} g s
c C s | i i d S( s Detach the underlying DB-API connection from its connection pool.
This Connection instance will remain useable. When closed,
the DB-API connection will be literally closed and not
returned to its pool. The pool will typically lazily create a
new connection to replace the detached connection.
This method can be used to insulate the rest of an application
from a modified state on a connection (such as a transaction
isolation level or similar). Also see
:class:`~sqlalchemy.interfaces.PoolListener` for a mechanism to modify
connection state when connections leave and return to their
connection pool.
N( Rl t detach( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s c C s: | i d j o t | | _ n t | | i S| i S( sw Begin a transaction and return a Transaction handle.
Repeated calls to ``begin`` on the same Connection will create
a lightweight, emulated nested transaction. Only the
outermost transaction may ``commit``. Calls to ``commit`` on
inner transactions are ignored. Any transaction in the
hierarchy may ``rollback``, however.
N( Rm RD R R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt begin s
c C s? | i d j o t | | _ n t | | i | _ | i S( sq Begin a nested transaction and return a Transaction handle.
Nested transactions require SAVEPOINT support in the
underlying database. Any transaction in the hierarchy may
``commit`` and ``rollback``, however the outermost transaction
still controls the overall ``commit`` or ``rollback`` of the
transaction of a whole.
N( Rm RD R R
( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt begin_nested s
c C s_ | i d j o t i d n | d j o | i i i } n t | | | _ | i S( s Begin a two-phase or XA transaction and return a Transaction handle.
xid
the two phase transaction id. If not supplied, a random id
will be generated.
sO Cannot start a two phase transaction when a transaction is already in progress.N( Rm RD R Rx Rj RQ R+ R ( R R1 ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt begin_twophase s
c C s | i i i | S( N( Rj RQ R8 ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt recover_twophase s c C s | i i i | | d | d S( NR5 ( Rj RQ R6 ( R R1 R5 ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt rollback_prepared s c C s | i i i | | d | d S( NR5 ( Rj RQ R7 ( R R1 R5 ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt commit_prepared s c C s
| i d j S( s, Return True if a transaction is in progress.N( Rm RD ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt in_transaction s c C sv | i i o | i i i d n y | i i i | i Wn1 t j
o% } | i | d d d d n Xd S( Nt BEGIN(
Rj t _should_log_infot loggerRz RQ R) R t Exceptiont _handle_dbapi_exceptionRD ( R R? ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _begin_impl s
c C s | i o | i o | i i o | i i o | i i i d n y# | i i i | i
d | _ Wq t
j
o% } | i | d d d d q Xn
d | _ d S( Nt ROLLBACK( Ru Rv Rl R| Rj R R Rz RQ R* R RD Rm R R ( R R? ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _rollback_impl s #
c C s | i i o | i i i d n y# | i i i | i d | _ Wn1 t j
o% } | i
| d d d d n Xd S( Nt COMMIT( Rj R R Rz RQ R, R RD Rm R R ( R R? ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _commit_impl s
c C sY | d j o | i d 7_ d | i } n | i i o | i i i | | | Sd S( Ni s sa_savepoint_%s( RD Ro Rl R| Rj RQ R. ( R R- ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _savepoint_impl s
c C s4 | i i o | i i i | | n | | _ d S( N( Rl R| Rj RQ R/ Rm ( R R- R< ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _rollback_to_savepoint_impl s
c C s4 | i i o | i i i | | n | | _ d S( N( Rl R| Rj RQ R0 Rm ( R R- R< ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _release_savepoint_impl s
c C s+ | i i o | i i i | | n d S( N( Rl R| Rj RQ R2 ( R R1 ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _begin_twophase_impl s
c C sE | i i o4 t | i t p t | i i i | | n d S( N( Rl R| t
isinstanceRm R t AssertionErrorRj RQ R3 ( R R1 ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _prepare_twophase_impl s
c C sQ | i i o7 t | i t p t | i i i | | | n d | _ d S( N(
Rl R| R Rm R R Rj RQ R6 RD ( R R1 R4 ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _rollback_twophase_impl s
c C sQ | i i o7 t | i t p t | i i i | | | n d | _ d S( N(
Rl R| R Rm R R Rj RQ R7 RD ( R R1 R4 ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _commit_twophase_impl s
c C s | i p | i n d S( N( R R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt
_autorollback s
c C sO y
| i } Wn t j
o d SX| i p | i n t | _ | ` d S( s Close this Connection.N( Rl Rw Rp t closeRF Rq ( R t conn( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
c O s | i | | | i S( s Executes and returns the first column of the first row.
The underlying result/cursor is closed after execution.
( R_ R` ( R Rg R^ RZ ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR` ( s c K s | i i | i | d | | S( NRS ( RQ t statement_compiler( R R: Rd ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR 0 s c O sh xa t | i D]1 } | t i j o t i | | | | | Sq Wt i d t t | d S( s# Executes and returns a ResultProxy.s Unexecutable object type: N( t typet __mro__R t executorsR Rx t str( R Rg R^ RZ t c( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR_ 3 s
c C s | p | o | g Sg Sn t | d j or | d } t | t t f o, | p t | d d o | S| g Sq t | d o | g S| g g Sn! t | d d o | S| g Sd S( s given arguments from the calling form *multiparams, **params, return a list
of bind parameter structures, usually a list of dictionaries.
in the case of 'raw' execution which accepts positional parameters,
it may be a list of tuples or lists.i i t __iter__t keysN( t lenR t listt tuplet hasattr( R R^ RZ t zero( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __distill_params< s
c C s | i | i | | S( N( Ri t select( R t funcR^ RZ ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _execute_functionY s c C s" | i i i | i i | S( N( Rj RQ t
defaultrunnert% _Connection__create_execution_contextt traverse_single( R t defaultR^ RZ ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _execute_default\ s c
C s | i | | } | o | d i } n g } | i d | i d | i d | d t | d j d | } | i | S( Ni t compiledRQ RR t inlinei R; ( t _Connection__distill_paramsR R RW RQ R t _Connection__execute_context( R Rh R^ RZ R R< ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRi _ s - c C s1 | i d | d | i | | } | i | S( s Execute a sql.Compiled object.R R; ( R R R ( R R R^ RZ R< ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR] l s c C s7 | i | | } | i d | d | } | i | S( NR: R; ( R R R ( R R: R^ RZ R; R< ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt
_execute_textu s c C s | i o | i n | i o& | i | i | i | i d | n' | i | i | i | i d d | | i o | i n | i o | i
o | i n | i S( NR< i (
R RH t executemanyt _cursor_executemanyR9 R: R; t _cursor_executeRI t should_autocommitR R t get_result_proxy( R R< ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __execute_contextz s
&&
c C s< | o | d | d } } n d } | d | | | | S( Ni i ( RD ( R t ddlRZ R^ t schema_item( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _execute_ddl s c C s t | d t o t i i d d | n t | _ z t | | i i
i p d S| o | i | n | i i
| } | o | i | | i i n8 | o | i n | i | i o | i n t i i | | | d | Wd | ` Xd S( Nt _reentrant_errort connection_invalidated( t getattrRF R t
DBAPIErrort instanceRD RE R R RQ t dbapit ErrorRK R@ R} Rj t disposeR R Rn ( R R? R: R; R9 R< R@ ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s&
"c K sv y& | i i } | i | d | | SWnI t j
o= } | i | | i d d | i d d d d n Xd S( NR R: R; ( Rj RQ t execution_ctx_clsR R t getRD ( R Rd RQ R? ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __create_execution_context s 1c C s | i i o0 | i i i | | i i i t | n y | i i | | | d | Wn1 t j
o% } | i | | | | | n Xd S( NR< ( Rj R R Rz t reprRQ R> R R ( R R9 R: R; R< R? ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
c C s | i i o0 | i i i | | i i i t | n y | i i | | | d | Wn1 t j
o% } | i | | | | | n Xd S( NR< ( Rj R R Rz R RQ R= R R ( R R9 R: R; R< R? ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
c K s | i i | d | | S( s; Create a Table or Index given an appropriate Schema object.R ( Rj Re ( R Rc Rd ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRe s c K s | i i | d | | S( s9 Drop a Table or Index given an appropriate Schema object.R ( Rj Rf ( R Rc Rd ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRf s c C s | i i | | | S( sE Reflect the columns in the given string table name from the database.( Rj R# ( R R! R" ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR# s c C s | i i i | S( N( Rj RQ R( ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt default_schema_name s c C s
| | S( N( ( R t callable_( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt run_callable s N(B RA RB RC RD RF RV Rs t propertyRQ Ru Rv R Ry Rz R{ Rb R} R R R R R R R R R R R R R R R R R R R R R` R R_ R R R Ri R] R R R R R R R R t Functiont
ClauseElementR R t
SchemaItemt DDLt
basestringR Re Rf R# R R ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR sx
c B sV e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
RS( s Represent a Transaction in progress.
The Transaction object is **not** threadsafe.
.. index::
single: thread safety; Transaction
c C s& | | _ | p | | _ t | _ d S( N( R t _parentRE t is_active( R R t parent( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRV s c C s4 | i i p d S| i | j o | i n d S( s0 Close this transaction.
If this transaction is the base transaction in a begin/commit
nesting, the transaction will rollback(). Otherwise, the
method returns.
This is used to cancel a Transaction without affecting the scope of
an enclosing transaction.
N( R R t rollback( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
c C s) | i i p d St | _ | i d S( N( R R RF t _do_rollback( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
c C s | i i d S( N( R R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s c C s7 | i i p t i d n | i t | _ d S( Ns This transaction is inactive( R R R Rx t
_do_commitRF ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt commit s
c C s d S( N( ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s c C s | S( N( ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __enter__ s c C s3 | d j o | i o | i n | i d S( N( RD R R R ( R R t valuet traceback( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __exit__ s ( RA RB RC RV R R R R R R R ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s c B s# e Z d Z d Z d Z RS( c C s* t t | i | d | i i d S( N( t superR RV RD R R ( R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRV s c C s | i i d S( N( R R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s c C s | i i d S( N( R R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR # s ( RA RB RV R R ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s c B s# e Z d Z d Z d Z RS( c C s/ t t | i | | | i i | _ d S( N( R R
RV R R t
_savepoint( R R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRV ' s c C s | i i | i | i d S( N( R R R R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR + s c C s | i i | i | i d S( N( R R R R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR . s ( RA RB RV R R ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR
& s c B s, e Z d Z d Z d Z d Z RS( c C sB t t | i | d t | _ | | _ | i i | i d S( N( R R RV RD RF t _is_preparedR1 R R ( R R R1 ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRV 2 s c C s@ | i i p t i d n | i i | i t | _ d S( Ns This transaction is inactive( R R R Rx R R R1 RE R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt prepare8 s
c C s | i i | i | i d S( N( R R R1 R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR > s c C s | i i | i | i d S( N( R R R1 R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR A s ( RA RB RV R R R ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR 1 s c B s" e Z d Z d d d Z e d Z e i Z d Z
d Z d d Z d d Z
d Z e d Z d Z d d
Z d d Z d d Z d
Z d Z d d d Z d Z d Z d Z e d Z d d d Z d d d Z d d Z d Z RS( s
Connects a :class:`~sqlalchemy.pool.Pool` and :class:`~sqlalchemy.engine.base.Dialect`
together to provide a source of database connectivity and behavior.
c C so | | _ | | _ | | _ | | _ | | _ t i | d | | _ | o t t | | _ n
t | _ d S( Nt echoflag(
t poolR RQ t echoRj R t instance_loggerR t _proxy_connection_clsR ( R R RQ R R t proxy( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRV K s c C s
| i i S( sQ String name of the :class:`~sqlalchemy.engine.Dialect` in use by this ``Engine``.( RQ R- ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR- W s c C s d t | i S( Ns
Engine(%s)( R R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __repr___ s c C s# | i i | i i | _ d S( N( R R t recreate( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR b s
c K s# | i | i i | d | | d S( s] Create a table or index within this engine's database connection given a schema.Table object.R N( t _run_visitorRQ t schemagenerator( R Rc R Rd ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRe f s c K s# | i | i i | d | | d S( s[ Drop a table or index within this engine's database connection given a schema.Table object.R N( R RQ t
schemadropper( R Rc R Rd ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRf k s c C s5 | i } z | i | d h SWd | i Xd S( N( ( Rb R R ( R R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR p s c C s t i d | S( NRS ( R t _FunctionGenerator( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR w s c O s t i | d | | | S( s: Return a sql.text() object for performing literal queries.RS ( R t text( R R t argsRd ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR { s c K sl | d j o | i d t } n | } z | | i | | i | Wd | d j o | i n Xd S( NRr ( RD Rb RF RQ t traverseR ( R t visitorcallablet elementR Rd R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
c
O s | d j o | i } n | } zK | i } y$ | | | | } | i | SWn | i n XWd | d j o | i n Xd S( sS Execute the given function within a transaction boundary.
This is a shortcut for explicitly calling `begin()` and `commit()`
and optionally `rollback()` when exceptions are raised. The
given `*args` and `**kwargs` will be passed to the function, as
well as the Connection used in the transaction.
N( RD Rb R R R R ( R R R R Rd R t transt ret( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt transaction s
c O sZ | d j o | i } n | } z | | | | SWd | d j o | i n Xd S( N( RD Rb R ( R R R R Rd R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
c O s% | i d t } | i | | | S( NRr ( Rb RE R_ ( R R: R^ RZ R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR_ s c O s | i | | | i S( N( R_ R` ( R R: R^ RZ ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR` s c C s% | i d t } | i | | | S( NRr ( Rb RE Ri ( R Rh R^ RZ R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRi s c C s% | i d t } | i | | | S( NRr ( Rb RE R] ( R R R^ RZ R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR] s c K s | i i | i | d | | S( NRS ( RQ R ( R R: Rd ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s c K s | i | | S( s+ Return a newly allocated Connection object.( R ( R Rd ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR{ s c K s" | i | | i i d | | S( s Return a Connection object which may be newly allocated, or may be part of some ongoing context.
This Connection is meant to be used by the various "auto-connecting" operations.
Rr ( R R R{ ( R Rr Rd ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRb s c C s | d j o | i } n | } | p0 y | i i | } WqZ t j
o qZ Xn z | i i | | SWd | d j o | i n Xd S( s Return a list of all table names available in the database.
schema:
Optional, retrieve names from a non-default schema.
connection:
Optional, use a specified connection. Default is the
``contextual_connect`` for this ``Engine``.
N( RD Rb RQ R( R t table_namesR ( R R R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
c C s` | d j o | i } n | } z | i i | | | Wd | d j o | i n Xd S( sL Given a Table object, reflects its columns and properties from the database.N( RD Rb RQ R# R ( R R! R R" R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR# s
c s i f d S( Nc s i i | d S( R ( RQ R% ( R ( R$ R R ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt s ( R ( R R$ R ( ( R R$ R s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR% s c C s
| i i S( s Return a DB-API connection.( R t unique_connection( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRk s N( RA RB RC RD RV R R- R t
echo_propertyR R R Re Rf R R R R R R R_ R` Ri R] R R{ RF Rb R R# R% Rk ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR D s2
c s# d | f f d Y S( Nt ProxyConnectionc s\ e Z f d Z d d f d Z d f d Z d f d Z RS( c s% i | t | i | | | S( N( R_ R ( R Rg R^ RZ ( R R ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR_ s c s3 i | t | i | | p g | p h S( N( R_ R ( R Rh R^ RZ ( R R ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRi s c s( i t | i | | | | t S( N( t cursor_executeR R RF ( R R9 R: R; R< ( R R ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s c s( i t | i | | | | t S( N( R R R RE ( R R9 R: R; R< ( R R ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s N( RA RB R_ RD Ri R R ( ( R R ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s ( ( t clsR ( ( R R s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
c B s e Z d Z d d g 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( s Proxy a single cursor row for a parent ResultProxy.
Mostly follows "ordered dictionary" behavior, mapping result
values to the string-based column name, the integer position of
the result in the row, as well as Column instances which can be
mapped to the original Columns that produced this result set (for
results that correspond to constructed SQL expressions).
t __parentt __rowc C sJ | | _ | | _ | i i o' | i i i i i d t | n d S( s8 RowProxy objects are constructed by ResultProxy objects.s Row N( t _RowProxy__parentt _RowProxy__rowt _echoR< Rj R t debugR ( R R t row( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRV s
c C s | i i d S( s Close the parent ResultProxy.N( R R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR " s c C s | i i | i | S( N( R t _has_keyR ( R t key( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __contains__' s c C s
t | i S( N( R R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __len__* s c c s; x4 t t | i D] } | i i | i | Vq Wd S( N( t xrangeR R R t _get_col( R t i( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR - s c s< | j p/ | t f d t t i D j S( Nc 3 s+ x$ | ] } i i i | Vq Wd S( N( R R R ( t .0R ( R ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pys 5 s ( R R R R ( R t other( ( R s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __eq__3 s
c C s | i | S( N( R ( R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __ne__8 s c C s t t | S( N( R R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR ; s c C s | i i | i | S( s4 Return True if this RowProxy contains the given key.( R R R ( R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt has_key> s c C s | i i | i | S( N( R R R ( R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __getitem__C s c C sI y | i i | i | SWn( t j
o } t | i d n Xd S( Ni ( R R R t KeyErrorRw R ( R R- R? ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __getattr__F s c C s4 g } | i D] } | | t | | f q ~ S( s@ Return a list of tuples, each tuple containing a key/value pair.( t iterkeysR ( R t _[1]R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt itemsL s c C s
| i i S( s@ Return the list of keys as strings represented by this RowProxy.( R R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR Q s c C s t | i i S( N( t iterR R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR V s c C s
t | S( s9 Return the values represented by this RowProxy as a list.( R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt valuesY s c C s
t | S( N( R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt
itervalues^ s N( RA RB RC t __slots__RV R R R
R RD t __hash__R R R R R R R R R R R ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR
s& c B s e Z d Z RS( c C sY g } t t | D] } | t i | | | q ~ } t t | i | | d S( N( R R R R R R RV ( R R R R R
( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRV b s <( RA RB RV ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR a s c B s e Z d Z e Z d Z e 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 Z d Z d Z d Z d Z d Z d Z d d Z d Z d Z d d Z d Z d Z RS( s Wraps a DB-API cursor object to provide easier access to row columns.
Individual columns may be accessed by their integer position,
case-insensitive column name, or by ``schema.Column``
object. e.g.::
row = fetchone()
col1 = row[0] # access via integer position
col2 = row['col2'] # access via name
col3 = row[mytable.c.mycol] # access via Column object.
ResultProxy also contains a map of TypeEngine objects and will
invoke the appropriate ``result_processor()`` method before
returning columns, as well as the ExecutionContext corresponding
to the statement execution. It provides several methods for which
to obtain information from the underlying ExecutionContext.
c C sS | | _ | i | _ t | _ | i | _ | i | _ | i i | _ | i
d S( sJ ResultProxy objects are constructed via the execute() method on SQLEngine.N( R< RQ RF Ru R9 t root_connectionR Rj R R t _init_metadata( R R< ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRV s c C s) | i d j o | i i S| i Sd S( N( t _rowcountRD R< t get_rowcount( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt rowcount s c C s
| i i S( N( R9 t lastrowid( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR# s c C s
| i i S( N( R< t out_parameters( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR$ s c C s | i i } | d j o! | i i | _ | i d Sd | _ t i d | _ | i
| i _ g | _ | i
i } x t | D]\ } } | d } | i
i o | i | i
i } n d | j o | } | i d d } n d } | i i od y# | i i | i \ } } } Wqt j
o. | d | i | d t i } } } qXn( | d | i | d t i } } } | | i | i
i | i
| f }
| i i | i |
|
j o) | | i | d f | i | i s ($ R9 t descriptionRD R< R! R R R t populate_column_dictt _propst _ResultProxy__key_fallbackt creatorR RQ t dbapi_type_mapt enumeratet description_encodingt decodet splitt
result_mapt lowerR R R t NULLTYPEt dialect_implt result_processort
setdefaultt! _ResultProxy__ambiguous_processort appendR Rj R R R R ( R t metadatat typemapR
t itemt colnamet orignameR- t objt type_t rect o( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR sP
#0''")"-
c s | i f d } | S( Nc s t | t o& | i } | j o | Sn t | t i on | i o( | i i j o | i i St | d o( | i i j o | i i Sn t i d t
| d S( NR- s. Could not locate column in row for column '%s'( R R R2 R t
ColumnElementt _labelR R- R t NoSuchColumnErrorR ( R ( t props( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt fallback s
&( R) ( R RF ( ( RE s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __key_fallback s c s f d } | S( Nc s t i d d S( NsV Ambiguous column name '%s' in result set! try 'use_labels' option on select statement.( R Rx ( R ( R< ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt process s ( ( R R< RH ( ( R< s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt __ambiguous_processor s c C sF | i p8 t | _ | i i | i i o | i i qB n d S( s Close this ResultProxy.
Closes the underlying DBAPI cursor corresponding to the execution.
If this ResultProxy was generated from an implicit execution,
the underlying Connection will also be closed (returns the
underlying DBAPI connection to the connection pool.)
This method is called automatically when:
* all result rows are exhausted using the fetchXXX() methods.
* cursor.description is None.
N( Ru RE R9 R R Ry ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
c C s. y | i | t SWn t j
o t SXd S( N( R) RE R RF ( R R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
c c s; x4 t o, | i } | d j o
t q | Vq Wd S( N( RE t fetchoneRD t
StopIteration( R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR
s
c C s
| i i S( sy Return ``last_inserted_ids()`` from the underlying ExecutionContext.
See ExecutionContext for details.
( R< RM ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRM s c C s
| i i S( s{ Return ``last_updated_params()`` from the underlying ExecutionContext.
See ExecutionContext for details.
( R< RO ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRO s c C s
| i i S( s| Return ``last_inserted_params()`` from the underlying ExecutionContext.
See ExecutionContext for details.
( R< RN ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRN " s c C s
| i i S( s Return ``lastrow_has_defaults()`` from the underlying ExecutionContext.
See ExecutionContext for details.
( R< RP ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRP * s c C s
| i i S( s~ Return ``postfetch_cols()`` from the underlying ExecutionContext.
See ExecutionContext for details.
( R< t postfetch_cols( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRL 2 s c C s
| i i S( N( R< t
prefetch_cols( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRM : s c C s
| i i S( s3 Return ``supports_sane_rowcount`` from the dialect.( RQ t supports_sane_rowcount( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRN = s c C s
| i i S( s9 Return ``supports_sane_multi_rowcount`` from the dialect.( RQ t supports_sane_multi_rowcount( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRO B s c s y i | \ } } } Wn_ t j
oS t | t o9 | i t } t f d t | D S n X| o | | S | Sd S( Nc 3 s% x | ] } i | Vq Wd S( N( R ( R R
( R R ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pys O s ( R) t TypeErrorR t slicet indicesR R R ( R R R R? t processort indexRR ( ( R R s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR G s $c C s
| i i S( N( R9 RJ ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _fetchone_implX s c C s | i i | S( N( R9 t fetchmany( R t size( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _fetchmany_impl[ s c C s
| i i S( N( R9 t fetchall( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt _fetchall_impl^ s c C s yK | i } g } | i D] } | | | | q ~ } | i | SWn: t j
o. } | i i | d d | i | i n Xd S( s7 Fetch all rows, just like DB-API ``cursor.fetchall()``.N( t _process_rowRZ R R R R RD R9 R< ( R t process_rowR R t lR? ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRY a s 0
"c C s ye | i } g } | i | D] } | | | | q ~ } t | d j o | i n | SWn: t j
o. } | i i | d d | i | i n Xd S( sN Fetch many rows, just like DB-API ``cursor.fetchmany(size=cursor.arraysize)``.i N(
R[ RX R R R R R RD R9 R< ( R RW R\ R R R] R? ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRV m s 3"c C s} y< | i } | d j o | i | | S| i d SWn: t j
o. } | i i | d d | i | i n Xd S( s6 Fetch one row, just like DB-API ``cursor.fetchone()``.N( RU RD R[ R R R R R9 R< ( R R R? ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRJ z s
"c C s y | i } Wn: t j
o. } | i i | d d | i | i n Xz* | d j o | i | | d Sd SWd | i Xd S( sB Fetch the first column of the first row, and close the result set.i N( RU R R R RD R9 R< R[ R ( R R R? ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR` s "
N(! RA RB RC R
R[ RV R R" R# R$ R R* R7 R R R RM RO RN RP RL RM RN RO R RU RD RX RZ RY RV RJ R` ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR g s8
8
c B sg e Z d Z d Z h d d 6d d 6d d 6d d 6d d 6Z d Z d Z d d
Z d Z RS(
s_ A ResultProxy with row buffering behavior.
``ResultProxy`` that buffers the contents of a selection of rows
before ``fetchone()`` is called. This is to allow the results of
``cursor.description`` to be available immediately, when
interfacing with a DB-API that requires rows to be consumed before
this information is available (currently psycopg2, when used with
server-side cursors).
The pre-fetching behavior fetches only one row initially, and then
grows its buffer size by a fixed amount with each successive need
for additional rows up to a size of 100.
c C s! | i t t | i d S( N( t$ _BufferedRowResultProxy__buffer_rowsR R R ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
i i i
i i2 id c C sC t | d d } | i i | | _ | i i | | | _ d S( Nt _bufsizei ( R R9 RV t" _BufferedRowResultProxy__rowbuffert size_growthR R_ ( R RW ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt
__buffer_rows s c C s^ | i o d St | i d j o) | i t | i d j o d Sn | i i d S( Ni ( Ru RD R R` R^ t pop( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRU s
c C sO g } xB t d | D]1 } | i } | d j o Pn | i | q W| S( Ni ( t rangeRU RD R8 ( R RW RJ R& R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRX s
c C s | i t | i i S( N( R` R R9 RY ( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRZ s N(
RA RB RC R Ra R^ RU RD RX RZ ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
c B s2 e Z d Z e Z d Z d Z d d Z RS( s A ResultProxy with column buffering behavior.
``ResultProxy`` that loads all columns into memory each time
fetchone() is called. If fetchmany() or fetchall() are called,
the full grid of results is fetched. This is to operate with
databases where result rows contain "live" results that fall out
of scope unless explicitly fetched. Currently this includes just
cx_Oracle LOB objects, but this behavior is known to exist in
other DB-APIs as well (Pygresql, currently unsupported).
c s y i | } | d SWn_ t j
oS t | t o9 | i t } t f d t | D S n Xd S( Ni c 3 s% x | ] } i | Vq Wd S( N( R ( R R
( R R ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pys s ( R) RP R RQ RR R R R ( R R R R@ RR ( ( R R s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
$c C sD g } x7 t o/ | i } | d j o Pn | i | q W| S( N( RE RJ RD R8 ( R R] R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRY s
c C sd | d j o | i Sg } x? t | D]1 } | i } | d j o Pn | i | q+ W| S( N( RD RY R RJ R8 ( R RW R] R
R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRV s
N( RA RB RC R R[ R RY RD RV ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s
c B s) e Z d Z d Z d Z d Z RS( sT A visitor that can gather text into a buffer and execute the contents of the buffer.c C s | | _ t i | _ d S( s Construct a new SchemaIterator.N( R R t buffer( R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRV s c C s | i i | d S( s4 Append content to the SchemaIterator's query buffer.N( Re t write( R t s( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR8 s c C s5 z | i i | i i SWd | i i d Xd S( s4 Execute the contents of the SchemaIterator's buffer.Ni ( R R_ Re t getvaluet truncate( R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR_ s ( RA RB RC RV R8 R_ ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s c B sb e Z d Z d Z d Z d Z d Z d Z d Z d
d Z
d Z d Z RS( so A visitor which accepts ColumnDefault objects, produces the
dialect-specific SQL corresponding to their execution, and
executes the SQL, returning the result value.
DefaultRunners are used internally by Engines and Dialects.
Specific database modules should provide their own subclasses of
DefaultRunner to allow database-specific behavior.
c C s% | | _ | i | _ | i | _ d S( N( R< RQ R9 ( R R< ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyRV # s c C s) | i d j o | i | i Sd Sd S( N( R RD R ( R t column( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt get_column_default( s c C s) | i d j o | i | i Sd Sd S( N( t onupdateRD R ( R Rj ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt get_column_onupdate. s c C s d S( N( RD ( R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt visit_passive_default4 s c C s d S( N( RD ( R t seq( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt visit_sequence7 s c C sF | i i } t i | i g i d | } | i | d h i S( NRS ( ( R< R R R t argRW R] R` ( R R R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt exec_default_sql: s !c C sj | i i } t | t o' | i i o | i | i i } n | i | i | | | i i
d S( sM execute a string statement, using the raw cursor, and return a scalar result.i ( R< t _connectionR t unicodeRQ t supports_unicode_statementst encodet encodingR R9 RJ ( R t stmtRZ R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt execute_string? s
c C sS t | i t i o | i | St i | i o | i | i S| i Sd S( N( R Rq R R Rr R t callableR< ( R Rl ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt visit_column_onupdateH s
c C sS t | i t i o | i | St i | i o | i | i S| i Sd S( N( R Rq R R Rr R Rz R< ( R R ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt visit_column_defaultP s
N(
RA RB RC RV Rk Rm Rn Rp Rr RD Ry R{ R| ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR s c s t i f d } | S( s Decorator, memoize a function in a connection.info stash.
Only applicable to functions which take no arguments other than a
connection. The memo will be stored in ``connection.info[key]``.
c sP | i } y | i SWn. t j
o" | | | | i <} | SXd S( N( R{ Rz R ( t fnR R t val( R ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt decorated` s ( R t decorator( R R ( ( R s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyR Y s (! RC t __all__t inspectR t
sqlalchemyR R R R R t sqlalchemy.sqlR Rg R R R R R R R R
R R R R
R R R R t
SchemaVisitorR R R ( ( ( s: /usr/lib/python2.6/site-packages/sqlalchemy/engine/base.pyt s6 (J 9 S 1:1A