u@Dc @ s; d Z d d k Z d d k Z d d k Ty d d k l Z l Z l Z Wn/ e j
o# d d k l Z l
Z l Z n Xd Z d Z d Z
d d8 d
YZ d d9 d YZ d
e f d YZ d Z d Z d d: d YZ e Z d d d d d d Z d d; d YZ e d d d d d Z e Z e d d d Z e d d d d d d d! Z e d Z e d d d! Z e d" Z e d# Z e d$ d% d& d' d( d) d* d+ d, Z! e d- d. Z" d/ Z# d0 Z$ d1 Z% d2 Z& d3 Z' d4 Z( d5 Z) e* d6 j o d7 Ge+ GHHe GHn d S(< s pgdb - DB-API 2.0 compliant module for PygreSQL.
(c) 1999, Pascal Andre .
See package documentation for further information on copyright.
Inline documentation is sparse.
See DB-API 2.0 specification for usage information:
http://www.python.org/peps/pep-0249.html
Basic usage:
pgdb.connect(connect_string) # open a connection
# connect_string = 'host:database:user:password:opt:tty'
# All parts are optional. You may also pass host through
# password as keyword arguments. To pass a port,
# pass it in the host keyword parameter:
pgdb.connect(host='localhost:5432')
connection.cursor() # open a cursor
cursor.execute(query[, params])
# Execute a query, binding params (a dictionary) if they are
# passed. The binding syntax is the same as the % operator
# for dictionaries, and no quoting is done.
cursor.executemany(query, list of params)
# Execute a query many times, binding each param dictionary
# from the list.
cursor.fetchone() # fetch one row, [value, value, ...]
cursor.fetchall() # fetch all rows, [[value, value, ...], ...]
cursor.fetchmany([size])
# returns size or cursor.arraysize number of rows,
# [[value, value, ...], ...] from result set.
# Default cursor.arraysize is 1.
cursor.description # returns information about the columns
# [(column_name, type_name, display_size,
# internal_size, precision, scale, null_ok), ...]
# Note that precision, scale and null_ok are not implemented.
cursor.rowcount # number of rows available in the result set
# Available after a call to execute.
connection.commit() # commit transaction
connection.rollback() # or rollback transaction
cursor.close() # close the cursor
connection.close() # close the connection
iN( t *( t DateTimet TimeDeltat DateTimeType( t datetimet timedeltaR s 2.0i t pyformatt
pgdbTypeCachec B s# e Z d Z d Z d Z RS( c C s | i | _ h | _ d S( N( t sourcet _pgdbTypeCache__sourcet _pgdbTypeCache__type_cache( t selft cnx( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt __init__] s c C s | d j o | S| t j o n | t j o n | t j o | d d j } n | t j o t | } n | t j o t | } n | t j o t | } np | t
j o4 | i d d } | i d d } t | } n/ | t j o n | t
j o t | } n | S( Ni t tt Tt $t t ,( R R ( t Nonet STRINGt BINARYt BOOLt INTEGERt intt LONGt longt FLOATt floatt MONEYt replacet DATETIMEt ROWID( R t typt value( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt typecasta s.
c C s{ y | i | SWne | i i d | | i i d d } | d d t | d d d d f } | | i | <| SXd S( Ns2 SELECT typname, typlen FROM pg_type WHERE oid = %si i ( R
R t executet fetchR R ( R t oidt res( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt getdescr} s
( t __name__t
__module__R
R# R( ( ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyR [ s t
pgdbCursorc B sw e Z d Z d Z d Z d d Z d Z d Z d Z d d d Z
d Z d
Z d d Z
RS(
c C s: | | _ | | _ d | _ d | _ d | _ d | _ d S( Nii ( t _pgdbCursor__cachet _pgdbCursor__sourceR t descriptiont rowcountt arraysizet lastrowid( R t srct cache( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyR
s c C s, | i i d | _ d | _ d | _ d S( Ni( R- t closeR R. R/ R1 ( R ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyR4 s
c C s
| | _ d S( N( R0 ( R t size( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyR0 s c C s\ | o> t | t i o+ t | d t i o | i | | n | i | | f d S( Ni ( t
isinstancet typest ListTypet TupleTypet executemany( R t operationt params( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyR$ s c C s d | _ d | _ d } d } yq xj | D]b } | d j o t | | } n | } | i i | } | d j o | | 7} q( d | _ q( WWnb t j
o } t d | | f n< t j
o } t d | | f n t d | n X| i i
t j o| | i i | _ g } xE | i i
D]4 }
|
d d !| i i |
d } | i | q,W| | _ | i i | _ n% | | _ d | _ | i i | _ d S( Nii t INITs error '%s' in '%s's internal error in '%s': %ss internal error in '%s'i i ( R R. R/ t _quoteparamsR- R$ t Errort
DatabaseErrort Exceptiont OperationalErrort
resulttypet
RESULT_DQLt ntuplest listinfoR, R( t appendt oidstatusR1 ( R R; t param_seqt totrowst sqlR< t rowst msgt errt dR! t desc( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyR: s@
! c C s- | i d d } y | d SWn d SXd S( Ni i ( t fetchmanyR ( R R' ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt fetchone s
c C s | i d d S( Nii ( RQ ( R ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt fetchall s i c
C s | d j o
| i } n | d j o
| | _ n y | i i | } Wn$ t j
o } t t | n Xg } xi | D]a } g } xE t t | D]1 } | i | i
i | i | d | | q W| i | q~ W| S( Ni (
R R0 R- R% R? R@ t strt ranget lenRG R, R# R. ( R R5 t keepR' t et resultt rt rowt i( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyRQ s&
c C s
t d d S( Ns nextset() is not supported( t NotSupportedError( R ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt nextset s c C s d S( N( ( R t sizes( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt
setinputsizes s c C s d S( N( ( R R5 t col( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt
setoutputsize s N( R) R* R
R4 R0 R R$ R: RR RS RQ R^ R` Rb ( ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyR+ s + t
_quoteitemc B s e Z d Z RS( c C s t t t | i | S( N( t _quotet superRc t __getitem__( R t key( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyRf s ( R) R* Rf ( ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyRc s c C s5 t | t o t | } n$ t | t o | i d } n t | t i o, d t | i d d i d d } n t | t i t i t i
f o n | d j o
d } ns t | t i t i
f o# d d i t d
| } n4 t | d o | i } n t d t | | S(
Ns utf-8s '%s's \s \\t 's ''t NULLs (%s)R c S s t t | S( ( RT Rd ( t x( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt s t __pg_repr__s! do not know how to handle type %s( R6 R RT t unicodet encodeR7 t
StringTypeR t IntTypet LongTypet FloatTypeR R8 R9 t joint mapt hasattrRl t InterfaceErrort type( Rj ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyRd s ,"
#c C s= t | d o t | } n t t t | } | | S( Nt has_key( Ru Rc t tupleRt Rd ( t sR< ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyR> s t pgdbCnxc B s5 e Z d Z d Z d Z d Z d Z RS( c C sO | | _ t | | _ y | i i } | i d Wn t d n Xd S( Nt BEGINs invalid connection.( t
_pgdbCnx__cnxR t _pgdbCnx__cacheR R$ RB ( R R R2 ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyR
) s c C s | i i d S( N( R} R4 ( R ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyR4 2 s c C sD y- | i i } | i d | i d Wn t d n Xd S( Nt COMMITR| s
can't commit.( R} R R$ RB ( R R2 ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt commit5 s
c C sD y- | i i } | i d | i d Wn t d n Xd S( Nt ROLLBACKR| s can't rollback.( R} R R$ RB ( R R2 ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt rollback= s
c C s: y# | i i } t | | i SWn t d n Xd S( Ns invalid connection.( R} R R+ R~ RB ( R R2 ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt cursorE s
( R) R* R
R4 R R R ( ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyR{ ' s
c C sf d } d } d } d } d } d }
d } yO | i d } | d } | d } | d } | d } | d }
| d } Wn n X| d j o
| } n | d j o
| } n | d j o
| } n | d j o; y- | i d } | d } t | d } WqqXn | d j o
d } n | d j o
d } n t | | | |
| | | }
t |
S(
NiR t :i i i i i i ( t splitR R t _connect_R{ ( t dsnt usert passwordt hostt databaset dbportt dbhostt dbbaset dbusert dbpasswdt dboptt dbttyR< R ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt connectP sJ
t pgdbTypec B s e Z d Z d Z RS( c G s
| | _ d S( N( t values( R R ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyR
s c C s2 | | i j o d S| | i j o d Sd Sd S( Ni i i( R ( R t other( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt __cmp__ s
( R) R* R
R ( ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyR s t chart bpchart namet textt varchart int2t int4t serialt int8t float4t float8t numerict boolt moneyt abstimet reltimet tintervalt datet timet timespant timestampt timestamptzt intervalR& t oid8c C s t | | | S( N( R ( t yeart montht day( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt Date s c C s t | | | S( N( R ( t hourt minutet second( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt Time s c C s t | | | | | | S( N( R ( R R R R R R ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt Timestamp s c C s t t t i | d S( Ni ( t applyR R t localtime( t ticks( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt
DateFromTicks s c C s t t t i | d d ! S( Ni i ( R R R R ( R ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt
TimeFromTicks s c C s t t t i | d S( Ni ( R R R R ( R ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt TimestampFromTicks s c C s | S( N( ( RT ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt Binary s t __main__s PyGreSQL version( ( ( ( (, t __doc__R7 R t _pgt mx.DateTimeR R R t ImportErrorR R t apilevelt threadsafetyt
paramstyleR R+ t dictRc Rd R> R{ R R R R R R R t NUMBERR R R R R R R R R R R R R R) t version( ( ( s* /usr/lib64/python2.6/site-packages/pgdb.pyt @ sZ
!7r
(3
!