)_*X d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ d d
lm Z d d lm
Z
G d d
e Z G d de Z G d de Z
G d de Z G d de ZeZdS )a
.. dialect:: mysql+mysqlconnector
:name: MySQL Connector/Python
:dbapi: myconnpy
:connectstring: mysql+mysqlconnector://:@[:]/
: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 e Zd Zd ZdS )$MySQLExecutionContext_mysqlconnectorc | j j S N)cursor lastrowidselfs |/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/sqlalchemy/dialects/mysql/mysqlconnector.py
get_lastrowidz2MySQLExecutionContext_mysqlconnector.get_lastrowid$ s
{$$ N)__name__
__module__ __qualname__r r r r
r
# s# % % % % %r r
c e Zd Zd Zd Zd ZdS ) MySQLCompiler_mysqlconnectorc | j j r* | j |j fi |dz | j |j fi |z S | j |j fi |dz | j |j fi |z S )Nz %% z % )dialect _mysqlconnector_double_percentsprocessleftright)r binaryoperatorkws r visit_mod_binaryz-MySQLCompiler_mysqlconnector.visit_mod_binary) s < 7 V[//B// $,v|22r223
V[//B// $,v|22r223
r c J | j j r| dd S |S N%z%%r r replacer texts r post_process_textz.MySQLCompiler_mysqlconnector.post_process_text7 ( < 7 <<T** *Kr c J | j j r| dd S |S r( r* r, s r escape_literal_columnz2MySQLCompiler_mysqlconnector.escape_literal_column= r/ r N)r r r r& r. r1 r r r r r ( sA r r c J e Zd Zed Zej d Zd ZdS )&MySQLIdentifierPreparer_mysqlconnectorc | j j S r )r r r s r _double_percentsz7MySQLIdentifierPreparer_mysqlconnector._double_percentsE s
|;;r c d S r r r values r r5 z7MySQLIdentifierPreparer_mysqlconnector._double_percentsI s r c | | j | j }| j j r| dd S |S r( )r+ escape_quoteescape_to_quoter r r7 s r _escape_identifierz9MySQLIdentifierPreparer_mysqlconnector._escape_identifierM sA
d /1EFF < 7 ==d++ +Lr N)r r r propertyr5 setterr< r r r r3 r3 D s[
< < X<
r r3 c e Zd Zd ZdS ) _myconnpyBITc dS )z0MySQL-connector already converts mysql bits, so.Nr )r r coltypes r result_processorz _myconnpyBIT.result_processorV s tr N)r r r rC r r r r@ r@ U s# r r@ c V e Zd ZdZdZdZdZdZdZe Z
e Z e
Z ej ej eei Z fdZd Zed Zej d Zed Z d Z d
Z ej d Z ej d Z d
Z!d Z"d Z#ddZ$ddZ% e&g d Z' fdZ( xZ)S )MySQLDialect_mysqlconnectormysqlconnectorTformatc t t | j |i | t j | j | _ d S r )superrE __init__r
(to_conditional_unicode_processor_factorydescription_encoding_description_decoder)r argr% __class__s r rJ z$MySQLDialect_mysqlconnector.__init__n sI 9)40093E"EEE
?
#%% %%!!!r c dS )NFr r
connections r _check_unicode_descriptionz6MySQLDialect_mysqlconnector._check_unicode_descriptionw s ur c dS )Nzlatin-1r r s r rL z0MySQLDialect_mysqlconnector.description_encoding| s yr c 0 t j p
| j dk S N) r r py3k _mysqlconnector_version_infor s r supports_unicode_statementsz7MySQLDialect_mysqlconnector.supports_unicode_statements s yFD = FFr c ddl m} |S )Nr ) connector)mysqlr] )clsr] s r dbapiz!MySQLDialect_mysqlconnector.dbapi s ######r c | d dS # | j j $ r#}| ||d rY d }~dS d }~ww xY w)NFT)pingr` Error
is_disconnect)r dbapi_connectionerrs r do_pingz#MySQLDialect_mysqlconnector.do_ping ss ! !% ( ( ( 4
z !!#'7>>
uuuuu s A AAA c | d }| |j t j |dt
t j |dt
t j |dt
t j |dt
t j |dt t j |dt t j |d t
t j |d
t
t j |d t
t j |d t
t j |d
t t j |dt
t j |dt
t j |dt
t j |dt
t j |dt
| dd | j O ddl m
} | d| }||j
z }||d< n# t $ r Y nw xY wg |gS )Nuser)usernameallow_local_infile
autocommitbufferedcompressconnection_timeoutconnect_timeoutconsume_results
force_ipv6 get_warningspool_reset_session pool_sizeraise_on_warningsrawssl_verify_certuse_pure use_unicodeTr )
ClientFlag client_flags)translate_connect_argsupdatequeryr coerce_kw_typeboolint
setdefaultr` mysql.connector.constantsr{ get get_default
FOUND_ROWS Exception)r urloptsr{ r| s r create_connect_argsz/MySQLDialect_mysqlconnector.create_connect_args s$ ))6):: CI D"6=== D,555 D*d333 D*d333 D"6<<< D"3S999 D"3T::: D,555 D.$777 D"6=== D+s333 D"5t<<< D%... D"3T::: D*d333 D-666
D))) : !
@@@@@@ #xx"J$:$:$<$<
55 '3^$$
Dzs ?=H= =
I
I
c | j rdt | j d rQt j d| j j }|r2t d | ddd D S d S d S d S )N __version__z(\d+)\.(\d+)(?:\.(\d+))?c 3 8 K | ]}|t | V d S r )r ).0xs r zKMySQLDialect_mysqlconnector._mysqlconnector_version_info.. s( O O SVV O Or r rW r )r` hasattrrematchr tuplegroup)r ms r rZ z8MySQLDialect_mysqlconnector._mysqlconnector_version_info s : P'$*m<< P4dj6LMMA
P O OQWWQ1-=-= O O OOOO P P P P
P
Pr c 2 t j o
| j dk S rV rX r s r r z;MySQLDialect_mysqlconnector._mysqlconnector_double_percents s 9}K!BV!KKr c |j j S r )rR charsetrQ s r _detect_charsetz+MySQLDialect_mysqlconnector._detect_charset s $,,r c |j S r )errno)r exceptions r _extract_error_codez/MySQLDialect_mysqlconnector._extract_error_code s
r c d}| j j | j j f}t || r+|j |v p!dt | v pdt | v S dS )N)i i i i i i z MySQL Connection not available.z$Connection to MySQL is not availableF)r` OperationalErrorInterfaceError
isinstancer str)r erR r errnos
exceptionss r rd z)MySQLDialect_mysqlconnector.is_disconnect sk 5j14:3LM
a $ $ 6! D4A>D9SVVC
5r Nc * | S r )fetchallr rpr s r _compat_fetchallz,MySQLDialect_mysqlconnector._compat_fetchall {{}} r c * | S r )fetchoner s r _compat_fetchonez,MySQLDialect_mysqlconnector._compat_fetchone r r ) SERIALIZABLEzREAD UNCOMMITTEDzREAD COMMITTEDzREPEATABLE READ
AUTOCOMMITc |dk r d|_ d S d|_ t t | || d S )Nr TF)rl rI rE _set_isolation_level)r rR levelrO s r r z0MySQLDialect_mysqlconnector._set_isolation_level sV L $(J ! ! !$)J ! -t 4 4 I IE
r r )*r r r driversupports_unicode_bindssupports_sane_rowcount supports_sane_multi_rowcountsupports_native_decimaldefault_paramstyler
execution_ctx_clsr statement_compilerr3 preparerr update_copyr colspecsr r@ rJ rS r= rL memoized_propertyr[ classmethodr` rg r rZ r r r rd r r set_isolation_lookupr
__classcell__)rO s @r rE rE \ s
F ! !#' "!<55H t 5\7JKKH% % % % %
X
G G G [
' ' 'R
P P P
L L L- - -
r rE )__doc__r baser r r r r r
r r
r r3 r@ rE r r r r r s
' ' ' ' ' ' ) ) ) ) ) ) % % % % %+@ % % %
= 8 -D " 3 W W W W W, W W Wt &r