U eB @sZdZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZz dd lZWn,ek rZzed eW5d Z[XYnXdd lmZmZdd lmZd dlmZd dlmZd dlmZd dlm Z d dl!m"Z"d dl#m$Z$d dl%m&Z&ej'Z(e(dkr edej)eej*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 z4mysqlclient 1.4.3 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)cursorselfrrA/tmp/pip-unpacked-wheel-lctamlir/django/db/backends/mysql/base.py__init__EszCursorWrapper.__init__Nc CsZz|j||WStjk rT}z$|jd|jkrBtt|jW5d}~XYnXdSNr)rexecuteDatabaseOperationalErrorargscodes_for_integrityerrorrtuplerqueryr"errrrHs zCursorWrapper.executec CsZz|j||WStjk rT}z$|jd|jkrBtt|jW5d}~XYnXdSr)r executemanyr r!r"r#rr$r%rrrr(Ss 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.rrrrr5s  rcspeZdZdZdddddddd d ddd d d d ddd ddddddddddZdZdddddddd ddddd! Zd"Zd#d$d%d&d'd(d)Zd*d+d,d-hZ e Z e Z e ZeZeZeZeZeZd.d/Zd0d1Zed2d3Zfd4d5ZedSd7d8Zd9d:Zd;d<Z d=d>Z!d?d@Z"dTdAdBZ#dCdDZ$e%dEdFZ&e%dGdHZ'e%dIdJZ(e%dKdLZ)e%dMdNZ*e%dOdPZ+e%dQdRZ,Z-S)UDatabaseWrapperZmysqlzinteger 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 JSONFieldZ OneToOneFieldPositiveBigIntegerFieldPositiveIntegerFieldPositiveSmallIntegerFieldZ SlugFieldZSmallAutoFieldZSmallIntegerFieldZ TextFieldZ TimeFieldZ UUIDField) ZtinyblobZblobZ mediumblobr4ZtinytexttextZ mediumtextr9r8z= %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@rArDrFrErGzread uncommittedread committedzrepeatable readZ serializablecCs|jSr) mysql_versionr-rrrget_database_versionsz$DatabaseWrapper.get_database_versioncCstdd}|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 krt d|d ddt |j Df||_ |||S)Nutf8)convcharsetUSERuserNAMEZdatabaseZPASSWORDpasswordZHOST/Z unix_sockethostZPORTportZ client_flagOPTIONSisolation_levelrHzKInvalid transaction isolation level '%s' specified. Use one of %s, or None.z, css|]}d|VqdS)z'%s'Nr).0srrr sz8DatabaseWrapper.get_connection_params..)django_conversions settings_dictrDintr Z FOUND_ROWScopypoplowerisolation_levelsrjoinsortedrVupdate)rkwargsr[optionsrVrrrget_connection_paramss@         z%DatabaseWrapper.get_connection_paramscCs,tjf|}|jttkr(|jt|Sr)r connectencodersgetbytesr^)rZ conn_params connectionrrrget_new_connections  z"DatabaseWrapper.get_new_connectionc sftg}|jjr |d|jr:|d|j|rb|}|d |W5QRXdS)NzSET SQL_AUTO_IS_NULL = 0z*SET SESSION TRANSACTION ISOLATION LEVEL %sz; ) superinit_connection_statefeaturesZis_sql_auto_is_null_enabledappendrVupperrrra)rZ assignmentsr __class__rrrns   z%DatabaseWrapper.init_connection_stateNcCs|j}t|Sr)rkrr)rnamerrrr create_cursors zDatabaseWrapper.create_cursorcCs*zt|Wntjk r$YnXdSr)r _rollbackr ZNotSupportedErrorr-rrrrvszDatabaseWrapper._rollbackc Cs"|j|j|W5QRXdSr)Zwrap_database_errorsrk autocommit)rrwrrr_set_autocommitszDatabaseWrapper._set_autocommitc Cs"|}|dW5QRXdS)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=0T)rrrrrrdisable_constraint_checking#s z+DatabaseWrapper.disable_constraint_checkingc Cs>d|j|_}z"|}|dW5QRXW5||_XdS)zM Re-enable foreign key checks after they have been disabled. FzSET foreign_key_checks=1N)needs_rollbackrr)rrzrrrrenable_constraint_checking-s  z*DatabaseWrapper.enable_constraint_checkingc Cs|}|dkr|j|}|D]}|j||}|s:q"|j||}|D]Z\}\}}|d||||||||f|D]&} td|| d||| d||fqqPq"W5QRXdS)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_columnZ get_relationsitemsrZfetchallr) rr}rZ table_nameZprimary_key_column_nameZ relationsZ column_nameZreferenced_column_nameZreferenced_table_nameZbad_rowrrrcheck_constraints:sR    z!DatabaseWrapper.check_constraintscCs0z|jWntjk r&YdSXdSdS)NFT)rkZpingr Errorr-rrr is_usablers zDatabaseWrapper.is_usablecCs|jr dSdS)NZMariaDBZMySQL)mysql_is_mariadbr-rrr display_namezszDatabaseWrapper.display_namecCs4|jjr0dddd}|jr,|jdkr,d|d<|SiS)Nz`%(column)s` >= 0)r;r<r=) rrzJSON_VALID(`%(column)s`)r:)roZ!supports_column_check_constraintsrrI)rrrrrdata_type_check_constraints~sz+DatabaseWrapper.data_type_check_constraintsc Cs\|}|d|}W5QRX|d|d|dt|dt|dt|ddS) 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 rr rr)versionsql_modeZdefault_storage_engineZsql_auto_is_nullZlower_case_table_namesZhas_zoneinfo_database)Ztemporary_connectionrZfetchoner5)rrrowrrrmysql_server_datas     z!DatabaseWrapper.mysql_server_datacCs |jdS)Nr)rr-rrrmysql_server_infosz!DatabaseWrapper.mysql_server_infocCs4t|j}|std|jtdd|DS)Nz8Unable to determine MySQL version from version string %rcss|]}t|VqdSr)r\)rWxrrrrYsz0DatabaseWrapper.mysql_version..)server_version_rematchr Exceptionr$groups)rrrrrrIs zDatabaseWrapper.mysql_versioncCsd|jkS)NZmariadb)rr_r-rrrrsz DatabaseWrapper.mysql_is_mariadbcCs |jd}t|r|dndS)Nr,r)rsetsplit)rrrrrrs zDatabaseWrapper.sql_mode)N)N).r/r0r1vendor data_typesZ_limited_data_types operatorsZ pattern_escZ pattern_opsr`r rZSchemaEditorClassr Z client_classrZcreation_classrZfeatures_classrZintrospection_classrZ ops_classrZvalidation_classrJrfrrlrnrurvrxryr{rrrrrrrrIrr __classcell__rrrrrr3ds#  '    8      r3)0r2Zdjango.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 Zcreationrrorr|r operationsrZschemarZ validationr version_infor __version__ZTIMEZ typecast_timerZrrr3rrrrsF                   /