Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /opt/alt/python37/lib64/python3.7/site-packages/MySQLdb/__pycache__/ |
B
u9Z�Y<�_� @ s� d Z ddlZddlZddlmZ ddlmZmZ ddlm Z m
Z
m Z m Z m
Z
mZmZmZmZmZ ddlZes�ejdd� dk r�dd � ed
�D �Zd d � Znd
d � Zdd� Ze�d�Zdd� ZG dd� dej �Z dS )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)�unicode�PY2)
�Warning�Error�InterfaceError� DataError�
DatabaseError�OperationalError�IntegrityError�
InternalError�NotSupportedError�ProgrammingError� )� � c C s( g | ] }|d k rt |�n
t |d ��qS )� i � )�chr)�.0�i� r �F/opt/alt/python37/lib64/python3.7/site-packages/MySQLdb/connections.py�
<listcomp> s r � c C s | � d��t�S )N�latin1)�decode� translate�_surrogateescape_table)�sr r r �_fast_surrogateescape s r c C s | � dd�S )N�ascii�surrogateescape)r )r r r r r s c C sV ||f}|r|j �|� n | j �|� ~~ t|t�r8|�|dk rJ||��nt|��dS )a*
If cursor is not None, (errorclass, errorvalue) is appended to
cursor.messages; otherwise it is appended to
connection.messages. Then errorclass is raised with errorvalue as
the value.
You can override this with your own error handler by assigning it
to the instance.
N)�messages�append�
isinstance�
BaseException� Exception)�
connection�cursorZ
errorclassZ
errorvalue�errorr r r �defaulterrorhandler s
r* z^(\d+)c C s t �| �}|r t|�d��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)r �mr r r � numeric_part; s
r1 c s� e Zd ZdZejZdZ� fdd�Zdd� Z d dd�Z
d d
� Z d d � Z d
d� Z
dd� Zdd� Zeejd�spdd� Z� fdd�Zdd� Zdd� ZeZeZeZeZeZe Z e Z e Z e Z e Z e!Z"� Z#S ) �
Connectionz MySQL Database Connection ObjectNc s. ddl m}m} ddlm} ddlm} |�� }d|krF|�d�|d< d|kr\|�d�|d< d |krn|d }n|}i } xB|� � D ]6\}
} t
|
t �r�t
| t �r�| d
d
� | |
< q�| | |
< q�W | |d < |�d | j
�} |�d d
�}
|
s�ts�d}nd}|�d|�}|�dd
�}|�dd�}|�dd�}tdd� t�� �d�d
d� D ��}|dk�rV||jO }|dk�rj||jO }||d< |�dd�}|�dd
�| _tt| �j||� | | _td d� |� � D ��| _ td d� | � � �d�d
d� D ��| _ || �� � fd d �}� fd d!�}� fd"d#�}d$d%� }|� }|� | _ }|� }|� | _ }|
�sH| �!� }
| �"|
� |�rb| �#|� |�r�| j$|j% �&d
|f� | j$|j' �&d
|f� | j$|j( �&d
|f� | j$|j) �&d
|f� |�r�t�r�|n|| j t*< || j t+< n
|| j t*< || j t,< | j-|j.@ | _/| j/�r$|d
k �r$| �0|� g | _1d
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 str 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 strings. columns are returned as
normal strings. 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.
:param str charset:
If supplied, the connection character set will be changed
to this character set (MySQL-4.1 and newer). This implies
use_unicode=True.
:param str sql_mode:
If supplied, the session SQL mode will be changed to this
setting (MySQL-4.1 and newer). 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)�proxyZdatabase�db�password�passwd�convN� cursorclass�charset� TF� use_unicode�sql_mode�
binary_prefix� client_flagc S s g | ] }t |��qS r )r1 )r �nr r r r � s z'Connection.__init__.<locals>.<listcomp>�.r )� r+ )� r �
autocommit�waiterc S s$ g | ] \}}t |�tk r||f�qS r )�typer. )r �k�vr r r r � s c S s g | ] }t |��qS r )r1 )r rB r r r r � s c s d� fdd� } | S )Nc s
� � | �S )N)�string_literal)�obj�dummy)r7 r r rK � s zHConnection.__init__.<locals>._get_string_literal.<locals>.string_literal)Nr )rK )r7 r r �_get_string_literal� s z0Connection.__init__.<locals>._get_string_literalc s* t rd�� fdd� � nd�� fdd� � � S )Nc s � � | ��j��S )N)rK �encoder< )�urM )r7 �unicode_literalr r rQ � s zJConnection.__init__.<locals>._get_unicode_literal.<locals>.unicode_literalc s � � t| ���j��S )N)rK �strrO r< )rP rM )r7 rQ r r rQ � s )N)N)r r )r7 )rQ r �_get_unicode_literal� s z1Connection.__init__.<locals>._get_unicode_literalc s d� fdd� } | S )Nc s d� � | � S )Ns _binary)rK )rL rM )r7 r r �
bytes_literal� s zFConnection.__init__.<locals>._get_bytes_literal.<locals>.bytes_literal)Nr )rT )r7 r r �_get_bytes_literal� s z/Connection.__init__.<locals>._get_bytes_literalc s � fdd�� � S )Nc s | � � j�S )N)r r< )r )�string_decoderr r rV � s zHConnection.__init__.<locals>._get_string_decoder.<locals>.string_decoderr r r )rV r �_get_string_decoder� s z0Connection.__init__.<locals>._get_string_decoder)2ZMySQLdb.constantsr3 r4 ZMySQLdb.convertersr5 �weakrefr6 �copy�pop�itemsr$ r. �list�default_cursorr �get�tuple�_mysqlZget_client_info�splitZMULTI_STATEMENTSZ
MULTI_RESULTSrG �superr2 �__init__r; �dict�encodersZget_server_info�_server_versionrQ rV �character_set_name�set_character_set� set_sql_mode� converter�STRINGr# Z
VAR_STRINGZVARCHARZBLOB�bytes� bytearrayr Zserver_capabilitiesZ TRANSACTIONSZ_transactionalrF r" ) �self�args�kwargsr3 r4 r5 r6 Zkwargs2r: Zconv2rI rJ r; r< r> r? r@ rA Zclient_versionrF rN rS rU rW rK rQ rT rV )� __class__)r7 r rc Q s� J
$
&
zConnection.__init__c C s& t |�}| �� |kr"tj�| |� d S )N)�bool�get_autocommitr` r' rF )rn �onr r r rF
s zConnection.autocommitc 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; )rn r; r r r r( s zConnection.cursorc C sP t |t�rt|�}| jd k r>| �|� | �| �� � | �� ntj� | |� d S )N)
r$ rm rl rG Z
send_query�filenoZread_query_resultr` r' �query)rn rv r r r rv s
zConnection.queryc C s2 ddl m} |dtd� | �� r*| �d� | �� S )Nr )�warnzRcontext interface will be changed. Use explicit conn.commit() or conn.rollback().r �BEGIN)�warningsrw �DeprecationWarningrs rv r( )rn rw r r r � __enter__& s
zConnection.__enter__c C s |r| � � n| �� d S )N)ZrollbackZcommit)rn �exc�value�tbr r r �__exit__. s
zConnection.__exit__c C s, | � || j�}ts(t|ttf�r(t|�S |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.
)�escapere r r$ rl rm r )rn �or r r r �literal4 s zConnection.literalc C s& ddl m} |dtd� | �d� dS )z�Explicitly begin a connection. Non-standard.
DEPRECATED: Will be removed in 1.3.
Use an SQL BEGIN statement instead.r )rw z2begin() is non-standard and will be removed in 1.4r rx N)ry rw rz rv )rn rw r r r �beginF s zConnection.begin�
warning_countc C s$ | � � }|r t|�� d �S dS dS )zpReturn the number of warnings generated from the
last query. This is derived from the info() method.���r N)�infor. ra )rn r� r r r r� Q s zConnection.warning_countc s� |dkrd}n|}| � � |krpytt| ��|� W n< tk
rn | jdk rTtd��| �d| � | �� Y nX || j _
|| j _
|| _ 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.Zutf8mb4�utf8)rD r+ z server is too old to set charsetz SET NAMES %sN)
rg rb r2 rh �AttributeErrorrf r
rv � store_resultrV r< rQ �encoding)rn r< Z
py_charset)rq r r rh Z s
z Connection.set_character_setc C s, | j dk rtd��| �d| � | �� dS )zNSet the connection sql_mode. See MySQL documentation for
legal values.)rD r+ z!server is too old to set sql_modezSET SESSION sql_mode='%s'N)rf r
rv r� )rn r? r r r ri o s
zConnection.set_sql_modec C s. | j dk rdS | �d� | �� }|�d�}|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.)rD r+ r z
SHOW WARNINGSr )rf rv r� Z fetch_row)rn �rry r r r �
show_warningsw s
zConnection.show_warnings)N)$�__name__�
__module__� __qualname__�__doc__r ZCursorr] rG rc rF r( rv r{ r r� r� �hasattrr` r' r� rh ri r� r r r r r r
r r r r
r* Z errorhandler�
__classcell__r r )rq r r2 K s8 =
r2 ) r� �re�sysZMySQLdbr ZMySQLdb.compatr r Z_mysql_exceptionsr r r r r r
r r r
r r` � version_info�ranger r r* �compiler, r1 r' r2 r r r r �<module> s 0