Edit File: mysqlconnector.cpython-37.pyc
B ��4]� � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ d d lm Z d d lm Z G d d � d e�Z G dd� de�Z G dd� de�Z G dd� de�ZG dd� de�ZeZdS )a .. dialect:: mysql+mysqlconnector :name: MySQL Connector/Python :dbapi: myconnpy :connectstring: mysql+mysqlconnector://<user>:<password>@<host>[:<port>]/<dbname> :url: https://pypi.org/project/mysql-connector-python/ .. note:: The MySQL Connector/Python DBAPI has had many issues since its release, some of which may remain unresolved, and the mysqlconnector dialect is **not tested as part of SQLAlchemy's continuous integration**. The recommended MySQL dialects are mysqlclient and PyMySQL. � N� )�BIT)� MySQLCompiler)� MySQLDialect)�MySQLExecutionContext)�MySQLIdentifierPreparer� )� processors)�utilc @ s e Zd Zdd� ZdS )�$MySQLExecutionContext_mysqlconnectorc C s | j jS )N)�cursorZ lastrowid)�self� r �[/opt/alt/python37/lib64/python3.7/site-packages/sqlalchemy/dialects/mysql/mysqlconnector.py� get_lastrowid$ s z2MySQLExecutionContext_mysqlconnector.get_lastrowidN)�__name__� __module__� __qualname__r r r r r r # s r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� MySQLCompiler_mysqlconnectorc K sT | j jr,| j|jf|�d | j|jf|� S | j|jf|�d | j|jf|� S d S )Nz %% z % )�dialect� _mysqlconnector_double_percents�process�left�right)r �binary�operator�kwr r r �visit_mod_binary) s $z-MySQLCompiler_mysqlconnector.visit_mod_binaryc C s | j jr|�dd�S |S d S )N�%z%%)r r �replace)r �textr r r �post_process_text7 s z.MySQLCompiler_mysqlconnector.post_process_textc C s | j jr|�dd�S |S d S )Nr z%%)r r r )r r r r r �escape_literal_column= s z2MySQLCompiler_mysqlconnector.escape_literal_columnN)r r r r r! r" r r r r r ( s r c @ s. e Zd Zedd� �Zejdd� �Zdd� ZdS )�&MySQLIdentifierPreparer_mysqlconnectorc C s | j jS )N)r r )r r r r �_double_percentsE s z7MySQLIdentifierPreparer_mysqlconnector._double_percentsc C s d S )Nr )r �valuer r r r$ I s c C s, |� | j| j�}| jjr$|� dd�S |S d S )Nr z%%)r Z escape_quoteZescape_to_quoter r )r r% r r r �_escape_identifierM s z9MySQLIdentifierPreparer_mysqlconnector._escape_identifierN)r r r �propertyr$ �setterr& r r r r r# D s r# c @ s e Zd Zdd� ZdS )� _myconnpyBITc C s dS )z0MySQL-connector already converts mysql bits, so.Nr )r r Zcoltyper r r �result_processorV s z _myconnpyBIT.result_processorN)r r r r* r r r r r) U s r) c s� e Zd ZdZdZdZdZdZdZe Z e Z e Ze�ejeei�Z� fdd�Zdd� Zedd � �Zejd d � �Zed d � �Z dd� Z dd� Z ejdd� �Z ejdd� �Z dd� Z!dd� Z"dd� Z#d(d d �Z$d)d d �Z%e&d!d"d#d$d%g�Z'� fd&d'�Z(� Z)S )*�MySQLDialect_mysqlconnectorZmysqlconnectorT�formatc s$ t t| �j||� t�| j�| _d S )N)�superr+ �__init__r Z(to_conditional_unicode_processor_factory�description_encodingZ_description_decoder)r �argr )� __class__r r r. n s z$MySQLDialect_mysqlconnector.__init__c C s dS )NFr )r � connectionr r r �_check_unicode_descriptionw s z6MySQLDialect_mysqlconnector._check_unicode_descriptionc C s dS )Nzlatin-1r )r r r r r/ | s z0MySQLDialect_mysqlconnector.description_encodingc C s t jp| jdkS )N)� r )r �py3k� _mysqlconnector_version_info)r r r r �supports_unicode_statements� s z7MySQLDialect_mysqlconnector.supports_unicode_statementsc C s ddl m} |S )Nr )� connector)�mysqlr8 )�clsr8 r r r �dbapi� s z!MySQLDialect_mysqlconnector.dbapic C sR y|� d� W n: | jjk rH } z| �||d �r6dS � W d d }~X Y nX dS d S )NFT)Zpingr; �Error� is_disconnect)r Zdbapi_connection�errr r r �do_ping� s z#MySQLDialect_mysqlconnector.do_pingc C sb |j dd�}|�|j� t�|dt� t�|dt� t�|dt� t�|dt� t�|dt� t�|dt� t�|d t� t�|d t� t�|d t� t�|d t� t�|d t� t�|dt� t�|dt� t�|dt� t�|dt� t�|dt� |�dd� | jd k �rZy2ddl m } |� d|� � �}||j O }||d< W n tk �rX Y nX g |gS )N�user)�usernameZallow_local_infile� autocommitZbuffered�compressZconnection_timeoutZconnect_timeoutZconsume_resultsZ force_ipv6Z get_warningsZpool_reset_sessionZ pool_sizeZraise_on_warnings�rawZssl_verify_certZuse_pureZ use_unicodeTr )� ClientFlag� client_flags)Ztranslate_connect_args�update�queryr Zcoerce_kw_type�bool�int� setdefaultr; Zmysql.connector.constantsrE �get� get_defaultZ FOUND_ROWS� Exception)r �url�optsrE rF r r r �create_connect_args� s: z/MySQLDialect_mysqlconnector.create_connect_argsc C sF | j rBt| j d�rBt�d| j j�}|rBtdd� |�ddd�D ��S d S )N� __version__z(\d+)\.(\d+)(?:\.(\d+))?c s s | ]}|d k rt |�V qd S )N)rJ )�.0�xr r r � <genexpr>� s zKMySQLDialect_mysqlconnector._mysqlconnector_version_info.<locals>.<genexpr>r r4 r )r; �hasattr�re�matchrR �tuple�group)r �mr r r r6 � s z8MySQLDialect_mysqlconnector._mysqlconnector_version_infoc C s t j o| jdk S )N)r4 r )r r5 r6 )r r r r r � s z;MySQLDialect_mysqlconnector._mysqlconnector_double_percentsc C s |j jS )N)r2 �charset)r r2 r r r �_detect_charset� s z+MySQLDialect_mysqlconnector._detect_charsetc C s |j S )N)�errno)r � exceptionr r r �_extract_error_code� s z/MySQLDialect_mysqlconnector._extract_error_codec C sH d}| j j| j jf}t||�r@|j|kp>dt|�kp>dt|�kS dS d S )N)i� i� i� i� i i z MySQL Connection not available.z$Connection to MySQL is not availableF)r; ZOperationalErrorZInterfaceError� isinstancer^ �str)r �er2 r Zerrnos� exceptionsr r r r= � s z)MySQLDialect_mysqlconnector.is_disconnectNc C s |� � S )N)Zfetchall)r �rpr\ r r r �_compat_fetchall� s z,MySQLDialect_mysqlconnector._compat_fetchallc C s |� � S )N)Zfetchone)r re r\ r r r �_compat_fetchone� s z,MySQLDialect_mysqlconnector._compat_fetchoneZ SERIALIZABLEzREAD UNCOMMITTEDzREAD COMMITTEDzREPEATABLE READ� AUTOCOMMITc s, |dkrd|_ nd|_ tt| ��||� d S )Nrh TF)rB r- r+ �_set_isolation_level)r r2 �level)r1 r r ri � s z0MySQLDialect_mysqlconnector._set_isolation_level)N)N)*r r r ZdriverZsupports_unicode_bindsZsupports_sane_rowcountZ supports_sane_multi_rowcountZsupports_native_decimalZdefault_paramstyler Zexecution_ctx_clsr Zstatement_compilerr# Zpreparerr Z update_copyr Zcolspecsr r) r. r3 r' r/ Zmemoized_propertyr7 � classmethodr; r? rQ r6 r r] r` r= rf rg �setZ_isolation_lookupri � __classcell__r r )r1 r r+ \ s> ) r+ )�__doc__rW �baser r r r r � r r r r r# r) r+ r r r r r �<module> s