o [hA @sRdZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZzdd lZWneyCZzed ed Z[wwdd lmZmZdd lmZd dlmZd dlmZd dlmZd dlm Z d dl!m"Z"d dl#m$Z$d dl%m&Z&ej'Z(e(dkredej)ieej*ej+iZ,edZ-GdddZ.Gddde Z/d S)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})c@s>eZdZdZdZddZdddZdd Zd d Zd d Z dS) 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(). )iiiicCs ||_dSN)cursorselfrr/home/ubuntu/experiments/live_experiments/Pythonexperiments/Otree/venv/lib/python3.10/site-packages/django/db/backends/mysql/base.py__init__F zCursorWrapper.__init__Nc CLz|j||WStjy%}z|jd|jvr tt|jd}~wwNr)rexecuteDatabaseOperationalErrorargscodes_for_integrityerrorrtuplerqueryr$errrr!IszCursorWrapper.executec Crr )r executemanyr"r#r$r%rr&r'rrrr*TszCursorWrapper.executemanycCs t|j|Sr)getattrr)rattrrrr __getattr__^s zCursorWrapper.__getattr__cCs t|jSr)iterrrrrr__iter__arzCursorWrapper.__iter__r) __name__ __module__ __qualname____doc__r%rr!r*r-r0rrrrr6s   rc seZdZdZidddddddd d d d d dddddddd dd dddddddddddd dd!d"d#d d$d%d&d'd(d) Zed*d+Zd,Zd-d.d/d.d0d1d2d3d/d/d.d.d4 Zd5Z d6d7d8d9d:d;d<Z hd=Z e Z e ZeZeZeZeZeZeZd>d?Zd@dAZedBdCZfdDdEZedcdGdHZ dIdJZ!dKdLZ"dMdNZ#dOdPZ$dcdQdRZ%dSdTZ&edUdVZ'edWdXZ(edYdZZ)ed[d\Z*ed]d^Z+ed_d`Z,edadbZ-Z.S)dDatabaseWrappermysqlZ 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)) Z OneToOneFieldPositiveBigIntegerFieldPositiveIntegerFieldPositiveSmallIntegerFieldZ SlugFieldZSmallAutoFieldZSmallIntegerFieldZ TextFieldZ TimeField UUIDFieldcCs|j}|jjr d|d<|S)Nuuidr@) _data_typescopyfeaturesZhas_native_uuid_field)rrBrrr data_typess zDatabaseWrapper.data_types) ZtinyblobZblobZ mediumblobr7ZtinytexttextZ mediumtextr<r;z= %szLIKE %szLIKE BINARY %sz> %sz>= %sz< %sz<= %s) exactZiexactcontains icontainsgtZgteltZlte startswithendswith istartswith iendswithzCREPLACE(REPLACE(REPLACE({}, '\\', '\\\\'), '%%', '\%%'), '_', '\_')z"LIKE BINARY CONCAT('%%', {}, '%%')zLIKE CONCAT('%%', {}, '%%')zLIKE BINARY CONCAT({}, '%%')zLIKE CONCAT({}, '%%')zLIKE BINARY CONCAT('%%', {})zLIKE CONCAT('%%', {}))rHrIrLrNrMrO>read committedzread uncommittedzrepeatable readZ serializablecCs|jSr) mysql_versionr/rrrget_database_versionsz$DatabaseWrapper.get_database_versioncCstdd}|j}|dr|d|d<|dr|d|d<|dr&|d|d<|d d r4|d |d <n |d r>|d |d <|d rJt|d |d<tj|d<|d}|dd}|ry|}||j vryt d|d ddt |j Df||_ |||S)NZutf8mb4)convcharsetUSERuserNAMEZdatabaseZPASSWORDpasswordZHOST/Z unix_sockethostZPORTportZ client_flagOPTIONSisolation_levelrPzKInvalid transaction isolation level '%s' specified. Use one of %s, or None.z, css|]}d|VqdS)z'%s'Nr).0srrr z8DatabaseWrapper.get_connection_params..)django_conversions settings_dictrLintr Z FOUND_ROWSrCpoplowerisolation_levelsrjoinsortedr]update)rkwargsrcoptionsr]rrrget_connection_paramss@         z%DatabaseWrapper.get_connection_paramscCs0tjdi|}|jttur|jt|S)Nr)r"connectencodersgetbytesre)rZ conn_params connectionrrrget_new_connections z"DatabaseWrapper.get_new_connectioncstg}|jjr|d|jr|d|j|r>|}|d |WddS1s7wYdSdS)NzSET SQL_AUTO_IS_NULL = 0z*SET SESSION TRANSACTION ISOLATION LEVEL %sz; ) superinit_connection_staterDZis_sql_auto_is_null_enabledappendr]upperrr!rh)rZ assignmentsr __class__rrru s   "z%DatabaseWrapper.init_connection_stateNcCs|j}t|Sr)rrrr)rnamerrrr create_cursors zDatabaseWrapper.create_cursorcCs(zt|WdStjyYdSwr)r _rollbackr"ZNotSupportedErrorr/rrrr|"s zDatabaseWrapper._rollbackcCs8|j|j|WddS1swYdSr)Zwrap_database_errorsrr autocommit)rr}rrr_set_autocommit(s"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)rr!rrrrdisable_constraint_checking,s   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_rollbackrr!)rrrrrrenable_constraint_checking6s   z*DatabaseWrapper.enable_constraint_checkingc Cs|Z}|dur|j|}|D]D}|j||}|sq|j||}|D],\}\}}|d||||||||f|D]} td|| d||| d||fq(qWddS1sawYdS)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_columnZ get_relationsitemsr!Zfetchallr) rrrZ table_nameZprimary_key_column_nameZ relationsZ column_nameZreferenced_column_nameZreferenced_table_nameZbad_rowrrrcheck_constraintsCsX    "z!DatabaseWrapper.check_constraintscCs(z|jWdStjyYdSw)NFT)rrZpingr"Errorr/rrr is_usable{s  zDatabaseWrapper.is_usablecCs|jrdSdS)NZMariaDBMySQL)mysql_is_mariadbr/rrr display_namezDatabaseWrapper.display_namecCs|jjr dddd}|SiS)Nz`%(column)s` >= 0)r=r>r?)rDZ!supports_column_check_constraints)rrrrrdata_type_check_constraintssz+DatabaseWrapper.data_type_check_constraintscCsp|}|d|}Wdn1swY|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 rr)versionsql_modeZdefault_storage_engineZsql_auto_is_nullZlower_case_table_namesZhas_zoneinfo_database)Ztemporary_connectionr!Zfetchoner8)rrrowrrrmysql_server_datas     z!DatabaseWrapper.mysql_server_datacCs |jdS)Nr)rr/rrrmysql_server_infos z!DatabaseWrapper.mysql_server_infocCs4t|j}|std|jtdd|DS)Nz8Unable to determine MySQL version from version string %rcss|]}t|VqdSr)rd)r^xrrrr`raz0DatabaseWrapper.mysql_version..)server_version_rematchr Exceptionr&groups)rrrrrrQs zDatabaseWrapper.mysql_versioncCsd|jvS)NZmariadb)rrfr/rrrrrz DatabaseWrapper.mysql_is_mariadbcCs"|jd}t|r|dSdS)Nr,r)rsetsplit)rrrrrrs zDatabaseWrapper.sql_moder)/r1r2r3vendorrBrrEZ_limited_data_types operatorsZ pattern_escZ pattern_opsrgr"rZSchemaEditorClassr Z client_classrZcreation_classrZfeatures_classrZintrospection_classrZ ops_classrZvalidation_classrRrmrrsrur{r|r~rrrrrrrrrQrr __classcell__rrrxrr5es         '    8      r5)0r4Zdjango.core.exceptionsrZ django.dbrZdjango.db.backendsrZ backend_utilsZdjango.db.backends.base.baserZdjango.utils.asynciorZdjango.utils.functionalrZdjango.utils.regex_helperrZMySQLdbr" ImportErrorerrZMySQLdb.constantsr r ZMySQLdb.convertersr clientr ZcreationrrDrrr operationsrZschemarZ validationr version_infor __version__ZTIMEZ typecast_timerbrrr5rrrrsP                 /