gAdZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZ dd lZdd lmZmZdd lmZd dlmZd dlmZd dlmZd dlm Z d dl!m"Z"d dl#m$Z$d dl%m&Z&ejNZ(e(dkredejRzieejTejViZ,edZ-GddZ.Gdde Z/y #e$rZed ed Z[wwxYw)za MySQL database backend for Django. Requires mysqlclient: https://pypi.org/project/mysqlclient/ )ImproperlyConfigured)IntegrityError)utils)BaseDatabaseWrapper) async_unsafe)cached_property)_lazy_re_compileNz:Error loading MySQLdb module. Did you install mysqlclient?)CLIENT FIELD_TYPE) conversions)DatabaseClient)DatabaseCreation)DatabaseFeatures)DatabaseIntrospection)DatabaseOperations)DatabaseSchemaEditor)DatabaseValidation)r z4mysqlclient 1.4.3 or newer is required; you have %s.z(\d{1,2})\.(\d{1,2})\.(\d{1,2})c4eZdZdZdZdZd dZdZdZdZ y) CursorWrappera6 A thin wrapper around MySQLdb's normal cursor class that catches particular exception instances and reraises them with the correct types. Implemented as a wrapper, rather than a subclass, so that it isn't stuck to the particular underlying representation returned by Connection.cursor(). )iiiic||_yN)cursorselfrs [/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/django/db/backends/mysql/base.py__init__zCursorWrapper.__init__Fs  Nc |jj||S#tj$r<}|jd|j vrt t|jd}~wwxYwNr)rexecuteDatabaseOperationalErrorargscodes_for_integrityerrorrtuplerqueryr&es rr#zCursorWrapper.executeIsb ;;&&ud3 3(( vvayD999$eAFFm44   A-7A((A-c |jj||S#tj$r<}|jd|j vrt t|jd}~wwxYwr")r executemanyr$r%r&r'rr(r)s rr.zCursorWrapper.executemanyTsb ;;**5$7 7(( vvayD999$eAFFm44   r,c.t|j|Sr)getattrr)rattrs r __getattr__zCursorWrapper.__getattr__^st{{D))r c,t|jSr)iterrrs r__iter__zCursorWrapper.__iter__asDKK  r r) __name__ __module__ __qualname____doc__r'rr#r.r2r6r rrr6s(  *!r rc eZdZdZidddddddd d d d d dddddddd dd dddddddddddd dd!d"d#d d$d%d&d'd(d) Zed*Zd+Zd,d-d.d-d/d0d1d2d.d.d-d-d3 Zd4Z d5d6d7d8d9d:d;Z hd<Z e Z e ZeZeZeZeZeZeZd=Zd>Zed?Zfd@ZedOdAZ dBZ!dCZ"dDZ#dEZ$dOdFZ%dGZ&edHZ'edIZ(edJZ)edKZ*edLZ+edMZ,edNZ-xZ.S)PDatabaseWrappermysql 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)) OneToOneFieldPositiveBigIntegerFieldPositiveIntegerFieldPositiveSmallIntegerField SlugFieldSmallAutoFieldSmallIntegerField TextField TimeField UUIDFieldcp|jj}|jjrd|d<|S)Nuuidra) _data_typescopyfeatureshas_native_uuid_field)rrds r data_typeszDatabaseWrapper.data_typess3&&++- == . .'-K $r ) tinyblobblob mediumblobrBtinytexttext mediumtextrWrUz= %szLIKE %szLIKE BINARY %sz> %sz>= %sz< %sz<= %s) exactiexactcontains icontainsgtgteltlte startswithendswith istartswith iendswithzCREPLACE(REPLACE(REPLACE({}, '\\', '\\\\'), '%%', '\%%'), '_', '\_')z"LIKE BINARY CONCAT('%%', {}, '%%')zLIKE CONCAT('%%', {}, '%%')zLIKE BINARY CONCAT({}, '%%')zLIKE CONCAT({}, '%%')zLIKE BINARY CONCAT('%%', {})zLIKE CONCAT('%%', {}))rqrrrwryrxrz>repeatable readread uncommitted serializableread committedc|jSr) mysql_versionr5s rget_database_versionz$DatabaseWrapper.get_database_versions!!!r c Ttdd}|j}|dr|d|d<|dr|d|d<|dr|d|d<|d jd r |d |d <n |d r|d |d <|d rt|d |d<tj |d<|dj }|jdd}|rY|j}||jvr;td|ddjdt|jDd||_ |j||S)Nutf8)convcharsetUSERuserNAMEdatabasePASSWORDpasswordHOST/ unix_sockethostPORTport client_flagOPTIONSisolation_levelr~z%Invalid transaction isolation level 'z' specified. Use one of z, c3&K|] }d|z yw)z'%s'Nr;).0ss r z8DatabaseWrapper.get_connection_params..s!T&1*!Tsz , or None.)django_conversions settings_dictrwintr FOUND_ROWSrepoplowerisolation_levelsrjoinsortedrupdate)rkwargsroptionsrs rget_connection_paramsz%DatabaseWrapper.get_connection_paramssX& **  *62F6N  !.v!6F:   $!.z!:F:   + +C 0$1&$9F= ! 6 "*62F6N   v!67F6N!' 1 1} *//1!++&79IJ -335Od&;&;;*( !TfT=R=R6S!TT  / g r ctjdi|}|jjttur|jj t|S)Nr;)r$connectencodersgetbytesr)r conn_params connections rget_new_connectionz"DatabaseWrapper.get_new_connectionsJ%%4 4    " "5 )U 2    # #E *r ctt|g}|jjr|j d|j r,|j d|j j z|r:|j5}|jdj|dddyy#1swYyxYw)NzSET SQL_AUTO_IS_NULL = 0z*SET SESSION TRANSACTION ISOLATION LEVEL %sz; ) superinit_connection_staterfis_sql_auto_is_null_enabledappendrupperrr#r)r assignmentsr __class__s rrz%DatabaseWrapper.init_connection_state s %' == 4 4   9 :      <&&,,./   7&tyy56 7 7  7 7s !B..B7cL|jj}t|Sr)rrr)rnamers r create_cursorzDatabaseWrapper.create_cursors'')V$$r cb tj|y#tj$rYywxYwr)r _rollbackr$NotSupportedErrorr5s rrzDatabaseWrapper._rollback"s-   ) )$ /))   s ..c||j5|jj|dddy#1swYyxYwr)wrap_database_errorsr autocommit)rrs r_set_autocommitzDatabaseWrapper._set_autocommit(s2  & & 3 OO & &z 2 3 3 3s2;cp|j5}|jddddy#1swYyxYw)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)rr#rs rdisable_constraint_checkingz+DatabaseWrapper.disable_constraint_checking,s2 [[] 7f NN5 6 7 7s,5cd|jc|_} |j5}|jdddd||_y#1swYxYw#||_wxYw)zM Re-enable foreign key checks after they have been disabled. FzSET foreign_key_checks=1N)needs_rollbackrr#)rrrs renable_constraint_checkingz*DatabaseWrapper.enable_constraint_checking6s` /4T5H5H+^ 1 ;&9: ;#1D  ; ;#1D s!AAAA A Ac|j5}||jj|}|D]}|jj||}|s"|jj ||}|j D]m\}\}}|j d|d|d|d|d|d|d|d |d |jD](} td |d | d d|d|d| dd|d|do dddy#1swYyxYw)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 'r z.' that does not have a corresponding value in ) r introspection table_namesget_primary_key_column get_relationsitemsr#fetchallr) rrr table_nameprimary_key_column_name relations column_namereferenced_column_namereferenced_table_namebad_rows rcheck_constraintsz!DatabaseWrapper.check_constraintsCs'[[]. f""00<w>r cB|jjrdddd}|SiS)Nz`%(column)s` >= 0)rYrZr[)rf!supports_column_check_constraints)rrs rdata_type_check_constraintsz+DatabaseWrapper.data_type_check_constraintss- == : :+>(;-@!  % $ r c |j5}|jd|j}dddd|d|dt|dt|dt|ddS#1swY?xYw) 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 rr)versionsql_modedefault_storage_enginesql_auto_is_nulllower_case_table_nameshas_zoneinfo_database)temporary_connectionr#fetchonerD)rrrows rmysql_server_dataz!DatabaseWrapper.mysql_server_datas  & & ( $F NN //#C $ 1vA&)!f $SV &*3q6l%)#a&\    $ $s "A11A:c |jdS)Nr)rr5s rmysql_server_infoz!DatabaseWrapper.mysql_server_infos%%i00r ctj|j}|std|jzt d|j DS)Nz8Unable to determine MySQL version from version string %rc32K|]}t|ywr)r)rxs rrz0DatabaseWrapper.mysql_version..s4SV4s)server_version_rematchr Exceptionr(groups)rrs rrzDatabaseWrapper.mysql_versionsR!''(>(>?J(() 4U\\^444r c:d|jjvS)Nmariadb)rrr5s rrz DatabaseWrapper.mysql_is_mariadbsD2288:::r cd|jd}t|r|jdSdS)Nr,r;)rsetsplit)rrs rrzDatabaseWrapper.sql_modes0))*5(8>>#&;;;;r r)/r7r8r9vendorrdrrh_limited_data_types operators pattern_esc pattern_opsrr$rSchemaEditorClassr client_classrcreation_classrfeatures_classrintrospection_classr ops_classrvalidation_classrrrrrrrrrrrrrrrrrrr __classcell__)rs@rr=r=es F -/ z   .  V   E  . 2 (   8 * !" V#$##4 2%8.3'7K< $&$  I.YK824.2, KH,!L%N%N/"I)"%N7(%% 3 16p??  21155;;<r s 8$5<-36 1*#&&0*(*    Y >AUAUU  334%%GH,!,!^\<)\