B 0H[6 @sVdZddlZddlmZddlmZddlmZddlm Z ddl m Z y ddl Z Wn,ek rZzedeWddZ[XYnXddlmZmZdd lmZd d lmZd d lmZd d lmZd dlmZd dlmZd dlm Z d dl!m"Z"e j#Z$e$dkrede j%e&Z'e'(ej)ej*ie+dZ,GdddZ-Gddde Z.dS)za MySQL database backend for Django. Requires mysqlclient: https://pypi.org/project/mysqlclient/ N)ImproperlyConfigured)utils)BaseDatabaseWrapper)cached_propertyz:Error loading MySQLdb module. Did you install mysqlclient?)CLIENT FIELD_TYPE) conversions)DatabaseClient)DatabaseCreation)DatabaseFeatures)DatabaseIntrospection)DatabaseOperations)DatabaseSchemaEditor)DatabaseValidation)r rz3mysqlclient 1.3.3 or newer is required; you have %sz(\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(). )iicCs ||_dS)N)cursor)selfrraC:\Users\HIRONO~1\AppData\Local\Temp\pip-install-6bm3nxem\django\django\db\backends\mysql\base.py__init__AszCursorWrapper.__init__Nc CsZy|j||Stjk rT}z&|jd|jkrBtjt|jWdd}~XYnXdS)Nr) rexecuteDatabaseOperationalErrorargscodes_for_integrityerrorrIntegrityErrortuple)rqueryrerrrrDs zCursorWrapper.executec CsZy|j||Stjk rT}z&|jd|jkrBtjt|jWdd}~XYnXdS)Nr) r executemanyrrrrrrr)rrrr rrrr!Os zCursorWrapper.executemanycCs t|j|S)N)getattrr)rattrrrr __getattr__YszCursorWrapper.__getattr__cCs t|jS)N)iterr)rrrr__iter__\szCursorWrapper.__iter__)N) __name__ __module__ __qualname____doc__rrrr!r$r&rrrrr4s  rc@seZdZdZdZddddddd d d ddd d d dddd ddddddddZeddZdZdddddddd ddddd! Z d"Z d#d$d%d&d'd(d)Z d*d+d,d-hZ e Z eZeZeZeZeZeZeZd.d/Zd0d1Zd2d3ZdEd5d6Zd7d8Z d9d:Z!d;d<Z"d=d>Z#dFd?d@Z$dAdBZ%edCdDZ&d4S)GDatabaseWrapperZmysqlZMySQLzinteger AUTO_INCREMENTzbigint AUTO_INCREMENTlongblobboolzvarchar(%(max_length)s)datedatetimez+numeric(%(max_digits)s, %(decimal_places)s)Zbigintzdouble precisionintegerzchar(15)zchar(39)zinteger UNSIGNEDzsmallint UNSIGNEDZsmallintlongtexttimezchar(32))Z AutoFieldZ BigAutoFieldZ BinaryFieldZ BooleanFieldZ CharFieldZ DateField DateTimeFieldZ DecimalFieldZ DurationFieldZ FileFieldZ FilePathFieldZ FloatFieldZ IntegerFieldZBigIntegerFieldZIPAddressFieldZGenericIPAddressFieldZNullBooleanFieldZ OneToOneFieldZPositiveIntegerFieldZPositiveSmallIntegerFieldZ SlugFieldZSmallIntegerFieldZ TextField TimeFieldZ UUIDFieldcCs"|jjrt|jdddS|jSdS)Nz datetime(6)ztime(6))r3r4)featuresZsupports_microsecond_precisiondict _data_types)rrrr data_typesszDatabaseWrapper.data_types) ZtinyblobZblobZ mediumblobr,ZtinytexttextZ mediumtextr1jsonz= %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('%%', {}))r<r=r@rBrArCzread uncommittedzread committedzrepeatable readZ serializablecCstdd}|j}|dr$|d|d<|dr8|d|d<|drL|d|d<|d d rh|d |d <n|d r||d |d <|d rt|d |d<tj|d<|d}|dd}|r|}||j krt d|d ddt |j Df||_ |||S)Nutf8)convcharsetUSERuserNAMEdbZPASSWORDpasswdZHOST/Z unix_sockethostZPORTportZ client_flagOPTIONSisolation_levelzread committedzKInvalid transaction isolation level '%s' specified. Use one of %s, or None.z, css|]}d|VqdS)z'%s'Nr).0srrr sz8DatabaseWrapper.get_connection_params..)django_conversions settings_dictr@intrZ FOUND_ROWScopypoplowerisolation_levelsrjoinsortedrPupdate)rkwargsrUoptionsrPrrrget_connection_paramss8          z%DatabaseWrapper.get_connection_paramscCs tjf|S)N)rconnect)rZ conn_paramsrrrget_new_connectionsz"DatabaseWrapper.get_new_connectionc Cs\g}|jjr|d|jr0|d|j|rX|}|d|WdQRXdS)NzSET SQL_AUTO_IS_NULL = 0z*SET SESSION TRANSACTION ISOLATION LEVEL %sz; )r5Zis_sql_auto_is_null_enabledappendrPupperrrr[)rZ assignmentsrrrrinit_connection_states  z%DatabaseWrapper.init_connection_stateNcCs|j}t|S)N) connectionrr)rnamerrrr create_cursors zDatabaseWrapper.create_cursorcCs*yt|Wntjk r$YnXdS)N)r _rollbackrZNotSupportedError)rrrrriszDatabaseWrapper._rollbackc Cs"|j|j|WdQRXdS)N)Zwrap_database_errorsrf autocommit)rrjrrr_set_autocommitszDatabaseWrapper._set_autocommitcCs|ddS)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)rr)rrrrdisable_constraint_checking sz+DatabaseWrapper.disable_constraint_checkingcCs.d|j|_}z|dWd||_XdS)zM Re-enable foreign key checks after they have been disabled. FzSET foreign_key_checks=1N)needs_rollbackrr)rrmrrrenable_constraint_checkingsz*DatabaseWrapper.enable_constraint_checkingc Cs|}|dkr|j|}x|D]}|j||}|s:q"|j||}xf|D]^\}}}|d||||||||fx4|D](} td|| d||| d||fqWqNWq"WdS)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. Raise an IntegrityError on the first invalid foreign key reference encountered (if any) and provide detailed information about the invalid reference in the error message. Backends can override this method if they can more directly apply constraint checking (e.g. via "SET CONSTRAINTS ALL IMMEDIATE") Na 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_columnZget_key_columnsrZfetchallrr) rrprZ table_nameZprimary_key_column_nameZ key_columnsZ column_nameZreferenced_table_nameZreferenced_column_nameZbad_rowrrrcheck_constraintss&    z!DatabaseWrapper.check_constraintscCs.y|jWntjk r$dSXdSdS)NFT)rfZpingrError)rrrr is_usableMs zDatabaseWrapper.is_usablec CsZ|}|d|d}WdQRXt|}|sDtd|tdd|DS)NzSELECT VERSION()rz8Unable to determine MySQL version from version string %rcss|]}t|VqdS)N)rV)rQxrrrrS]sz0DatabaseWrapper.mysql_version..)Ztemporary_connectionrZfetchoneserver_version_rematch Exceptionrgroups)rrZ server_inforvrrr mysql_versionUs    zDatabaseWrapper.mysql_version)N)N)'r'r(r)vendorZ display_namer7rr8Z_limited_data_types operatorsZ pattern_escZ pattern_opsrZrrZSchemaEditorClassr Z client_classr Zcreation_classr Zfeatures_classr Zintrospection_classrZ ops_classrZvalidation_classr`rbrerhrirkrlrnrqrsryrrrrr+`s  %   .r+)/r*reZdjango.core.exceptionsrZ django.dbrZdjango.db.backendsZ backend_utilsZdjango.db.backends.base.baserZdjango.utils.functionalrZMySQLdbr ImportErrorerrZMySQLdb.constantsrrZMySQLdb.convertersrclientr Zcreationr r5r ror operationsrZschemarZ validationr version_infoversion __version__rWrTr]ZTIMEZ typecast_timecompilerurr+rrrrs<                ,