ó H`¾Tc@sŅdZddlmZmZddlmZmZddlm Z ddl Z de fd „ƒYZ d e ej fd „ƒYZd e ejfd „ƒ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(t FBDialecttFBExecutionContexti(tutilttypesi’’’’(tmatchNt_kinterbasdb_numericcBseZd„ZRS(cCs d„}|S(NcSs$t|tjƒrt|ƒS|SdS(N(t isinstancetdecimaltDecimaltstr(tvalue((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pytprocess1s ((tselftdialectR ((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pytbind_processor0s (t__name__t __module__R(((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyR/st_FBNumeric_kinterbasdbcBseZRS((RR(((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyR9st_FBFloat_kinterbasdbcBseZRS((RR(((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyR=stFBExecutionContext_kinterbasdbcBseZed„ƒZRS(cCs-|jjd|jjƒr%|jjSdSdS(Ntenable_rowcounti’’’’(texecution_optionstgetR Rtcursortrowcount(R ((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyRBs  (RRtpropertyR(((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyRAstFBDialect_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((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyR\s    cCs tdƒS(NR(t __import__(tcls((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pytdbapigscCs|j||pgƒdS(N(texecute(R Rt statementt parameterstcontext((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyt do_executekscCs|j|jƒdS(N(trollbackR (R tdbapi_connection((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyt do_rollbackpscCs|j|jƒdS(N(tcommitR (R R-((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyt do_commitsscCs |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((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pytcreate_connect_argsvs"     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((sn/var/www/send.findwatt.com/datamanager/lib/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d 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((sn/var/www/send.findwatt.com/datamanager/lib/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((sn/var/www/send.findwatt.com/datamanager/lib/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(((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyRKs*        (t__doc__tbaseRRtRRR\treRRtobjectRR]RR^RRRR (((sn/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.pyt's   m