a xd; @s`dZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZz dd lZWn.eyZzed eWYd Z[n d Z[00dd lmZmZdd lmZd dlmZd dlmZd dlmZd dlm Z d dl!m"Z"d dl#m$Z$d dl%m&Z&ej'Z(e(dkr"edej)ieej*ej+iZ,edZ-GdddZ.Gddde 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 rz4mysqlclient 1.4.0 or newer is required; you have %s.z(\d{1,2})\.(\d{1,2})\.(\d{1,2})c@s>eZdZdZdZddZdddZdd 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(). )iiiicCs ||_dSN)cursorselfrrU/var/www/html/Ranjet/env/lib/python3.9/site-packages/django/db/backends/mysql/base.py__init__CszCursorWrapper.__init__Nc Cs\z|j||WStjyV}z,|jd|jvr@tt|jWYd}~n d}~00dSNr)rexecuteDatabaseOperationalErrorargscodes_for_integrityerrorrtuplerqueryr!errrrFs zCursorWrapper.executec Cs\z|j||WStjyV}z,|jd|jvr@tt|jWYd}~n d}~00dSr)r executemanyrr r!r"rr#r$rrrr'Qs zCursorWrapper.executemanycCs t|j|Sr)getattrr)rattrrrr __getattr__[szCursorWrapper.__getattr__cCs t|jSr)iterrrrrr__iter__^szCursorWrapper.__iter__)N) __name__ __module__ __qualname____doc__r"rrr'r*r-rrrrr4s  rc@sReZdZdZdddddddd d ddd d d d dddd ddddddddddZdZdddddddd ddddd! Zd"Zd#d$d%d&d'd(d)Zhd*Z e Z e Z e ZeZeZeZeZeZd+d,Zed-d.Zd/d0ZedLd2d3Zd4d5Zd6d7Zd8d9Z d:d;Z!dMdd?Z#e$d@dAZ%e$dBdCZ&e$dDdEZ'e$dFdGZ(e$dHdIZ)e$dJdKZ*d1S)NDatabaseWrapperZmysqlzinteger AUTO_INCREMENTzbigint AUTO_INCREMENTlongblobboolzvarchar(%(max_length)s)datez datetime(6)z+numeric(%(max_digits)s, %(decimal_places)s)Zbigintzdouble precisionintegerzchar(15)zchar(39)jsonzbigint UNSIGNEDzinteger UNSIGNEDzsmallint UNSIGNEDzsmallint AUTO_INCREMENTZsmallintlongtextztime(6)zchar(32))Z AutoFieldZ BigAutoFieldZ BinaryFieldZ BooleanFieldZ CharFieldZ DateFieldZ DateTimeFieldZ DecimalFieldZ DurationFieldZ FileFieldZ FilePathFieldZ FloatFieldZ IntegerFieldZBigIntegerFieldZIPAddressFieldZGenericIPAddressField JSONFieldZNullBooleanFieldZ OneToOneFieldPositiveBigIntegerFieldPositiveIntegerFieldPositiveSmallIntegerFieldZ SlugFieldZSmallAutoFieldZSmallIntegerFieldZ TextFieldZ TimeFieldZ UUIDField) ZtinyblobZblobZ mediumblobr3ZtinytexttextZ mediumtextr8r7z= %szLIKE %szLIKE BINARY %sz> %sz>= %sz< %sz<= %s) exactZiexactcontains icontainsgtZgteltZlte startswithendswith istartswith iendswithzCREPLACE(REPLACE(REPLACE({}, '\\', '\\\\'), '%%', '\%%'), '_', '\_')z"LIKE BINARY CONCAT('%%', {}, '%%')zLIKE CONCAT('%%', {}, '%%')zLIKE BINARY CONCAT({}, '%%')zLIKE CONCAT({}, '%%')zLIKE BINARY CONCAT('%%', {})zLIKE CONCAT('%%', {}))r?r@rCrErDrF>Z serializablezrepeatable readzread uncommittedread committedcCstdd}|j}|dr$|d|d<|dr8|d|d<|drL|d|d<|d d rh|d |d <n|d r||d |d <|d rt|d |d<tj|d<|d}|dd}|r|}||j vrt d|d ddt |j Df||_ |||S)Nutf8)convcharsetUSERuserNAMEdbZPASSWORDpasswdZHOST/Z unix_sockethostZPORTportZ client_flagOPTIONSisolation_levelrGzKInvalid transaction isolation level '%s' specified. Use one of %s, or None.z, css|]}d|VqdS)z'%s'Nr).0srrr z8DatabaseWrapper.get_connection_params..)django_conversions settings_dictrCintr Z FOUND_ROWScopypoplowerisolation_levelsrjoinsortedrTupdate)rkwargsrZoptionsrTrrrget_connection_paramss@         z%DatabaseWrapper.get_connection_paramscCstjfi|Sr)rconnect)rZ conn_paramsrrrget_new_connectionsz"DatabaseWrapper.get_new_connectioncCspg}|jjr|d|jr0|d|j|rl| }|d|Wdn1sb0YdS)NzSET SQL_AUTO_IS_NULL = 0z*SET SESSION TRANSACTION ISOLATION LEVEL %sz; )featuresZis_sql_auto_is_null_enabledappendrTupperrrr`)rZ assignmentsrrrrinit_connection_states  z%DatabaseWrapper.init_connection_stateNcCs|j}t|Sr) connectionrr)rnamerrrr create_cursors zDatabaseWrapper.create_cursorcCs(zt|Wntjy"Yn0dSr)r _rollbackrZNotSupportedErrorr,rrrroszDatabaseWrapper._rollbackcCs6|j|j|Wdn1s(0YdSr)Zwrap_database_errorsrl autocommit)rrprrr_set_autocommitszDatabaseWrapper._set_autocommitcCs6|}|dWdn1s(0YdS)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)rrrrrrdisable_constraint_checking s (z+DatabaseWrapper.disable_constraint_checkingcCsXd|j|_}z<|}|dWdn1s80YW||_n||_0dS)zM Re-enable foreign key checks after they have been disabled. FzSET foreign_key_checks=1N)needs_rollbackrr)rrsrrrrenable_constraint_checkings  *z*DatabaseWrapper.enable_constraint_checkingc Cs|}|dur|j|}|D]}|j||}|s:q"|j||}|D]X\}}}|d||||||||f|D]&} td|| d||| d||fq|qLq"Wdn1s0YdS)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 zThe 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.rr )r introspection table_namesZget_primary_key_columnZget_key_columnsrZfetchallr) rrvrZ table_nameZprimary_key_column_nameZ key_columnsZ column_nameZreferenced_table_nameZreferenced_column_nameZbad_rowrrrcheck_constraints"s2     z!DatabaseWrapper.check_constraintscCs.z|jWntjy$YdS0dSdS)NFT)rlZpingrErrorr,rrr is_usableJs zDatabaseWrapper.is_usablecCs|jr dSdS)NZMariaDBZMySQL)mysql_is_mariadbr,rrr display_nameRszDatabaseWrapper.display_namecCs4|jjr0dddd}|jr,|jdkr,d|d<|SiS)Nz`%(column)s` >= 0)r:r;r<) rzJSON_VALID(`%(column)s`)r9)rhZ!supports_column_check_constraintsrz mysql_version)rrwrrrdata_type_check_constraintsVsz+DatabaseWrapper.data_type_check_constraintscCsB|&}|d|dWdS1s40YdS)NzSELECT VERSION()r)Ztemporary_connectionrfetchonerrrrmysql_server_infoes  z!DatabaseWrapper.mysql_server_infocCs4t|j}|std|jtdd|DS)Nz8Unable to determine MySQL version from version string %rcss|]}t|VqdSr)r[)rUxrrrrWprXz0DatabaseWrapper.mysql_version..)server_version_rematchr Exceptionr#groups)rrrrrr~ks zDatabaseWrapper.mysql_versioncCsd|jvS)NZmariadb)rr^r,rrrrzrsz DatabaseWrapper.mysql_is_mariadbcCsT|"}|d|}Wdn1s00Yt|rN|ddndS)NzSELECT @@sql_moder,r)rrrsetsplit)rrsql_moderrrrvs  &zDatabaseWrapper.sql_mode)N)N)+r.r/r0vendor data_typesZ_limited_data_types operatorsZ pattern_escZ pattern_opsr_rrZSchemaEditorClassr Z client_classrZcreation_classrZfeatures_classrZintrospection_classrZ ops_classrZvalidation_classrerrgrkrnrorqrrrtrwryrr{rrr~rzrrrrrr2bs$ %    (     r2)0r1Zdjango.core.exceptionsrZ django.dbrZdjango.db.backendsrZ backend_utilsZdjango.db.backends.base.baserZdjango.utils.asynciorZdjango.utils.functionalrZdjango.utils.regex_helperrZMySQLdbr ImportErrorerrZMySQLdb.constantsr r ZMySQLdb.convertersr clientr Zcreationrrhrrur operationsrZschemarZ validationr version_infoversion __version__ZTIMEZ typecast_timerYrrr2rrrrsF                  .