관리-도구
편집 파일: mariadbconnector.cpython-38.pyc
U -?�fx! � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ dd l m Z dd l m Z dd l m Z d Z G d d� de je j �ZG dd� de�ZG dd� de�ZG dd� de�ZeZdS )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)�UUID� )� MySQLCompiler)� MySQLDialect)�MySQLExecutionContext� )�sql)�util)�sqltypes)r r r c @ s e Zd Zdd� ZdS )� _MariaDBUUIDc C s" | j rdd� }|S dd� }|S d S )Nc S s( | d k r$t | d�r | �d�} t| �} | S �N�decode�ascii)�hasattrr � _python_UUID��value� r �Z/opt/hc_python/lib64/python3.8/site-packages/sqlalchemy/dialects/mysql/mariadbconnector.py�process5 s z._MariaDBUUID.result_processor.<locals>.processc S s, | d k r(t | d�r | �d�} tt| ��} | S r )r r �strr r r r r r ? s )Zas_uuid)�self�dialectZcoltyper r r r �result_processor2 s z _MariaDBUUID.result_processorN)�__name__� __module__� __qualname__r r r r r r . s r c s8 e Zd ZdZdd� Zdd� Z� fdd�Zdd � Z� ZS ) �&MySQLExecutionContext_mariadbconnectorNc C s | j jdd�S )NF��buffered�Z_dbapi_connection�cursor�r r r r �create_server_side_cursorL s z@MySQLExecutionContext_mariadbconnector.create_server_side_cursorc C s | j jdd�S )NTr r r" r r r �create_default_cursorO s z<MySQLExecutionContext_mariadbconnector.create_default_cursorc s0 t � �� | jj| _| jr,| jjr,| jj| _ d S �N) �super� post_execr! ZrowcountZ _rowcountZisinsert�compiledZpostfetch_lastrowidZ lastrowid� _lastrowidr" �� __class__r r r' R s z0MySQLExecutionContext_mariadbconnector.post_execc C s | j S r% )r) r" r r r � get_lastrowidZ s z4MySQLExecutionContext_mariadbconnector.get_lastrowid) r r r r) r# r$ r' r, � __classcell__r r r* r r I 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 eZdZe�ejejei�Zejdd� �Z� fdd�Zed d � �Z � fd d �Z d d� Z dd� Z dd� Z dd� Z!� fdd�Z"dd� Z#dd� Z$d d d �Z%d!d d �Z&� Z'S )"� MySQLDialect_mariadbconnectorZmariadbconnectorT�utf8mb4�qmarkc C s8 | j r0t| j d�r0tdd� 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 r8 r8 )�dbapir �tuple�re�findallr2 r" r r r �_dbapi_version� s ��� z,MySQLDialect_mariadbconnector._dbapi_versionc sH t � jf |� d| _| jd k rD| jtk rDtdd�dd� tD �� ��d S )Nr1 z?The minimum required version for MariaDB Connector/Python is %s�.c s s | ]}t |�V qd S r% )r r4 r r r � <genexpr>� s z9MySQLDialect_mariadbconnector.__init__.<locals>.<genexpr>)r& �__init__Z paramstyler9 r= �mariadb_cpy_minimum_version�NotImplementedError�join)r �kwargsr* r r r@ � s ��z&MySQLDialect_mariadbconnector.__init__c C s t d�S )NZmariadb)� __import__)�clsr r r � import_dbapi� s z*MySQLDialect_mariadbconnector.import_dbapic sF t � �|||�rdS t|| jj�r>t|��� }d|kp<d|kS dS d S )NTz not connectedz isn't validF)r& � is_disconnect� isinstancer9 �Errorr �lower)r �e� connectionr! Zstr_er* r r rH � 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_typer3 �bool�getr9 rE r � constantsZCLIENTZ FOUND_ROWS�AttributeError� ImportError�supports_sane_rowcount)r �url�optsZ int_paramsZ bool_params�keyrP 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 )Nr0 r )r rM 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 )Nrc TF)Z autocommitr& �set_isolation_level)r rM �levelr* r r re � 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 rM rg 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 :xidrg Trh zXA PREPARE :xidri rn 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 )Nrp rg Trh zXA ROLLBACK :xidri �r rM rg 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 :xidrg Trh )rq rj r rk rl rm rr r r r �do_commit_twophase s ��z0MySQLDialect_mariadbconnector.do_commit_twophase)TF)TF)(r r r ZdriverZsupports_statement_cacheZsupports_unicode_statements�encodingZconvert_unicoderX Z supports_sane_multi_rowcountZsupports_native_decimalZdefault_paramstyler Zexecution_ctx_clsr. Zstatement_compilerZ supports_server_side_cursorsr Z update_copyr Zcolspecsr ZUuidr Zmemoized_propertyr= r@ � classmethodrG rH r\ ra rb rd re ro rq rs rt r- r r r* r r/ b sF � % � �r/ )�__doc__r; �uuidr r �baser r r � r r r rA Z _UUID_RETURNr r r. r/ r r r r r �<module> s 2