"i4OBdZddlZddlZddlmZddlmZddlmZddlm Z ddl m Z ddlm Z dd l mZdd lmZmZ ddlZdd lmZn+#e$r#Zed edZ[wwxYw dd lmZmZdZn #e$rdZYnwxYwddlmZddlm 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+j0Z0dZ1GddZ2Gdde Z3GddeZ4dS)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_mysqlTF)DatabaseClient)DatabaseCreation)DatabaseIntrospection)DatabaseValidation)DatabaseFeatures)DatabaseOperations)DatabaseSchemaEditorctjrtj|rEt jd|zt tj}tj||}| tj  d}trt|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_naivewarningswarnRuntimeWarningget_default_timezone make_aware astimezoneutcreplace HAVE_CEXTr strftime)valuedefault_timezones S/srv/django_bis/venv311/lib/python3.11/site-packages/mysql/connector/django/base.py$adapt_datetime_with_timezone_supportr)UsD  U # # A M@BGH( * * * (<>> '/?@@E  ..66d6CC6 '''~~4555cBeZdZdZdZdZdZdZd dZdZ d Z d Z dS) 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. )iiiic||_dSN)cursorselfr/s r(__init__zCursorWrapper.__init__ss  r*c|s|St|}|D],\}}t|trt |||<-|Sr.)dictitems isinstancerr))r1argsnew_argskeyr&s r(_adapt_execute_args_dictz&CursorWrapper._adapt_execute_args_dictvsa K::**,, L LJC%** L DU K K r*c|s|St|}t|D],\}}t|trt |||<-t |Sr.)list enumerater6rr)tuple)r1r7r8iargs r(_adapt_execute_argsz!CursorWrapper._adapt_execute_argssf K::oo H HFAs#x(( HB3GG Xr*NcRt|tr||}n||} |j||S#t jj$r5}|j d|j vrtt|j d}~wwxYw)zExecutes the given operation This wrapper method around the execute()-method of the cursor is mainly needed to re-raise using different exceptions. rN) r6r4r:rAr/executemysql connectorOperationalErrorr7codes_for_integrityerrorrr>)r1queryr7r8es r(rCzCursorWrapper.executes dD ! ! 644T::HH//55H ;&&uh77 7/   vayD999$eAFmm44  sAB&10B!!B&c |j||S#tjj$r5}|jd|jvrtt|jd}~wwxYw)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/ executemanyrDrErFr7rGrr>)r1rHr7rIs r(rKzCursorWrapper.executemanysm  ;**5$77 7/   vayD999$eAFmm44  sA&0A!!A&c,t|j|S)z"Return attribute of wrapped cursor)getattrr/r1attrs r( __getattr__zCursorWrapper.__getattr__st{D)))r*c*t|jS)z$Returns iterator over wrapped cursor)iterr/r1s r(__iter__zCursorWrapper.__iter__sDK   r*r.) __name__ __module__ __qualname____doc__rGr2r:rArCrKrPrTr*r(r,r,es  "   ***!!!!!r*r,ceZdZdZidddddddd 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>Zd?Zd@ZdAZdBZdRdDZ dEZ!dFZ"dGZ#dHZ$dRdIZ%dJZ&e'dKZ(e'dLZ)e'dMZ*e'dNZ+e'dOZ,e'dPZ-e.dQZ/xZ0S)SDatabaseWrapperrD 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 mediumblobr_tinytexttext mediumtextrtrrz= %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('%%', {}))rrrrrr>read committedrepeatable readread uncommitted serializablectt|j|i||jd}|rq|dt |_|dt}t|tstd||_ dSt|_ t |_dS)NOPTIONSuse_pureconverter_classzXConverter class should be a subclass of mysql.connector.django.base.DjangoMySQLConverter) superr[r2 settings_dictgetr$ _use_pureDjangoMySQLConverter issubclassProgrammingError converter)r1r7kwargsoptionsr __class__s r(r2zDatabaseWrapper.__init__s-ot$$-t>v>>>$((33  ,$[[]CCDN%kk!$Oo/CDD &G-_..DNNN244T^"+mT^^^r*c>|drdSt)Nmysql_isF)rAttributeErrorrNs r(rPzDatabaseWrapper.__getattr__(s! ??: & & 5r*cddddd}|j}|dr |d|d<|dr |d|d<|d r |d |d <|d d r |d |d <n|d r |d |d<|drt|d|d<tj|d<t jjjj g|d< | |dn#t$rYnwxYw|S)Nutf8TF)charset use_unicodebufferedconsume_resultsUSERuserNAMEdatabasePASSWORDpasswdHOST/ unix_sockethostPORTportraise_on_warnings client_flagsr) rrintrDEBUGrDrE constants ClientFlag FOUND_ROWSupdateKeyError)r1rrs r(get_connection_paramsz%DatabaseWrapper.get_connection_params-sS#   *   3*62F6N   7!.v!6F:   $ 9,Z8F8   + +C 0 0 3$1&$9F= ! ! 6 " 3*62F6N   8 v!677F6N'/n"# O % 0 ;" ~  MM- 2 3 3 3 3    D  sC-- C:9C:cNd|vr t|d<tjjdi|}|S)NrrY)rrDrEconnect)r1 conn_paramscnxs r(get_new_connectionz"DatabaseWrapper.get_new_connectionSs5 K//-AK) *o%44 44 r*cg}|jjr|d|rT|5}|d|dddn #1swxYwYd|jvrT ||jddS#t$r$| |jdYdSwxYwdS)NzSET SQL_AUTO_IS_NULL = 0z; AUTOCOMMIT) featuresis_sql_auto_is_null_enabledappendr/rCjoinrset_autocommitr_set_autocommit)r1 assignmentsr/s r(init_connection_statez%DatabaseWrapper.init_connection_stateZs5 = 4 ;   9 : : :  7 7&tyy55666 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 4- - - G##D$6|$DEEEEE! G G G$$T%7 %EFFFFFF G . -s#)A//A36A3 B&&*CCNcR|j}t|Sr.) connectionr/r,)r1namer/s r( create_cursorzDatabaseWrapper.create_cursorms#''))V$$$r*cR tj|dS#t$rYdSwxYwr.)r _rollbackNotSupportedErrorrSs r(rzDatabaseWrapper._rollbackqs@   )$ / / / / /     DD s  &&c^|j5||j_ddddS#1swxYwYdSr.)wrap_database_errorsr autocommit)r1rs r(rzDatabaseWrapper._set_autocommitwsy  & 4 4)3DO & 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4s "&&c|5}|ddddn #1swxYwYdS)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/rCr0s r(disable_constraint_checkingz+DatabaseWrapper.disable_constraint_checking{s| [[]] 7f NN5 6 6 6 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7ts 7;;cd|jc|_} |5}|ddddn #1swxYwY||_dS#||_wxYw)zM Re-enable foreign key checks after they have been disabled. FzSET foreign_key_checks=1N)needs_rollbackr/rC)r1rr/s r(enable_constraint_checkingz*DatabaseWrapper.enable_constraint_checkings /4T5H+^ 1 ;&9::: ; ; ; ; ; ; ; ; ; ; ; ; ; ; ;#1D   .D  0 0 0 0s-AA AA  AA A A$c|5}||j|}|D]}|j||}|s |j||}|D]{\}}}|d|d|d|d|d|d|d|d |d |D]2} td |d | d d|d|d| dd|d|d| ddddS#1swxYwYdS)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 `z5` as REFERRED ON (REFERRING.`z` = REFERRED.`z,`) WHERE REFERRING.`z` 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 'rz.' that does not have a corresponding value in )r/ introspection table_namesget_primary_key_columnget_key_columnsrCfetchallr) r1rr/ table_nameprimary_key_column_name key_columns column_namereferenced_table_namereferenced_column_namebad_rows r(check_constraintsz!DatabaseWrapper.check_constraintss[[]] f""0<= 0)rwrxry)r!supports_column_check_constraints)r1rs r(data_type_check_constraintsz+DatabaseWrapper.data_type_check_constraintss2 = : %+>(;-@!!  % $ r*c T|5}|d|}dddn #1swxYwY|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_modedefault_storage_enginesql_auto_is_nulllower_case_table_nameshas_zoneinfo_database)temporary_connectionrCfetchonera)r1r/rows r(mysql_server_dataz!DatabaseWrapper.mysql_server_datas  & & ( ( $F NN   //##C $ $ $ $ $ $ $ $ $ $ $ $ $ $ $1vA&)!f $SV &*3q6ll%)#a&\\    *A  AAc|5}|d|dcdddS#1swxYwYdS)NzSELECT VERSION()r)rrCr r0s r(mysql_server_infoz!DatabaseWrapper.mysql_server_infos  & & ( ( (F NN- . . .??$$Q' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (s/AAAc|}tjjdi|5}|}dddn #1swxYwY|S)NrY)rrDrErget_server_version)r1configconnserver_versions r( mysql_versionzDatabaseWrapper.mysql_versions++-- _ $ . .v . . 7$!4466N 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7sA  AAc|5}|d|}dddn #1swxYwYt|r|ddndS)NzSELECT @@sql_moder,rY)r/rCr setsplit)r1r/rs r(rzDatabaseWrapper.sql_modes [[]] )f NN. / / /((H ) ) ) ) ) ) ) ) ) ) ) ) ) ) )X=8A;$$S)))2>>>r c|jSr.)rrSs r(rzDatabaseWrapper.use_pures ~r*r.)1rUrVrWvendor data_types_limited_data_types operators pattern_esc pattern_opsisolation_levelsrDrEDatabaserSchemaEditorClassr client_classrcreation_classrfeatures_classrintrospection_classr ops_classrvalidation_classr2rPrrrrrrrrrrr rrr rrrpropertyr __classcell__)rs@r(r[r[s^ F -/ z   .  V   E  . 2 (   8 * !" V#$#"#4 2%8.3'9JH $#&$ I2YK824.2, KH,!L%N%N/"I),,,,,( $$$LGGG&%%%% 444 1 1 1&&&&P__  _ .((_( _ ??_? Xr*r[c4eZdZdZddZddZdZdZdZdS) rzCustom converter for Django.NcPtj|dS)zXReturn MySQL TIME data type as datetime.time() Returns datetime.time() zutf-8)r parse_timedecode)r1r&dscs r(_TIME_to_pythonz$DjangoMySQLConverter._TIME_to_pythons! #ELL$9$9:::r*c|sdStj||}|dStjr4t j|r |tj}|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 _DATETIME_to_pythonrrr rr#r")r1r&r/dts r(__DATETIME_to_pythonz)DjangoMySQLConverter.__DATETIME_to_python sc 4  /e < < :4 ? 1x044 18<00B r*c,||Sr. _str_to_mysqlr1r&s r(_safestring_to_mysqlz)DjangoMySQLConverter._safestring_to_mysql!!%(((r*c,||Sr.r6r8s r(_safetext_to_mysqlz'DjangoMySQLConverter._safetext_to_mysql r:r*c,||Sr.)_bytes_to_mysqlr8s r(_safebytes_to_mysqlz(DjangoMySQLConverter._safebytes_to_mysql#s##E***r*r.) rUrVrWrXr0)_DjangoMySQLConverter__DATETIME_to_pythonr9r<r?rYr*r(rrso&&;;;;$))))))+++++r*r)5rXrsysr django.confrdjango.core.exceptionsr django.dbrdjango.db.backends.base.baserrdjango.utils.functionalr django.utilsr r mysql.connectorrDmysql.connector.conversionr ImportErrorerrformat_mysql_connectorr rr$clientrcreationrrr validationrrr operationsrschemarrEr DatabaseErrorrrFrr)r,r[rrYr*r(rTs:    777777$$$$$$<<<<<<333333,,,,,,,,A9999999AAA  3::3?? A AAAAAAAAAAAIIIII #"""""&&&&&&000000******&&&&&&******(((((( - O5?3?3 6 6 6 I!I!I!I!I!I!I!I!XNNNNN)NNNb "+"+"+"+"+>"+"+"+"+"+s) A A1A,,A15BB  B