U e4^ @s4dZddlZddlmZmZddlmZmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZdd lmZmZdd lmZz|ddlZdd lmZdd lm Z dd l!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,m-Z-m.Z.m/Z/m0Z0Wn4e1k rDZ2zede2e2W5dZ2[2XYnXzddl3m4Z4Wne1k rpdZ5YnXdZ5ddl6m7Z7ddl8m9Z9ddl:m;Z;ddlm?Z?ddl@mAZAddlBmCZCejDjEZEejDjFZFejDjGZGejDjHZHejDjIZIee0dd d!ZJGd"d#d#ZKGd$d%d%eZLGd&d'd'e"ZMdS)(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)datetimetime) AnyDict GeneratorIteratorListOptionalSetTupleUnion)settings)ImproperlyConfigured)IntegrityError)BaseDatabaseWrapper) dateparsetimezone)cached_property)MySQLConnection)CMySQLConnection)MySQLConverter) MySQLCursor) CMySQLCursor) HexLiteral)PooledMySQLConnection)ParamsDictTypeParamsSequenceOrDictTypeParamsSequenceTypeRowType StrOrBytesz&Error loading mysql.connector module: )datetime_to_mysqlFT)DatabaseClient)DatabaseCreation)DatabaseFeatures)DatabaseIntrospection)DatabaseOperations)DatabaseSchemaEditor)DatabaseValidationvaluereturncCsftjrLt|r8td|dtt}t||}| tj j dd}t r\t |}|S|dS)zDEquivalent to DateTimeField.get_db_prep_value. Used only by raw SQL.z!MySQL received a naive datetime (z$) while time zone support is active.N)tzinfoz%Y-%m-%d %H:%M:%S.%f)r ZUSE_TZrZis_naivewarningswarnRuntimeWarningZget_default_timezoneZ make_aware astimezoneutcreplace HAVE_CEXTr strftime)r*Zdefault_timezoneZmysql_datetimer5\/var/www/html/assets/scripts/venv/lib/python3.8/site-packages/mysql/connector/django/base.py$adapt_datetime_with_timezone_supportbs   r7c@seZdZdZdZeeefddddZe e e ddd Z e e e e e dd d Zdee ee eeeefddfd d dZeeeedfeefe eeeefddfd ddZeedddZeedddZdS) 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. )iiiiN)cursorr+cCs ||_dSN)r9selfr9r5r5r6__init__szCursorWrapper.__init__)argsr+cCs<|s|St|}|D]\}}t|trt|||<q|Sr:)dictitems isinstancerr7)r>new_argskeyr*r5r5r6_adapt_execute_args_dicts z&CursorWrapper._adapt_execute_args_dictcCs@|s|St|}t|D]\}}t|trt|||<qt|Sr:)list enumeraterArr7tuple)r>rBiargr5r5r6_adapt_execute_argss z!CursorWrapper._adapt_execute_args)queryr>r+c Csd}t|tr||}n ||}z|j||WStjjk r|}z&|j d|j krjt t |j dW5d}~XYnXdS)zExecutes the given operation This wrapper method around the execute()-method of the cursor is mainly needed to re-raise using different exceptions. Nr) rAr?rDrJr9executemysql connectorOperationalErrorr>codes_for_integrityerrorrrG)r<rKr>rBexcr5r5r6rLs   zCursorWrapper.execute.c Cs^z|j||WStjjk rX}z&|jd|jkrFtt|jdW5d}~XYnXdS)zExecutes the given operation This wrapper method around the executemany()-method of the cursor is mainly needed to re-raise using different exceptions. rN) r9 executemanyrMrNrOr>rPrrG)r<rKr>rQr5r5r6rRs zCursorWrapper.executemanyattrr+cCs t|j|S)z%Return an attribute of wrapped cursor)getattrr9r<rTr5r5r6 __getattr__szCursorWrapper.__getattr__r+cCs t|jS)z&Return an iterator over wrapped cursor)iterr9r<r5r5r6__iter__szCursorWrapper.__iter__)N)__name__ __module__ __qualname____doc__rPr rrr= staticmethodrrDr rrJstrrrrLr rrRrrWrrr[r5r5r5r6r8ts2     r8csPeZdZUdZdZddddddd d d ddd d d ddddd ddddddddddZdZddddddd d!d"d#ddddd$Zd%Zd&d'd(d)d*d+d,Z d-Z e e e d.<d/d0d1d2hZejZeZeZeZeZeZeZeZe e d-d3fd4d5 Z!e e"d6d7d8Z#e$e e fd9d:d;Z%e$e e fe&e'e(e)fd<d=d>Z*d-d9d?d@Z+dae e,dAdBdCZ-d-d9dDdEZ.e"d-dFdGdHZ/e"d9dIdJZ0d-d9dKdLZ1dbe e2e d-dMdNdOZ3e"d9dPdQZ4e5e6e d9dRdSZ7e5e$e e fd9dTdUZ8e5e$e e fd9dVdWZ9e5e d9dXdYZ:e5e;ee d9d]d^Z?e@e"d9d_d`ZAZBS)cDatabaseWrapperz Represent a database connection.rMzinteger 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 mediumblobrcZtinytexttextZ mediumtextrhrgz= %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('%%', {}))rnrorsrurtrvNisolation_levelzread uncommittedzread committedzrepeatable readZ serializable)r>kwargsr+csjtj|||jd}|rV|dt |_|dt}t|tsLtd||_ nt|_ t |_dS)NOPTIONSuse_pureconverter_classzXConverter class should be a subclass of mysql.connector.django.base.DjangoMySQLConverter) superr= settings_dictgetr3 _use_pureDjangoMySQLConverter issubclassProgrammingError converter)r<r>rxoptionsr{ __class__r5r6r=<s   zDatabaseWrapper.__init__rScCs|drdStdS)NZmysql_isF)rsAttributeErrorrVr5r5r6rWPs zDatabaseWrapper.__getattr__rXcCsfddddd}|j}|dr(|d|d<|dr<|d|d<|d rP|d |d <|d d rl|d |d <n|d r|d |d<|drt|d|d<|didr|dd|d<tj|d<tjjj j g|d<zt|d }| d}|r8| }||jkr8dddt|jD}td|d|d||_||Wntk r`YnX|S)Nutf8TF)charsetZ use_unicodebufferedZconsume_resultsUSERuserNAMEZdatabaseZPASSWORDpasswdZHOST/Z unix_sockethostZPORTportryZ init_commandZraise_on_warningsZ client_flagsrwz, css|]}d|dVqdS)'Nr5).0levelr5r5r6 |sz8DatabaseWrapper.get_connection_params..z%Invalid transaction isolation level 'z' specified. Use one of z , or None.)r}rsintr~r DEBUGrMrN constantsZ ClientFlagZ FOUND_ROWScopypoplowerisolation_levelsjoinsortedrrwupdateKeyError)r<rxr}rrwZ valid_levelsr5r5r6get_connection_paramsUsP          z%DatabaseWrapper.get_connection_params) conn_paramsr+cCs"d|krt|d<tjjf|}|S)Nr{)rrMrNconnect)r<rZcnxr5r5r6get_new_connectionsz"DatabaseWrapper.get_new_connectionc Csg}|jjr|d|jr2|d|j|rZ|}|d|W5QRXd|jkrz| |jdWn$t k r| |jdYnXdS)NzSET SQL_AUTO_IS_NULL = 0z(SET SESSION TRANSACTION ISOLATION LEVEL z; Z AUTOCOMMIT) featuresZis_sql_auto_is_null_enabledappendrwupperr9rLrr}Zset_autocommitr_set_autocommit)r<Z assignmentsr9r5r5r6init_connection_states   z%DatabaseWrapper.init_connection_state)namer+cCs|j}t|Sr:) connectionr9r8)r<rr9r5r5r6 create_cursors zDatabaseWrapper.create_cursorcCs(zt|Wntk r"YnXdSr:)r _rollbackNotSupportedErrorrZr5r5r6rszDatabaseWrapper._rollback) autocommitr+c Cs|j||j_W5QRXdSr:)Zwrap_database_errorsrr)r<rr5r5r6rszDatabaseWrapper._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)r9rLr;r5r5r6disable_constraint_checkings 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_rollbackr9rL)r<rr9r5r5r6enable_constraint_checkings  z*DatabaseWrapper.enable_constraint_checking) table_namesr+c Cs|}|dkr|j|}|D]}|j||}|s:q"|j||}|D]\}}}|d|d|d|d|d|d|d|d |d |D]@} td |d | d d|d|d| dd|d|dqqLq"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. Nz+ SELECT REFERRING.`z&`, REFERRING.`z ` FROM `z2` as REFERRING LEFT JOIN `zR` as REFERRED ON ( REFERRING.`z*` = REFERRED.`zE` ) WHERE REFERRING.`z4` IS NOT NULL AND REFERRED.`z"` IS NULL zThe row in table 'z' with primary key 'rz' has an invalid foreign key: .z contains a value 'r!z.' that does not have a corresponding value in )r9 introspectionrZget_primary_key_columnZget_key_columnsrLZfetchallr) r<rr9Z table_nameZprimary_key_column_nameZ key_columnsZ column_nameZreferenced_table_nameZreferenced_column_nameZbad_rowr5r5r6check_constraintssN   6z!DatabaseWrapper.check_constraintscCs.z|jWntk r$YdSXdSdS)NFT)rZpingErrorrZr5r5r6 is_usables zDatabaseWrapper.is_usablecCsdS)z Display name.MySQLr5r5r5r5r6 display_name szDatabaseWrapper.display_namecCs|jjrdddd}|SiS)z= 0)rirjrk)rZ!supports_column_check_constraints)r<rr5r5r6data_type_check_constraintssz+DatabaseWrapper.data_type_check_constraintsc Cs\|}|d|}W5QRX|d|d|dt|dt|dt|ddS) zReturn MySQL server data.a2 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_connectionrLfetchonerd)r<r9rowr5r5r6mysql_server_datas     z!DatabaseWrapper.mysql_server_datac Cs6|$}|d|dW5QRSQRXdS)Return MySQL version.zSELECT VERSION()rN)rrLrr;r5r5r6mysql_server_info6s  z!DatabaseWrapper.mysql_server_info.c Cs.|}tjjf|}|}W5QRX|S)r)rrMrNrZget_server_version)r<configconnZserver_versionr5r5r6 mysql_version=szDatabaseWrapper.mysql_versionc Cs@|}|d|}W5QRXt|r:|ddndS)zReturn SQL mode.zSELECT @@sql_moder,r5)r9rLrsetsplit)r<r9rr5r5r6rEs  zDatabaseWrapper.sql_modecCs |j}|S)z1Return True if pure Python version is being used.)r)r<Zansr5r5r6rzMszDatabaseWrapper.use_pure)N)N)Cr\r]r^r_vendor data_typesZ_limited_data_types operatorsZ pattern_escZ pattern_opsrwr ra__annotations__rrMrNZDatabaser'ZSchemaEditorClassr"Z client_classr#Zcreation_classr$Zfeatures_classr%Zintrospection_classr&Z ops_classr(Zvalidation_classrr=rdrWrrr rrrrrr8rrrrrrrrrr`rrrrr rrr rpropertyrz __classcell__r5r5rr6rbs $  6    0 rbc@seZdZdZedeeeedddZ edeeee dddZ e e eefdd d Ze e eefdd d Zeedd dZdS)rzCustom converter for Django.N)r*dscr+cCst|dS)zXReturn MySQL TIME data type as datetime.time() Returns datetime.time() zutf-8)rZ parse_timedecoder*rr5r5r6_time_to_pythonYsz$DjangoMySQLConverter._time_to_pythoncCs|rt|SdS)aoConnector/Python always returns naive datetime.datetime Connector/Python always returns naive timestamps since MySQL has no time zone support. - A naive datetime is a datetime that doesn't know its own timezone. Django needs a non-naive datetime, but in this method we don't need to make a datetime value time zone aware since Django itself at some point will make it aware (at least in versions 3.2.16 and 4.1.2) when USE_TZ=True. This may change in a future release, we need to keep an eye on this behaviour. Returns datetime.datetime() N)r_datetime_to_pythonrr5r5r6rasz(DjangoMySQLConverter._datetime_to_pythonr)cCs ||Sr:Z _str_to_mysqlr<r*r5r5r6_safestring_to_mysqlvsz)DjangoMySQLConverter._safestring_to_mysqlcCs ||Sr:rrr5r5r6_safetext_to_mysqlysz'DjangoMySQLConverter._safetext_to_mysqlcCs ||Sr:)Z_bytes_to_mysqlrr5r5r6_safebytes_to_mysql|sz(DjangoMySQLConverter._safebytes_to_mysql)N)N)r\r]r^r_r`bytesrr rrrrrar rrrrr5r5r5r6rTsr)Nr_r-rrtypingrrrrrr r r r Z django.confr Zdjango.core.exceptionsrZ django.dbrZdjango.db.backends.base.baserZ django.utilsrrZdjango.utils.functionalrZmysql.connectorrMZmysql.connector.connectionrZmysql.connector.connection_cextrZmysql.connector.conversionrZmysql.connector.cursorrZmysql.connector.cursor_cextrZmysql.connector.custom_typesrZmysql.connector.poolingrZmysql.connector.typesrrrrr ImportErrorerrZ_mysql_connectorr r3clientr"Zcreationr#rr$rr% operationsr&Zschemar'Z validationr(rNrZ DatabaseErrorrrOrr7r8rbrr5r5r5r6sZ ,             "        [