File: //usr/lib/python3/dist-packages/django/db/backends/mysql/__pycache__/base.cpython-310.pyc
o
3�aP? �
@ sR d Z ddlmZ ddlmZ ddlmZ ddlm Z ddl
m Z ddl m
Z
ddlmZ zdd lZW n eyC Z zed
�e�d Z[ww dd lmZmZ dd lmZ d
dlmZ d
dlm Z d
dl m Z d
dl m Z d
dl!m"Z" d
dl#m$Z$ d
dl%m&Z& ej'Z(e(dk r�edej) ��i e�ej*ej+i�Z,ed�Z-G dd� d�Z.G dd� de �Z/d S ) za
MySQL database backend for Django.
Requires mysqlclient: https://pypi.org/project/mysqlclient/
� )�ImproperlyConfigured)�IntegrityError)�utils)�BaseDatabaseWrapper)� async_unsafe)�cached_property)�_lazy_re_compileNz:Error loading MySQLdb module.
Did you install mysqlclient?)�CLIENT�
FIELD_TYPE)� conversions� )�DatabaseClient)�DatabaseCreation)�DatabaseFeatures)�DatabaseIntrospection)�DatabaseOperations)�DatabaseSchemaEditor)�DatabaseValidation)r � r z4mysqlclient 1.4.0 or newer is required; you have %s.z (\d{1,2})\.(\d{1,2})\.(\d{1,2})c @ s> e Zd ZdZdZdd� Zddd�Zdd � Zd
d � Zd d
� Z dS )�
CursorWrappera6
A thin wrapper around MySQLdb's normal cursor class that catches particular
exception instances and reraises them with the correct types.
Implemented as a wrapper, rather than a subclass, so that it isn't stuck
to the particular underlying representation returned by Connection.cursor().
)i i� i� i� c C s
|| _ d S �N)�cursor��selfr � r �?/usr/lib/python3/dist-packages/django/db/backends/mysql/base.py�__init__C �
zCursorWrapper.__init__Nc
C �L z| j �||�W S tjy% } z|jd | jv r tt|j�� �� d }~ww �Nr )r �execute�Database�OperationalError�args�codes_for_integrityerrorr �tuple�r �queryr# �er r r r F s ��zCursorWrapper.executec
C r r )r � executemanyr! r" r# r$ r r% r& r r r r) Q s ��zCursorWrapper.executemanyc C s t | j|�S r )�getattrr )r �attrr r r � __getattr__[ s zCursorWrapper.__getattr__c C s
t | j�S r )�iterr �r r r r �__iter__^ r zCursorWrapper.__iter__r )
�__name__�
__module__� __qualname__�__doc__r$ r r r) r, r/ r r r r r 4 s
r c
@ s� e Zd ZdZi dd�dd�dd�dd �d
d �d d
�dd�dd�dd�dd �dd �dd�dd�dd�dd �d d �d d �d dd!d"d#d d$d%d&d'd(d)� �Zd*Zd+d,d-d,d.d/d0d1d-d-d,d,d2� Zd3Zd4d5d6d7d8d9d:�Zh d;�Z e
Z
e Z e
ZeZeZeZeZeZd<d=� Zed>d?� �Zd@dA� Z ed_dCdD��Z dEdF� Z dGdH� Z dIdJ� Z dKdL� Z!d_dMdN�Z"dOdP� Z#e$dQdR� �Z%e$dSdT� �Z&e$dUdV� �Z'e$dWdX� �Z(e$dYdZ� �Z)e$d[d\� �Z*e$d]d^� �Z+dBS )`�DatabaseWrapper�mysql� AutoFieldzinteger AUTO_INCREMENT� BigAutoFieldzbigint AUTO_INCREMENT� BinaryField�longblob� BooleanField�bool� CharFieldzvarchar(%(max_length)s)� DateField�date�
DateTimeFieldz datetime(6)� DecimalFieldz+numeric(%(max_digits)s, %(decimal_places)s)�
DurationField�bigint� FileField�
FilePathField�
FloatFieldzdouble precision� IntegerField�integer�BigIntegerField�IPAddressFieldzchar(15)�GenericIPAddressFieldzchar(39)� JSONField�jsonzbigint UNSIGNEDzinteger UNSIGNEDzsmallint UNSIGNEDzsmallint AUTO_INCREMENT�smallint�longtextztime(6)zchar(32)) �NullBooleanField�
OneToOneField�PositiveBigIntegerField�PositiveIntegerField�PositiveSmallIntegerField� SlugField�SmallAutoField�SmallIntegerField� TextField� TimeField� UUIDField) �tinyblob�blob�
mediumblobr9 �tinytext�text�
mediumtextrN rL z= %szLIKE %szLIKE BINARY %sz> %sz>= %sz< %sz<= %s) �exact�iexact�contains� icontains�gt�gte�lt�lte�
startswith�endswith� istartswith� iendswithzCREPLACE(REPLACE(REPLACE({}, '\\', '\\\\'), '%%', '\%%'), '_', '\_')z"LIKE BINARY CONCAT('%%', {}, '%%')zLIKE CONCAT('%%', {}, '%%')z LIKE BINARY CONCAT({}, '%%')zLIKE CONCAT({}, '%%')z LIKE BINARY CONCAT('%%', {})zLIKE CONCAT('%%', {}))rb rc rh rj ri rk > �repeatable read�read uncommitted� serializable�read committedc C s t dd�}| j}|d r|d |d< |d r |d |d< |d r&|d |d< |d �d
�r4|d |d < n
|d r>|d |d < |d
rJt|d
�|d< tj|d< |d �� }|�dd�}|ry|�� }|| j vryt
d|d� dd� t | j �D ��f ��|| _
|�|� |S )N�utf8)�conv�charset�USER�user�NAME�database�PASSWORD�password�HOST�/� unix_socket�host�PORT�port� client_flag�OPTIONS�isolation_levelro zKInvalid transaction isolation level '%s' specified.
Use one of %s, or None.z, c s s � | ]}d | V qdS )z'%s'Nr )�.0�sr r r � <genexpr>� � � z8DatabaseWrapper.get_connection_params.<locals>.<genexpr>)�django_conversions�
settings_dictrh �intr �
FOUND_ROWS�copy�pop�lower�isolation_levelsr �join�sortedr� �update)r �kwargsr� �optionsr� r r r �get_connection_params� s@ �
���
z%DatabaseWrapper.get_connection_paramsc C s0 t jdi |��}|j�t�tu r|j�t� |S )Nr )r! �connect�encoders�get�bytesr� )r � conn_params�
connectionr r r �get_new_connection� s z"DatabaseWrapper.get_new_connectionc C sv g }| j jr |�d� | jr|�d| j�� � |r9| �� �}|�d�|�� W d � d S 1 s2w Y d S d S )NzSET SQL_AUTO_IS_NULL = 0z*SET SESSION TRANSACTION ISOLATION LEVEL %sz; )�features�is_sql_auto_is_null_enabled�appendr� �upperr r r� )r � assignmentsr r r r �init_connection_state� s
"��z%DatabaseWrapper.init_connection_stateNc C s | j �� }t|�S r )r� r r )r �namer r r r �
create_cursor s
z DatabaseWrapper.create_cursorc C s( zt �| � W d S tjy Y d S w r )r � _rollbackr! �NotSupportedErrorr. r r r r� s
�zDatabaseWrapper._rollbackc C s8 | j � | j�|� W d � d S 1 sw Y d S r )�wrap_database_errorsr� �
autocommit)r r� r r r �_set_autocommit s "�z DatabaseWrapper._set_autocommitc C s8 | � � �}|�d� W d � dS 1 sw Y dS )z�
Disable foreign key checks, primarily for use in adding rows with
forward references. Always return True to indicate constraint checks
need to be re-enabled.
zSET foreign_key_checks=0NT)r r r r r r �disable_constraint_checking s
��z+DatabaseWrapper.disable_constraint_checkingc C sb d| j | _ }z%| �� �
}|�d� W d � n1 s w Y W || _ dS W || _ dS || _ w )zM
Re-enable foreign key checks after they have been disabled.
FzSET foreign_key_checks=1N)�needs_rollbackr r )r r� r r r r �enable_constraint_checking s
�
�z*DatabaseWrapper.enable_constraint_checkingc
C s� | � � �W}|du r| j�|�}|D ]A}| j�||�}|s q| j�||�}|D ]+\}}}|�d||||||||f � |�� D ]} td|| d ||| d ||f ��q&qW d � dS 1 s^w Y dS )a]
Check each table name in `table_names` for rows with invalid foreign
key references. This method is intended to be used in conjunction with
`disable_constraint_checking()` and `enable_constraint_checking()`, to
determine if rows with invalid references were entered while constraint
checks were off.
Na0
SELECT REFERRING.`%s`, REFERRING.`%s` FROM `%s` as REFERRING
LEFT JOIN `%s` as REFERRED
ON (REFERRING.`%s` = REFERRED.`%s`)
WHERE REFERRING.`%s` IS NOT NULL AND REFERRED.`%s` IS NULL
z�The row in table '%s' with primary key '%s' has an invalid foreign key: %s.%s contains a value '%s' that does not have a corresponding value in %s.%s.r r )r �
introspection� table_names�get_primary_key_column�get_key_columnsr �fetchallr )
r r� r �
table_name�primary_key_column_name� key_columns� column_name�referenced_table_name�referenced_column_name�bad_rowr r r �check_constraints) s:
���
������"�z!DatabaseWrapper.check_constraintsc C s( z| j �� W dS tjy Y dS w )NFT)r� �pingr! �Errorr. r r r � is_usableQ s ��zDatabaseWrapper.is_usablec C s | j rdS dS )N�MariaDB�MySQL)�mysql_is_mariadbr. r r r � display_nameY � z DatabaseWrapper.display_namec C s4 | j jrdddd�}| jr| jdk rd|d< |S i S )Nz`%(column)s` >= 0)rQ rR rS )�
r � zJSON_VALID(`%(column)s`)rK )r� �!supports_column_check_constraintsr� �
mysql_version)r r� r r r �data_type_check_constraints] s �z+DatabaseWrapper.data_type_check_constraintsc C sp | � � �}|�d� |�� }W d � n1 sw Y |d |d |d t|d �t|d �t|d �d�S ) Na2
SELECT VERSION(),
@@sql_mode,
@@default_storage_engine,
@@sql_auto_is_null,
@@lower_case_table_names,
CONVERT_TZ('2001-01-01 01:00:00', 'UTC', 'UTC') IS NOT NULL
r r � r� r � )�version�sql_mode�default_storage_engine�sql_auto_is_null�lower_case_table_names�has_zoneinfo_database)�temporary_connectionr �fetchoner; )r r �rowr r r �mysql_server_datal s
�
�z!DatabaseWrapper.mysql_server_datac C s
| j d S )Nr� )r� r. r r r �mysql_server_info� s
z!DatabaseWrapper.mysql_server_infoc C s4 t �| j�}|std| j ��tdd� |�� D ��S )Nz8Unable to determine MySQL version from version string %rc s s � | ]}t |�V qd S r )r� )r� �xr r r r� � r� z0DatabaseWrapper.mysql_version.<locals>.<genexpr>)�server_version_re�matchr� � Exceptionr% �groups)r r� r r r r� � s z DatabaseWrapper.mysql_versionc C s d| j �� v S )N�mariadb)r� r� r. r r r r� � r� z DatabaseWrapper.mysql_is_mariadbc C s" | j d }t|r|�d��S d�S )Nr� �,r )r� �set�split)r r� r r r r� � s
zDatabaseWrapper.sql_moder ),r0 r1 r2 �vendor�
data_types�_limited_data_types� operators� pattern_esc� pattern_opsr� r! r �SchemaEditorClassr
� client_classr �creation_classr �features_classr �introspection_classr � ops_classr �validation_classr� r r� r� r� r� r� r� r� r� r� r r� r� r� r� r� r� r� r r r r r4 b s� �������� �
� � �
������$�� %
(
r4 )0r3 �django.core.exceptionsr � django.dbr �django.db.backendsr �
backend_utils� django.db.backends.base.baser �django.utils.asyncior �django.utils.functionalr �django.utils.regex_helperr �MySQLdbr! � ImportError�err�MySQLdb.constantsr r
�MySQLdb.convertersr �clientr
�creationr r� r r� r �
operationsr �schemar �
validationr � version_infor� � __version__�TIME�
typecast_timer� r� r r4 r r r r �<module> sL ���� �
�.