Edit File: kinterbasdb.cpython-37.pyc
B ��4]� � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ dd lm Z G d d � d e �Z G d d � d e e j �ZG dd� de e j�ZG dd� de�ZG dd� de�ZeZdS )aK .. 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 � N)�match� )� FBDialect)�FBExecutionContext� )�types)�utilc @ s e Zd Zdd� ZdS )�_kinterbasdb_numericc C s dd� }|S )Nc S s t | tj�rt| �S | S d S )N)� isinstance�decimalZDecimal�str)�value� r �[/opt/alt/python37/lib64/python3.7/site-packages/sqlalchemy/dialects/firebird/kinterbasdb.py�process3 s z4_kinterbasdb_numeric.bind_processor.<locals>.processr )�self�dialectr r r r �bind_processor2 s z#_kinterbasdb_numeric.bind_processorN)�__name__� __module__� __qualname__r r r r r r 1 s r c @ s e Zd ZdS )�_FBNumeric_kinterbasdbN)r r r r r r r r < s r c @ s e Zd ZdS )�_FBFloat_kinterbasdbN)r r r r r r r r @ s r c @ s e Zd Zedd� �ZdS )� FBExecutionContext_kinterbasdbc C s" | j �d| jj�r| jjS dS d S )N�enable_rowcount���)Zexecution_options�getr r �cursor�rowcount)r r r r r E s z'FBExecutionContext_kinterbasdb.rowcountN)r r r �propertyr r r r r r D s r c s� e Zd ZdZdZdZeZdZe � e j e jee jei�Z d� fdd� Zedd � �Zdd d �Zd d� Zdd� Zdd� Zdd� Zdd� Zdd� Z� Z S )�FBDialect_kinterbasdb� kinterbasdbFT�� r c s8 t t| �jf |� || _|| _|| _|| _|r4d| _d S )NT)�superr �__init__r � type_conv�concurrency_level� retaining�supports_sane_rowcount)r r% r& r r' �kwargs)� __class__r r r$ _ s z FBDialect_kinterbasdb.__init__c C s t d�S )Nr! )� __import__)�clsr r r �dbapio s zFBDialect_kinterbasdb.dbapiNc C s |� ||p g � d S )N)�execute)r r � statement� parameters�contextr r r � do_executes s z FBDialect_kinterbasdb.do_executec C s |� | j� d S )N)Zrollbackr' )r �dbapi_connectionr r r � do_rollbackx s z!FBDialect_kinterbasdb.do_rollbackc C s |� | j� d S )N)Zcommitr' )r r3 r r r � do_commit{ s z FBDialect_kinterbasdb.do_commitc C s� |j dd�}|�d�r4d|d |d f |d< |d= |�|j� t�|dt� |�d| j�}|�d| j �}| j d k r�t | j dd �}|d kr�t | j d d �}|s�| j j ||d � g |fS ) N�user)�username�portz%s/%s�hostr% r& � initialized� _initializedF)r% r& ) Ztranslate_connect_argsr �update�queryr Zcoerce_kw_type�int�popr% r& r- �getattr�init)r �url�optsr% r& r: r r r �create_connect_args~ s" z)FBDialect_kinterbasdb.create_connect_argsc C s |j }|j}| �|�S )z�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. )� connectionZserver_version�_parse_version_info)r rE Zfbconn�versionr r r �_get_server_version_info� s z.FBDialect_kinterbasdb._get_server_version_infoc C sp t d|�}|std| ��|�d�d krJtdd� |�ddd�D �d g �S td d� |�d d d �D �dg �S d S )Nz3\w+-V(\d+)\.(\d+)\.(\d+)\.(\d+)( \w+ (\d+)\.(\d+))?z,Could not determine version from string '%s'� c S s g | ] }t |��qS r )r> )�.0�xr r r � <listcomp>� s z=FBDialect_kinterbasdb._parse_version_info.<locals>.<listcomp>� � � Zfirebirdc S s g | ] }t |��qS r )r> )rJ rK r r r rL � s r � r Z interbase)r �AssertionError�group�tuple)r rG �mr r r rF � s "z)FBDialect_kinterbasdb._parse_version_infoc C sF t || jj| jjf�r>t|�}d|kp<d|kp<d|kp<d|kS dS d S )Nz*Unable to complete network request to hostzInvalid connection statezInvalid cursor statezconnection shutdownF)r r- ZOperationalErrorZProgrammingErrorr )r �erE r �msgr r r � is_disconnect� s z#FBDialect_kinterbasdb.is_disconnect)r" r TF)N) r r r Zdriverr( Z supports_sane_multi_rowcountr Zexecution_ctx_clsZsupports_native_decimalr Z update_copyr Zcolspecs�sqltypes�Numericr �Floatr r$ � classmethodr- r2 r4 r5 rD rH rF rW � __classcell__r r )r* r r O s* r )�__doc__r �rer �baser r � r rX r �objectr rY r rZ r r r r r r r r �<module>& s y