ó ¿b›]c@sædZddlZddlmZddlmZddlmZddlmZ dd lm Z d e fd „ƒYZ d e e j fd „ƒYZde e 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((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pytprocess3s ((tselftdialectR ((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pytbind_processor2s (t__name__t __module__R(((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyR1st_FBNumeric_kinterbasdbcBseZRS((RR(((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyR<st_FBFloat_kinterbasdbcBseZRS((RR(((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyR@stFBExecutionContext_kinterbasdbcBseZed„ƒZRS(cCs-|jjd|jjƒr%|jjSdSdS(Ntenable_rowcountiÿÿÿÿ(texecution_optionstgetR Rtcursortrowcount(R ((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyREs  (RRtpropertyR(((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyRDstFBDialect_kinterbasdbcBsµeZdZeZeZeZeZ e j e j ieej6eej6ƒZ ddeed„Zed„ƒZd d„Zd„Zd„Zd„Zd „Zd „Zd „ZRS( t kinterbasdbiÈicKsPtt|ƒj|||_||_||_||_|rLt|_ndS(N( tsuperRt__init__Rt type_convtconcurrency_levelt retainingtTruetsupports_sane_rowcount(R RRRR tkwargs((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyR_s    cCs tdƒS(NR(t __import__(tcls((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pytdbapioscCs|j||pgƒdS(N(texecute(R Rt statementt parameterstcontext((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyt do_executesscCs|j|jƒdS(N(trollbackR (R tdbapi_connection((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyt do_rollbackxscCs|j|jƒdS(N(tcommitR (R R-((sGlib/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/%sthostRRt initializedt _initialized(ttranslate_connect_argsRtupdatetqueryRtcoerce_kw_typetinttpopRRR&tNonetgetattrtFalsetinit(R turltoptsRRR5((sGlib/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(R RDtfbconntversion((sGlib/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|ƒ^qd gƒSdS( Ns3\w+-V(\d+)\.(\d+)\.(\d+)\.(\d+)( \w+ (\d+)\.(\d+))?s,Could not determine version from string '%s'iiiitfirebirdiiit interbase(RtAssertionErrortgroupR=ttupleR;(R RHtmtx((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyRF«s 9cCsct||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?(R teRDRtmsg((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyt is_disconnect¹s     N(RRtdriverR?R"tsupports_sane_multi_rowcountRtexecution_ctx_clsR!tsupports_native_decimalRt update_copyRtcolspecsRtsqltypestNumericRtFloatRt classmethodR&R=R+R.R0RCRIRFRU(((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyROs,        (t__doc__RtreRtbaseRRtRR\RtobjectRR]RR^RRRR (((sGlib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyt&s   y