Edit File: mysqldb.cpython-37.pyc
B ��4] � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ d d lm Z d d lm Z G d d � d e�Z G dd� de�Z G dd� de�Z G dd� de�ZeZdS )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 <http://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. 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 | d�r| jS | jjS d S )N� _rowcount)�hasattrr �cursor�rowcount)�self� r �T/opt/alt/python37/lib64/python3.7/site-packages/sqlalchemy/dialects/mysql/mysqldb.pyr > s z&MySQLExecutionContext_mysqldb.rowcountN)�__name__� __module__� __qualname__�propertyr r r r r r = s r c @ s e Zd ZdS )�MySQLCompiler_mysqldbN)r r r r r r r r F s r c @ s e Zd ZdS )� MySQLIdentifierPreparer_mysqldbN)r r r r r r r r J s r c s� e Zd ZdZdZdZdZdZdZe Z e Z e Zd!� fdd� Zdd� Zejjd d � �Zed d � �Zd d� Zd"dd�Z� fdd�Zdd� Zdd� Zdd� Z e ddd d d g�Z � fd d �Z � Z S )#�MySQLDialect_mysqldbZmysqldbT�formatFc sF t t| �jf |� || _| jd k r<t| jd�r<| �| jj�nd| _d S )N� __version__)r r r ) �superr �__init__�server_side_cursors�dbapir �_parse_dbapi_versionr Z_mysql_dbapi_version)r 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>g s z<MySQLDialect_mysqldb._parse_dbapi_version.<locals>.<genexpr>r � r )r r r )�re�match�tuple�group)r �version�mr r r r d s z)MySQLDialect_mysqldb._parse_dbapi_versionc C s4 yt d�j}|j| _dS ttfk r. dS X d S )NzMySQLdb.cursorsTF)� __import__�cursorsZSSCursorZ _sscursor� ImportError�AttributeError)r r/ r r r � supports_server_side_cursorsk s z1MySQLDialect_mysqldb.supports_server_side_cursorsc C s t d�S )NZMySQLdb)r. )�clsr r r r t s zMySQLDialect_mysqldb.dbapic C sR y|� d� W n: | jjk rH } z| �||d �r6dS � W d d }~X Y nX dS d S )NFT)Zpingr �ErrorZ is_disconnect)r Zdbapi_connection�errr r r �do_pingx s z MySQLDialect_mysqldb.do_pingNc C s |� ||�}|d k r||_d S )N)Z executemanyr )r r � statement� parameters�contextr r r r �do_executemany� s z#MySQLDialect_mysqldb.do_executemanyc sj | j dko*|�d| j�d�| j�d�f �}|rTt�t�t�d�tdd��d�g}ng }t t | �� ||�S ) N)� z:show collation where %s = 'utf8mb4' and %s = 'utf8mb4_bin'�CharsetZ Collationz'test collated returns'Zutf8mb4)�charsetZ utf8mb4_bin) Zserver_version_infoZscalarZidentifier_preparer�quoter �collate�castZliteral_columnr r r �_check_unicode_returns)r � connectionZhas_utf8mb4_bin�additional_tests)r" r r rA � s z+MySQLDialect_mysqldb._check_unicode_returnsc C s\ |j dddd�}|�|j� t�|dt� t�|dt� t�|dt� t�|dt� t�|d t� t�|d t� t�|d t� t�|d t� i }d ddddg}xD|D ]<}||kr�|| ||dd � < t�||dd � t� ||= q�W |r�||d< |�d d�}| j d k �rTy"t | j j d �j j }||jO }W n ttfk �rJ d| _Y nX ||d < g |gS )NZdb�user�passwd)Zdatabase�username�password�compressZconnect_timeoutZ read_timeoutZ write_timeout� client_flagZ local_infileZ use_unicoder= Zssl_caZssl_keyZssl_certZ ssl_capathZ ssl_cipher� �sslr z.constants.CLIENTF)Ztranslate_connect_args�update�queryr Zcoerce_kw_type�boolr# �str�getr r. r � constantsZCLIENTZ FOUND_ROWSr1 r0 �supports_sane_rowcount)r �url�optsrK �keys�keyrI Z CLIENT_FLAGSr r r �create_connect_args� s< z(MySQLDialect_mysqldb.create_connect_argsc C s |j d S )Nr )�args)r � exceptionr r r �_extract_error_code� s z(MySQLDialect_mysqldb._extract_error_codec C s6 y |j j}W n tk r* t�d� dS X |� S dS )z:Sniff out the character set in use for connection results.z�No 'character_set_name' can be detected with this MySQL-Python version; please upgrade to a recent version of MySQL-Python. Assuming latin1.�latin1N)rB Zcharacter_set_namer1 r �warn)r rB Z cset_namer r r �_detect_charset� s z$MySQLDialect_mysqldb._detect_charsetZ SERIALIZABLEzREAD UNCOMMITTEDzREAD COMMITTEDzREPEATABLE READ� AUTOCOMMITc s4 |dkr|� d� n |� d� tt| ��||� d S )Nr^ TF)Z autocommitr r �_set_isolation_level)r rB �level)r" r r r_ � s z)MySQLDialect_mysqldb._set_isolation_level)F)N)!r r r ZdriverZsupports_unicode_statementsrR Z supports_sane_multi_rowcountZsupports_native_decimalZdefault_paramstyler Zexecution_ctx_clsr Zstatement_compilerr Zpreparerr r r Z langhelpersZmemoized_propertyr2 � classmethodr r6 r: rA rW rZ r] �setZ_isolation_lookupr_ � __classcell__r r )r" r r N s4 -r )�__doc__r( �baser r r r r � r r r r r r Zdialectr r r r �<module>0 s /