관리-도구
편집 파일: mysqlconnector.cpython-38.pyc
U -?�f+ � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ dd lmZ G d d � d e�Z G d d � d e�Z G dd� de�Z G dd� de�Z e Z dS )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)�MySQLIdentifierPreparer� )�utilc @ s e Zd Zdd� ZdS )� MySQLCompiler_mysqlconnectorc K s$ | j |jf|�d | j |jf|� S )Nz % )�process�left�right)�self�binary�operator�kw� r �X/opt/hc_python/lib64/python3.8/site-packages/sqlalchemy/dialects/mysql/mysqlconnector.py�visit_mod_binary$ s ���z-MySQLCompiler_mysqlconnector.visit_mod_binaryN)�__name__� __module__� __qualname__r r r r r r # s r c @ s. e Zd Zedd� �Zejdd� �Zdd� ZdS )�&MySQLIdentifierPreparer_mysqlconnectorc C s dS )NFr )r r r r �_double_percents- s z7MySQLIdentifierPreparer_mysqlconnector._double_percentsc C s d S �Nr �r �valuer r r r 1 s c C s |� | j| j�}|S r )�replaceZ escape_quoteZescape_to_quoter r r r �_escape_identifier5 s z9MySQLIdentifierPreparer_mysqlconnector._escape_identifierN)r r r �propertyr �setterr r r r r r , s r c @ s e Zd Zdd� ZdS )� _myconnpyBITc C s dS )z0MySQL-connector already converts mysql bits, so.Nr )r �dialectZcoltyper r r �result_processor; s z _myconnpyBIT.result_processorN)r r r r" r r r r r : s r c s� e Zd ZdZdZdZdZdZdZe Z e Z e �ejeei�Zedd� �Zdd� Zdd � Ze jd d � �Zd d � Zdd� Zdd� Zd dd�Z d dd�Z dddddhZ � fd d �Z � Z S ) �MySQLDialect_mysqlconnectorZmysqlconnectorT�formatc C s ddl m} |S )Nr )� connector)�mysqlr% )�clsr% r r r � import_dbapiQ s z(MySQLDialect_mysqlconnector.import_dbapic C s |� d� dS )NFT)Zping)r Zdbapi_connectionr r r �do_pingW 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 �rZz2ddl m } |� d|� � �}||j O }||d< W n tk �rX Y nX g |gS )N�user)�usernameZallow_local_infile� autocommit�buffered�compressZconnection_timeout�connect_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� setdefault�dbapiZmysql.connector.constantsr1 �get� get_defaultZ FOUND_ROWS� Exception)r �url�optsr1 r2 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 r )r6 )�.0�xr r r � <genexpr>� s zKMySQLDialect_mysqlconnector._mysqlconnector_version_info.<locals>.<genexpr>r � r )r8 �hasattr�re�matchr? �tuple�group)r �mr r r � _mysqlconnector_version_info� s z8MySQLDialect_mysqlconnector._mysqlconnector_version_infoc C s |j jS r )� connection�charset)r rK r r r �_detect_charset� s z+MySQLDialect_mysqlconnector._detect_charsetc C s |j S r )�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)r8 ZOperationalErrorZInterfaceError� isinstancerN �str)r �erK �cursorZerrnos� exceptionsr r r � is_disconnect� s � �z)MySQLDialect_mysqlconnector.is_disconnectNc C s |� � S r )Zfetchall�r �rprL r r r �_compat_fetchall� s z,MySQLDialect_mysqlconnector._compat_fetchallc C s |� � S r )ZfetchonerW r r r �_compat_fetchone� s z,MySQLDialect_mysqlconnector._compat_fetchoneZ SERIALIZABLEzREAD UNCOMMITTEDzREAD COMMITTEDzREPEATABLE READ� AUTOCOMMITc s( |dkrd|_ nd|_ t� �||� d S )Nr[ TF)r, �super�_set_isolation_level)r rK �level�� __class__r r r] � s z0MySQLDialect_mysqlconnector._set_isolation_level)N)N)!r r r ZdriverZsupports_statement_cacheZsupports_sane_rowcountZ supports_sane_multi_rowcountZsupports_native_decimalZdefault_paramstyler Zstatement_compilerr �preparerr Z update_copyr Zcolspecsr r � classmethodr( r) r> Zmemoized_propertyrJ rM rP rV rY rZ Z_isolation_lookupr] � __classcell__r r r_ r r# A s6 ) �r# )�__doc__rE �baser r r r � r r r r r# r! r r r r �<module> s r