OwlCyberSecurity - MANAGER
Edit File: base.cpython-39.pyc
a ���eB � @ s` d Z ddlmZ ddlmZ ddlmZ ddlm Z ddl m Z ddl m Z ddlmZ z dd lZW n. ey� Z zed �e�W Y d Z[n d Z[0 0 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 � � z4mysqlclient 1.4.3 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 �^/home/gouroczh/virtualenv/pat/3.9/lib/python3.9/site-packages/django/db/backends/mysql/base.py�__init__E s zCursorWrapper.__init__Nc C s\ z| j �||�W S tjyV } z,|jd | jv r@tt|j�� �� W Y d }~n d }~0 0 d S �Nr )r �execute�Database�OperationalError�args�codes_for_integrityerrorr �tuple�r �queryr" �er r r r H s zCursorWrapper.executec C s\ z| j �||�W S tjyV } z,|jd | jv r@tt|j�� �� W Y d }~n d }~0 0 d S r )r � executemanyr r! r" r# r r$ r% r r r r( S 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__` s zCursorWrapper.__iter__)N) �__name__� __module__� __qualname__�__doc__r# r r r( r+ r. r r r r r 5 s r c sl e Zd ZdZdddddddd d ddd d d d ddd dddddddddd�ZdZddd dd d d d d d ddd!� Zd"Zd#d$d%d&d'd(d)�Zh d*�Z e Z e Z e ZeZeZeZeZeZd+d,� Zd-d.� Zed/d0� �Z � fd1d2�Z edPd4d5��Z d6d7� Z d8d9� Z d:d;� Z!d<d=� Z"dQd>d?�Z#d@dA� Z$e%dBdC� �Z&e%dDdE� �Z'e%dFdG� �Z(e%dHdI� �Z)e%dJdK� �Z*e%dLdM� �Z+e%dNdO� �Z,� Z-S )R�DatabaseWrapper�mysqlzinteger AUTO_INCREMENTzbigint AUTO_INCREMENT�longblob�boolzvarchar(%(max_length)s)�datez datetime(6)z+numeric(%(max_digits)s, %(decimal_places)s)Zbigintzdouble precision�integerzchar(15)zchar(39)�jsonzbigint UNSIGNEDzinteger UNSIGNEDzsmallint UNSIGNEDzsmallint AUTO_INCREMENTZsmallint�longtextztime(6)zchar(32))Z AutoFieldZ BigAutoFieldZ BinaryFieldZ BooleanFieldZ CharFieldZ DateFieldZ DateTimeFieldZ DecimalFieldZ DurationFieldZ FileFieldZ FilePathFieldZ FloatFieldZ IntegerFieldZBigIntegerFieldZIPAddressFieldZGenericIPAddressField� JSONFieldZ OneToOneField�PositiveBigIntegerField�PositiveIntegerField�PositiveSmallIntegerFieldZ SlugFieldZSmallAutoFieldZSmallIntegerFieldZ TextFieldZ TimeFieldZ UUIDField) ZtinyblobZblobZ mediumblobr5 Ztinytext�textZ mediumtextr: r9 z= %szLIKE %szLIKE BINARY %sz> %sz>= %sz< %sz<= %s) �exactZiexact�contains� icontains�gtZgte�ltZlte� startswith�endswith� istartswith� iendswithzCREPLACE(REPLACE(REPLACE({}, '\\', '\\\\'), '%%', '\%%'), '_', '\_')z"LIKE BINARY CONCAT('%%', {}, '%%')zLIKE CONCAT('%%', {}, '%%')z LIKE BINARY CONCAT({}, '%%')zLIKE CONCAT({}, '%%')z LIKE BINARY CONCAT('%%', {})zLIKE CONCAT('%%', {}))rA rB rE rG rF rH > zrepeatable readzread uncommittedZ serializable�read committedc C s | j S r )� mysql_versionr- r r r �get_database_version� s z$DatabaseWrapper.get_database_versionc C s t dd�}| j}|d r$|d |d< |d r8|d |d< |d rL|d |d< |d �d �rh|d |d < n|d r||d |d < |d r�t|d �|d< tj|d< |d �� }|�dd�}|r�|�� }|| j vr�t d|d� dd� t | j �D ��f ��|| _ |�|� |S )N�utf8)�conv�charset�USER�user�NAMEZdatabaseZPASSWORD�passwordZHOST�/Z unix_socket�hostZPORT�portZ client_flag�OPTIONS�isolation_levelrI 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_dictrE �intr Z FOUND_ROWS�copy�pop�lower�isolation_levelsr �join�sortedrW �update)r �kwargsr] �optionsrW r r r �get_connection_params� s@ � ��� z%DatabaseWrapper.get_connection_paramsc C s0 t jf i |��}|j�t�tu r,|j�t� |S r )r �connect�encoders�get�bytesr` )r Z conn_params� connectionr r r �get_new_connection� s z"DatabaseWrapper.get_new_connectionc sz t � �� g }| jjr |�d� | jr:|�d| j�� � |rv| �� � }|�d� |�� W d � n1 sl0 Y d S )NzSET SQL_AUTO_IS_NULL = 0z*SET SESSION TRANSACTION ISOLATION LEVEL %sz; ) �super�init_connection_state�featuresZis_sql_auto_is_null_enabled�appendrW �upperr r rc )r Z assignmentsr �� __class__r r rp s �� z%DatabaseWrapper.init_connection_stateNc C s | j �� }t|�S r )rm r r )r �namer r r r � create_cursor s z DatabaseWrapper.create_cursorc C s( zt �| � W n tjy" Y n0 d S r )r � _rollbackr ZNotSupportedErrorr- r r r rx s zDatabaseWrapper._rollbackc C s6 | j � | j�|� W d � n1 s(0 Y d S r )Zwrap_database_errorsrm � autocommit)r ry r r r �_set_autocommit s z DatabaseWrapper._set_autocommitc C s6 | � � �}|�d� W d � n1 s(0 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 sX d| j | _ }z<| �� �}|�d� W d � n1 s80 Y W || _ n|| _ 0 dS )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� | � � ��}|du r | j�|�}|D ]�}| j�||�}|s:q"| j�||�}|�� D ]Z\}\}}|�d||||||||f � |�� D ]&} td|| d ||| d ||f ��q�qPq"W d � n1 s�0 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_namesZget_primary_key_columnZ get_relations�itemsr Zfetchallr ) r r r Z table_nameZprimary_key_column_nameZ relationsZ column_nameZreferenced_column_nameZreferenced_table_nameZbad_rowr r r �check_constraints: sP �� ��� ���z!DatabaseWrapper.check_constraintsc C s. z| j �� W n tjy$ Y dS 0 dS d S )NFT)rm Zpingr �Errorr- r r r � is_usabler s zDatabaseWrapper.is_usablec C s | j r dS dS )NZMariaDB�MySQL)�mysql_is_mariadbr- r r r � display_namez s z DatabaseWrapper.display_namec C s4 | j jr0dddd�}| jr,| jdk r,d|d< |S i S )Nz`%(column)s` >= 0)r< r= r> )� r r zJSON_VALID(`%(column)s`)r; )rq Z!supports_column_check_constraintsr� rJ )r r� r r r �data_type_check_constraints~ s �z+DatabaseWrapper.data_type_check_constraintsc C sp | � � �"}|�d� |�� }W d � n1 s00 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_modeZdefault_storage_engineZsql_auto_is_nullZlower_case_table_namesZhas_zoneinfo_database)Ztemporary_connectionr Zfetchoner6 )r r �rowr r r �mysql_server_data� 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�}|s td| j ��tdd� |�� D ��S )Nz8Unable to determine MySQL version from version string %rc s s | ]}t |�V qd S r )r^ )rX �xr r r rZ � r[ z0DatabaseWrapper.mysql_version.<locals>.<genexpr>)�server_version_re�matchr� � Exceptionr$ �groups)r r� r r r rJ � s ��z DatabaseWrapper.mysql_versionc C s d| j �� v S )NZmariadb)r� ra r- r r r r� � s z DatabaseWrapper.mysql_is_mariadbc C s | j d }t|r|�d�nd�S )Nr� �,r )r� �set�split)r r� r r r r� � s zDatabaseWrapper.sql_mode)N)N).r/ r0 r1 �vendor� data_typesZ_limited_data_types� operatorsZ pattern_escZ pattern_opsrb r r ZSchemaEditorClassr Z client_classr Zcreation_classr Zfeatures_classr Zintrospection_classr Z ops_classr Zvalidation_classrK rh r rn rp rw rx rz r{ r} r� r� r r� r� r� r� rJ r� r� � __classcell__r r rt r r3 d s� �# �� ' 8 r3 )0r2 Zdjango.core.exceptionsr Z django.dbr Zdjango.db.backendsr Z backend_utilsZ django.db.backends.base.baser Zdjango.utils.asyncior Zdjango.utils.functionalr Zdjango.utils.regex_helperr ZMySQLdbr � ImportError�errZMySQLdb.constantsr r ZMySQLdb.convertersr �clientr Zcreationr rq r r~ r � operationsr Zschemar Z validationr � version_infor� � __version__ZTIMEZ typecast_timer\ r� r r3 r r r r �<module> sJ �� �� �/