ó
‹EYc@@sJdZd
dl
mZ
d
dlZd
dlZddlmZmZ
d
dlZddlm	Z	
ddl
mZ
ddl
mZ
dd	lmZ
d
dlmZmZmZmZmZmZmZmZmZmZ
d
dlmZ
d
d
lmZm Z 
yd
dl!mZ"
Wne#k
r)



dZ"n
Xej%dƒ
Z&dej'f
d„ƒYZ(def
d„ƒYZ)def
d„ƒYZ*def
d„ƒYZ+de f
d„ƒYZ,def
d„ƒYZ-ej.dej/ej0BƒZ1ej2ƒZ3def
d„ƒYZ4def
d „ƒYZ5d!ef
d"„ƒYZ6d#ef
d$„ƒYZ7e7Z8dS(%sì.
.. dialect:: postgresql+psycopg2
    :name: psycopg2
    :dbapi: psycopg2
    :connectstring: postgresql+psycopg2://user:password@host:port/dbname[?key=value&key=value...]
    :url: http://pypi.python.org/pypi/psycopg2/

psycopg2 Connect Arguments
-----------------------------------

psycopg2-specific keyword arguments which are accepted by
:func:`.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.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.
  Note that the ``stream_results=True`` execution option is a more targeted
  way of enabling this mode on a per-execution basis.
* ``use_native_unicode``: Enable the usage of Psycopg2 "native unicode" mode
  per connection.  True by default.

  .. seealso::

    :ref:`psycopg2_disable_native_unicode`

* ``isolation_level``: This option, available for all PostgreSQL dialects,
  includes the ``AUTOCOMMIT`` isolation level when using the psycopg2
  dialect.

  .. seealso::

    :ref:`psycopg2_isolation_level`

* ``client_encoding``: sets the client encoding in a libpq-agnostic way,
  using psycopg2's ``set_client_encoding()`` method.

  .. seealso::

    :ref:`psycopg2_unicode`

Unix Domain Connections
------------------------

psycopg2 supports connecting via Unix domain connections.   When the ``host``
portion of the URL is omitted, SQLAlchemy passes ``None`` to psycopg2,
which specifies Unix-domain communication rather than TCP/IP communication::

    create_engine("postgresql+psycopg2://user:password@/dbname")

By default, the socket file used is to connect to a Unix-domain socket
in ``/tmp``, or whatever socket directory was specified when PostgreSQL
was built.  This value can be overridden by passing a pathname to psycopg2,
using ``host`` as an additional keyword argument::

    create_engine("postgresql+psycopg2://user:password@/dbname?host=/var/lib/postgresql")

See also:

`PQconnectdbParams <http://www.postgresql.org/docs/9.1/static/libpq-connect.html#LIBPQ-PQCONNECTDBPARAMS>`_

.. _psycopg2_execution_options:

Per-Statement/Connection Execution Options
-------------------------------------------

The following DBAPI-specific options are respected when used with
:meth:`.Connection.execution_options`, :meth:`.Executable.execution_options`,
:meth:`.Query.execution_options`, in addition to those not specific to DBAPIs:

* ``isolation_level`` - Set the transaction isolation level for the lifespan of a
  :class:`.Connection` (can only be set on a connection, not a statement
  or query).   See :ref:`psycopg2_isolation_level`.

* ``stream_results`` - Enable or disable usage of psycopg2 server side cursors -
  this feature makes use of "named" cursors in combination with special
  result handling methods so that result rows are not fully buffered.
  If ``None`` or not set, the ``server_side_cursors`` option of the
  :class:`.Engine` is used.

* ``max_row_buffer`` - when using ``stream_results``, an integer value that
  specifies the maximum number of rows to buffer at a time.  This is
  interpreted by the :class:`.BufferedRowResultProxy`, and if omitted the
  buffer will grow to ultimately store 1000 rows at a time.

  .. versionadded:: 1.0.6

.. _psycopg2_unicode:

Unicode with Psycopg2
----------------------

By default, the psycopg2 driver uses the ``psycopg2.extensions.UNICODE``
extension, such that the DBAPI receives and returns all strings as Python
Unicode objects directly - SQLAlchemy passes these values through without
change.   Psycopg2 here will encode/decode string values based on the
current "client encoding" setting; by default this is the value in
the ``postgresql.conf`` file, which often defaults to ``SQL_ASCII``.
Typically, this can be changed to ``utf8``, as a more useful default::

    # postgresql.conf file

    # client_encoding = sql_ascii # actually, defaults to database
                                 # encoding
    client_encoding = utf8

A second way to affect the client encoding is to set it within Psycopg2
locally.   SQLAlchemy will call psycopg2's
:meth:`psycopg2:connection.set_client_encoding` method
on all new connections based on the value passed to
:func:`.create_engine` using the ``client_encoding`` parameter::

    # set_client_encoding() setting;
    # works for *all* Postgresql versions
    engine = create_engine("postgresql://user:pass@host/dbname",
                           client_encoding='utf8')

This overrides the encoding specified in the Postgresql client configuration.
When using the parameter in this way, the psycopg2 driver emits
``SET client_encoding TO 'utf8'`` on the connection explicitly, and works
in all Postgresql versions.

Note that the ``client_encoding`` setting as passed to :func:`.create_engine`
is **not the same** as the more recently added ``client_encoding`` parameter
now supported by libpq directly.   This is enabled when ``client_encoding``
is passed directly to ``psycopg2.connect()``, and from SQLAlchemy is passed
using the :paramref:`.create_engine.connect_args` parameter::

    # libpq direct parameter setting;
    # only works for Postgresql **9.1 and above**
    engine = create_engine("postgresql://user:pass@host/dbname",
                           connect_args={'client_encoding': 'utf8'})

    # using the query string is equivalent
    engine = create_engine("postgresql://user:pass@host/dbname?client_encoding=utf8")

The above parameter was only added to libpq as of version 9.1 of Postgresql,
so using the previous method is better for cross-version support.

.. _psycopg2_disable_native_unicode:

Disabling Native Unicode
^^^^^^^^^^^^^^^^^^^^^^^^

SQLAlchemy can also be instructed to skip the usage of the psycopg2
``UNICODE`` extension and to instead utilize its own unicode encode/decode
services, which are normally reserved only for those DBAPIs that don't
fully support unicode directly.  Passing ``use_native_unicode=False`` to
:func:`.create_engine` will disable usage of ``psycopg2.extensions.UNICODE``.
SQLAlchemy will instead encode data itself into Python bytestrings on the way
in and coerce from bytes on the way back,
using the value of the :func:`.create_engine` ``encoding`` parameter, which
defaults to ``utf-8``.
SQLAlchemy's own unicode encode/decode functionality is steadily becoming
obsolete as most DBAPIs now support unicode fully.

Bound Parameter Styles
----------------------

The default parameter style for the psycopg2 dialect is "pyformat", where
SQL is rendered using ``%(paramname)s`` style.   This format has the limitation
that it does not accommodate the unusual case of parameter names that
actually contain percent or parenthesis symbols; as SQLAlchemy in many cases
generates bound parameter names based on the name of a column, the presence
of these characters in a column name can lead to problems.

There are two solutions to the issue of a :class:`.schema.Column` that contains
one of these characters in its name.  One is to specify the
:paramref:`.schema.Column.key` for columns that have such names::

    measurement = Table('measurement', metadata,
        Column('Size (meters)', Integer, key='size_meters')
    )

Above, an INSERT statement such as ``measurement.insert()`` will use
``size_meters`` as the parameter name, and a SQL expression such as
``measurement.c.size_meters > 10`` will derive the bound parameter name
from the ``size_meters`` key as well.

.. versionchanged:: 1.0.0 - SQL expressions will use :attr:`.Column.key`
   as the source of naming when anonymous bound parameters are created
   in SQL expressions; previously, this behavior only applied to
   :meth:`.Table.insert` and :meth:`.Table.update` parameter names.

The other solution is to use a positional format; psycopg2 allows use of the
"format" paramstyle, which can be passed to
:paramref:`.create_engine.paramstyle`::

    engine = create_engine(
        'postgresql://scott:tiger@localhost:5432/test', paramstyle='format')

With the above engine, instead of a statement like::

    INSERT INTO measurement ("Size (meters)") VALUES (%(Size (meters))s)
    {'Size (meters)': 1}

we instead see::

    INSERT INTO measurement ("Size (meters)") VALUES (%s)
    (1, )

Where above, the dictionary style is converted into a tuple with positional
style.


Transactions
------------

The psycopg2 dialect fully supports SAVEPOINT and two-phase commit operations.

.. _psycopg2_isolation_level:

Psycopg2 Transaction Isolation Level
-------------------------------------

As discussed in :ref:`postgresql_isolation_level`,
all Postgresql dialects support setting of transaction isolation level
both via the ``isolation_level`` parameter passed to :func:`.create_engine`,
as well as the ``isolation_level`` argument used by
:meth:`.Connection.execution_options`.  When using the psycopg2 dialect, these
options make use of psycopg2's ``set_isolation_level()`` connection method,
rather than emitting a Postgresql directive; this is because psycopg2's
API-level setting is always emitted at the start of each transaction in any
case.

The psycopg2 dialect supports these constants for isolation level:

* ``READ COMMITTED``
* ``READ UNCOMMITTED``
* ``REPEATABLE READ``
* ``SERIALIZABLE``
* ``AUTOCOMMIT``

.. versionadded:: 0.8.2 support for AUTOCOMMIT isolation level when using
    psycopg2.

.. seealso::

    :ref:`postgresql_isolation_level`

    :ref:`pg8000_isolation_level`


NOTICE logging
---------------

The psycopg2 dialect will log Postgresql NOTICE messages via the
``sqlalchemy.dialects.postgresql`` logger::

    import logging
    logging.getLogger('sqlalchemy.dialects.postgresql').setLevel(logging.INFO)

.. _psycopg2_hstore::

HSTORE type
------------

The ``psycopg2`` DBAPI includes an extension to natively handle marshalling of
the HSTORE type.   The SQLAlchemy psycopg2 dialect will enable this extension
by default when psycopg2 version 2.4 or greater is used, and
it is detected that the target database has the HSTORE type set up for use.
In other words, when the dialect makes the first
connection, a sequence like the following is performed:

1. Request the available HSTORE oids using
   ``psycopg2.extras.HstoreAdapter.get_oids()``.
   If this function returns a list of HSTORE identifiers, we then determine
   that the ``HSTORE`` extension is present.
   This function is **skipped** if the version of psycopg2 installed is
   less than version 2.4.

2. If the ``use_native_hstore`` flag is at its default of ``True``, and
   we've detected that ``HSTORE`` oids are available, the
   ``psycopg2.extensions.register_hstore()`` extension is invoked for all
   connections.

The ``register_hstore()`` extension has the effect of **all Python
dictionaries being accepted as parameters regardless of the type of target
column in SQL**. The dictionaries are converted by this extension into a
textual HSTORE expression.  If this behavior is not desired, disable the
use of the hstore extension by setting ``use_native_hstore`` to ``False`` as
follows::

    engine = create_engine("postgresql+psycopg2://scott:tiger@localhost/test",
                use_native_hstore=False)

The ``HSTORE`` type is **still supported** when the
``psycopg2.extensions.register_hstore()`` extension is not used.  It merely
means that the coercion between Python dictionaries and the HSTORE
string format, on both the parameter side and the result side, will take
place within SQLAlchemy's own marshalling logic, and not that of ``psycopg2``
which may be more performant.

i(
tabsolute_importNi(tutiltexc(
t
processors(
tresult(
t
expression(
ttypesi
(
t	PGDialectt
PGCompilertPGIdentifierPreparertPGExecutionContexttENUMtARRAYt_DECIMAL_TYPESt_FLOAT_TYPESt
_INT_TYPEStUUID(
tHSTORE(tJSONtJSONB(
Rssqlalchemy.dialects.postgresqlt
_PGNumericc
B@seZ
d„Zd
„ZRS(c
C@sdS(
N(
tNone(tselftdialect((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pytbind_processorR
s
cC@s£|jr]|t
kr+tjtj|jƒS|tksC|tkrGdSt
jd
|ƒ
‚
nB|t
krmdS|tks…|tkrŒtjSt
jd
|ƒ
‚
dS(NsUnknown PG numeric type: %d(
t	asdecimalRRtto_decimal_processor_factorytdecimaltDecimalt_effective_decimal_return_scaleR
RRRtInvalidRequestErrortto_float(RRtcoltype((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pytresult_processorU
s
	









(t__name__t
__module__RR!(((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyRQ
s
	t_PGEnumc
B@seZ
d„ZRS(
cC@sF|jr-t
jr-|jtkr-d
|_ntt|ƒj|
|ƒS(Nt
force_nocheck(tnative_enumR
tpy2ktconvert_unicodetTruetsuperR$R!(RRR ((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR!m
s
!
(R"R#R!(((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR$l
s
t	_PGHStorec
B@seZ
d„Zd
„ZRS(cC@s'|
jr
dStt|ƒj|
ƒ
SdS(
N(t_has_native_hstoreRR*R+R(RR((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyRw
s
	
cC@s*|
jr
dStt|ƒj|
|ƒSdS(
N(R,RR*R+R!(RRR ((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR!}
s
	
(R"R#RR!(((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR+v
s
	t_PGJSONc
B@seZ
d„ZRS(
cC@s*|
jr
dStt|ƒj|
|ƒSdS(
N(t_has_native_jsonRR*R-R!(RRR ((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR!†
s
	
(R"R#R!(((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR-„
st_PGJSONBc
B@seZ
d„ZRS(
cC@s*|
jr
dStt|ƒj|
|ƒSdS(
N(t_has_native_jsonbRR*R/R!(RRR ((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR!
s
	
(R"R#R!(((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR/
st_PGUUIDc
B@seZ
d„Zd
„ZRS(cC@s0|jr,|
j
r,tdƒ
}d
„}|SdS(Nc

S@s|dk	rt
|ƒ
}n|S(
N(Rt_python_UUID(
tvalue((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pytprocess›
s


(tas_uuidtuse_native_uuidttypeR(RRtnonetypeR4((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR—
s

	c
C@s$|jr |
j
r d
„}|SdS(Nc

S@s|dk	rt
|ƒ
}n|S(
N(Rtstr(
R3((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR4£
s


(R5R6(RRR R4((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR!¡
s

	(R"R#RR!(((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR1–
s
	
s	\s*SELECTtPGExecutionContext_psycopg2c
B@s#eZ
d„Zd
„Zd„ZRS(c
C@sô|jj
r‚|jjd
tƒo||jrBt|jjtj	ƒp||jsdt|jjtj
ƒo||jo|tj|jƒ
}
n|jjd
t
ƒ}
|
|_|
rãdtt|ƒ
ƒ
dttƒƒ
df}|jj|ƒ
S|jjƒSdS(Ntstream_resultssc_%s_%si(Rtserver_side_cursorstexecution_optionstgetR)tcompiledt
isinstancet	statementRt
Selectablet
TextClausetSERVER_SIDE_CURSOR_REtmatchtFalset,_PGExecutionContext_psycopg2__is_server_sidethextidt_server_side_idt_dbapi_connectiontcursor(Rtis_server_sidetident((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyt
create_cursor³
s 






	


c

C@sLtj
tjƒ
r%|j|jƒ

n|jr;tj|ƒ
Stj	|ƒ
SdS(
N(
tloggertisEnabledFortloggingtINFOt_log_noticesRLRGt_resulttBufferedRowResultProxytResultProxy(
R((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pytget_result_proxyÒ
s

	

cC@s;x'|
jj
D]}tj|jƒƒ

q
Wg|
jj
(dS(
N(t
connectiontnoticesRPtinfotrstrip(RRLtnotice((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyRTÜ
s
(R"R#RORXRT(((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR:²
s
		
tPGCompiler_psycopg2c
B@seZ
d„Zd
„ZRS(cK@s*|j|
j
|
d
|j|
j|
S(Ns %% (R4tlefttright(Rtbinarytoperatortkw((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pytvisit_mod_binaryæ
s

cC@s|
jd
dƒS(Nt
%s%%(
treplace(Rttext((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pytpost_process_textê
s
(R"R#RdRh(((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR^å
s
	tPGIdentifierPreparer_psycopg2c
B@seZ
d„ZRS(
cC@s(|
j|j
|jƒ}
|
jd
dƒS(NRes%%(Rftescape_quotetescape_to_quote(RR3((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyt_escape_identifierï
s

(R"R#Rl(((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyRiî
s
tPGDialect_psycopg2cB@s}
eZ
dZejreZnd
ZeZe	Z
eZe
ZdZeddddddd
dddƒZeZeZeZejjd
ejfg
ƒ
Zejejieej6ee6eej 6e!e"6e#e$6e%e&6e'e(6ƒZee)de)e)d„Z+d„Z,e-d„ƒ
Z.e-d„ƒ
Z/e-d„ƒ
Z0ej1d„ƒ
Z2d„Z3d„Z4ej5d„ƒ
Z6d„Z7d„Z8RS( tpsycopg2tpyformatitnative_jsoniitnative_jsonbitsane_multi_rowcounti	t	array_oidithstore_adaptertuse_native_unicodecK@s±tj
||

|
|_||_||_||_||_||_|jr­t	|jd
ƒr­t
jd|jjƒ}|r­t
d„|jdddƒDƒ
ƒ
|_q­ndS(Nt__version__s(\d+)\.(\d+)(?:\.(\d+))?c
s@s'|]}
|
dk	rt
|
ƒ
V
qdS(
N(Rtint(t.0t
x((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pys	<genexpr>.s

i
ii(Rt__init__R<Rutuse_native_hstoreR6tsupports_unicode_bindstclient_encodingtdbapithasattrtreRERvttupletgrouptpsycopg2_version(RR<RuR}R{R6tkwargst
m((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyRzs
	
	
	
	
	
	

	




cC@s‰tt
|ƒj|
ƒ

|jo4|j|
jƒ
dk	|_|j|j	d
k|_
|j|j	dk|_|j|j	dk|_dS(NRpRqRr(
R*Rmt
initializeR{t_hstore_oidsRYRR,RƒtFEATURE_VERSION_MAPR.R0tsupports_sane_multi_rowcount(RRY((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR†2s

	


c
C@sd
dl}
|
S(Ni(
Rn(tclsRn((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR~As
c
C@sd
dlm
}

|
S(Ni(
t
extensions(RnR‹(RŠR‹((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyt_psycopg2_extensionsFs
c
C@sd
dlm
}

|
S(Ni(
textras(RnR(RŠR((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyt_psycopg2_extrasKs
c
C@sB|jƒ}
i|
j
d
6|
jd6|
jd6|
jd6|
jd6S(Nt
AUTOCOMMITsREAD COMMITTEDsREAD UNCOMMITTEDsREPEATABLE READtSERIALIZABLE(RŒtISOLATION_LEVEL_AUTOCOMMITtISOLATION_LEVEL_READ_COMMITTEDt ISOLATION_LEVEL_READ_UNCOMMITTEDtISOLATION_LEVEL_REPEATABLE_READtISOLATION_LEVEL_SERIALIZABLE(RR‹((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyt_isolation_lookupPs









cC@smy|j|j
d
dƒ}Wn<tk
r[


tjd||jdj|jƒ
fƒ
‚
n
X|
j|ƒ

dS(Nt
_t
 sLInvalid value '%s' for isolation_level. Valid isolation levels for %s are %ss, (R–RftKeyErrorRt
ArgumentErrortnametjointset_isolation_level(RRYtlevel((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR[s





&c
@se
ˆjƒ‰
ˆj
ƒ‰g‰ˆjdk	rL‡f
d
†}
ˆj|
ƒ

nˆjdk	rz‡f
d†}
ˆj|
ƒ

nˆjr«ˆjr«‡
f
d†}
ˆj|
ƒ

nˆjr܈jr܇f
d†}
ˆj|
ƒ

nˆjr
ˆj	r
‡
‡fd†}
ˆj|
ƒ

nˆjrD
ˆj
rD
‡
‡fd†}
ˆj|
ƒ

nˆr]
‡f
d†}
|
SdSdS(Nc

@s|jˆj
ƒ

dS(
N(tset_client_encodingR}(
tconn(
R(s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyt
on_connectms
c

@sˆj|ˆj
ƒ
dS(
N(Rtisolation_level(
R (
R(s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR¡rs
c

@sˆjd|ƒ
dS(
N(t
register_uuidR(
R (
R(s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR¡ws
c

@s*ˆjˆj
|ƒ
ˆjˆj|ƒ
dS(
N(t
register_typetUNICODEtUNICODEARRAY(
R (
R‹(s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR¡|s

c
@s„ˆ
j|ƒ
}
|
dk	r€|
\}}i
|d
6}tjrJt|d<nˆ
jˆ
jdkrm||d<nˆj||

ndS(NtoidtunicodeRs(R‡RR
R'R)RƒRˆtregister_hstore(R thstore_oidsR§RsRc(RR(s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR¡‚s





	






c

@sHˆ
jr"ˆj
|d
ˆ
jƒ


nˆ
jrDˆj|d
ˆ
jƒ


ndS(Ntloads(R.tregister_default_jsont_json_deserializerR0tregister_default_jsonb(
R (RR(s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR¡s
	


	

c
@sxˆD]}
|
|ƒ

qWdS(
N((R tfn(
tfns(s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR¡šs


(RŽRŒR}RtappendR¢R~R6RuR{R­(RR¡((R‹RR°Rs\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR¡gs2









cC@s\|j|j
d
krX|jƒ}|jj|
ƒ
}|dk	rX|drX|dd!SndS(NRtii(RƒRˆRŽt
HstoreAdaptertget_oidsR(RR Rtoids((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyR‡¡s




cC@sO|
jd
dƒ
}d|kr5t
|dƒ
|d<n|j|
jƒ

g|fS(Ntusernametusertport(ttranslate_connect_argsRwtupdatetquery(Rturltopts((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pytcreate_connect_argsªs





cC@s¯t|
|j
jƒr«t|d
tƒr+tSt|
ƒ
jdƒ
d}xddddddd	d
ddd
ddgD]5}|j|ƒ
}|dkrod|| krotSqoWntS(Ntcloseds

isterminating connectionsclosed the connectionsconnection not opens"could not receive data from serverscould not send data to serversconnection already closedscursor already closeds!losed the connection unexpectedlys'connection has been closed unexpectedlys&SSL SYSCALL error: Bad file descriptorsSSL SYSCALL error: EOF detecteds.SSL error: decryption failed or bad record mact
"(	R@R~tErrortgetattrRFR)R9t	partitiontfind(Rt
eRYRLtstr_etmsgtidx((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyt
is_disconnect±s*














(ii(ii(iii(iii	(iii(iiN(9R"R#tdriverR
R'RFtsupports_unicode_statementstdefault_paramstyleR‰R:texecution_ctx_clsR^tstatement_compilerRitpreparerRƒtdictRˆR,R.R0Rtengine_config_typestuniontasbooltupdate_copytcolspecsRtsqltypestNumericR$RtEnumR+RR-RR/RR1RR)RRzR†tclassmethodR~RŒRŽtmemoized_propertyR–RR¡tmemoized_instancemethodR‡R½RÈ(((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyRmô
sV

	
	








	

	














			:		(9t__doc__t
__future__RR€RRtR
RRRtengineRRUtsqlRRRÕtbaseRRR	R
RRR
RRRthstoreRtjsonRRtuuidR2tImportErrorRt	getLoggerRPRÖRR$R+R-R/R1tcompilet
IR¥RDtcounterRJR:R^RiRmR(((s\/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.pyt<module>5
s@







F






		

3	ã