o bM @sdZddlZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Zdd lmZdd lmZdd lmZmZzddlZdd lmZmZWneycZzed edZ[wwz ddlmZmZWn eyydZ YnwdZ ddl!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.ej/j0Z0ej/j1Z1ej/j2Z2ej/j3Z3ej/j4Z4ddZ5GdddZ6GdddeZ Gdd d eZ7Gd!d"d"eZ8dS)#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)DatabaseWrapper)utils)cached_property) dateparsetimezone)MySQLConverterMySQLConverterBasez)Error loading mysql.connector module: {0})datetime_to_mysql time_to_mysqlFT)DatabaseClient)DatabaseCreation)DatabaseIntrospection)DatabaseValidation)DatabaseFeatures)DatabaseOperations)DatabaseSchemaEditorcCs^tjr$t|rtd|tt}t||}| tj j dd}t r*t |S|dS)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_CEXTrstrftime)valueZdefault_timezoner%Z/var/www/secure340b-portal/env/lib/python3.10/site-packages/mysql/connector/django/base.py$adapt_datetime_with_timezone_supportVs   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__t zCursorWrapper.__init__cCs<|s|St|}|D]\}}t|trt|||<q |Sr))dictitems isinstancerr')r,argsnew_argskeyr$r%r%r&_adapt_execute_args_dictws  z&CursorWrapper._adapt_execute_args_dictcCs@|s|St|}t|D]\}}t|trt|||<q t|Sr))list enumerater1rr'tuple)r,r2r3iargr%r%r&_adapt_execute_argss  z!CursorWrapper._adapt_execute_argsNc Csnt|tr ||}n||}z|j||WStjjy6}z|j d|j vr1t t |j d}~ww)zExecutes the given operation This wrapper method around the execute()-method of the cursor is mainly needed to re-raise using different exceptions. rN) r1r/r5r;r*executemysql connectorOperationalErrorr2codes_for_integrityerrorrr8)r,queryr2r3er%r%r&r<s   zCursorWrapper.executec CsNz|j||WStjjy&}z|jd|jvr!tt|jd}~ww)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?r2r@rr8)r,rAr2rBr%r%r&rCszCursorWrapper.executemanycCs t|j|S)z"Return attribute of wrapped cursor)getattrr*r,attrr%r%r& __getattr__s zCursorWrapper.__getattr__cCs t|jS)z$Returns iterator over wrapped cursor)iterr*r,r%r%r&__iter__s zCursorWrapper.__iter__r)) __name__ __module__ __qualname____doc__r@r-r5r;r<rCrGrJr%r%r%r&r(fs  r(cseZdZdZidddddddd d d d d dddddddd dd dddddddddddd d dd!d"d#d d$d%d&d'd(d) Zd*Zd+d,d-d,d.d/d0d1d2d3d-d-d,d,d4Zd5Zd6d7d8d9d:d;d<Zhd=Z e j Z e ZeZeZeZeZeZeZfd>d?Zd@dAZdBdCZdDdEZdFdGZdcdIdJZ dKdLZ!dMdNZ"dOdPZ#dQdRZ$dcdSdTZ%dUdVZ&e'dWdXZ(e'dYdZZ)e'd[d\Z*e'd]d^Z+e'd_d`Z,e-dadbZ.Z/S)drr=Z 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)Z JSONFieldjsonzbigint UNSIGNEDzinteger UNSIGNEDzsmallint UNSIGNEDzsmallint AUTO_INCREMENTZsmallintlongtextztime(6)zchar(32)) ZNullBooleanFieldZ OneToOneFieldPositiveBigIntegerFieldPositiveIntegerFieldPositiveSmallIntegerFieldZ SlugFieldZSmallAutoFieldZSmallIntegerFieldZ TextFieldZ TimeFieldZ UUIDField) ZtinyblobZblobZ mediumblobrOZtinytexttextZ mediumtextrTrSz= %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('%%', {}))rZr[r_rar`rb> serializableread committedrepeatable readread uncommittedcsdtt|j|i|z |jdd|_Wn ty"t |_Ynw|jr,t|_ dSt |_ dS)NOPTIONSuse_pure) superrr- settings_dict _use_pureKeyErrorr"rhDjangoMySQLConverterDjangoCMySQLConverter converter)r,r2kwargs __class__r%r&r-s  zDatabaseWrapper.__init__cCs|drdSt)NZmysql_isF)r_AttributeErrorrEr%r%r&rG s zDatabaseWrapper.__getattr__cCsddddd}|j}|dr|d|d<|dr|d|d<|d r(|d |d <|d d r6|d |d <n |d r@|d |d<|drLt|d|d<tj|d<tjjjj g|d<z | |dW|St ynY|Sw)Nutf8TF)charsetZ use_unicodebufferedZconsume_resultsUSERuserNAMEZdatabaseZPASSWORDpasswdZHOST/Z unix_sockethostZPORTportZraise_on_warningsZ client_flagsrg) rjr_intrDEBUGr=r> constantsZ ClientFlagZ FOUND_ROWSupdaterl)r,rprjr%r%r&get_connection_params%s8       z%DatabaseWrapper.get_connection_paramscCs.|jst|d<nt|d<tjjdi|}|S)NZconverter_classr%)rhrnrmr=r>connect)r,Z conn_paramsZcnxr%r%r&get_new_connectionKs  z"DatabaseWrapper.get_new_connectioncCsg}|jjr |d|r)|}|d|Wdn1s$wYd|jvrLz ||jdWdStyK| |jdYdSwdS)NzSET SQL_AUTO_IS_NULL = 0z; Z AUTOCOMMIT) featuresZis_sql_auto_is_null_enabledappendr*r<joinrjZset_autocommitrs_set_autocommit)r,Z assignmentsr*r%r%r&init_connection_stateTs    z%DatabaseWrapper.init_connection_stateNcCs|j}t|Sr)) connectionr*r()r,namer*r%r%r& create_cursorgs zDatabaseWrapper.create_cursorcCs&zt|WdStyYdSwr))r _rollbackNotSupportedErrorrIr%r%r&rks  zDatabaseWrapper._rollbackcCs4|j ||j_WddS1swYdSr))Zwrap_database_errorsr autocommit)r,rr%r%r&rqs "zDatabaseWrapper._set_autocommitcCs8|}|dWddS1swYdS)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_checkingus   z+DatabaseWrapper.disable_constraint_checkingcCsbd|j|_}z%| }|dWdn1swYW||_dSW||_dS||_w)zM Re-enable foreign key checks after they have been disabled. FzSET foreign_key_checks=1N)needs_rollbackr*r<)r,rr*r%r%r&enable_constraint_checkings   z*DatabaseWrapper.enable_constraint_checkingc Cs|W}|dur|j|}|D]A}|j||}|sq|j||}|D]+\}}}|d||||||||f|D]} td|| d||| d||fq&qWddS1s^wYdS)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_columnsr<Zfetchallr) r,rr*Z table_nameZprimary_key_column_nameZ key_columnsZ column_nameZreferenced_table_nameZreferenced_column_nameZbad_rowr%r%r&check_constraintss:     "z!DatabaseWrapper.check_constraintscCs&z|jWdStyYdSw)NFT)rZpingErrorrIr%r%r& is_usables   zDatabaseWrapper.is_usablecCsdS)NMySQLr%rIr%r%r& display_nameszDatabaseWrapper.display_namecCs|jjr dddd}|SiS)Nz`%(column)s` >= 0)rUrVrW)rZ!supports_column_check_constraints)r,rr%r%r&data_type_check_constraintssz+DatabaseWrapper.data_type_check_constraintscCsB|}|d|dWdS1swYdS)NzSELECT VERSION()r)Ztemporary_connectionr<fetchoner+r%r%r&mysql_server_infos   $z!DatabaseWrapper.mysql_server_infocCsH|}tjjdi| }|}Wd|S1swY|S)Nr%)rr=r>rZget_server_version)r,configconnZserver_versionr%r%r& mysql_versions  zDatabaseWrapper.mysql_versioncCsV|}|d|}Wdn1swYt|r(|ddSdS)NzSELECT @@sql_moder,r%)r*r<rsetsplit)r,r*sql_moder%r%r&rs   zDatabaseWrapper.sql_modecCs|jSr))rkrIr%r%r&rhszDatabaseWrapper.use_purer))0rKrLrMvendor data_typesZ_limited_data_types operatorsZ pattern_escZ pattern_opsZisolation_levelsr=r>ZDatabaserZSchemaEditorClassrZ client_classrZcreation_classrZfeatures_classrZintrospection_classrZ ops_classrZvalidation_classr-rGrrrrrrrrrrr rrrrrpropertyrh __classcell__r%r%rqr&rs     $   &  (     rc@s<eZdZdZd ddZd ddZddZd d Zd d ZdS)rmz/Custom converter for Django for MySQLConnectionNcCst|dS)XReturn MySQL TIME data type as datetime.time() Returns datetime.time() zutf-8)r parse_timedecoder,r$dscr%r%r&_TIME_to_pythonsz$DjangoMySQLConverter._TIME_to_pythoncCsB|sdSt||}|durdStjrt|r|jtjd}|SaConnector/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 rr!r )r,r$rdtr%r%r&__DATETIME_to_pythons  z)DjangoMySQLConverter.__DATETIME_to_pythoncC ||Sr)Z _str_to_mysqlr,r$r%r%r&_safestring_to_mysqlr.z)DjangoMySQLConverter._safestring_to_mysqlcCrr)rrr%r%r&_safetext_to_mysqlr.z'DjangoMySQLConverter._safetext_to_mysqlcCrr))Z_bytes_to_mysqlrr%r%r&_safebytes_to_mysqlr.z(DjangoMySQLConverter._safebytes_to_mysqlr)) rKrLrMrNrZ)_DjangoMySQLConverter__DATETIME_to_pythonrrrr%r%r%r&rms   rmc@s$eZdZdZdddZdddZdS)rnz0Custom converter for Django for CMySQLConnectionNcCstt|S)r)r rstrrr%r%r&r sz%DjangoCMySQLConverter._TIME_to_pythoncCs*|sdStjrt|r|jtjd}|Sr)rrr rr!r rr%r%r&rs  z*DjangoCMySQLConverter.__DATETIME_to_pythonr))rKrLrMrNrZ*_DjangoCMySQLConverter__DATETIME_to_pythonr%r%r%r&rn s rn)9rNrsysrZ django.confrZdjango.core.exceptionsrZ django.dbrZdjango.db.backends.base.baserZdjango.db.backends.mysql.baserZMySQLDatabaseWrapperrZdjango.utils.functionalr Z django.utilsr r Zmysql.connectorr=Zmysql.connector.conversionr r ImportErrorerrformatZ_mysql_connectorrrr"clientrZcreationrrrZ validationrrr operationsrZschemarr>rZ DatabaseErrorrr?ZProgrammingErrorr'r(rmrnr%r%r%r&s\                 L5%