a cfKM @sdZddlZddlZddlmZddlmZddlmZddlm Z ddl m Z ddlm Z dd l mZdd lmZmZzddlZdd lmZWn2eyZzed eWYdZ[n dZ[00zdd lmZmZWneydZYn0dZddlmZddlm Z ddl!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(ddl)m*Z*ej+j,Z,ej+j-Z-ej+j.Z.ej+j/Z/ej+j0Z0ddZ1GdddZ2Gddde Z3GdddeZ4dS) aDjango database Backend using MySQL Connector/Python. This Django database backend is heavily based on the MySQL backend from Django. Changes include: * Support for microseconds (MySQL 5.6.3 and later) * Using INFORMATION_SCHEMA where possible * Using new defaults for, for example SQL_AUTO_IS_NULL Requires and comes with MySQL Connector/Python v8.0.22 and later: http://dev.mysql.com/downloads/connector/python/ N)datetime)settings)ImproperlyConfigured)IntegrityError)BaseDatabaseWrapper)utils)cached_property) dateparsetimezone)MySQLConverterz)Error loading mysql.connector module: {0})datetime_to_mysql time_to_mysqlFT)DatabaseClient)DatabaseCreation)DatabaseIntrospection)DatabaseValidation)DatabaseFeatures)DatabaseOperations)DatabaseSchemaEditorcCsbtjrHt|r4td|tt}t||}| tj j dd}t rTt |S|dSdS)NzGMySQL received a naive datetime (%s) while time zone support is active.tzinfoz%Y-%m-%d %H:%M:%S.%f)rUSE_TZr is_naivewarningswarnRuntimeWarningZget_default_timezoneZ make_aware astimezoneutcreplace HAVE_CEXTr strftime)valueZdefault_timezoner#X/home/httpd/docs/test/DocsMgr/lib/python3.9/site-packages/mysql/connector/django/base.py$adapt_datetime_with_timezone_supportUs  r%c@sNeZdZdZdZddZddZddZdd d Zd d Z ddZ ddZ d S) CursorWrapperzWrapper around MySQL Connector/Python's cursor class. The cursor class is defined by the options passed to MySQL Connector/Python. If buffered option is True in those options, MySQLCursorBuffered will be used. )iiiicCs ||_dSN)cursorselfr(r#r#r$__init__sszCursorWrapper.__init__cCs<|s|St|}|D]\}}t|trt|||<q|Sr')dictitems isinstancerr%)r*argsnew_argskeyr"r#r#r$_adapt_execute_args_dictvs z&CursorWrapper._adapt_execute_args_dictcCs@|s|St|}t|D]\}}t|trt|||<qt|Sr')list enumerater.rr%tuple)r*r/r0iargr#r#r$_adapt_execute_argss z!CursorWrapper._adapt_execute_argsNc Cs~t|tr||}n ||}z|j||WStjjyx}z,|j d|j vrbt t |j WYd}~n d}~00dS)zExecutes the given operation This wrapper method around the execute()-method of the cursor is mainly needed to re-raise using different exceptions. rN) r.r,r2r8r(executemysql connectorOperationalErrorr/codes_for_integrityerrorrr5)r*queryr/r0er#r#r$r9s   zCursorWrapper.executec Cs^z|j||WStjjyX}z,|jd|jvrBtt|jWYd}~n d}~00dS)zExecutes the given operation This wrapper method around the executemany()-method of the cursor is mainly needed to re-raise using different exceptions. rN) r( executemanyr:r;r<r/r=rr5)r*r>r/r?r#r#r$r@s zCursorWrapper.executemanycCs t|j|S)z"Return attribute of wrapped cursor)getattrr(r*attrr#r#r$ __getattr__szCursorWrapper.__getattr__cCs t|jS)z$Returns iterator over wrapped cursor)iterr(r*r#r#r$__iter__szCursorWrapper.__iter__)N) __name__ __module__ __qualname____doc__r=r+r2r8r9r@rDrGr#r#r#r$r&es   r&csteZdZdZdddddddd d ddd d d d dddd ddddddddddZdZdddddddd d!d"ddddd#Zd$Zd%d&d'd(d)d*d+Zhd,Z e j Z e ZeZeZeZeZeZeZfd-d.Zd/d0Zd1d2Zd3d4Zd5d6ZdTd8d9Z d:d;Z!dd?Z#d@dAZ$dUdBdCZ%dDdEZ&e'dFdGZ(e'dHdIZ)e'dJdKZ*e'dLdMZ+e'dNdOZ,e'dPdQZ-e.dRdSZ/Z0S)VDatabaseWrapperr:zinteger 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 IntegerFieldZBigIntegerFieldZIPAddressFieldZGenericIPAddressFieldZ JSONFieldZNullBooleanFieldZ OneToOneFieldPositiveBigIntegerFieldPositiveIntegerFieldPositiveSmallIntegerFieldZ SlugFieldZSmallAutoFieldZSmallIntegerFieldZ TextFieldZ TimeFieldZ UUIDField) ZtinyblobZblobZ mediumblobrMZtinytexttextZ mediumtextrRrQz= %szLIKE %szLIKE BINARY %szREGEXP BINARY %sz REGEXP %sz> %sz>= %sz< %sz<= %s)exactZiexactcontains icontainsregexZiregexgtZgteltZlte startswithendswith istartswith iendswithzCREPLACE(REPLACE(REPLACE({}, '\\', '\\\\'), '%%', '\%%'), '_', '\_')z"LIKE BINARY CONCAT('%%', {}, '%%')zLIKE CONCAT('%%', {}, '%%')zLIKE BINARY CONCAT({}, '%%')zLIKE CONCAT({}, '%%')zLIKE BINARY CONCAT('%%', {})zLIKE CONCAT('%%', {}))rXrYr]r_r^r`>zread committedzrepeatable readzread uncommittedZ serializablecsRtt|j|i|z|jdd|_WntyDt |_Yn0t|_dS)NOPTIONSuse_pure) superrLr+ settings_dict _use_pureKeyErrorr DjangoMySQLConverter converter)r*r/kwargs __class__r#r$r+s  zDatabaseWrapper.__init__cCs|drdStdS)NZmysql_isF)r]AttributeErrorrBr#r#r$rDs zDatabaseWrapper.__getattr__cCsddddd}|j}|dr(|d|d<|dr<|d|d<|d rP|d |d <|d d rl|d |d <n|d r|d |d<|drt|d|d<tj|d<tjjjj g|d<z| |dWnt yYn0|S)Nutf8TF)charsetZ use_unicodebufferedZconsume_resultsUSERuserNAMEZdatabaseZPASSWORDpasswdZHOST/Z unix_sockethostZPORTportZraise_on_warningsZ client_flagsra) rdr]intrDEBUGr:r; constantsZ ClientFlagZ FOUND_ROWSupdaterf)r*rirdr#r#r$get_connection_params#s4       z%DatabaseWrapper.get_connection_paramscCs&d|vrt|d<tjjfi|}|S)NZconverter_class)rgr:r;connect)r*Z conn_paramsZcnxr#r#r$get_new_connectionIsz"DatabaseWrapper.get_new_connectioncCsg}|jjr|d|rR| }|d|Wdn1sH0Yd|jvrz||jdWn"ty| |jdYn0dS)NzSET SQL_AUTO_IS_NULL = 0z; Z AUTOCOMMIT) featuresZis_sql_auto_is_null_enabledappendr(r9joinrdZset_autocommitrl_set_autocommit)r*Z assignmentsr(r#r#r$init_connection_statePs  .  z%DatabaseWrapper.init_connection_stateNcCs|j}t|Sr') connectionr(r&)r*namer(r#r#r$ create_cursorcs zDatabaseWrapper.create_cursorcCs&zt|Wnty Yn0dSr')r _rollbackNotSupportedErrorrFr#r#r$rgs zDatabaseWrapper._rollbackcCs2|j||j_Wdn1s$0YdSr')Zwrap_database_errorsr autocommit)r*rr#r#r$rmszDatabaseWrapper._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)r(r9r)r#r#r$disable_constraint_checkingqs (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_rollbackr(r9)r*rr(r#r#r$enable_constraint_checking{s  *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_columnsr9Zfetchallr) r*rr(Z table_nameZprimary_key_column_nameZ key_columnsZ column_nameZreferenced_table_nameZreferenced_column_nameZbad_rowr#r#r$check_constraintss2     z!DatabaseWrapper.check_constraintscCs,z|jWnty"YdS0dSdS)NFT)rZpingErrorrFr#r#r$ is_usables  zDatabaseWrapper.is_usablecCsdS)NMySQLr#rFr#r#r$ display_nameszDatabaseWrapper.display_namecCs|jjrdddd}|SiS)Nz`%(column)s` >= 0)rSrTrU)r~Z!supports_column_check_constraints)r*rr#r#r$data_type_check_constraintssz+DatabaseWrapper.data_type_check_constraintscCsp|"}|d|}Wdn1s00Y|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)versionsql_modeZdefault_storage_engineZsql_auto_is_nullZlower_case_table_namesZhas_zoneinfo_database)temporary_connectionr9fetchonerN)r*r(rowr#r#r$mysql_server_datas  &   z!DatabaseWrapper.mysql_server_datacCsB|&}|d|dWdS1s40YdS)NzSELECT VERSION()r)rr9rr)r#r#r$mysql_server_infos  z!DatabaseWrapper.mysql_server_infocCsF|}tjjfi|}|}Wdn1s80Y|Sr')r{r:r;r|Zget_server_version)r*configconnZserver_versionr#r#r$ mysql_versions&zDatabaseWrapper.mysql_versioncCsT|"}|d|}Wdn1s00Yt|rN|ddndS)NzSELECT @@sql_moder,r#)r(r9rsetsplit)r*r(rr#r#r$rs  &zDatabaseWrapper.sql_modecCs|jSr')rerFr#r#r$rbszDatabaseWrapper.use_pure)N)N)1rHrIrJvendor data_typesZ_limited_data_types operatorsZ pattern_escZ pattern_opsZisolation_levelsr:r;ZDatabaserZSchemaEditorClassrZ client_classrZcreation_classrZfeatures_classrZintrospection_classrZ ops_classrZvalidation_classr+rDr{r}rrrrrrrrrrrrrrrpropertyrb __classcell__r#r#rjr$rLs$  &   (      rLc@s<eZdZdZd ddZdddZddZd d Zd d ZdS)rgzCustom converter for Django.NcCst|dS)zXReturn MySQL TIME data type as datetime.time() Returns datetime.time() zutf-8)r Z parse_timedecode)r*r"dscr#r#r$_TIME_to_pythonsz$DjangoMySQLConverter._TIME_to_pythoncCsB|sdSt||}|dur dStjr>t|r>|jtjd}|S)aConnector/Python always returns naive datetime.datetime Connector/Python always returns naive timestamps since MySQL has no time zone support. Since Django needs non-naive, we need to add the UTC time zone. Returns datetime.datetime() Nr)r Z_DATETIME_to_pythonrrr rrr)r*r"rdtr#r#r$Z__DATETIME_to_pythons  z)DjangoMySQLConverter.__DATETIME_to_pythoncCs ||Sr'Z _str_to_mysqlr*r"r#r#r$_safestring_to_mysqlsz)DjangoMySQLConverter._safestring_to_mysqlcCs ||Sr'rrr#r#r$_safetext_to_mysqlsz'DjangoMySQLConverter._safetext_to_mysqlcCs ||Sr')Z_bytes_to_mysqlrr#r#r$_safebytes_to_mysqlsz(DjangoMySQLConverter._safebytes_to_mysql)N)N) rHrIrJrKrZ)_DjangoMySQLConverter__DATETIME_to_pythonrrrr#r#r#r$rgs   rg)5rKrsysrZ django.confrZdjango.core.exceptionsrZ django.dbrZdjango.db.backends.base.baserrZdjango.utils.functionalrZ django.utilsr r Zmysql.connectorr:Zmysql.connector.conversionr ImportErrorerrformatZ_mysql_connectorr r r clientrZcreationrrrZ validationrr~r operationsrZschemarr;rZ DatabaseErrorrr<ZProgrammingErrorr%r&rLrgr#r#r#r$sP                 LI