관리-도구
편집 파일: zxjdbc.cpython-37.pyc
B ��4] � @ s d Z ddlZddlZddlZddlmZ ddlmZ ddlmZ ddlm Z dd lm Z dd lm Z dd l mZ dd lmZ dd l mZ d aaG dd� de j�ZG dd� de j�ZG dd� de�ZG dd� de�ZG dd� dej�Z G dd� de �Z G dd� dee�Z e Z dS ) am .. dialect:: oracle+zxjdbc :name: zxJDBC for Jython :dbapi: zxjdbc :connectstring: oracle+zxjdbc://user:pass@host/dbname :driverurl: http://www.oracle.com/technetwork/database/features/jdbc/index-091264.html .. note:: Jython is not supported by current versions of SQLAlchemy. The zxjdbc dialect should be considered as experimental. � N� )�OracleCompiler)� OracleDialect)�OracleExecutionContext� )�sql)�types)�util)�ZxJDBCConnector)�result)� expressionc @ s e Zd Zdd� ZdS )� _ZxJDBCDatec C s dd� }|S )Nc S s | d kr d S | � � S d S )N)�date)�value� r �T/opt/alt/python37/lib64/python3.7/site-packages/sqlalchemy/dialects/oracle/zxjdbc.py�process' s z-_ZxJDBCDate.result_processor.<locals>.processr )�self�dialect�coltyper r r r �result_processor& s z _ZxJDBCDate.result_processorN)�__name__� __module__� __qualname__r r r r r r % s r c @ s e Zd Zdd� ZdS )�_ZxJDBCNumericc C s | j rdd� }ndd� }|S )Nc S s" t | tj�r| S t�t| ��S d S )N)� isinstance�decimal�Decimal�str)r r r r r 7 s z0_ZxJDBCNumeric.result_processor.<locals>.processc S s t | tj�rt| �S | S d S )N)r r r �float)r r r r r ? s )Z asdecimal)r r r r r r r r 1 s z _ZxJDBCNumeric.result_processorN)r r r r r r r r r 0 s r c @ s e Zd Zdd� ZdS )�OracleCompiler_zxjdbcc s� t t�|��� _� fdd�� jD �}t� d�s4g � _g }xzt� j�D ]l\}}|j�� j �� � j j �}� j� |d |f� t jd| t|�d�}|� j|j< |� � �� �|��� qDW dd�|� d d�|� S ) Nc s g | ]}� j |d d��qS )F)Zwithin_columns_clause)r )�.0�c)r r r � <listcomp>P s z:OracleCompiler_zxjdbc.returning_clause.<locals>.<listcomp>�returning_parametersr zret_%d)r z RETURNING z, z INTO )�listr Z_select_iterables�returning_cols�hasattrr$ � enumerate�typeZ dialect_implr Zget_dbapi_typeZdbapi�appendr � bindparam�ReturningParam�binds�keyZbindparam_stringZ_truncate_bindparam�join) r �stmtr& �columnsr- �i�col�dbtyper+ r )r r �returning_clauseI s" z&OracleCompiler_zxjdbc.returning_clauseN)r r r r5 r r r r r H s r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� OracleExecutionContext_zxjdbcc C s t | jd�r | j�| j�| _d S )Nr$ )r' �compiled�cursorZprepare� statement)r r r r �pre_execj s z&OracleExecutionContext_zxjdbc.pre_execc s� t �jd�r�d � z�y�jj�� � t� � W n\ tk r� } z>d|�� |�� f }|� � d k rl|d|� � 7 }t � |��W d d }~X Y n(X t � �fdd��jj D ��}t�|�S W d � d k r�y � �� W n tk r� Y nX �j�� X t���S )Nr$ z%s [SQLCode: %d]z [SQLState: %s]c 3 s$ | ] \}}�j j�� ||�V qd S )N)r8 � datahandlerZ getPyObject)r! �indexr4 )�rrsr r r � <genexpr>� s zAOracleExecutionContext_zxjdbc.get_result_proxy.<locals>.<genexpr>)r' r7 r9 Z __statement__ZgetReturnResultSet�next� SQLException� getMessageZ getErrorCodeZ getSQLState�zxJDBC�Error�tupler$ �ReturningResultProxy�close�_resultZ ResultProxy)r Zsqle�msg�rowr )r= r r �get_result_proxyp s0 z.OracleExecutionContext_zxjdbc.get_result_proxyc C s | j �� }| j�|j�|_|S )N)Z_dbapi_connectionr8 r � DataHandlerr; )r r8 r r r � create_cursor� s z+OracleExecutionContext_zxjdbc.create_cursorN)r r r r: rJ rL r r r r r6 i s r6 c s0 e Zd ZdZ� fdd�Zdd� Zdd� Z� ZS )rE z6ResultProxy backed by the RETURNING ResultSet results.c s || _ tt| ��|� d S )N)�_returning_row�superrE �__init__)r �contextZ returning_row)� __class__r r rO � s z ReturningResultProxy.__init__c C sL g }xB| j jjD ]4}t|d�r2|�|j|jf� q|�|j|jf� qW |S )N�name)rP r7 r& r' r* rR r) Z anon_label)r �retr" r r r �_cursor_description� s z(ReturningResultProxy._cursor_descriptionc C s t �| jg�S )N)� collections�dequerM )r r r r � _buffer_rows� s z!ReturningResultProxy._buffer_rows)r r r �__doc__rO rT rW � __classcell__r r )rQ r rE � s rE c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) r, zpA bindparam value representing a RETURNING parameter. Specially handled by OracleReturningDataHandler. c C s || _ d S )N)r) )r �type_r r r rO � s zReturningParam.__init__c C s t |t�r| j|jkS tS )N)r r, r) �NotImplemented)r �otherr r r �__eq__� s zReturningParam.__eq__c C s t |t�r| j|jkS tS )N)r r, r) r[ )r r\ r r r �__ne__� s zReturningParam.__ne__c C s | j }d|j|jt| �| jf S )Nz <%s.%s object at 0x%x type=%s>)rQ r r �idr) )r Zklsr r r �__repr__� s zReturningParam.__repr__N)r r r rX rO r] r^ r` r r r r r, � s r, c sb e Zd ZdZdZeZeZe � e j e jee jei�Z � fdd�Z� fdd�Zdd� Zd d � Z� ZS ) �OracleDialect_zxjdbc�oraclezoracle.jdbc.OracleDriverc sT t t| �j||� ddlma ddlma ddlm� G � fdd�d� �}|| _ d S )Nr )r@ )rB )�OracleDataHandlerc s e Zd ZdZd� fdd� ZdS )zAOracleDialect_zxjdbc.__init__.<locals>.OracleReturningDataHandlerz9zxJDBC DataHandler that specially handles ReturningParam.Nc sL t |�tkr |�||j � n,|d kr6� �| |||� n� �| ||||� d S )N)r) r, ZregisterReturnParameter� setJDBCObject)r r9 r< Zobject_r4 )rc r r rd � s zOOracleDialect_zxjdbc.__init__.<locals>.OracleReturningDataHandler.setJDBCObject)N)r r r rX rd r )rc r r �OracleReturningDataHandler� s re ) rN ra rO Zjava.sqlr@ Zcom.ziclix.python.sqlrB Z com.ziclix.python.sql.handlerrc rK )r �args�kwargsre )rQ )rc r rO � s z OracleDialect_zxjdbc.__init__c s" t t| ��|� |jjdk| _d S )Nz10.2)rN ra � initialize� connectionZ driverversionZimplicit_returning)r ri )rQ r r rh � s z OracleDialect_zxjdbc.initializec C s d|j |jpd|jf S )Nzjdbc:oracle:thin:@%s:%s:%si� )�host�portZdatabase)r �urlr r r �_create_jdbc_url� s z%OracleDialect_zxjdbc._create_jdbc_urlc C s. t �d|jj��d�}tdd� |�d�D ��S )NzRelease ([\d\.]+)r c s s | ]}t |�V qd S )N)�int)r! �xr r r r> � s z@OracleDialect_zxjdbc._get_server_version_info.<locals>.<genexpr>�.)�re�searchri Z dbversion�grouprD �split)r ri �versionr r r �_get_server_version_info� s z-OracleDialect_zxjdbc._get_server_version_info)r r r Z jdbc_db_nameZjdbc_driver_namer Zstatement_compilerr6 Zexecution_ctx_clsr Z update_copyr Zcolspecs�sqltypes�Dater �Numericr rO rh rm rv rY r r )rQ r ra � s ra )!rX rU r rq �baser r r � r r rw r Zconnectors.zxJDBCr Zenginer rG r r@ rB rx r ry r r r6 ZFullyBufferedResultProxyrE �objectr, ra r r r r r �<module> s* !, 6