U
|
¸ý°dê& ã @ s d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ d d
|
lm Z d d lm
|
Z
|
G d d d eZ G dd deZ G dd deZ e ZdS )a
|
|
.. dialect:: mysql+mysqldb
|
:name: mysqlclient (maintained fork of MySQL-Python)
|
:dbapi: mysqldb
|
:connectstring: mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname>
|
:url: https://pypi.org/project/mysqlclient/
|
|
Driver Status
|
-------------
|
|
The mysqlclient DBAPI is a maintained fork of the
|
`MySQL-Python <https://sourceforge.net/projects/mysql-python>`_ DBAPI
|
that is no longer maintained. `mysqlclient`_ supports Python 2 and Python 3
|
and is very stable.
|
|
.. _mysqlclient: https://github.com/PyMySQL/mysqlclient-python
|
|
.. _mysqldb_unicode:
|
|
Unicode
|
-------
|
|
Please see :ref:`mysql_unicode` for current recommendations on unicode
|
handling.
|
|
.. _mysqldb_ssl:
|
|
SSL Connections
|
----------------
|
|
The mysqlclient and PyMySQL DBAPIs accept an additional dictionary under the
|
key "ssl", which may be specified using the
|
:paramref:`_sa.create_engine.connect_args` dictionary::
|
|
engine = create_engine(
|
"mysql+mysqldb://scott:tiger@192.168.0.134/test",
|
connect_args={
|
"ssl": {
|
"ca": "/home/gord/client-ssl/ca.pem",
|
"cert": "/home/gord/client-ssl/client-cert.pem",
|
"key": "/home/gord/client-ssl/client-key.pem"
|
}
|
}
|
)
|
|
For convenience, the following keys may also be specified inline within the URL
|
where they will be interpreted into the "ssl" dictionary automatically:
|
"ssl_ca", "ssl_cert", "ssl_key", "ssl_capath", "ssl_cipher",
|
"ssl_check_hostname". An example is as follows::
|
|
connection_uri = (
|
"mysql+mysqldb://scott:tiger@192.168.0.134/test"
|
"?ssl_ca=/home/gord/client-ssl/ca.pem"
|
"&ssl_cert=/home/gord/client-ssl/client-cert.pem"
|
"&ssl_key=/home/gord/client-ssl/client-key.pem"
|
)
|
|
.. seealso::
|
|
:ref:`pymysql_ssl` in the PyMySQL dialect
|
|
|
Using MySQLdb with Google Cloud SQL
|
-----------------------------------
|
|
Google Cloud SQL now recommends use of the MySQLdb dialect. Connect
|
using a URL like the following::
|
|
mysql+mysqldb://root@/<dbname>?unix_socket=/cloudsql/<projectid>:<instancename>
|
|
Server Side Cursors
|
-------------------
|
|
The mysqldb dialect supports server-side cursors. See :ref:`mysql_ss_cursors`.
|
|
é Né )Ú MySQLCompiler)Ú MySQLDialect)ÚMySQLExecutionContext)ÚMySQLIdentifierPreparer)ÚTEXTé )Úsql)Úutilc @ s e Zd Zedd ZdS )Ú MySQLExecutionContext_mysqldbc C s t | dr| jS | jjS d S )NÚ _rowcount)Úhasattrr ÚcursorÚrowcount)Úself© r úXd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/dialects/mysql/mysqldb.pyr d s
|
z&MySQLExecutionContext_mysqldb.rowcountN)Ú__name__Ú
|
__module__Ú __qualname__Úpropertyr r r r r r c s r c @ s e Zd ZdS )ÚMySQLCompiler_mysqldbN)r r r r r r r r l s r c sÈ e Zd ZdZdZdZdZdZdZdZ e
|
Z e Z eZ fddZdd Zejjdd Zed
|
d Z fd d Zdd Zd!ddZ fddZd"ddZ dd Z dd Z dd Z d d Z fd d Z! Z"S )#ÚMySQLDialect_mysqldbZmysqldbTÚformatc s< t jf | | jd k r2t| jdr2| | jj¡nd| _d S )NÚ __version__©r r r )ÚsuperÚ__init__Údbapir Ú_parse_dbapi_versionr Z_mysql_dbapi_version)r Úkwargs©Ú __class__r r r ~ s ÿ
|
ÿýz MySQLDialect_mysqldb.__init__c C s4 t d|¡}|r,tdd | ddd¡D S dS d S )Nz(\d+)\.(\d+)(?:\.(\d+))?c s s | ]}|d k rt |V qd S ©N)Úint)Ú.0Úxr r r Ú <genexpr> s z<MySQLDialect_mysqldb._parse_dbapi_version.<locals>.<genexpr>r é r r )ÚreÚmatchÚtupleÚgroup)r ÚversionÚmr r r r s z)MySQLDialect_mysqldb._parse_dbapi_versionc C s8 zt dj}|j| _W dS ttfk
|
r2 Y dS X d S )NzMySQLdb.cursorsTF)Ú
|
__import__ÚcursorsZSSCursorZ _sscursorÚ ImportErrorÚAttributeError)r r0 r r r Ú supports_server_side_cursors s
|
z1MySQLDialect_mysqldb.supports_server_side_cursorsc C s t dS )NZMySQLdb)r/ )Úclsr r r Ú import_dbapi s z!MySQLDialect_mysqldb.import_dbapic s t ¡ fdd}|S )Nc sB d k r | | ¡ }|d k r>| ¡ }| d| ¡ | ¡ d S )Nz SET NAMES %s)Úcharacter_set_namer ÚexecuteÚclose)ÚconnÚ charset_namer ©Zsuper_r r Ú
|
on_connect s z3MySQLDialect_mysqldb.on_connect.<locals>.on_connect)r r< )r r< r! r; r r< s
|
z MySQLDialect_mysqldb.on_connectc C s | d¡ dS )NFT)Zping©r Údbapi_connectionr r r Údo_pingª s
|
z MySQLDialect_mysqldb.do_pingNc C s | ||¡}|d k r||_d S r# )Z executemanyr )r r Z statementÚ
|
parametersÚcontextr r r r Údo_executemany® s z#MySQLDialect_mysqldb.do_executemanyc sn | d| j d¡| j d¡f ¡ ¡ }| jdko2|}|r\t t t d¡t dd¡d¡g}ng }t
|
||¡S ) Nz:show collation where %s = 'utf8mb4' and %s = 'utf8mb4_bin'ÚCharsetZ Collation)é z'test collated returns'Zutf8mb4)ÚcharsetZ utf8mb4_bin) Zexec_driver_sqlZidentifier_preparerÚquoteZscalarZserver_version_infor ZcollateÚcastZliteral_columnr r Ú_check_unicode_returns)r Ú
|
connectionZ collationZhas_utf8mb4_binZadditional_testsr! r r rH ³ s&
|
|
þÿÿþûÿ
|
z+MySQLDialect_mysqldb._check_unicode_returnsc
|
C sT |d krt dddd}|jf |}| |j¡ t |dt¡ t |dt¡ t |dt¡ t |dt¡ t |d t¡ t |d
|
t¡ t |d t¡ t |d t¡ i }d tfdtfdtfdtfdtfdtfg}|D ]@\}}||krÎ|| ||dd
< t ||dd
|¡ ||= qÎ|r ||d< | d d¡}|
|
¡ } | d k rL|| O }||d < g |gS )NÚdbÚuserÚpasswd)ZdatabaseÚusernameÚpasswordÚcompressÚconnect_timeoutÚ read_timeoutZ write_timeoutÚ client_flagZ local_infileZ use_unicoderE Zssl_caZssl_keyZssl_certZ
|
ssl_capathZ
|
ssl_cipherZssl_check_hostnameé Ússlr ) ÚdictZtranslate_connect_argsÚupdateÚqueryr
|
Zcoerce_kw_typeÚboolr$ ÚstrÚgetÚ_found_rows_client_flag)
|
r ÚurlZ_translate_argsÚoptsrT ÚkeysÚkeyZkw_typerR Zclient_flag_found_rowsr r r Úcreate_connect_argsÎ sJ ÿ ú
|
z(MySQLDialect_mysqldb.create_connect_argsc C sN | j d k rFzt| j jd jj}W n ttfk
|
r< Y d S X |jS nd S d S )Nz.constants.CLIENT)r r/ r Ú constantsZCLIENTr2 r1 Z
|
FOUND_ROWS)r Z CLIENT_FLAGSr r r r[ s
|
|
ÿ z,MySQLDialect_mysqldb._found_rows_client_flagc C s
|
|j d S )Nr )Úargs)r Ú exceptionr r r Ú_extract_error_code s z(MySQLDialect_mysqldb._extract_error_codec C s8 z |j j}W n tk
|
r, t d¡ Y dS X | S dS )z:Sniff out the character set in use for connection results.zNo 'character_set_name' can be detected with this MySQL-Python version; please upgrade to a recent version of MySQL-Python. Assuming latin1.Úlatin1N)rI r6 r2 r
|
Úwarn)r rI Z cset_namer r r Ú_detect_charset s ÿz$MySQLDialect_mysqldb._detect_charsetc C s dS )N)Z SERIALIZABLEzREAD UNCOMMITTEDzREAD COMMITTEDzREPEATABLE READÚ
|
AUTOCOMMITr r= r r r Úget_isolation_level_values# s z/MySQLDialect_mysqldb.get_isolation_level_valuesc s0 |dkr| d¡ n| d¡ t ||¡ d S )Nrh TF)Z
|
autocommitr Úset_isolation_level)r r> Úlevelr! r r rj , s
|
z(MySQLDialect_mysqldb.set_isolation_level)N)N)#r r r ZdriverZsupports_statement_cacheZsupports_unicode_statementsZsupports_sane_rowcountZ supports_sane_multi_rowcountZsupports_native_decimalZdefault_paramstyler Zexecution_ctx_clsr Zstatement_compilerr Úpreparerr r r
|
Z langhelpersZmemoized_propertyr3 Ú classmethodr5 r< r? rB rH r` r[ rd rg ri rj Ú __classcell__r r r! r r p s4
|
|
|
|
3 r )Ú__doc__r) Úbaser r r r r Ú r r
|
r r r Údialectr r r r Ú<module>
|
s N E
|
