Edit File: oursql.cpython-37.pyc
B ��4]� � @ sx d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ G dd � d e�Z G d d � d e�Z G d d � d e�Z e Z dS )a .. dialect:: mysql+oursql :name: OurSQL :dbapi: oursql :connectstring: mysql+oursql://<user>:<password>@<host>[:<port>]/<dbname> :url: http://packages.python.org/oursql/ .. note:: The OurSQL MySQL dialect is legacy and is no longer supported upstream, and is **not tested as part of SQLAlchemy's continuous integration**. The recommended MySQL dialects are mysqlclient and PyMySQL. Unicode ------- Please see :ref:`mysql_unicode` for current recommendations on unicode handling. � )�BIT)� MySQLDialect)�MySQLExecutionContext� )�types)�utilc @ s e Zd Zdd� ZdS )� _oursqlBITc C s dS )z'oursql already converts mysql bits, so.N� )�self�dialectZcoltyper r �S/opt/alt/python37/lib64/python3.7/site-packages/sqlalchemy/dialects/mysql/oursql.py�result_processor( s z_oursqlBIT.result_processorN)�__name__� __module__� __qualname__r r r r r r ' s r c @ s e Zd Zedd� �ZdS )� MySQLExecutionContext_oursqlc C s | j �dd�S )N�_oursql_plain_queryF)�execution_options�get)r r r r � plain_query/ s z(MySQLExecutionContext_oursql.plain_queryN)r r r �propertyr r r r r r . s r c @ s e Zd ZdZejrdZdZdZdZ dZ e Z e� ejejejeei�Zedd� �Zd3dd�Zdd � Zd d � Zd d � Zdd� Zd4dd�Zd5dd�Z d6dd�Z d7dd�Z d8dd�Z d9dd �Z d:d d �Z!d d � Z"d!d"� Z#d;d#d$�Z$d%d&� Z%d'd(� Z&d)d*� Z'd+d,� Z(d<d-d.�Z)d=d/d0�Z*d>d1d2�Z+dS )?�MySQLDialect_oursql�oursqlTc C s t d�S )Nr )� __import__)�clsr r r �dbapiE s zMySQLDialect_oursql.dbapiNc C s* |r|j r|j|dd� n |�||� dS )zMProvide an implementation of *cursor.execute(statement, parameters)*.T)r N)r �execute)r �cursor� statement� parameters�contextr r r � do_executeI s z MySQLDialect_oursql.do_executec C s |� � jddd� d S )NZBEGINT)r )r r )r � connectionr r r �do_beginR s z MySQLDialect_oursql.do_beginc C sT t jr|j�|�}n | j}|j�|�|���|�}d| }|jdd��|| � d S )Nz'%s'T)r ) r �py2kr" Z_escape_stringZ_connection_charset�encode�decoder r )r r" �query�xid�arg�charsetr r r � _xa_queryU s z MySQLDialect_oursql._xa_queryc C s | � |d|� d S )Nz XA BEGIN %s)r+ )r r" r( r r r �do_begin_twophaseg s z%MySQLDialect_oursql.do_begin_twophasec C s | � |d|� | � |d|� d S )Nz XA END %sz XA PREPARE %s)r+ )r r" r( r r r �do_prepare_twophasej s z'MySQLDialect_oursql.do_prepare_twophaseFc C s$ |s| � |d|� | � |d|� d S )Nz XA END %szXA ROLLBACK %s)r+ )r r" r( � is_prepared�recoverr r r �do_rollback_twophasen s z(MySQLDialect_oursql.do_rollback_twophasec C s" |s| � ||� | �|d|� d S )Nz XA COMMIT %s)r- r+ )r r" r( r. r/ r r r �do_commit_twophaseu s z&MySQLDialect_oursql.do_commit_twophasec C s t �| |�� jdd�||�S )NT)r )r � has_table�connectr )r r" � table_name�schemar r r r2 ~ s z MySQLDialect_oursql.has_tablec K s& t j| |�� jdd�|fd|i|��S )NT)r r5 )r �get_table_optionsr3 r )r r" r4 r5 �kwr r r r6 � s z%MySQLDialect_oursql.get_table_optionsc K s& t j| |�� jdd�|fd|i|��S )NT)r r5 )r � get_columnsr3 r )r r" r4 r5 r7 r r r r8 � s z MySQLDialect_oursql.get_columnsc K s$ t j| |�� jdd�fd|i|��S )NT)r r5 )r �get_view_namesr3 r )r r" r5 r7 r r r r9 � s z"MySQLDialect_oursql.get_view_namesc K s t �| |�� jdd�|�S )NT)r )r �get_table_namesr3 r )r r" r5 r7 r r r r: � s z#MySQLDialect_oursql.get_table_namesc K s t j| |�� jdd�f|�S )NT)r )r �get_schema_namesr3 r )r r" r7 r r r r; � s z$MySQLDialect_oursql.get_schema_namesc C s t �| |jdd��S )NT)r )r � initializer )r r" r r r r< � s z MySQLDialect_oursql.initializec C s" t �| |jdd�jdd�|||�S )NT)Zclose_with_result)r )r �_show_create_tableZ_contextual_connectr )r r" �tabler* � full_namer r r r= � s z&MySQLDialect_oursql._show_create_tablec C sD t || jj�r6|jd ko4d|jd ko4|jd �d�S |jdkS d S )Nr r �closed)i� i� i� i� i )� isinstancer ZProgrammingError�errno�args�endswith)r �er" r r r r � is_disconnect� s z!MySQLDialect_oursql.is_disconnectc C s |j dddd�}|�|j� t�|dt� t�|dt� t�|dt� t�|dt� t�|d t� |�d d �rxd |d < nt�|d t� |� d d �|d < t�|d t� |� dd � i }xDdD ]<}||kr�|| ||dd � < t�||dd � t� ||= q�W |�r||d< g |gS )NZdb�user�passwd)Zdatabase�username�password�port�compressZautopingZraise_on_warningsZdefault_charsetFr* Z use_unicodeTZ found_rows)Zssl_caZssl_keyZssl_certZ ssl_capathZ ssl_cipher� �ssl) Ztranslate_connect_args�updater' r Zcoerce_kw_type�int�bool�pop�strr � setdefault)r �url�optsrN �keyr r r �create_connect_args� s. z'MySQLDialect_oursql.create_connect_argsc C s |j S )N)rB )r � exceptionr r r �_extract_error_code� s z'MySQLDialect_oursql._extract_error_codec C s |j jS )z:Sniff out the character set in use for connection results.)r" r* )r r" r r r �_detect_charset� s z#MySQLDialect_oursql._detect_charsetc C s |� � S )z.oursql isn't super-broken like MySQLdb, yaaay.)Zfetchall)r �rpr* r r r �_compat_fetchall� s z$MySQLDialect_oursql._compat_fetchallc C s |� � S )z.oursql isn't super-broken like MySQLdb, yaaay.)Zfetchone)r r\ r* r r r �_compat_fetchone� s z$MySQLDialect_oursql._compat_fetchonec C s |� � S )N)�first)r r\ r* r r r � _compat_first s z!MySQLDialect_oursql._compat_first)N)TF)TF)N)N)N)N)N)NN)N)N)N),r r r Zdriverr r$ Zsupports_unicode_bindsZsupports_unicode_statementsZsupports_native_decimalZsupports_sane_rowcountZ supports_sane_multi_rowcountr Zexecution_ctx_clsZ update_copyr Zcolspecs�sqltypesZTimer r � classmethodr r! r# r+ r, r- r0 r1 r2 r6 r8 r9 r: r; r< r= rF rX rZ r[ r] r^ r` r r r r r 4 sB ( r N) �__doc__�baser r r � r ra r r r r r r r r r �<module> s S