HEX

File: //opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyo
�
��4]c@s�dZddlZddlmZddlmZddlmZddlmZ	dd	lm
Z
d
efd��YZdee	j
fd
��YZdee	jfd��YZdefd��YZdefd��YZeZdS(sK
.. dialect:: firebird+kinterbasdb
    :name: kinterbasdb
    :dbapi: kinterbasdb
    :connectstring: firebird+kinterbasdb://user:password@host:port/path/to/db[?key=value&key=value...]
    :url: http://firebirdsql.org/index.php?op=devel&sub=python

Arguments
----------

The Kinterbasdb backend accepts the ``enable_rowcount`` and ``retaining``
arguments accepted by the :mod:`sqlalchemy.dialects.firebird.fdb` dialect.
In addition, it also accepts the following:

* ``type_conv`` - select the kind of mapping done on the types: by default
  SQLAlchemy uses 200 with Unicode, datetime and decimal support.  See
  the linked documents below for further information.

* ``concurrency_level`` - set the backend policy with regards to threading
  issues: by default SQLAlchemy uses policy 1.  See the linked documents
  below for further information.

.. seealso::

    http://sourceforge.net/projects/kinterbasdb

    http://kinterbasdb.sourceforge.net/dist_docs/usage.html#adv_param_conv_dynamic_type_translation

    http://kinterbasdb.sourceforge.net/dist_docs/usage.html#special_issue_concurrency

i����N(tmatchi(t	FBDialect(tFBExecutionContexti(ttypes(tutilt_kinterbasdb_numericcBseZd�ZRS(cCs
d�}|S(NcSs$t|tj�rt|�S|SdS(N(t
isinstancetdecimaltDecimaltstr(tvalue((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pytprocess3s
((tselftdialectR((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pytbind_processor2s	(t__name__t
__module__R(((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyR1st_FBNumeric_kinterbasdbcBseZRS((RR(((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyR<st_FBFloat_kinterbasdbcBseZRS((RR(((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyR@stFBExecutionContext_kinterbasdbcBseZed��ZRS(cCs-|jjd|jj�r%|jjSdSdS(Ntenable_rowcounti����(texecution_optionstgetR
Rtcursortrowcount(R((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyREs	
(RRtpropertyR(((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyRDstFBDialect_kinterbasdbcBs�eZdZeZeZeZeZ	e
jej
ieej6eej6�Z
ddeed�Zed��Zdd�Zd�Zd�Zd�Zd	�Zd
�Zd�ZRS(
tkinterbasdbi�icKsPtt|�j|�||_||_||_||_|rLt|_ndS(N(	tsuperRt__init__Rt	type_convtconcurrency_levelt	retainingtTruetsupports_sane_rowcount(RRRRR tkwargs((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyR_s				cCs
td�S(NR(t
__import__(tcls((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pytdbapioscCs|j||pg�dS(N(texecute(RRt	statementt
parameterstcontext((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyt
do_executesscCs|j|j�dS(N(trollbackR (Rtdbapi_connection((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pytdo_rollbackxscCs|j|j�dS(N(tcommitR (RR-((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyt	do_commit{scCs|jdd�}|jd�rGd|d|df|d<|d=n|j|j�tj|dt�|jd|j�}|jd|j	�}|j
dk	rt|j
dd�}|dkr�t|j
d	t
�}n|s|j
jd|d|�qng|fS(
Ntusernametusertports%s/%sthostRRtinitializedt_initialized(ttranslate_connect_argsRtupdatetqueryRtcoerce_kw_typetinttpopRRR&tNonetgetattrtFalsetinit(RturltoptsRRR5((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pytcreate_connect_args~s"
cCs|j}|j}|j|�S(s�Get the version of the Firebird server used by a connection.

        Returns a tuple of (`major`, `minor`, `build`), three integers
        representing the version of the attached server.
        (t
connectiontserver_versiont_parse_version_info(RRDtfbconntversion((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyt_get_server_version_info�s
		cCs�td|�}|s(td|��n|jd�dkrvtg|jddd�D]}t|�^qVdg�Stg|jdd	d
�D]}t|�^q�dg�SdS(Ns3\w+-V(\d+)\.(\d+)\.(\d+)\.(\d+)( \w+ (\d+)\.(\d+))?s,Could not determine version from string '%s'iiiitfirebirdiiit	interbase(RtAssertionErrortgroupR=ttupleR;(RRHtmtx((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyRF�s9cCsct||jj|jjf�r[t|�}d|kpZd|kpZd|kpZd|kStSdS(Ns*Unable to complete network request to hostsInvalid connection statesInvalid cursor statesconnection shutdown(RR&tOperationalErrortProgrammingErrorR	R?(RteRDRtmsg((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyt
is_disconnect�s
N(RRtdriverR?R"tsupports_sane_multi_rowcountRtexecution_ctx_clsR!tsupports_native_decimalRtupdate_copyRtcolspecsRtsqltypestNumericRtFloatRtclassmethodR&R=R+R.R0RCRIRFRU(((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyROs,
					(t__doc__RtreRtbaseRRtRR\RtobjectRR]RR^RRRR
(((s[/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyt<module>&sy