o h"^ @s&dZddlZddlmZmZddlmZmZmZmZm 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/m0Z0Wne1yZ2zede2e2dZ2[2wwzddl3m4Z4Wn e1ydZ5YnwdZ5ddl6m7Z7ddl8m9Z9ddl:m;Z;ddlm?Z?ddl@mAZAddlBmCZCejDjEZEejDjFZFejDjGZGejDjHZHejDjIZIded e0fd!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)DatabaseValidationvaluereturncCsftjr&t|rtd|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 USE_TZris_naivewarningswarnRuntimeWarningget_default_timezone make_aware astimezoneutcreplace HAVE_CEXTr strftime)r)default_timezonemysql_datetimer:V/var/www/html/scripts/venv/lib/python3.10/site-packages/mysql/connector/django/base.py$adapt_datetime_with_timezone_supportbs    r<c @seZdZdZdZdeeefddfddZe de de fd d Z e de e de e fd d Z dd ede ede eeeefddffddZd edeeedfeefde eeeefddffddZdedefddZdeefddZdS) 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. )iiiicursorr*NcCs ||_dSN)r>selfr>r:r:r;__init__ zCursorWrapper.__init__argscCs<|s|St|}|D]\}}t|trt|||<q |Sr?)dictitems isinstancerr<)rDnew_argskeyr)r:r:r;_adapt_execute_args_dicts  z&CursorWrapper._adapt_execute_args_dictcCs@|s|St|}t|D]\}}t|trt|||<q t|Sr?)list enumeraterGrr<tuple)rDrHiargr:r:r;_adapt_execute_argss  z!CursorWrapper._adapt_execute_argsqueryc Cstd}t|tr ||}n||}z|j||WStjjy9}z|j d|j vr4t t |j dd}~ww)zExecutes the given operation This wrapper method around the execute()-method of the cursor is mainly needed to re-raise using different exceptions. Nr) rGrErJrPr>executemysql connectorOperationalErrorrDcodes_for_integrityerrorrrM)rArQrDrHexcr:r:r;rRs   zCursorWrapper.execute.c CsPz|j||WStjjy'}z|jd|jvr"tt|jdd}~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> executemanyrSrTrUrDrVrrM)rArQrDrWr:r:r;rXs zCursorWrapper.executemanyattrcCs t|j|S)z%Return an attribute of wrapped cursor)getattrr>rArYr:r:r; __getattr__s zCursorWrapper.__getattr__cCs t|jS)z&Return an iterator over wrapped cursor)iterr>rAr:r:r;__iter__s zCursorWrapper.__iter__r?)__name__ __module__ __qualname____doc__rVr rrrB staticmethodrrJr rrPstrrrrRr rrXrr\rrr_r:r:r:r;r=tsB      r=cseZdZUdZdZiddddddd d d d d ddddddddd dd ddddddddddd d!d dd"d#d$d d%d&d'd(d)d* Zd+Zd,d-d.d-d/d0d1d2d3d4d.d.d-d-d5Zd6Zd7d8d9d:d;dZ e e e d?<hd@ZejZeZeZeZeZeZeZeZdAe dBe dCd>ffdDdE Z!dFe dCe"fdGdHZ#dCe$e e ffdIdJZ%dKe$e e fdCe&e'e(e)ffdLdMZ*dpdNdOZ+dqdPe dCe,fdQdRZ-dpdSdTZ.dUe"dCd>fdVdWZ/dCe"fdXdYZ0dpdZd[Z1dqd\e e2e dCd>fd]d^Z3dCe"fd_d`Z4e5e6dCe fdadbZ7e5dCe$e e ffdcddZ8e5dCe$e e ffdedfZ9e5dCe fdgdhZ:e5dCe;ee fdldmZ?e@dCe"fdndoZAZBS)rDatabaseWrapperz Represent a database connection.rS AutoFieldzinteger AUTO_INCREMENT BigAutoFieldzbigint AUTO_INCREMENT BinaryFieldlongblob BooleanFieldbool CharFieldzvarchar(%(max_length)s) DateFielddate DateTimeFieldz datetime(6) DecimalFieldz+numeric(%(max_digits)s, %(decimal_places)s) DurationFieldbigint FileField FilePathField FloatFieldzdouble precision IntegerFieldintegerBigIntegerFieldIPAddressFieldzchar(15)GenericIPAddressFieldzchar(39) JSONFieldjsonzbigint UNSIGNEDzinteger UNSIGNEDzsmallint UNSIGNEDzsmallint AUTO_INCREMENTsmallintlongtextztime(6)zchar(32)) NullBooleanField OneToOneFieldPositiveBigIntegerFieldPositiveIntegerFieldPositiveSmallIntegerField SlugFieldSmallAutoFieldSmallIntegerField TextField TimeField UUIDField) tinyblobblob mediumblobrjtinytexttext mediumtextrr}z= %szLIKE %szLIKE BINARY %szREGEXP BINARY %sz REGEXP %sz> %sz>= %sz< %sz<= %s)exactiexactcontains icontainsregexiregexgtgteltlte startswithendswith istartswith iendswithzCREPLACE(REPLACE(REPLACE({}, '\\', '\\\\'), '%%', '\%%'), '_', '\_')z"LIKE BINARY CONCAT('%%', {}, '%%')zLIKE CONCAT('%%', {}, '%%')zLIKE BINARY CONCAT({}, '%%')zLIKE CONCAT({}, '%%')zLIKE BINARY CONCAT('%%', {})zLIKE CONCAT('%%', {}))rrrrrrNisolation_level>read committedrepeatable readread uncommitted serializablerDkwargsr*csptj|i||jd}|r.|dt |_|dt}t|ts(td||_ dSt|_ t |_dS)NOPTIONSuse_pureconverter_classzXConverter class should be a subclass of mysql.connector.django.base.DjangoMySQLConverter) superrB settings_dictgetr6 _use_pureDjangoMySQLConverter issubclassProgrammingError converter)rArDroptionsr __class__r:r;rB<s    zDatabaseWrapper.__init__rYcCs|drdSt)Nmysql_isF)rAttributeErrorr[r:r:r;r\Ps zDatabaseWrapper.__getattr__cCs^ddddd}|j}|dr|d|d<|dr|d|d<|d r(|d |d <|d d r6|d |d <n |d r@|d |d<|drLt|d|d<|didr]|dd|d<tj|d<tjjj j g|d<z9|d }| d}|r| }||jvrdddt|jD}td|d|d||_||W|StyY|Sw)Nutf8TF)charset use_unicodebufferedconsume_resultsUSERuserNAMEdatabasePASSWORDpasswdHOST/ unix_sockethostPORTportr init_commandraise_on_warnings client_flagsrz, css|] }d|dVqdS)'Nr:).0levelr:r:r; |s  z8DatabaseWrapper.get_connection_params..z%Invalid transaction isolation level 'z' specified. Use one of z , or None.)rrintrr DEBUGrSrT constants ClientFlag FOUND_ROWScopypoplowerisolation_levelsjoinsortedrrupdateKeyError)rArrrr valid_levelsr:r:r;get_connection_paramsUsX            z%DatabaseWrapper.get_connection_params conn_paramscCs&d|vrt|d<tjjdi|}|S)Nrr:)rrSrTconnect)rArcnxr:r:r;get_new_connectionsz"DatabaseWrapper.get_new_connectioncCsg}|jjr |d|jr|d|j|r7|}|d|Wdn1s2wYd|jvrZz | |jdWdSt yY| |jdYdSwdS)NzSET SQL_AUTO_IS_NULL = 0z(SET SESSION TRANSACTION ISOLATION LEVEL z; AUTOCOMMIT) featuresis_sql_auto_is_null_enabledappendrupperr>rRrrset_autocommitr_set_autocommit)rA assignmentsr>r:r:r;init_connection_states(    z%DatabaseWrapper.init_connection_statenamecCs|j}t|Sr?) connectionr>r=)rArr>r:r:r; create_cursors zDatabaseWrapper.create_cursorcCs&zt|WdStyYdSwr?)r _rollbackNotSupportedErrorr^r:r:r;rs  zDatabaseWrapper._rollback autocommitcCs4|j ||j_WddS1swYdSr?)wrap_database_errorsrr)rArr:r:r;rs "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>rRr@r:r:r;disable_constraint_checkings   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>rR)rArr>r:r:r;enable_constraint_checkings   z*DatabaseWrapper.enable_constraint_checking table_namesc Cs|s}|dur|j|}|D]]}|j||}|sq|j||}|D]G\}}}|d|d|d|d|d|d|d|d |d |D]} td |d | d d|d|d| dd|d|dq&qWddS1szwYdS)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 )r> introspectionrget_primary_key_columnget_key_columnsrRfetchallr) rArr> table_nameprimary_key_column_name key_columns column_namereferenced_table_namereferenced_column_namebad_rowr:r:r;check_constraintssl     "z!DatabaseWrapper.check_constraintscCs&z|jWdStyYdSw)NFT)rpingErrorr^r:r:r; is_usables   zDatabaseWrapper.is_usablecCsdS)z Display name.MySQLr:r:r:r:r; display_nameszDatabaseWrapper.display_namecCs|jjr dddd}|SiS)z= 0)rrr)r!supports_column_check_constraints)rArr:r:r;data_type_check_constraintssz+DatabaseWrapper.data_type_check_constraintscCsp|}|d|}Wdn1swY|d|d|dt|dt|dt|dd S) 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 Nrr!)versionsql_modedefault_storage_enginesql_auto_is_nulllower_case_table_nameshas_zoneinfo_database)temporary_connectionrRfetchonerl)rAr>rowr:r:r;mysql_server_datas     z!DatabaseWrapper.mysql_server_datacCsB|}|d|dWdS1swYdS)Return MySQL version.zSELECT VERSION()rN)rrRrr@r:r:r;mysql_server_info5s   $z!DatabaseWrapper.mysql_server_info.cCsH|}tjjdi| }|}Wd|S1swY|S)rNr:)rrSrTrget_server_version)rAconfigconnserver_versionr:r:r; mysql_version<s  zDatabaseWrapper.mysql_versioncCsV|}|d|}Wdn1swYt|r(|ddSdS)zReturn SQL mode.zSELECT @@sql_modeNr,r:)r>rRrsetsplit)rAr>r r:r:r;r Ds   zDatabaseWrapper.sql_modecCs |j}|S)z1Return True if pure Python version is being used.)r)rAansr:r:r;rLszDatabaseWrapper.use_pure)r*Nr?)Cr`rarbrcvendor data_types_limited_data_types operators pattern_esc pattern_opsrr re__annotations__rrSrTDatabaser'SchemaEditorClassr" client_classr#creation_classr$features_classr%introspection_classr& ops_classr(validation_classrrBrlr\rrr rrrrrr=rrrrrrrrrrdrrrrr rrr r propertyr __classcell__r:r:rr;rfs      $  5      0 rfc @seZdZdZeddededeefddZ eddededee fdd Z de de eeffd d Zde de eeffd d ZdedefddZdS)rzCustom converter for Django.Nr)dscr*cCst|dS)zXReturn MySQL TIME data type as datetime.time() Returns datetime.time() zutf-8)r parse_timedecoder)r2r:r:r;_time_to_pythonXsz$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_pythonr5r:r:r;r7`sz(DjangoMySQLConverter._datetime_to_pythoncC ||Sr? _str_to_mysqlrAr)r:r:r;_safestring_to_mysqlurCz)DjangoMySQLConverter._safestring_to_mysqlcCr8r?r9r;r:r:r;_safetext_to_mysqlxrCz'DjangoMySQLConverter._safetext_to_mysqlcCr8r?)_bytes_to_mysqlr;r:r:r;_safebytes_to_mysql{rCz(DjangoMySQLConverter._safebytes_to_mysqlr?)r`rarbrcrdbytesrr rr6rr7rer rr<r=r?r:r:r:r;rSsr)Nrcr.rrtypingrrrrrr r r r django.confr django.core.exceptionsr django.dbrdjango.db.backends.base.baser django.utilsrrdjango.utils.functionalrmysql.connectorrSmysql.connector.connectionrmysql.connector.connection_cextrmysql.connector.conversionrmysql.connector.cursorrmysql.connector.cursor_cextrmysql.connector.custom_typesrmysql.connector.poolingrmysql.connector.typesrrrrr ImportErrorerr_mysql_connectorr r6clientr"creationr#rr$rr% operationsr&schemar' validationr(rTr DatabaseErrorrrUrr<r=rfrr:r:r:r;sb ,                     [