U
|
¸ý°dÕ ã @ s d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ dd lmZ G d
|
d d eZ G d d d eZ
|
G dd deZ G dd deZ 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 ú_d:\z\workplace\vscode\pyvenv\venv\Lib\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 ddZ d ddZ dddddhZ fd d Z Z S ) ÚMySQLDialect_mysqlconnectorZmysqlconnectorTÚformatc C s ddl m} |S )Nr )Ú connector)Zmysqlr% )Ú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Ú
|
autocommitZbufferedÚ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.constantsr/ ÚgetZ get_defaultZ
|
FOUND_ROWSÚ Exception)r ÚurlÚoptsr/ r0 r r r Úcreate_connect_args[ s> ÿ
|
z/MySQLDialect_mysqlconnector.create_connect_argsc C sF | j rBt| j drBt 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 )r4 )Ú.0Úxr r r Ú <genexpr> s zKMySQLDialect_mysqlconnector._mysqlconnector_version_info.<locals>.<genexpr>r é r )r6 Ú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 rH 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)r6 ZOperationalErrorZInterfaceErrorÚ
|
isinstancerK Ústr)r ÚerH ÚcursorZerrnosÚ
|
exceptionsr r r Ú is_disconnect s
|
|
|
ÿ
|
ýz)MySQLDialect_mysqlconnector.is_disconnectNc C s | ¡ S r )Zfetchall©r ÚrprI r r r Ú_compat_fetchall s z,MySQLDialect_mysqlconnector._compat_fetchallc C s | ¡ S r )ZfetchonerT r r r Ú_compat_fetchone s z,MySQLDialect_mysqlconnector._compat_fetchoneZ SERIALIZABLEzREAD UNCOMMITTEDzREAD COMMITTEDzREPEATABLE READÚ
|
AUTOCOMMITc s( |dkrd|_ nd|_ t ||¡ d S )NrX TF)r+ ÚsuperÚ_set_isolation_level)r rH Úlevel©Ú __class__r r rZ « 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_propertyrG rJ rM rS rV rW Z_isolation_lookuprZ Ú __classcell__r r r\ r r# A s6
|
)
|
|
|
ûr# )Ú__doc__rB Úbaser r r r Ú r r r r r# r! r r r r Ú<module>
|
s r
|
