U
|
¸ý°d ã @ s d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ dd lmZ d
|
Z G d d d eZ
|
G d d deZ G dd deZ e Z dS )aì
|
|
.. dialect:: mysql+mariadbconnector
|
:name: MariaDB Connector/Python
|
:dbapi: mariadb
|
:connectstring: mariadb+mariadbconnector://<user>:<password>@<host>[:<port>]/<dbname>
|
:url: https://pypi.org/project/mariadb/
|
|
Driver Status
|
-------------
|
|
MariaDB Connector/Python enables Python programs to access MariaDB and MySQL
|
databases using an API which is compliant with the Python DB API 2.0 (PEP-249).
|
It is written in C and uses MariaDB Connector/C client library for client server
|
communication.
|
|
Note that the default driver for a ``mariadb://`` connection URI continues to
|
be ``mysqldb``. ``mariadb+mariadbconnector://`` is required to use this driver.
|
|
.. mariadb: https://github.com/mariadb-corporation/mariadb-connector-python
|
|
é Né )Ú MySQLCompiler)Ú MySQLDialect)ÚMySQLExecutionContexté )Úsql)Úutil)r r r c @ s0 e Zd ZdZdd Zdd Zdd Zdd ZdS )
|
Ú&MySQLExecutionContext_mariadbconnectorNc C s | j jddS )NF©Zbuffered©Z_dbapi_connectionÚcursor©Úself© r úad:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/dialects/mysql/mariadbconnector.pyÚcreate_server_side_cursor. s z@MySQLExecutionContext_mariadbconnector.create_server_side_cursorc C s | j jddS )NTr
|
r r r r r Úcreate_default_cursor1 s z<MySQLExecutionContext_mariadbconnector.create_default_cursorc C s | j r| jjr| jj| _d S ©N)ZisinsertZcompiledZpostfetch_lastrowidr Z lastrowidÚ
|
_lastrowidr r r r Ú post_exec4 s z0MySQLExecutionContext_mariadbconnector.post_execc C s | j S r )r r r r r Ú get_lastrowid8 s z4MySQLExecutionContext_mariadbconnector.get_lastrowid)Ú__name__Ú
|
__module__Ú __qualname__r r r r r r r r r r + s
|
r c @ s e Zd ZdS )Ú MySQLCompiler_mariadbconnectorN)r r r r r r r r < s r c s e Zd ZdZdZdZdZdZdZdZ dZ
|
dZ e Z eZdZejdd Z fddZed d
|
Z fd d Zd d Zdd Zdd Zdd Z fddZ dd Z dd Z d d d Z d!d d Z Z!S )"Ú MySQLDialect_mariadbconnectorZmariadbconnectorTÚutf8mb4Úqmarkc C s8 | j r0t| j dr0tdd t d| j j¡D S dS d S )NÚ __version__c S s g | ] }t |qS r )Úint©Ú.0Úxr r r Ú
|
<listcomp>^ s ÿz@MySQLDialect_mariadbconnector._dbapi_version.<locals>.<listcomp>z(\d+)(?:[-\.]?|$))éc r$ r$ )ÚdbapiÚhasattrÚtupleÚreÚfindallr r r r r Ú_dbapi_versionZ s ÿþÿ z,MySQLDialect_mariadbconnector._dbapi_versionc sH t jf | d| _| jd k rD| jtk rDtdd dd tD ¡ d S )Nr z?The minimum required version for MariaDB Connector/Python is %sÚ.c s s | ]}t |V qd S r )Ústrr r r r Ú <genexpr>p s z9MySQLDialect_mariadbconnector.__init__.<locals>.<genexpr>)ÚsuperÚ__init__Z
|
paramstyler% r* Úmariadb_cpy_minimum_versionÚNotImplementedErrorÚjoin)r Úkwargs©Ú __class__r r r/ h s
|
|
þÿz&MySQLDialect_mariadbconnector.__init__c C s t dS )NZmariadb)Ú
|
__import__)Úclsr r r Ú import_dbapis s z*MySQLDialect_mariadbconnector.import_dbapic sF t |||¡rdS t|| jjr>t| ¡ }d|kp<d|kS dS d S )NTz not connectedz isn't validF)r. Ú is_disconnectÚ
|
isinstancer% ÚErrorr, Úlower)r ÚeÚ
|
connectionr Zstr_er4 r r r9 w s z+MySQLDialect_mariadbconnector.is_disconnectc C s¼ | ¡ }ddddddg}ddd d
|
g}|D ]}t ||t¡ q(|D ]}t ||t¡ q@| dd ¡}| jd k r´z"t| jjd j j
|
}||j O }W n t t fk
|
rª d | _Y nX ||d< g |gS )NÚconnect_timeoutÚ read_timeoutZ write_timeoutÚ client_flagÚportZ pool_sizeZ local_infileZssl_verify_certÚsslZpool_reset_connectionr z.constants.CLIENTF)Ztranslate_connect_argsr Zcoerce_kw_typer ÚboolÚgetr% r6 r Ú constantsZCLIENTZ
|
FOUND_ROWSÚAttributeErrorÚ ImportErrorÚsupports_sane_rowcount)r ÚurlÚoptsZ
|
int_paramsZ bool_paramsÚkeyrA Z CLIENT_FLAGSr r r Úcreate_connect_args s8 ú ü
|
|
ÿ z1MySQLDialect_mariadbconnector.create_connect_argsc C s z
|
|j }W n d}Y nX |S )Néÿÿÿÿ)Úerrno)r Ú exceptionÚrcr r r Ú_extract_error_code¥ s
|
|
|
z1MySQLDialect_mariadbconnector._extract_error_codec C s dS )Nr r )r r> r r r Ú_detect_charset¬ s z-MySQLDialect_mariadbconnector._detect_charsetc C s dS )N)Z SERIALIZABLEzREAD UNCOMMITTEDzREAD COMMITTEDzREPEATABLE READÚ
|
AUTOCOMMITr )r Zdbapi_connectionr r r Úget_isolation_level_values¯ s z8MySQLDialect_mariadbconnector.get_isolation_level_valuesc s( |dkrd|_ nd|_ t ||¡ d S )NrT TF)Z
|
autocommitr. Úset_isolation_level)r r> Úlevelr4 r r rV ¸ s z1MySQLDialect_mariadbconnector.set_isolation_levelc C s& | t d¡ tjd|dd¡¡ d S )Nz XA BEGIN :xidÚxidT©Zliteral_execute©Úexecuter ÚtextÚ
|
bindparamsÚ bindparam©r r> rX r r r Údo_begin_twophase¿ s
|
|
ÿÿz/MySQLDialect_mariadbconnector.do_begin_twophasec C sH | t d¡ tjd|dd¡¡ | t d¡ tjd|dd¡¡ d S )Nú XA END :xidrX TrY zXA PREPARE :xidrZ r_ r r r Údo_prepare_twophaseÆ s
|
ÿÿ
|
ÿÿz1MySQLDialect_mariadbconnector.do_prepare_twophaseFc C sL |s&| t d¡ tjd|dd¡¡ | t d¡ tjd|dd¡¡ d S )Nra rX TrY zXA ROLLBACK :xidrZ ©r r> rX Z is_preparedZrecoverr r r Údo_rollback_twophaseÒ s
|
ÿÿ
|
ÿÿz2MySQLDialect_mariadbconnector.do_rollback_twophasec C s6 |s| ||¡ | t d¡ tjd|dd¡¡ d S )NzXA COMMIT :xidrX TrY )rb r[ r r\ r] r^ rc r r r Údo_commit_twophaseá s
|
ÿÿz0MySQLDialect_mariadbconnector.do_commit_twophase)TF)TF)"r r r ZdriverZsupports_statement_cacheZsupports_unicode_statementsÚencodingZconvert_unicoderI Z supports_sane_multi_rowcountZsupports_native_decimalZdefault_paramstyler Zexecution_ctx_clsr Zstatement_compilerZ supports_server_side_cursorsr Zmemoized_propertyr* r/ Ú classmethodr8 r9 rM rR rS rU rV r` rb rd re Ú __classcell__r r r4 r r @ s>
|
|
% ÿ
|
ÿr )Ú__doc__r( Úbaser r r Ú r r r0 r r r Údialectr r r r Ú<module>
|
s .
|
