�
Tc@sdZd
dl
Zd
dlZd
dlZd
dlZyd
dl	Z
Wn



dZ
n
Xd
dlZd
dlm
Z
d
dlmZ
d
dlmZ
d
dlmZ
d
dlmZ
def
d	��YZd
ef
d��YZdef
d
��YZdef
d��YZdef
d��YZdef
d��YZdef
d��YZdef
d��YZ def
d��YZ!def
d��YZ"def
d��YZ#de"f
d��YZ$d e#f
d!��YZ%d"e&f
d#��YZ'ddd$�Z(d%e&f
d&��YZ)ddd'�Z*ddd(�Z+d)�Z,d*�Z-d+e&f
d,��YZ.e/e/ddd-�Z0d.e&f
d/��YZ1e/dd0�Z2d
d1l3m4Z4m5Z5m6Z6
d
d2l3m7Z7m8Z8
d
d3l9m:Z:m;Z;
d
d4l9m<Z<m=Z=m>Z>
d
d5l9m?Z?m@Z@mAZA
dS(6s�Miscellaneous goodies for psycopg2

This module is a generic place used to hold little helper functions
and classes until a better place in the distribution is found.
i����N(
t
extensions(
tcursor(
t
connection(
tadapt(
t
btDictCursorBasecBs>eZ
dZd
�Zd�Zdd�
Zd�Zd�ZRS(s%Base class for all dict-like cursors.c
Osdd
|kr |d
}|d
=ntd�
�
t
t|�j|
|�
d|_d|_||_dS(Ntrow_factorys;DictCursorBase can't be instantiated without a row factory.i(tNotImplementedErrortsuperRt__init__t_query_executedt	_prefetchR(tselftargstkwargsR((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR	1s





	

	
	
c
Cs\|jr!t
t|�j�}
n|jr7|j�
n|jsXt
t|�j�}
n|
S(
N(RRRtfetchoneR
t_build_index(Rtres((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR=s
	

	


	

cCsb|jr$t
t|�j|
�
}n|jr:|j�
n|js^t
t|�j|
�
}n|S(
N(RRRt	fetchmanyR
R(RtsizeR((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRFs
	

	


	

c
Cs\|jr!t
t|�j�}
n|jr7|j�
n|jsXt
t|�j�}
n|
S(
N(RRRtfetchallR
R(RR((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyROs
	

	


	

c
cs�|jr-t
t|�j�}
|
j�}n|jrC|j�
n|jspt
t|�j�}
|
j�}n|V
x|
j�V
qxdS(
N(RRRt__iter__tnextR
R(RRtfirst((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRXs
	


	


	



N(	t__name__t
__module__t__doc__R	RtNoneRRR(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR.s
						tDictConnectionc
BseZ
dZd
�ZRS(s2A connection that uses `DictCursor` automatically.c
Os)|jd
t
�
tt|�j|
|�S(Ntcursor_factory(t
setdefaultt
DictCursorRRR
(RR
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR
is

(RRRR
(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRgs

RcBs8eZ
dZd
�Zdd�
Zdd�
Zd�ZRS(s<A cursor that keeps a list of column name -> index mappings.c
Os0t|d
<t
t|�j|
|�
d|_dS(NRi
(tDictRowRRR	R(RR
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR	ps



cCs+i|_d
|_
tt|�j|
|�S(Ni
(tindexR
RRtexecute(Rtquerytvars((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR"us
	
	
cCs+i|_d
|_
tt|�j|
|�S(Ni
(R!R
RRtcallproc(RtprocnameR$((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR%zs
	
	
c
Cs`|jd
kr\|j
r\x5tt|j
�
�
D]}
|
|j|j
|
d<q.Wd|_ndS(Ni
i(R
tdescriptiontrangetlenR!(Rt
i((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRs



N(RRRR	RR"R%R(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRms

	R cBs�eZ
dZdZd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
dd	�
Zd
�Z
d�Zd�Zd
�Zd�Zd�Zd�Zejddkr�e
Z[
eZ[eZ	[[
nRS(s6A row object that allow by-column-name access to data.t_indexcCs'|
j|_
dg
t|
j�
|(dS(
N(R!R+RR)R'(RR
((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR	�s

cCs5t|
t
tf�s%|j|
}
ntj||
�S(
N(t
isinstancetinttsliceR+tlistt__getitem__(Rt
x((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR0�s


cCs<t|
t
tf�s%|j|
}
ntj||
|�
dS(
N(R,R-R.R+R/t__setitem__(RR1t
v((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR2�s


c

Cst|j
��
S(
N(R/t	iteritems(
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pytitems�s
c


Cs
|jj
�S(
N(R+tkeys(
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR6�s
c

Cst|�
S(
N(
ttuple(
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pytvalues�s
cCs
|
|jkS(
N(
R+(RR1((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pythas_key�s
cCsy||
SWn


|SXdS(
N((RR1tdefault((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pytget�s



c
cs;x4|jj
�D]#\}
}|
tj||�fV
qWdS(
N(R+R4R/R0(Rt
nR3((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR4�s

c


Cs
|jj
�S(
N(R+titerkeys(
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR=�s
c

Cs
tj
|�
S(
N(R/R(
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt
itervalues�s
c

Cst|j
��
S(
N(tdictR4(
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pytcopy�s
cCs
|
|jkS(
N(
R+(RR1((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt__contains__�s
c

Cs||jj
�fS(
N(R+R@(
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt__getstate__�s
cCs|
d
|(|
d|_dS(Nii
(
R+(Rtdata((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt__setstate__�s

ii(
s_indexN(RRRt	__slots__R	R0R2R5R6R8R9RR;R4R=R>R@RARBRDt_systversion_info(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR �s2
														



tRealDictConnectionc
BseZ
dZd
�ZRS(s6A connection that uses `RealDictCursor` automatically.c
Os)|jd
t
�
tt|�j|
|�S(NR(RtRealDictCursorRRHR
(RR
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR
�s

(RRRR
(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRH�s

RIcBs8eZ
dZd
�Zdd�
Zdd�
Zd�ZRS(sQ
A cursor that uses a real dict as the base type for rows.

    Note that this cursor is extremely specialized and does not allow
    the normal access (using integer indices) to fetched data. If you need
    to access database rows both as a dictionary and a list, then use
    the generic `DictCursor` instead of `!RealDictCursor`.
    c
Os0t|d
<t
t|�j|
|�
d|_dS(NRi(tRealDictRowRRIR	R(RR
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR	�s



cCs+g|_d
|_
tt|�j|
|�S(Ni
(tcolumn_mappingR
RRIR"(RR#R$((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR"�s
	
	
cCs+g|_d
|_
tt|�j|
|�S(Ni
(RKR
RRIR%(RR&R$((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR%�s
	
	
c
Csc|jd
kr_|j
r_x8tt|j
�
�
D]!}
|jj|j
|
d�

q.Wd|_ndS(Ni
i(R
R'R(R)RKtappend(RR*((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR�s



N(RRRR	RR"R%R(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRI�s

	RJc
Bs8eZ
dZd
Zd�Zd�Zd�Zd�ZRS(s.A `!dict` subclass representing a data record.t_column_mappingcCs=tj
|�

|
jr-|
jr-|
j�
n|
j|_dS(
N(R?R	R'RKRRM(RR
((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR	�s



cCs5t|
�
t
kr"|j|
}
ntj||
|�S(
N(ttypeR-RMR?R2(Rtnametvalue((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR2�s


c

Cs|j�|j
fS(
N(R@RM(
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRB�s
cCs"|j|
d
�

|
d|_
dS(Nii
(tupdateRM(RRC((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRD

s

(RRRRER	R2RBRD(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRJ�s
			tNamedTupleConnectionc
BseZ
dZd
�ZRS(s8A connection that uses `NamedTupleCursor` automatically.c
Os)|jd
t
�
tt|�j|
|�S(NR(RtNamedTupleCursorRRRR
(RR
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR

s

(RRRR
(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRR
s

RScBs�eZ
dZdZdd
�
Zd�Zdd�
Zd�Zdd�
Z	d�Z
d�Zydd	lm
Z

Wnek
r�
Z
d
�Zn
Xe
d�
ZRS(
s�
A cursor that generates results as `~collections.namedtuple`.

    `!fetch*()` methods will return named tuples instead of regular tuples, so
    their elements can be accessed both as regular numeric items as well as
    attributes.

        >>> nt_cur = conn.cursor(cursor_factory=psycopg2.extras.NamedTupleCursor)
        >>> rec = nt_cur.fetchone()
        >>> rec
        Record(id=1, num=100, data="abc'def")
        >>> rec[1]
        100
        >>> rec.data
        "abc'def"
    cCs"d|_
tt|�j|
|�S(
N(RtRecordRRSR"(RR#R$((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR"
s
	
cCs"d|_
tt|�j|
|�S(
N(RRTRRStexecutemany(RR#R$((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRU"
s
	
cCs"d|_
tt|�j|
|�S(
N(RRTRRSR%(RR&R$((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR%&
s
	
c
Cs]tt
|�j�}
|
dk	rY|j}|dkrL|j�}|_n|j|
�
SdS(
N(RRSRRRTt_make_ntt_make(Rt
ttnt((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR*
s


	


cCsStt
|�j|
�
}|j}|dkrC|j�}|_nt|j|�S(
N(RRSRRTRRVtmapRW(RRttsRY((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR2
s


	


c
CsPtt
|�j�}
|j}|dkr@|j�}|_nt|j|
�S(
N(RRSRRTRRVRZRW(RR[RY((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR9
s


	


c
csxtt
|�j�}
|
j�}|j}|dkrL|j�}|_n|j|�
V
x|j|
j��
V
q]dS(
N(RRSRRRTRRVRW(RtitRXRY((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR@
s

	


i����(
t
namedtuplec


Cs
|j�
dS(
N(
t_exc(
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRVP
s
cCs-|
d
g|jpdD]}|d^q�S(NRTi((
R'(RR]t
d((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRVS
s
N(RRRRRTR"RUR%RRRRtcollectionsR]tImportErrorR^RV(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRS
s
				




tLoggingConnectionc
BsDeZ
dZd
�Zd�Zd�Zd�Zd�Zd�ZRS(s}A connection that logs all queries to a file or logger__ object.

    .. __: http://docs.python.org/library/logging.html
    cCs@|
|_t
r0t|
t
j�r0|j|_n|j|_d
S(s�Initialize the connection to log to `!logobj`.

        The `!logobj` parameter can be an open file object or a Logger
        instance from the standard logging module.
        N(t_logobjt_loggingR,tLoggert_logtologgertlogt
_logtofile(Rtlogobj((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt
initialize]
s	

c
Cs|
S(
s�Filter the query before logging it.

        This is the method to overwrite to filter unwanted queries out of the
        log or to add some extra data to the output. The default implementation
        just does nothing.
        ((Rtmsgtcurs((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pytfilteri
scCs6|j|
|�}
|
r2|j
j|
tj�

ndS(
N(RmRctwritet_ostlinesep(RRkRl((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRhr
s

cCs/|j|
|�}
|
r+|j
j|
�

ndS(
N(RmRctdebug(RRkRl((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRfv
s

c

Cs%t|d
�s!|j
d�
�
ndS(NRcs3LoggingConnection object has not been initialize()d(thasattrtProgrammingError(
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt_checkz
s


c
Os3|j�
|j
d
t�
tt|�j|
|�S(NR(RtRt
LoggingCursorRRbR
(RR
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR

s



(	RRRRjRmRhRfRtR
(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRbW
s						RucBs&eZ
dZdd
�
Zdd�
ZRS(sCA cursor that logs queries using its connection logging facilities.cCs;ztt
|�j|
|�SWd|jj|j|�
XdS(
N(RRuR"RRgR#(RR#R$((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR"�
s

cCs;ztt
|�j|
|�SWd|jj|j|�
XdS(
N(RRuR%RRgR#(RR&R$((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR%�
s

N(RRRRR"R%(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRu�
s
tMinTimeLoggingConnectioncBs,eZ
dZd
d�
Zd�Zd�ZRS(s�
A connection that logs queries based on execution time.

    This is just an example of how to sub-class `LoggingConnection` to
    provide some extra filtering for the logged queries. Both the
    `initialize()` and `filter()` methods are overwritten to make sure
    that only queries executing for more than ``mintime`` ms are logged.

    Note that this connection uses the specialized cursor
    `MinTimeLoggingCursor`.
    icCstj
||
�
||_dS(
N(RbRjt_mintime(RRitmintime((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRj�
s

cCs=tj
�|jd
}||jkr9|
tjd|SdS(Ni�s  (execution time: %d ms)(t_timettimet	timestampRwRoRp(RRkRlRX((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRm�
s


c
Os#|jd
t
�
tj||
|�
S(NR(RtMinTimeLoggingCursorRbR
(RR
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR
�
s

(RRRRjRmR
(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyRv�
s

	R|cBs&eZ
dZdd
�
Zdd�
ZRS(s=The cursor sub-class companion to `MinTimeLoggingConnection`.cCs"tj
�|_tj||
|�S(
N(RyRzR{RuR"(RR#R$((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR"�
s

cCs"tj
�|_tj||
|�S(
N(RyRzR{RuR"(RR&R$((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR%�
s

N(RRRRR"R%(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR|�
s
tUUID_adapterc
Bs2eZ
dZd
�Zd�Zd�Zd�ZRS(s�Adapt Python's uuid.UUID__ type to PostgreSQL's uuid__.

    .. __: http://docs.python.org/library/uuid.html
    .. __: http://www.postgresql.org/docs/current/static/datatype-uuid.html
    cCs
|
|_dS(
N(
t_uuid(Rtuuid((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR	�
s
cCs|
tj
kr|SdS(
N(t_extt	ISQLQuote(Rtproto((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt__conform__�
s

c

Cstd
|j
�
S(Ns
'%s'::uuid(RR~(
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt	getquoted�
s
c

Csd
|jS(Ns
'%s'::uuid(
R~(
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt__str__�
s
(RRRR	R�R�R�(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR}�
s
			cs�d
dl�|s!d}d}n0t
|ttf�rE|\}}n|}d}tj|f
d�f
d��t_tj|f
dtj�t_tj	tj|
�
tj	tj|
�
tj
�jt�
tjS(sR
Create the UUID type and an uuid.UUID adapter.

    :param oids: oid for the PostgreSQL :sql:`uuid` type, or 2-items sequence
        with oids of the type and the array. If not specified, use PostgreSQL
        standard oids.
    :param conn_or_curs: where to register the typecaster. If not specified,
        register it globally.
    i����Ni�i�tUUIDcs|r�j|�
pdS(
N(R�R(RCR
(
R(sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt<lambda>�
ssUUID[](RR,R/R7R�tnew_typeR�tnew_array_typet	UUIDARRAYt
register_typetregister_adapterR}(toidstconn_or_curstoid1toid2((
RsB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt
register_uuid�
s


	






tInetc
BsDeZ
dZd
�Zd�Zd�Zd�Zd�Zd�ZRS(sC
Wrap a string to allow for correct SQL-quoting of inet values.

    Note that this adapter does NOT check the passed value to make
    sure it really is an inet-compatible address but DOES call adapt()
    on it to make sure it is impossible to execute an SQL-injection
    by passing an evil value to the initializer.
    cCs
|
|_dS(
N(
taddr(RR�((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR	�
s
c

Csd
|jj
|jfS(Ns%s(%r)(t	__class__RR�(
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt__repr__�
s
cCs
|
|_dS(
N(
t_conn(Rtconn((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pytprepare�
s
c
CsEt|j
�
}
t|
d
�r1|
j|j�

n|
j�td�
S(NR�s::inet(t_AR�RrR�R�R�R(Rtobj((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR�
s



cCs|
tj
kr|SdS(
N(R�R�(RR�((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR�s

c

Cs
t|j
�
S(
N(tstrR�(
R((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR�s
(	RRRR	R�R�R�R�R�(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR��
s
					cCs�|sd
}d}n0t|t
tf�r9|\}}n|}d}tj|f
dd��t_tj|f
dtj�t_tjtj|
�
tjtj|
�
tjS(sL
Create the INET type and an Inet adapter.

    :param oid: oid for the PostgreSQL :sql:`inet` type, or 2-items sequence
        with oids of the type and the array. If not specified, use PostgreSQL
        standard oids.
    :param conn_or_curs: where to register the typecaster. If not specified,
        register it globally.
    ieitINETcSs|rt|�
pdS(
N(R�R(RCR
((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR�!st	INETARRAY(	R,R/R7R�R�R�R�R�R�(toidR�R�R�((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt
register_inets	

	





cCs d
dl}|j
dt�
dS(s
The function used to register an alternate type caster for
    :sql:`TIMESTAMP WITH TIME ZONE` to deal with historical time zones with
    seconds in the UTC offset.

    These are now correctly handled by the default type caster, so currently
    the function doesn't do anything.
    i����Nt
deprecated(twarningstwarntDeprecationWarning(R�R�R�((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pytregister_tstz_w_secs*s
c
Cs�d
dl}
d
dl
m}m}m}
x�|j�}||krGPq+||krr|
j|j�g
gg�
q+||kr�|
jg|j�g
g�
q+|jd|�
�
q+dS(s
Wait until a connection or cursor has data available.

    The function is an example of a wait callback to be registered with
    `~psycopg2.extensions.set_wait_callback()`. This function uses
    :py:func:`~select.select()` to wait for data available.

    i����N(tPOLL_OKt	POLL_READt
POLL_WRITEsbad state from poll: %s(tselecttpsycopg2.extensionsR�R�R�tpolltfilenotOperationalError(R�R�R�R�R�tstate((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pytwait_select6s







c
Csm|dkrt
jd
�
�
nt|d�rK|j}
|
jdt�
}n|}
|
jdt�
}|
|fS(sEReturn the connection and a DBAPI cursor from a connection or cursor.s no connection or cursor providedR"RN(Rtpsycopg2RsRrRR
t_cursor(R�R�Rl((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt_solve_conn_cursMs

	

t
HstoreAdaptercBs�eZ
dZd
�Zd�Zd�Zd�ZeZej	dej
�Zeej	d�
d�
�
Z
ed��
Zed	��
ZRS(
s)Adapt a Python dict to the hstore syntax.cCs
|
|_dS(
N(
twrapped(RR�((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR	^s
cCs+|
|_|
j
d
kr'|j|_ndS(Ni�_
(R�tserver_versiont_getquoted_8R�(RR�((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR�as
	
c
Cs
|jst
d
�
Stj}
g}x�|jj�D]�\}}|
|�
}|j|j�

|j�}|dk	r�|
|�
}|j|j�

|j�}nt
d�
}|j	t
d�
|t
d�
|t
d�
�

q2Wt
d�
t
d�
j
|�
t
d�
S(s*Use the operators available in PG pre-9.0.s
''::hstoretNULLt
(s => t
)s||N(R�RR�RR4R�R�R�RRLtjoin(RRtrvt
kR3((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR�hs	

	







3c
Cs�|jst
d
�
Stj|jj��
}
|
j|j�

tj|jj��
}|j|j�

t
d�
|
j�t
d�
|j�t
d�
S(s(Use the hstore(text[], text[]) function.s
''::hstoreshstore(s, R�(	R�RR�RR6R�R�R8R�(RR�R3((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt_getquoted_9�s	





sm

        # hstore key:
        # a string of normal or escaped chars
        "((?: [^"\\] | \\. )*)"
        \s*=>\s* # hstore value
        (?:
            NULL # the value can be null - not catched
            # or a quoted string like the key
            | "((?: [^"\\] | \\. )*)"
        )
        (?:\s*,\s*|$) # pairs separated by comma or end of string.
    s\\(.)c	Cs�|
dkrdSi}d
}x�|j
j|
�
D]�}|dksS|j�|kritjd|�
�
n|jd|jd�
�}|jd�
}|dk	r�|jd|�}n|||<|j�}q/W|t	|
�
kr�tjd|�
�
n|S(s�Parse an hstore representation in a Python string.

        The hstore is represented as something like::

            "a"=>"1", "b"=>"2"

        with backslash-escaped strings.
        is$error parsing hstore pair at char %ds\1i
is1error parsing hstore: unparsed data after char %dN(
Rt
_re_hstoretfinditertstartR�tInterfaceErrortsubtgrouptendR)(	Rt
stcurt_bsdecR�R�t
mR�R3((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pytparse�s$














cCs<|
d
krd
S|
j
tj|jj�
}
|j|
|�S(s2Parse an hstore returning unicode keys and values.N(RtdecodeR�t	encodingsRtencodingR�(RR�R�((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt
parse_unicode�s

c	Cs�t|
�
\}}|j
}|jd
kr0dp3d}gg}}|jd|�

x0|D](}|j|d�

|j|d�

q[W|tjkr�|jr�|j�
nt	|�
t	|�
fS(sBReturn the lists of OID of the hstore and hstore[] types.
        i�9
ttyparrayR�slSELECT t.oid, %s
FROM pg_type t JOIN pg_namespace ns
    ON typnamespace = ns.oid
WHERE typname = 'hstore';
ii
(
R�tstatusR�R"RLR�tSTATUS_IN_TRANSACTIONt
autocommittrollbackR7(	RR�R�Rltconn_statusR�trv0trv1R�((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pytget_oids�s	








(RRRR	R�R�R�R�t_retcompiletVERBOSER�tclassmethodR�R�R�(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR�\s

				
 	c		Cst
|dkr[t
j|�
}|dks2|d
rDtjd�
�
q[|d}|d
}nt|t�rv|f
}n|dk	r�t|t�r�|f
}q�tg|D]}|r�|^q��
}ntj	d
dkr�|r�t
j
}n	t
j}tj
|d|�}tj||
r
|p!
d�
tjtt
�
|rp
tj|d|�}tj||
rf
|pi
d�
ndS(sRegister adapter and typecaster for `!dict`\-\ |hstore| conversions.

    :param conn_or_curs: a connection or cursor: the typecaster will be
        registered only on this object unless *globally* is set to `!True`
    :param globally: register the adapter globally, not only on *conn_or_curs*
    :param unicode: if `!True`, keys and values returned from the database
        will be `!unicode` instead of `!str`. The option is not available on
        Python 3
    :param oid: the OID of the |hstore| type if known. If not, it will be
        queried on *conn_or_curs*.
    :param array_oid: the OID of the |hstore| array type if known. If not, it
        will be queried on *conn_or_curs*.

    The connection or cursor passed to the function will be used to query the
    database and look for the OID of the |hstore| type (which may be different
    across databases). If querying is not desirable (e.g. with
    :ref:`asynchronous connections <async-support>`) you may specify it in the
    *oid* parameter, which can be found using a query such as :sql:`SELECT
    'hstore'::regtype::oid`. Analogously you can obtain a value for *array_oid*
    using a query such as :sql:`SELECT 'hstore[]'::regtype::oid`.

    Note that, when passing a dictionary from Python to the database, both
    strings and unicode keys and values are supported. Dictionaries returned
    from the database have keys/values according to the *unicode* parameter.

    The |hstore| contrib module must be already installed in the database
    (executing the ``hstore.sql`` script in your ``contrib`` directory).
    Raise `~psycopg2.ProgrammingError` if the type is not found.
    is\hstore type not found in the database. please install it from your 'contrib/hstore.sql' filei
itHSTOREtHSTOREARRAYN(RR�R�R�RsR,R-R7RFRGR�R�R�R�R�R�R?R�(	R�tgloballytunicodeR�t	array_oidR1tcastR�R�((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pytregister_hstore�s,









(
	



tCompositeCastercBszeZ
dZd	d	d
�Zd�Zd�Zejdej	�Z
ejd�
Zed��
Z
d�Zed��
ZRS(
sm
Helps conversion of a PostgreSQL composite type into a Python object.

    The class is usually created by the `register_composite()` function.
    You may want to create and register manually instances of the class if
    querying the database at registration time is not desirable (such as when
    using an :ref:`asynchronous connections <async-support>`).

    cCs�|
|_||_
||_||_g|D]}|d
^q+|_g|D]}|d^qK|_|j|
|j�
tj|f
|
|j	�|_
|r�tj|f
d|
|j
�|_n	d|_dS(Nii
s%sARRAY(ROtschemaR�R�tattnamestatttypest_create_typeR�R�R�t
typecasterR�tarray_typecasterR(RROR�tattrsR�R�t
a((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR	.s
	
	
	
	 
 




cCs�|
dkrdS|j
|
�
}t|�
t|j�
krktjd
t|j�
|jt|�
f�
�
ngt|j|�D]\}}|j||�^q~}|j	|�
S(Ns9expecting %d components for the type %s, %d found instead(
RttokenizeR)R�R�t	DataErrorROtzipR�tmake(RR�RlttokensR�ttokenR8((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR�>s





(
4cCs
|j|
�
S(
s
Return a new Python object representing the data being casted.

        *values* is the list of attributes, already casted into their Python
        representation.

        You can subclass this method to :ref:`customize the composite cast
        <custom-composite>`.
        (
t_ctor(RR8((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR�Ms
s�
  \(? ([,)])                        # an empty token, representing NULL
| \(? " ((?: [^"] | "")*) " [,)]    # or a quoted string
| \(? ([^",)]+) [,)]                # or an unquoted string
    s	(["\\])\1cCs�g}x�|jj
|
�
D]�}|dkrAtjd
|
�
�
n|jd�
dk	rf|jd�

q|jd�
dk	r�|j|jjd|jd�
��

q|j|jd�
�

qW|S(Nscan't parse type: %ri
is\1i(	t_re_tokenizeR�RR�R�R�RLt_re_undoubleR�(RR�R�R�((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR�as






(cCsbyd
dlm
}
Wn&tk
r<


t|_|j|_n"X||
|�|_|jj|_dS(Ni����(
R](R`R]RaR7RNR�RW(RROR�R]((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR�ps




	

cCs0
t|�
\}}|j
}d
|
krB|
jd
d�\}}n|
}d}|jdkrcdpfd}|jd|||f�
|j�}	|tjkr�|jr�|j	�
n|	s�t
jd|
�
�
n|	d	d	}
|	d	d}g|	D]}|d
|df^q�}
|||
|
d|d
|�S(s}Return a `CompositeCaster` instance for the type *name*.

        Raise `ProgrammingError` if the type is not found.
        t
.i
tpublici�9
R�R�s�SELECT t.oid, %s, attname, atttypid
FROM pg_type t
JOIN pg_namespace ns ON typnamespace = ns.oid
JOIN pg_attribute a ON attrelid = typrelid
WHERE typname = %%s AND nspname = %%s
    AND attnum > 0 AND NOT attisdropped
ORDER BY attnum;
sPostgreSQL type '%s' not foundiiiR�R�(R�R�tsplitR�R"RR�R�R�R�R�Rs(RROR�R�RlR�R�ttnameR�trecsttype_oidR�t
rt
type_attrs((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt_from_dbzs*	









'
N(RRRRR	R�R�R�R�R�R�R�R�R�R�R�(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyR�%s
			
cCs}|d
krt
}n|j||
�}tj|j|r@|
pCd
�
|jd
k	rytj|j|ro|
prd
�
n|S(sRegister a typecaster to convert a composite type into a tuple.

    :param name: the name of a PostgreSQL composite type, e.g. created using
        the |CREATE TYPE|_ command
    :param conn_or_curs: a connection or cursor used to find the type oid and
        components; the typecaster is registered in a scope limited to this
        object, unless *globally* is set to `!True`
    :param globally: if `!False` (default) register the typecaster only on
        *conn_or_curs*, otherwise register it globally
    :param factory: if specified it should be a `CompositeCaster` subclass: use
        it to :ref:`customize how to cast composite types <custom-composite>`
    :return: the registered `CompositeCaster` or *factory* instance
        responsible for the conversion
    N(RR�R�R�R�R�R�(ROR�R�tfactorytcaster((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pytregister_composite�s
	
 
#(tjsontJsont
register_json(tregister_default_jsontregister_default_jsonb(tRangetNumericRange(t	DateRanget
DateTimeRangetDateTimeTZRange(tregister_rangetRangeAdaptertRangeCaster(BRtosRotsysRFRzRytreR�tloggingRdRR�RR�R�R
R�Rt_connectionRR�RRRRR/R RHRIR?RJRRRSRbRuRvR|tobjectR}R�R�R�R�R�R�R�tFalseR�R�R�tpsycopg2._jsonR�R
R

R
R
tpsycopg2._rangeR
R
R
R
R
R	
R

R
(((sB/opt/alt/python27/lib64/python2.7/site-packages/psycopg2/extras.pyt<module>sX











9DK-"		�
@�