관리-도구
편집 파일: __init__.cpython-38.pyc
U )�e# � . @ s� d Z ddlZddlmZ ddlmZmZmZmZ ddl m Z m Z ddl m Z mZmZmZ ddlmZ dd lmZmZmZmZmZmZmZmZm Z m Z dd l m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z% dd l&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9 d d � Z:dd� Z;dd� Z<dd� Z=dd� Z>dd� Z?ddddddd d d d d d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d<d=d>d?d@dAdBdCg.Z@dS )Dz$MySQL X DevAPI Python implementation� N� )� constants)� STRING_TYPES�urlparse�unquote� parse_qsl)�XSession� NodeSession)�Schema� Collection�Table�View)�DbDoc) �Error�Warning�InterfaceError� DatabaseError�NotSupportedError� DataError�IntegrityError�ProgrammingError�OperationalError� InternalError)�ColumnMetaData�Row�Result�BufferingResult� RowResult� SqlResult� ColumnType)� Statement�FilterableStatement� SqlStatement� FindStatement� AddStatement�RemoveStatement�ModifyStatement�SelectStatement�InsertStatement�DeleteStatement�UpdateStatement� CreateCollectionIndexStatement� DropCollectionIndexStatement�CreateViewStatement�AlterViewStatement� ColumnDef�GeneratedColumnDef� ForeignKeyDef�Exprc C s� t �d�}t �d�}t �d�}g }|�| �rB| �d�} |�| �} n td�| ��}|j|jd�S | r�i }| � d��� }|�|�}|r�|� d��� }t |� d ��|d < td�|��}|js�t d �|���|j|d < |j|d < |� |� q^d |iS )z�Parses a list of host, port pairs Args: address_list: String containing a list of routers or just router Returns: Returns a dict with parsed values of host, port and priority if specified. z^\[(?![^,]*\]).*]$z,(?![^\(\)]*\))zJ^\(address\s*=\s*(?P<address>.+)\s*,\s*priority\s*=\s*(?P<priority>\d+)\)$z[]z//{0})�host�portr �address�priorityzInvalid address: {0}r3 r4 �routers)�re�compile�match�strip�splitr �format�hostnamer4 �pop�group�intr �append)Z address_listZis_listZhst_listZpri_addrr7 r: �routerr5 � rD �d/opt/hc_python/lib64/python3.8/site-packages/../../../lib/python3.8/site-packages/mysqlx/__init__.py�_parse_address_list1 s2 � rF c C sT ddi}d� | �d�rdnd| �} | �dd�\}}|�d�ddd � \}}|�d �ddd � \}}|�d �}||d� �d �d kr�|dkr�|�d d�\}|d< |�d�}|r�|r�d|kr�td� | ���|�dd�\|d< |d< |�d�r�t |�|d< n$|�d��r td��n|� t |�� t t |d���� D ]"\}} t | �d���pFd||< �q,|S )a Parses the connection string and returns a dictionary with the connection settings. Args: uri: mysqlx URI scheme to connect to a MySQL server/farm. Returns: Returns a dict with parsed values of credentials and address of the MySQL server/farm. Zschema� z{0}{1}z mysqlx://z://r �@N� �?�/�)���r z()�:zMalformed URI '{0}'�user�password)rK z..�.�socketz\.z Windows Pipe is not supported.T)r= � startswithr< � partition�rfind�find�rsplitr; r r �updaterF �dictr �items) �uri�settings�scheme�temp�userinfor3 Z query_str�pos�opt�valrD rD rE �_parse_connection_uri\ s. � rc c C s� d| krB| d rBzt | d �| d< W n tk r@ td��Y nX d| kr�| d r�zt | d �| d< W q� tk r� td��Y q�X nd| kr�d| d< dS )a Validates the settings to be passed to a Session object the port values are converted to int if specified or set to 33060 otherwise. The priority values for each router is converted to int if specified. Args: settings: dict containing connection settings. r6 zInvalid priorityr4 z Invalid portr3 i$� N)rA � NameErrorr )r\ rD rD rE �_validate_settings� s re c O s� i }| rBt | d t�r$t| d �}qPt | d t�rP|�| d � n|rP|�|� |s\td��d|kr~|�d�D ] }t|� qnnt|� |S )a� Parses the connection string and returns a dictionary with the connection settings. Args: *args: Variable length argument list with the connection data used to connect to the database. It can be a dictionary or a connection string. **kwargs: Arbitrary keyword arguments with connection data used to connect to the database. Returns: mysqlx.XSession: XSession object. r zSettings not providedr7 )� isinstancer rc rY rX r �getre )�args�kwargsr\ rC rD rD rE �_get_connection_settings� s rj c O s t | |�}t|�S )a� Creates a XSession instance using the provided connection data. Args: *args: Variable length argument list with the connection data used to connect to the database. It can be a dictionary or a connection string. **kwargs: Arbitrary keyword arguments with connection data used to connect to the database. Returns: mysqlx.XSession: XSession object. )rj r �rh ri r\ rD rD rE � get_session� s rl c O s" t | |�}d|krtd��t|�S )a� Creates a NodeSession instance using the provided connection data. Args: *args: Variable length argument list with the connection data used to connect to the database. It can be a dictionary or a connection string. **kwargs: Arbitrary keyword arguments with connection data used to connect to the database. Returns: mysqlx.XSession: XSession object. r7 z2NodeSession expects only one pair of host and port)rj r r rk rD rD rE �get_node_session� s rm r r r r r r r r r r r r r r r r r r r r r r r r r r r! r" r# r$ r% r& r' r( r) r* r+ r, r- r. r/ r0 r1 r2 )A�__doc__r8 rG r �compatr r r r � connectionr r Zcrudr r r r Zdbdocr �errorsr r r r r r r r r r �resultr r r r r r r Z statementr r! r" r# r$ r% r& r' r( r) r* r+ r, r- r. r/ r0 r1 r2 rF rc re rj rl rm �__all__rD rD rD rE �<module> s| 0$T +&" �