[Jc
@ s d Z d d k Z d d k Z d d k Z d d k Z d d k l Z l Z l Z l Z d d k
l Z l Z d d k
l Z l Z d d k
l Z d d k l Z d e i f d YZ d
e i f d YZ d e i f d
YZ d e i f d YZ d e i f d YZ d e i f d YZ d e i f d YZ d e f d YZ d e i! f d YZ" d e i# f d YZ$ d e i% f d YZ& d e i f d YZ' d e i( f d! YZ) d" e i* f d# YZ+ d$ e i, f d% YZ- d& e i. f d' YZ/ d( e i0 f d) YZ1 d* e i f d+ YZ2 d, e i f d- YZ3 d. e i4 e i5 e i f d/ YZ6 h e e i 6e e i 6e e i 6e e i 6e" e i! 6e$ e i# 6e& e i% 6e+ e i* 6e/ e i. 6e1 e i0 6e) e i( 6e- e i, 6Z7 h e d0 6e d1 6e d2 6e+ d3 6e- d4 6e- d5 6e- d6 6e) d7 6e d8 6e d9 6e d: 6e d; 6e d< 6e3 d= 6e2 d> 6e d? 6e d@ 6e" dA 6e" dB 6e" dC 6e& dD 6e& dE 6e$ dF 6e& dG 6e/ dH 6e1 dI 6e' dJ 6Z8 e i9 dK e i: e i; B Z< dL e i= f dM YZ> dN e i? f dO YZ@ dP e iA f dQ YZB dR e iC f dS YZD dT e iE f dU YZF dV e iG f dW YZH dX e iI f dY YZJ e@ ZK eB eK _L eD eK _M eF eK _N eJ eK _O eH eK _P e> eK _Q d S(Z s=
Support for the PostgreSQL database.
Driver
------
The psycopg2 driver is supported, available at http://pypi.python.org/pypi/psycopg2/ .
The dialect has several behaviors which are specifically tailored towards compatibility
with this module.
Note that psycopg1 is **not** supported.
Connecting
----------
URLs are of the form `postgres://user:password@host:port/dbname[?key=value&key=value...]`.
PostgreSQL-specific keyword arguments which are accepted by :func:`~sqlalchemy.create_engine()` are:
* *server_side_cursors* - Enable the usage of "server side cursors" for SQL statements which support
this feature. What this essentially means from a psycopg2 point of view is that the cursor is
created using a name, e.g. `connection.cursor('some name')`, which has the effect that result rows
are not immediately pre-fetched and buffered after statement execution, but are instead left
on the server and only retrieved as needed. SQLAlchemy's :class:`~sqlalchemy.engine.base.ResultProxy`
uses special row-buffering behavior when this feature is enabled, such that groups of 100 rows
at a time are fetched over the wire to reduce conversational overhead.
Sequences/SERIAL
----------------
PostgreSQL supports sequences, and SQLAlchemy uses these as the default means of creating
new primary key values for integer-based primary key columns. When creating tables,
SQLAlchemy will issue the ``SERIAL`` datatype for integer-based primary key columns,
which generates a sequence corresponding to the column and associated with it based on
a naming convention.
To specify a specific named sequence to be used for primary key generation, use the
:func:`~sqlalchemy.schema.Sequence` construct::
Table('sometable', metadata,
Column('id', Integer, Sequence('some_id_seq'), primary_key=True)
)
Currently, when SQLAlchemy issues a single insert statement, to fulfill the contract of
having the "last insert identifier" available, the sequence is executed independently
beforehand and the new value is retrieved, to be used in the subsequent insert. Note
that when an :func:`~sqlalchemy.sql.expression.insert()` construct is executed using
"executemany" semantics, the sequence is not pre-executed and normal PG SERIAL behavior
is used.
PostgreSQL 8.3 supports an ``INSERT...RETURNING`` syntax which SQLAlchemy supports
as well. A future release of SQLA will use this feature by default in lieu of
sequence pre-execution in order to retrieve new primary key values, when available.
INSERT/UPDATE...RETURNING
-------------------------
The dialect supports PG 8.3's ``INSERT..RETURNING`` and ``UPDATE..RETURNING`` syntaxes,
but must be explicitly enabled on a per-statement basis::
# INSERT..RETURNING
result = table.insert(postgres_returning=[table.c.col1, table.c.col2]).\
values(name='foo')
print result.fetchall()
# UPDATE..RETURNING
result = table.update(postgres_returning=[table.c.col1, table.c.col2]).\
where(table.c.name=='foo').values(name='bar')
print result.fetchall()
Indexes
-------
PostgreSQL supports partial indexes. To create them pass a postgres_where
option to the Index constructor::
Index('my_index', my_table.c.id, postgres_where=tbl.c.value > 10)
Transactions
------------
The PostgreSQL dialect fully supports SAVEPOINT and two-phase commit operations.
iN( t sqlt schemat exct util( t baset default( t compilert
expression( t operators( t typest PGInetc B s e Z d Z RS( c C s d S( Nt INET( ( t self( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt get_col_specf s ( t __name__t
__module__R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
e s t PGCidrc B s e Z d Z RS( c C s d S( Nt CIDR( ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
j s ( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR i s t PGMacAddrc B s e Z d Z RS( c C s d S( Nt MACADDR( ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
n s ( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR m s t PGNumericc B s# e Z d Z d Z d Z RS( c C s/ | i p d Sd h | i d 6| i d 6Sd S( Nt NUMERICs! NUMERIC(%(precision)s, %(scale)s)t precisiont scale( R R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
r s
c C s d S( N( t None( R t dialect( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt bind_processorx s c C s | i o d Sd } | Sd S( Nc S s& t | t i o t | S| Sd S( N( t
isinstancet decimalt Decimalt float( t value( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt process s ( t asdecimalR ( R R R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt result_processor{ s
( R R R
R R" ( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR q s t PGFloatc B s e Z d Z RS( c C s% | i p d Sd h | i d 6Sd S( Nt FLOATs FLOAT(%(precision)s)R ( R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s
( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR# s t PGIntegerc B s e Z d Z RS( c C s d S( Nt INTEGER( ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s ( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR% s t PGSmallIntegerc B s e Z d Z RS( c C s d S( Nt SMALLINT( ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s ( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR' s t PGBigIntegerc B s e Z d Z RS( c C s d S( Nt BIGINT( ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s ( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR) s t
PGDateTimec B s e Z d Z RS( c C s d | i o d p d d S( Ns
TIMESTAMP t WITHt WITHOUTs
TIME ZONE( t timezone( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s ( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR+ s t PGDatec B s e Z d Z RS( c C s d S( Nt DATE( ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s ( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR/ s t PGTimec B s e Z d Z RS( c C s d | i o d p d d S( Ns TIME R, R- s
TIME ZONE( R. ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s ( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR1 s t
PGIntervalc B s e Z d Z RS( c C s d S( Nt INTERVAL( ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s ( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR2 s t PGTextc B s e Z d Z RS( c C s d S( Nt TEXT( ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s ( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR4 s t PGStringc B s e Z d Z RS( c C s% | i o d h | i d 6Sd Sd S( Ns VARCHAR(%(length)d)t lengtht VARCHAR( R7 ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s
( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR6 s t PGCharc B s e Z d Z RS( c C s% | i o d h | i d 6Sd Sd S( Ns CHAR(%(length)d)R7 t CHAR( R7 ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s
( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR9 s t PGBinaryc B s e Z d Z RS( c C s d S( Nt BYTEA( ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s ( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR; s t PGBooleanc B s e Z d Z RS( c C s d S( Nt BOOLEAN( ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s ( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR= s t PGBitc B s e Z d Z RS( c C s d S( Nt BIT( ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s ( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR? s t PGUuidc B s e Z d Z RS( c C s d S( Nt UUID( ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s ( R R R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyRA s t PGArrayc B sS e Z e d Z d Z d Z d Z d Z d Z d Z d Z
RS( c C s3 t | t o
| } n | | _ | | _ d S( N( R t typet item_typet mutable( R RE RF ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt __init__ s
c C s/ | d j o d S| i o t | S| Sd S( N( R RF t list( R R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt
copy_value s
c C s
| | j S( N( ( R t xt y( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt compare_values s c C s | i S( N( RF ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt
is_mutable s c K sA | i i | i } | i i | i | i i | | _ | S( N( t __class__t __new__t __dict__t updateRE t dialect_impl( R R t kwargst impl( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyRR s c s% | i i | f d } | S( Nc sI | d j o | S f d g } | D] } | | q/ ~ S( Nc sV t | t t f o& g } | D] } | | q! ~ S o | S| Sd S( N( R RH t tuple( t itemt _[1]t child( t convert_itemt item_proc( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyRY s
& ( R ( R RW RV ( RZ ( RY sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR s
( RE R ( R R R ( ( RZ sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR s c s% | i i | f d } | S( Nc sI | d j o | S f d g } | D] } | | q/ ~ S( Nc sP t | t o& g } | D] } | | q ~ S o | S| Sd S( N( R RH ( RV RW RX ( RZ RY ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyRY s
& ( R ( R RW RV ( RZ ( RY sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR s
( RE R" ( R R R ( ( RZ sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR" s c C s | i i d S( Ns []( RE R
( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR
s ( R R t TrueRG RI RL RM RR R R" R
( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyRC s t integert bigintt smallints character varyingt characters "char"t namet textt numericR t realt inett cidrt uuidt bitt macaddrs double precisiont timestamps timestamp with time zones timestamp without time zones time with time zones time without time zonet datet timet byteat booleant intervals \s*SELECTt PGExecutionContextc B s e Z d Z d Z RS( c C s | i i o{ | i o3 t | i i t i o t | i i d t p> | i p t | i i t i o | i o t
i | i } | | _ | oJ d t
t | d t
t i d d d f } | i i i | S| i i i Sd S( Nt
for_updates c_%s_%si i i ( R t server_side_cursorst compiledR t statementR t
Selectablet getattrt Falset _TextClauset SERVER_SIDE_CURSOR_REt matcht# _PGExecutionContext__is_server_sidet hext idt randomt randintt _connectiont
connectiont cursor( R t is_server_sidet ident( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt
create_cursor< s
#$ 6c C s) | i o t i | St i | Sd S( N( Rz R t BufferedRowResultProxyt ResultProxy( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt get_result_proxyQ s
( R R R R ( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyRo ; s t PGDialectc B s e Z d Z e Z e Z d Z e Z e Z e Z
e Z d Z e Z
e Z e d Z d Z e e Z d Z d Z d Z d Z e e d Z e e d
Z d Z d Z e i d e Z d Z d d Z d Z d Z d Z! d Z" d Z# d Z$ RS( t postgresi? t pyformatc K s t i i | | | | _ d S( N( R t DefaultDialectRG Rq ( R Rq RS ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyRG d s c C s d d k } | S( Ni( t psycopg2( t clst psycopg( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt dbapih s c C sQ | i d d } d | j o t | d | d | i# |$ }% | i$ i% |% |% i& d j o
t |% _' q{q q Wd# }& t i |& d h t
i d$ 6t
i d% 6}" | i
|" d" | }
x|
i D]\ }' }( t i d& |( i( }) |) \ }* }+ }, }- g }. t i d' |* D] }/ |. | i) |/ q ~. }* |+ o | i) |+ }+ n7 | i d j o& | i | i* | j o
| i }+ n | i) |, }, g }0 t i d( |- D] }/ |0 | i) |/ q~0 }- g }1 |+ d j oY t i+ |, | i, d) t d |+ d* | x} |- D]% }2 |1 i d i- |+ |, |2 g qWnM t i+ |, | i, d) t d* | x* |- D]" }2 |1 i d i- |, |2 g qcW| i. t i/ |* |1 |' d+ t qWd, }3 t i |3 d h t
i d 6}" | i
|" d" | }
h }4 d }5 x |
i D] }# |# \ }6 }7 }8 }9 }% |8 o/ |6 |5 j p t i d- |6 n |6 }5 qn |9 o) |6 |5 j o t i d. |6 |6 }5 n |4 i0 |6 p |7 g g |4 |6 0 AND NOT a.attisdropped
ORDER BY a.attnum
R R t type_R t typemapt attnameR s ([^\([]+)i s []s \(([\d,]+)\)Rb t ,s double precisioni5 R\ i i s timestamp with time zoneR. s timestamp without time zonet attypet nullables* Did not recognize type '%s' of column '%s's (nextval\(')([^']+)('.*$)t .i s "%s"i s
SELECT attname FROM pg_attribute
WHERE attrelid = (
SELECT indexrelid FROM pg_index i
WHERE i.indrelid = :table
AND i.indisprimary = 't')
ORDER BY attnum
t tables
SELECT conname, pg_catalog.pg_get_constraintdef(oid, true) as condef
FROM pg_catalog.pg_constraint r
WHERE r.conrelid = :table AND r.contype = 'f'
ORDER BY 1
t connamet condefs; FOREIGN KEY \((.*?)\) REFERENCES (?:(.*?)\.)?(.*?)\((.*?)\)s \s*,\s*s \s*,\st autoloadt
autoload_witht link_to_names>
SELECT c.relname, i.indisunique, i.indexprs, i.indpred,
a.attname
FROM pg_index i, pg_class c, pg_attribute a
WHERE i.indrelid = :table AND i.indexrelid = c.oid
AND a.attrelid = i.indexrelid AND i.indisprimary = 'f'
ORDER BY c.relname, a.attnum
s; Skipped unsupported reflection of expression-based index %ss7 Predicate of partial index %s ignored during reflectiont unique( NN( i i (5 t identifier_preparerR R R R R R R Ra R R t UnicodeR` R t fetchallR t NoSuchTableErrort
_load_domainsR t searchR t endswithRv t splitt appendR R[ t
ischema_namesRC R t warnt NULLTYPEt
DefaultClauset
append_columnt Columnt ct primary_keyt addR t
autoincrementt groupst _unquote_identifierR t Tablet metadatat joint append_constraintt ForeignKeyConstraintt has_keyt itemst Indext columnst dict(< R R R t include_columnst preparert schema_where_clauset
schemanamet SQL_COLSR t tablenameR t rowst domainsR` t format_typeR t notnullt attnumt table_oidR R t is_arrayt charlent numericprect numericscalet argst aRS t coltypet domaint colargsRy t scht PK_SQLt tR t pkt colt FK_SQLR R R t constrained_columnst referred_schemat referred_tablet referred_columnsRW RJ t _[2]t refspect columnt IDX_SQLt indexest sv_idx_namet idx_nameR t exprt prdR t _[3]( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt reflecttable s
Y
#=#&
)
6)
6
' &
.c C s d } t i | d h t i d 6} | i | } h } x | i D]} } t i d | d i d } | d o | d } n d | d
| d f } h | d 6| d d 6| d d 6| | s c C s$ d | | f | o d | p d S( s %s NOT ILIKE %ss ESCAPE '%s'R7 ( ( RJ RK R8 ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR9 s c C s d | | f S( s %s @@ to_tsquery(%s)( ( RJ RK ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR9 s t messages0 Use a literal string 'timestamp ' insteadc C s d | S( s TIMESTAMP %s( ( RJ ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR9 s t TIMESTAMPc C s' | i o d Sd | i i | Sd S( Ns
nextval('%s')( t optionalR R t format_sequence( R t seq( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt visit_sequence s
c C s. d | j o t i d n | i d d S( Ns %%s\ The SQLAlchemy psycopg2 dialect now automatically escapes '%' in text() expressions to '%%'.t %( R R t replace( R Ra ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt post_process_text s
c C s~ d } | i d j o | d t | i 7} n | i d j o9 | i d j o | d 7} n | d t | i 7} n | S( NR7 s
LIMIT s
LIMIT ALLs OFFSET ( t _limitR R t _offset( R t selectRa ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt limit_clause s c C s | i o t | i t o d St | i t t f oT d d i g } | i D]- } | t | t o | p
| i | qR ~ d Sd t | i d Sn d Sd S( Ns DISTINCT s
DISTINCT ON (s , s ) R7 ( t _distinctR R RH RU R t
basestringR t unicode( R RE RW R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt get_select_precolumns s
Tc C s/ | i d j o d St t | i | Sd S( Nt nowaits FOR UPDATE NOWAIT( Rp t superR6 t for_update_clause( R RE ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyRM s c C sj | i d } d } g } | | D] } | | i | d t q' ~ } | d t i | d 7} | S( Nt postgres_returningc s sJ xC | D]; } t | t i o x | i D] } | Vq* Wq | Vq Wd S( N( R R Rt R ( t collistR t co( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt flatten_columnlist s
t within_columns_clauses RETURNING s , ( RS R R[ t stringR ( R Ra t stmtt returning_colsRQ RW R R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt _append_returning s
6c C sA t t | i | } d | i j o | i | | S| Sd S( NRN ( RL R6 t visit_updateRS RV ( R t update_stmtRa ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyRW s c C sA t t | i | } d | i j o | i | | S| Sd S( NRN ( RL R6 t visit_insertRS RV ( R t insert_stmtRa ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyRY s c K s5 | i i | i | i } d | | i | i f S( Ns EXTRACT(%s FROM %s::timestamp)( t extract_mapt gett fieldR R$ ( R t extractRS R] ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt
visit_extract s N( R R R t DefaultCompilerR t copyRQ t
sql_operatorst modR t ilike_opt notilike_opt match_opt functionsR t
deprecatedR? RB RF RJ RM RV RW RY R_ ( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR6 s(
t PGSchemaGeneratorc B s# e Z d Z d Z d Z RS( c K s8 | i i | } | i o t | i d j o | i o t | i t i oy t | i t i
ob | i d j p# t | i t
i o< | i i o/ t | i t o | d 7} q | d 7} nR | d | i i | i i 7} | i | } | d j o | d | 7} n | i p | d 7} n | S( Ni s
BIGSERIALs SERIALt s DEFAULT s NOT NULL( R t
format_columnR t lent foreign_keysR R RD R t Integert SmallIntegerR R R t SequenceR< R) RR R R
t get_column_default_stringR ( R R RS t colspecR ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt get_column_specification! s #
c C sb | i oS | i p | i i | i | i o+ | i d | i i | | i n d S( Ns CREATE SEQUENCE %s(
R< t
checkfirstR R R R` R R R= R ( R t sequence( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR? 2 s 3 c
C sH | i } | i d | i o | i d n | i d | i | i | i t | i | i | i t i
g } | i D] } | | i | q~ ~ d f | i
i d d } | d j op | i | d } t | t g } | i i D] \ } } | | | i f q ~ }
| i d |
n | i d S( Ns CREATE s UNIQUE s INDEX %s ON %s (%s)s , t postgres_wheres WHERE ( R R R t quotet _validate_identifierR` R[ t format_tableR RS R R Rk RS R\ R t _compileR R t bindst iteritemsR R ( R t indexR RW R t whereclauseR R t keyt bindt inlined_clause( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt visit_index7 s
!>
=( R R Rs R? R ( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyRi s t PGSchemaDropperc B s e Z d Z RS( c C sa | i oR | i p | i i | i | i o+ | i d | i i | | i n d S( Ns DROP SEQUENCE %s(
R< Rt R R R R` R R R= R ( R Ru ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR? J s 2 ( R R R? ( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR I s t PGDefaultRunnerc B s& e Z d Z e d Z d Z RS( c C s, t i i | | | i i i | _ d S( N( R t
DefaultRunnerRG R R R ( R R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyRG P s c C s' | i ot | i t i o+ | i i d j o | i d | i i St | i t i
o: | i o | i d j p# t | i t i
o| | i i oo | i i } | d j o d | | i i | i f } n d | i i | i f } | i | i | i i Sn t t | i | S( Ns select %ss" select nextval('"%s"."%s_%s_seq"')s select nextval('"%s_%s_seq"')( R R t server_defaultR R t argR t execute_stringRD R Rn R R Rp R< R R` R R R RL R t get_column_default( R R t isinsertR R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR U s
S
!c C s3 | i p! | i d | i i i | Sd Sd S( Ns select nextval('%s')( R< R R R R= R ( R R> ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR? g s
!( R R RG R[ R R? ( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR O s t PGIdentifierPreparerc B s e Z d Z RS( c C s5 | d | i j o | d d !i d d } n | S( Ni i is ""t "( t
initial_quoteRA ( R R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR n s ( R R R ( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyR m s (R t __doc__R R} R RS t
sqlalchemyR R R R t sqlalchemy.engineR R t sqlalchemy.sqlR R R Rb R R t
TypeEngineR
R R t NumericR t FloatR# Rn R% t SmallintegerR' R) t DateTimeR+ t DateR/ t TimeR1 R2 t TextR4 t StringR6 R: R9 t BinaryR; t BooleanR= R? RA t MutableTypet ConcatenableRC R R t compilet It UNICODERx t DefaultExecutionContextRo R R R` R6 t SchemaGeneratorRi t
SchemaDropperR R R t IdentifierPreparerR R t statement_compilert schemageneratort
schemadropperR t
defaultrunnert execution_ctx_cls( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/databases/postgres.pyt Z s 0"%=
o[)