o 9&i"^ @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 ZUSE_TZrZis_naivewarningswarnRuntimeWarningZget_default_timezoneZ make_aware astimezoneutcreplace HAVE_CEXTr strftime)r)Zdefault_timezoneZmysql_datetimer4FC:\wamp64\www\opt\env\Lib\site-packages\mysql/connector/django/base.py$adapt_datetime_with_timezone_supportbs    r6c @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)r8selfr8r4r4r5__init__ zCursorWrapper.__init__argscCs<|s|St|}|D]\}}t|trt|||<q |Sr9)dictitems isinstancerr6)r>new_argskeyr)r4r4r5_adapt_execute_args_dicts  z&CursorWrapper._adapt_execute_args_dictcCs@|s|St|}t|D]\}}t|trt|||<q t|Sr9)list enumeraterArr6tuple)r>rBiargr4r4r5_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) rAr?rDrJr8executemysql connectorOperationalErrorr>codes_for_integrityerrorrrG)r;rKr>rBexcr4r4r5rLs   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) r8 executemanyrMrNrOr>rPrrG)r;rKr>rQr4r4r5rRs zCursorWrapper.executemanyattrcCs t|j|S)z%Return an attribute of wrapped cursor)getattrr8r;rSr4r4r5 __getattr__s zCursorWrapper.__getattr__cCs t|jS)z&Return an iterator over wrapped cursor)iterr8r;r4r4r5__iter__s zCursorWrapper.__iter__r9)__name__ __module__ __qualname____doc__rPr rrr< staticmethodrrDr rrJstrrrrLr rrRrrVrrrYr4r4r4r5r7tsB      r7cseZdZUdZdZiddddddd 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.rMZ 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)) ZNullBooleanFieldZ OneToOneFieldPositiveBigIntegerFieldPositiveIntegerFieldPositiveSmallIntegerFieldZ SlugFieldZSmallAutoFieldZSmallIntegerFieldZ TextFieldZ TimeFieldZ UUIDField) ZtinyblobZblobZ mediumblobraZtinytexttextZ mediumtextrfrez= %szLIKE %szLIKE BINARY %szREGEXP BINARY %sz REGEXP %sz> %sz>= %sz< %sz<= %s)exactZiexactcontains icontainsregexZiregexgtZgteltZlte startswithendswith istartswith iendswithzCREPLACE(REPLACE(REPLACE({}, '\\', '\\\\'), '%%', '\%%'), '_', '\_')z"LIKE BINARY CONCAT('%%', {}, '%%')zLIKE CONCAT('%%', {}, '%%')zLIKE BINARY CONCAT({}, '%%')zLIKE CONCAT({}, '%%')zLIKE BINARY CONCAT('%%', {})zLIKE CONCAT('%%', {}))rlrmrqrsrrrtNisolation_level>zrepeatable readzread committedZ serializablezread uncommittedr>kwargsr*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) superr< settings_dictgetr2 _use_pureDjangoMySQLConverter issubclassProgrammingError converter)r;r>rvoptionsry __class__r4r5r<<s    zDatabaseWrapper.__init__rScCs|drdSt)NZmysql_isF)rqAttributeErrorrUr4r4r5rVPs 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)charsetZ use_unicodebufferedZconsume_resultsUSERuserNAMEZdatabaseZPASSWORDpasswdZHOST/Z unix_sockethostZPORTportrwZ init_commandZraise_on_warningsZ client_flagsruz, css|] }d|dVqdS)'Nr4).0levelr4r4r5 |s  z8DatabaseWrapper.get_connection_params..z%Invalid transaction isolation level 'z' specified. Use one of z , or None.)r{rqintr|r DEBUGrMrN constantsZ ClientFlagZ FOUND_ROWScopypoplowerisolation_levelsjoinsortedrruupdateKeyError)r;rvr{rruZ valid_levelsr4r4r5get_connection_paramsUsX            z%DatabaseWrapper.get_connection_params conn_paramscCs&d|vrt|d<tjjdi|}|S)Nryr4)r~rMrNconnect)r;rZcnxr4r4r5get_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; Z AUTOCOMMIT) featuresZis_sql_auto_is_null_enabledappendruupperr8rLrr{Zset_autocommitr_set_autocommit)r;Z assignmentsr8r4r4r5init_connection_states(    z%DatabaseWrapper.init_connection_statenamecCs|j}t|Sr9) connectionr8r7)r;rr8r4r4r5 create_cursors zDatabaseWrapper.create_cursorcCs&zt|WdStyYdSwr9)r _rollbackNotSupportedErrorrXr4r4r5rs  zDatabaseWrapper._rollback autocommitcCs4|j ||j_WddS1swYdSr9)Zwrap_database_errorsrr)r;rr4r4r5rs "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)r8rLr:r4r4r5disable_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_rollbackr8rL)r;rr8r4r4r5enable_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 )r8 introspectionrZget_primary_key_columnZget_key_columnsrLZfetchallr) r;rr8Z table_nameZprimary_key_column_nameZ key_columnsZ column_nameZreferenced_table_nameZreferenced_column_nameZbad_rowr4r4r5check_constraintssl     "z!DatabaseWrapper.check_constraintscCs&z|jWdStyYdSw)NFT)rZpingErrorrXr4r4r5 is_usables   zDatabaseWrapper.is_usablecCsdS)z Display name.MySQLr4r4r4r4r5 display_nameszDatabaseWrapper.display_namecCs|jjr dddd}|SiS)z= 0)rgrhri)rZ!supports_column_check_constraints)r;rr4r4r5data_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_modeZdefault_storage_engineZsql_auto_is_nullZlower_case_table_namesZhas_zoneinfo_database)temporary_connectionrLfetchonerb)r;r8rowr4r4r5mysql_server_datas     z!DatabaseWrapper.mysql_server_datacCsB|}|d|dWdS1swYdS)Return MySQL version.zSELECT VERSION()rN)rrLrr:r4r4r5mysql_server_info5s   $z!DatabaseWrapper.mysql_server_info.cCsH|}tjjdi| }|}Wd|S1swY|S)rNr4)rrMrNrZget_server_version)r;configconnZserver_versionr4r4r5 mysql_version<s  zDatabaseWrapper.mysql_versioncCsV|}|d|}Wdn1swYt|r(|ddSdS)zReturn SQL mode.zSELECT @@sql_modeNr,r4)r8rLrsetsplit)r;r8rr4r4r5rDs   zDatabaseWrapper.sql_modecCs |j}|S)z1Return True if pure Python version is being used.)r})r;Zansr4r4r5rxLszDatabaseWrapper.use_pure)r*Nr9)CrZr[r\r]vendor data_typesZ_limited_data_types operatorsZ pattern_escZ pattern_opsrur r___annotations__rrMrNZDatabaser'ZSchemaEditorClassr"Z client_classr#Zcreation_classr$Zfeatures_classr%Zintrospection_classr&Z ops_classr(Zvalidation_classrr<rbrVrrr rrrrrr7rrrrrrrrrr^rrrrr rrr rpropertyrx __classcell__r4r4rr5r`s      $  5      0 r`c @seZdZdZeddededeefddZ eddededee fdd Z de de eeffd d Zde de eeffd d ZdedefddZdS)r~zCustom converter for Django.Nr)dscr*cCst|dS)zXReturn MySQL TIME data type as datetime.time() Returns datetime.time() zutf-8)rZ parse_timedecoder)rr4r4r5_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_pythonrr4r4r5r`sz(DjangoMySQLConverter._datetime_to_pythoncC ||Sr9Z _str_to_mysqlr;r)r4r4r5_safestring_to_mysqlur=z)DjangoMySQLConverter._safestring_to_mysqlcCrr9rrr4r4r5_safetext_to_mysqlxr=z'DjangoMySQLConverter._safetext_to_mysqlcCrr9)Z_bytes_to_mysqlrr4r4r5_safebytes_to_mysql{r=z(DjangoMySQLConverter._safebytes_to_mysqlr9)rZr[r\r]r^bytesrr rrrrr_r rrrrr4r4r4r5r~Ssr~)Nr]r,rrtypingrrrrrr r r r Z django.confr Zdjango.core.exceptionsrZ django.dbrZdjango.db.backends.base.baserZ django.utilsrrZdjango.utils.functionalrZmysql.connectorrMZmysql.connector.connectionrZmysql.connector.connection_cextrZmysql.connector.conversionrZmysql.connector.cursorrZmysql.connector.cursor_cextrZmysql.connector.custom_typesrZmysql.connector.poolingrZmysql.connector.typesrrrrr ImportErrorerrZ_mysql_connectorr r2clientr"Zcreationr#rr$rr% operationsr&Zschemar'Z validationr(rNrZ DatabaseErrorrrOrr6r7r`r~r4r4r4r5sb ,                     [