Current File : /usr/lib64/python3.6/site-packages/MySQLdb/__pycache__//connections.cpython-36.pyc
3
���]1 � @ s� d Z ddlZddlZddlmZmZ ddlmZmZ ddl m
Z
m Z m Z m
Z
mZmZmZmZmZmZ ddddd d
�Zejd �Zd d
� ZG dd� dej�ZdS )a
This module implements connections for MySQLdb. Presently there is
only one class: Connection. Others are unlikely. However, you might
want to make your own subclasses. In most cases, you will probably
override Connection.default_cursor with a non-standard Cursor class.
� N)�cursors�_mysql)�unicode�PY2)
�Warning�Error�InterfaceError� DataError�
DatabaseError�OperationalError�IntegrityError�
InternalError�NotSupportedError�ProgrammingError�utf8�cp1252�koi8_rZkoi8_u)Zutf8mb4Zutf8mb3�latin1Zkoi8rZkoi8uz^(\d+)c C s t j| �}|r t|jd��S dS )z�Returns the leading numeric part of a string.
>>> numeric_part("20-alpha")
20
>>> numeric_part("foo")
>>> numeric_part("16b")
16
� N)�re_numeric_part�match�int�group)�s�m� r �#/usr/lib64/python3.6/connections.py� numeric_part s
r c s� e Zd ZdZejZ� fdd�Zdd� Zd dd�Z d d
� Z
d d � Z d
d� Z dd� Z
dd� Zeejd�sldd� Z� fdd�Zdd� Zdd� ZeZeZeZeZeZeZe Z e Z e Z e Z � Z S ) �
Connectionz MySQL Database Connection Objectc s� ddl m}m} ddlm}m} ddlm} |j� }d|krJ|j d�|d< d|kr`|j d�|d< d |krr|d } n|} i }
xB| j
� D ]6\} } t | t �r�t | t
�r�| d
d
� |
| < q�| |
| < q�W |
|d < |j d | j�}
|jd d
�}|s�t r�d}nd}|j d|�}|j dd
�}|j dd�| _|jdd�}tdd� tj� jd�d
d� D ��}|d!k�r^||jO }|d"k�rr||jO }||d< |j dd�}tt| �j||� |
| _t d d� | j
� D ��| _ t | j t < td d� | j � jd�d
d� D ��| _ d | _!|| �� d#� fd d � }|�s| j"� }| j#|� |�r*| j$|� |�rrx4|j%|j&|j'|j(|j)|j*|j+fD ]}|| j,|< �qRW t-| j,|j.< || j t-< | j/|j0@ | _1| j1�r�|d
k �r�| j2|� g | _3d
S )$a�
Create a connection to the database. It is strongly recommended
that you only use keyword parameters. Consult the MySQL C API
documentation for more information.
:param str host: host to connect
:param str user: user to connect as
:param str password: password to use
:param str passwd: alias of password, for backward compatibility
:param str database: database to use
:param str db: alias of database, for backward compatibility
:param int port: TCP/IP port to connect to
:param str unix_socket: location of unix_socket to use
:param dict conv: conversion dictionary, see MySQLdb.converters
:param int connect_timeout:
number of seconds to wait before the connection attempt fails.
:param bool compress: if set, compression is enabled
:param str named_pipe: if set, a named pipe is used to connect (Windows only)
:param str init_command:
command which is run once the connection is created
:param str read_default_file:
file from which default client values are read
:param str read_default_group:
configuration group to use from the default file
:param type cursorclass:
class object, used to create cursors (keyword only)
:param bool use_unicode:
If True, text-like columns are returned as unicode objects
using the connection's character set. Otherwise, text-like
columns are returned as bytes. Unicode objects will always
be encoded to the connection's character set regardless of
this setting.
Default to False on Python 2 and True on Python 3
so that you can always get python `str` object by default.
:param str charset:
If supplied, the connection character set will be changed
to this character set.
On Python 2, this option changes default value of `use_unicode`
option from False to True.
:param str auth_plugin:
If supplied, the connection default authentication plugin will be
changed to this value. Example values:
`mysql_native_password` or `caching_sha2_password`
:param str sql_mode:
If supplied, the session SQL mode will be changed to this
setting.
For more details and legal values, see the MySQL documentation.
:param int client_flag:
flags to use or 0 (see MySQL docs or constants/CLIENTS.py)
:param dict ssl:
dictionary or mapping contains SSL connection parameters;
see the MySQL documentation for more details
(mysql_ssl_set()). If this is set, and the client does not
support SSL, NotSupportedError will be raised.
:param bool local_infile:
enables LOAD LOCAL INFILE; zero disables
:param bool autocommit:
If False (default), autocommit is disabled.
If True, autocommit is enabled.
If None, autocommit isn't set and server default is used.
:param bool binary_prefix:
If set, the '_binary' prefix will be used for raw byte query
arguments (e.g. Binary). This is disabled by default.
There are a number of undocumented, non-standard methods. See the
documentation for the MySQL C API for some hints on what they do.
r )�CLIENT�
FIELD_TYPE)� conversions�
_bytes_or_str)�proxyZdatabase�dbZpasswordZpasswd�convN� cursorclass�charset� TF� use_unicode�sql_modeZ
binary_prefix� client_flagc S s g | ] }t |��qS r )r )�.0�nr r r �
<listcomp>� s z'Connection.__init__.<locals>.<listcomp>�.� � r � �
autocommitc S s$ g | ] \}}t |�tk r||f�qS r )�typer )r, �k�vr r r r. � s c S s g | ] }t |��qS r )r )r, r- r r r r. � s �asciic s � j | j� j��S )N)�string_literal�encode�encoding)�uZdummy)r$ r r �unicode_literal� s z,Connection.__init__.<locals>.unicode_literal)r1 r )r2 r )N)4ZMySQLdb.constantsr r ZMySQLdb.convertersr! r" �weakrefr# �copy�pop�items�
isinstancer �list�default_cursor�getr �_binary_prefix�tupler Zget_client_info�splitZMULTI_STATEMENTSZ
MULTI_RESULTS�superr �__init__r& �dict�encoders�bytesZget_server_info�_server_versionr: �character_set_name�set_character_set� set_sql_mode�STRINGZ
VAR_STRINGZVARCHARZ TINY_BLOBZ MEDIUM_BLOBZ LONG_BLOBZBLOBZ converterr ZJSONZserver_capabilitiesZ TRANSACTIONSZ_transactionalr3 Zmessages)�self�args�kwargsr r r! r" r# Zkwargs2r% Zconv2r5 r6 r& r' r) r* r+ Zclient_versionr3 r< �t)� __class__)r$ r rI 2 sr Q
$
&
zConnection.__init__c C s& t |�}| j� |kr"tjj| |� d S )N)�boolZget_autocommitr �
connectionr3 )rR Zonr r r r3 � s zConnection.autocommitNc C s |p| j | �S )z�
Create a cursor on which queries may be performed. The
optional cursorclass parameter is used to create the
Cursor. By default, self.cursorclass=cursors.Cursor is
used.
)r& )rR r& r r r �cursor� s zConnection.cursorc C s$ t |t�rt|�}tjj| |� d S )N)rA � bytearrayrL r rX �query)rR r[ r r r r[ � s
zConnection.queryc C s. t |ttf�st�| j|�}| jr*d| S |S )Ns _binary)rA rL rZ �AssertionErrorr8 rE )rR Zbs�xr r r �_bytes_literal� s
zConnection._bytes_literalc C s ddj t| j|�� S )Ns (%s)� ,)�join�map�literal)rR rU r r r �_tuple_literal� s zConnection._tuple_literalc C s� t |t�r | j|j| j��}nzt |t�r4| j|�}ndt |t�rZtrN| j|�}q�| j|�}n>t |t t
f�rt| j |�}n$| j || j
�}t |t�r�|j| j�}t |t�s�t�|S )a If o is a single object, returns an SQL literal as a string.
If o is a non-string sequence, the items of the sequence are
converted and returned as a sequence.
Non-standard. For internal use; do not use this in your
applications.
)rA r r8 r9 r: rZ r^ rL r rF rB rc �escaperK r\ )rR �or r r r rb � s
zConnection.literalc C s | j d� dS )ziExplicitly begin a connection.
This method is not used when autocommit=False (default).
s BEGINN)r[ )rR r r r �begin s zConnection.begin�
warning_countc C s$ | j � }|r t|j� d �S dS dS )zpReturn the number of warnings generated from the
last query. This is derived from the info() method.r r N���)�infor rG )rR ri r r r rg s zConnection.warning_countc st t j||�}| j� |krjytt| �j|� W n< tk
rh | jdk rNtd��| j d| � | j
� Y nX || _ dS )z�Set the connection character set to charset. The character
set can only be changed in MySQL-4.1 and newer. If you try
to change the character set from the current value in an
older version, NotSupportedError will be raised.r1 r z server is too old to set charsetz SET NAMES %sN)r1 r ) �_charset_to_encodingrD rN rH r rO �AttributeErrorrM r r[ � store_resultr: )rR r' Z
py_charset)rV r r rO ' s
z Connection.set_character_setc C s, | j dk rtd��| jd| � | j� dS )zNSet the connection sql_mode. See MySQL documentation for
legal values.r1 r z!server is too old to set sql_modezSET SESSION sql_mode='%s'N)r1 r )rM r r[ rl )rR r* r r r rP 7 s
zConnection.set_sql_modec C s. | j dk rf S | jd� | j� }|jd�}|S )z�Return detailed information about warnings as a
sequence of tuples of (Level, Code, Message). This
is only supported in MySQL-4.1 and up. If your server
is an earlier version, an empty sequence is returned.r1 r z
SHOW WARNINGSr )r1 r )rM r[ rl Z fetch_row)rR �r�warningsr r r �
show_warnings? s
zConnection.show_warnings)N)!�__name__�
__module__� __qualname__�__doc__r ZCursorrC rI r3 rY r[ r^ rc rb rf �hasattrr rX rg rO rP ro r r r r
r r r r
r r �
__classcell__r r )rV r r - s4 ,
r )rs �re�sysZMySQLdbr r ZMySQLdb.compatr r ZMySQLdb._exceptionsr r r r r
r r r
r r rj �compiler r rX r r r r r �<module> s 0
