v^a8@sdZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z yddlZWn4ek rZzedeWYddZ[XnXdd lmZmZdd lmZd d lmZd d lmZd dlmZd dlmZd dlm Z d dl!m"Z"d dl#m$Z$ej%Z&e&dkrwedej'eej(ej)iZ*ej+dZ,GdddZ-Gddde Z.dS)za MySQL database backend for Django. Requires mysqlclient: https://pypi.org/project/mysqlclient/ N)ImproperlyConfigured)utils)BaseDatabaseWrapper) async_unsafe)cached_propertyz:Error loading MySQLdb module. Did you install mysqlclient?)CLIENT FIELD_TYPE) conversions)DatabaseClient)DatabaseCreation)DatabaseFeatures)DatabaseIntrospection)DatabaseOperations)DatabaseSchemaEditor)DatabaseValidation z5mysqlclient 1.3.13 or newer is required; you have %s.z(\d{1,2})\.(\d{1,2})\.(\d{1,2})c@s[eZdZdZdZddZdd d Zd d Zd dZddZ 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(). cCs ||_dS)N)cursor)selfrr?/tmp/pip-build-8lau8j11/django/django/db/backends/mysql/base.py__init__DszCursorWrapper.__init__NcCswy|jj||SWnYtjk rr}z6|jd|jkr]tjt|jWYdd}~XnXdS)Nr) rexecuteDatabaseOperationalErrorargscodes_for_integrityerrorrIntegrityErrortuple)rqueryr!errrrGs zCursorWrapper.executecCswy|jj||SWnYtjk rr}z6|jd|jkr]tjt|jWYdd}~XnXdS)Nr) r executemanyrr r!r"rr#r$)rr%r!r&rrrr'Rs zCursorWrapper.executemanycCst|j|S)N)getattrr)rattrrrr __getattr__\szCursorWrapper.__getattr__cCs t|jS)N)iterr)rrrr__iter___szCursorWrapper.__iter__)rrrr) __name__ __module__ __qualname____doc__r"rrr'r*r,rrrrr5s   rc4@sbeZdZdZdddddddd d d d d dddddddd dd dddddddddddd d dd!d"d#d$d%d d&d'd(d)d*d+d,d-d.d/iZdtZd7d8d9d:d;d<d=d:d>d?d@dAdBdCdDdEdFd<dGd<dHd:dId:i ZdJZd;dKd=dLdFdMdHdNdGdOdIdPiZdQdRdSdThZ e Z e Z e ZeZeZeZeZeZdUdVZedWdXZdYdZZed[d\d]Zd^d_Zd`daZdbdcZ dddeZ!d[dfdgZ"dhdiZ#e$djdkZ%e$dldmZ&e$dndoZ'e$dpdqZ(e$drdsZ)d[S)uDatabaseWrapperZmysqlZ AutoFieldzinteger AUTO_INCREMENTZ BigAutoFieldzbigint AUTO_INCREMENTZ BinaryFieldlongblobZ BooleanFieldboolZ CharFieldzvarchar(%(max_length)s)Z DateFielddateZ DateTimeFieldz datetime(6)Z DecimalFieldz+numeric(%(max_digits)s, %(decimal_places)s)Z DurationFieldZbigintZ FileFieldZ FilePathFieldZ FloatFieldzdouble precisionZ IntegerFieldintegerZBigIntegerFieldZIPAddressFieldzchar(15)ZGenericIPAddressFieldzchar(39)ZNullBooleanFieldZ OneToOneFieldPositiveIntegerFieldzinteger UNSIGNEDPositiveSmallIntegerFieldzsmallint UNSIGNEDZ SlugFieldZSmallAutoFieldzsmallint AUTO_INCREMENTZSmallIntegerFieldZsmallintZ TextFieldlongtextZ TimeFieldztime(6)Z UUIDFieldzchar(32)tinyblobblob mediumblobtinytexttext mediumtextjsonexactz= %sZiexactzLIKE %scontainszLIKE BINARY %sZ icontainsgtz> %sgtez>= %sltz< %sltez<= %s startswithendswithZ istartswithZ iendswithzCREPLACE(REPLACE(REPLACE({}, '\\', '\\\\'), '%%', '\%%'), '_', '\_')z"LIKE BINARY CONCAT('%%', {}, '%%')zLIKE CONCAT('%%', {}, '%%')zLIKE BINARY CONCAT({}, '%%')zLIKE CONCAT({}, '%%')zLIKE BINARY CONCAT('%%', {})zLIKE CONCAT('%%', {})zread uncommittedzread committedzrepeatable readZ serializablecCs\dtddi}|j}|dr3|d|d<|drK|d|d<|drc|d|d <|d jd r|d |d sz8DatabaseWrapper.get_connection_params..)django_conversions settings_dictrFintrZ FOUND_ROWScopypoplowerisolation_levelsrjoinsortedrTupdate)rkwargsrYoptionsrTrrrget_connection_paramss8         ,  z%DatabaseWrapper.get_connection_paramscCs tj|S)N)rconnect)rZ conn_paramsrrrget_new_connectionsz"DatabaseWrapper.get_new_connectionc Csxg}|jjr|jd|jrB|jd|jj|rt|j}|jdj|WdQRXdS)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|jj}t|S)N) connectionrr)rnamerrrr create_cursorszDatabaseWrapper.create_cursorc Cs-ytj|Wntjk r(YnXdS)N)r _rollbackrZNotSupportedError)rrrrrnszDatabaseWrapper._rollbackc Cs%|j|jj|WdQRXdS)N)Zwrap_database_errorsrk autocommit)rrorrr_set_autocommits zDatabaseWrapper._set_autocommitcCs|jjddS)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)rr)rrrrdisable_constraint_checking sz+DatabaseWrapper.disable_constraint_checkingc Cs;d|j|_}z|jjdWd||_XdS)zM Re-enable foreign key checks after they have been disabled. FzSET foreign_key_checks=1N)needs_rollbackrr)rrrrrrenable_constraint_checkingsz*DatabaseWrapper.enable_constraint_checkingc Cs|j}|dkr-|jj|}x|D]}|jj||}|sXq4|jj||}x|D]\}}}|jd||||||||fxD|jD]6} tjd|| d||| d||fqWqtWq4WWdQRXdS)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_columnsrZfetchallrr#) rrurZ table_nameZprimary_key_column_nameZ key_columnsZ column_nameZreferenced_table_nameZreferenced_column_nameZbad_rowrrrcheck_constraintss&    z!DatabaseWrapper.check_constraintsc Cs5y|jjWntjk r,dSYnXdSdS)NFT)rkZpingrError)rrrr is_usableGs  zDatabaseWrapper.is_usablecCs|jr dSdS)NZMariaDBZMySQL)mysql_is_mariadb)rrrr display_nameOszDatabaseWrapper.display_namecCs |jjrddddiSiS)Nr6z`%(column)s` >= 0r7)rgZ!supports_column_check_constraints)rrrrdata_type_check_constraintsSs  z+DatabaseWrapper.data_type_check_constraintsc Cs5|j"}|jd|jdSWdQRXdS)NzSELECT VERSION()r)Ztemporary_connectionrZfetchone)rrrrrmysql_server_info\s z!DatabaseWrapper.mysql_server_infocCsHtj|j}|s+td|jtdd|jDS)Nz8Unable to determine MySQL version from version string %rcss|]}t|VqdS)N)rZ)rUxrrrrWgsz0DatabaseWrapper.mysql_version..)server_version_rematchr| Exceptionr$groups)rrrrr mysql_versionbszDatabaseWrapper.mysql_versioncCsd|jjkS)NZmariadb)r|r])rrrrryisz DatabaseWrapper.mysql_is_mariadb) r9r:r;r2r<ztextr>r8zjson)*r-r.r/vendorZ data_typesZ_limited_data_types operatorsZ pattern_escZ pattern_opsr^rrZSchemaEditorClassr Z client_classr Zcreation_classr Zfeatures_classrZintrospection_classrZ ops_classrZvalidation_classrdrrfrjrmrnrprqrsrvrxrrzr{r|rryrrrrr1cs      %    (  r1)r rr)/r0reZdjango.core.exceptionsrZ django.dbrZdjango.db.backendsZ backend_utilsZdjango.db.backends.base.baserZdjango.utils.asynciorZdjango.utils.functionalrZMySQLdbr ImportErrorerrZMySQLdb.constantsrrZMySQLdb.convertersr clientr Zcreationr rgr rtr operationsrZschemarZ validationr version_infoversion __version__ZTIMEZ typecast_timerXcompiler~rr1rrrrs<   .