U
|
£ý°d"^ ã
|
@ s4 d Z ddlZddlmZmZ ddlmZmZmZmZm Z m
|
Z
|
m Z m Z m Z ddlmZ ddlmZ ddlmZ ddlmZ dd lmZmZ dd
|
lmZ z|ddlZ dd l m Z dd l m 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/m0Z0 W n4 e1k
|
rD Z2 zede2 e2W 5 dZ2[2X Y nX zddl3m4Z4 W n e1k
|
rp dZ5Y nX dZ5ddl6m7Z7 ddl8m9Z9 ddl:m;Z; ddl<m=Z= dd l>m?Z? dd l@mAZA dd lBmCZC e jDjEZEe jDjFZFe jDjGZGe jDjHZHe jDjIZIee0d d d!ZJG d"d# d#ZKG d$d% d%eZLG d&d' d'e"ZMdS )(a¥ Django 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Útime) ÚAnyÚDictÚ GeneratorÚIteratorÚListÚOptionalÚSetÚTupleÚUnion)Úsettings)ÚImproperlyConfigured)ÚIntegrityError)ÚBaseDatabaseWrapper)Ú dateparseÚtimezone)Úcached_property)ÚMySQLConnection)ÚCMySQLConnection)ÚMySQLConverter)Ú MySQLCursor)Ú CMySQLCursor)Ú
|
HexLiteral)ÚPooledMySQLConnection)ÚParamsDictTypeÚParamsSequenceOrDictTypeÚParamsSequenceTypeÚRowTypeÚ
|
StrOrBytesz&Error loading mysql.connector module: )Údatetime_to_mysqlFTé )ÚDatabaseClient)ÚDatabaseCreation)ÚDatabaseFeatures)ÚDatabaseIntrospection)ÚDatabaseOperations)ÚDatabaseSchemaEditor)ÚDatabaseValidation©ÚvalueÚreturnc C sf t jrLt | ¡r8t d| dt¡ t ¡ }t | |¡} | tj
|
¡j dd} t r\t | }|S | d¡S )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_TZr Zis_naiveÚwarningsÚwarnÚRuntimeWarningZget_default_timezoneZ
|
make_awareÚ
|
astimezoneÚutcÚreplaceÚ HAVE_CEXTr Ústrftime)r* Zdefault_timezoneZmysql_datetime© r5 úRd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\mysql/connector/django/base.pyÚ$adapt_datetime_with_timezone_supportb s
|
|
ý r7 c @ sè e Zd ZdZdZeeef ddddZe e
|
e
|
ddd Z e e e e e dd
|
d Zdee e e eeeef ddf d d dZeeeedf ee f e eeeef ddf d ddZeedddZee dddZdS )Ú CursorWrapperzãWrapper 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.
|
)i i ië i¹ N)Úcursorr+ c C s
|
|| _ d S ©N)r9 ©Úselfr9 r5 r5 r6 Ú__init__ s zCursorWrapper.__init__)Úargsr+ c C s< | s| S t | }| ¡ D ] \}}t|trt|||< q|S r: )ÚdictÚitemsÚ
|
isinstancer r7 )r> Únew_argsÚkeyr* r5 r5 r6 Ú_adapt_execute_args_dict s
|
z&CursorWrapper._adapt_execute_args_dictc C s@ | s| S t | }t| D ] \}}t|trt|||< qt|S r: )ÚlistÚ enumeraterA r r7 Útuple)r> rB ÚiÚargr5 r5 r6 Ú_adapt_execute_args s
|
z!CursorWrapper._adapt_execute_args)Úqueryr> r+ c
|
C s d}t |tr| |¡}n
|
| |¡}z| j ||¡W S tjjk
|
r| } z&|j d | j
|
krjt t |j d W 5 d}~X Y nX dS )zExecutes the given operation
|
|
This wrapper method around the execute()-method of the cursor is
|
mainly needed to re-raise using different exceptions.
|
Nr ) rA r? rD rJ r9 ÚexecuteÚmysqlÚ connectorÚOperationalErrorr> Úcodes_for_integrityerrorr rG )r< rK r> rB Úexcr5 r5 r6 rL s
|
|
zCursorWrapper.execute.c
|
C s^ z| j ||¡W S tjjk
|
rX } z&|jd | jkrFtt|j d W 5 d}~X Y nX dS )z±Executes the given operation
|
|
This wrapper method around the executemany()-method of the cursor is
|
mainly needed to re-raise using different exceptions.
|
r N) r9 Ú executemanyrM rN rO r> rP r rG )r< rK r> rQ r5 r5 r6 rR ² s zCursorWrapper.executemany©Úattrr+ c C s t | j|S )z%Return an attribute of wrapped cursor)Úgetattrr9 ©r< rT r5 r5 r6 Ú __getattr__Æ s zCursorWrapper.__getattr__©r+ c C s
|
t | jS )z&Return an iterator over wrapped cursor)Úiterr9 ©r< r5 r5 r6 Ú__iter__Ê s zCursorWrapper.__iter__)N)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__rP r r r r= Ú staticmethodr rD r r rJ Ústrr r rL r r rR r rW r r r[ r5 r5 r5 r6 r8 t s2
|
þ ÿ þ
|
ÿÿù r8 c sP e Zd ZU dZdZddddddd d
|
d ddd d d ddddd dddddddddd ZdZdd d d d d d d!d"d#d d d d d$Zd%Zd&d'd(d)d*d+d,Z d-Z
|
e e e d.< d/d0d1d2hZejZeZeZeZeZeZe Z e Z e e d-d3 fd4d5 Z!e e"d6d7d8Z#e$e e f d9d:d;Z%e$e e f e&e'e(e)f d<d=d>Z*d-d9d?d@Z+dae e,dAdBdCZ-d-d9dDdEZ.e"d-dFdGdHZ/e"d9dIdJZ0d-d9dKdLZ1dbe e2e d-dMdNdOZ3e"d9dPdQZ4e5e6e d9dRdSZ7e5e$e e f d9dTdUZ8e5e$e e f d9dVdWZ9e5e d9dXdYZ:e5e;e<dZf d9d[d\Z=e5e>e d9d]d^Z?e@e"d9d_d`ZA ZBS )cÚDatabaseWrapperz Represent a database connection.rM zinteger AUTO_INCREMENTzbigint AUTO_INCREMENTÚlongblobÚboolzvarchar(%(max_length)s)Údatez datetime(6)z+numeric(%(max_digits)s, %(decimal_places)s)Zbigintzdouble precisionÚintegerzchar(15)zchar(39)Újsonzbigint UNSIGNEDzinteger UNSIGNEDzsmallint UNSIGNEDzsmallint AUTO_INCREMENTZsmallintÚlongtextztime(6)zchar(32)) Z AutoFieldZ BigAutoFieldZ BinaryFieldZ BooleanFieldZ CharFieldZ DateFieldZ DateTimeFieldZ DecimalFieldZ DurationFieldZ FileFieldZ FilePathFieldZ
|
FloatFieldZ IntegerFieldZBigIntegerFieldZIPAddressFieldZGenericIPAddressFieldZ JSONFieldZNullBooleanFieldZ OneToOneFieldÚPositiveBigIntegerFieldÚPositiveIntegerFieldÚPositiveSmallIntegerFieldZ SlugFieldZSmallAutoFieldZSmallIntegerFieldZ TextFieldZ TimeFieldZ UUIDField) ZtinyblobZblobZ
|
mediumblobrc ZtinytextÚtextZ
|
mediumtextrh rg z= %szLIKE %szLIKE BINARY %szREGEXP BINARY %sz REGEXP %sz> %sz>= %sz< %sz<= %s)ÚexactZiexactÚcontainsÚ icontainsÚregexZiregexÚgtZgteÚltZlteÚ
|
startswithÚendswithÚ istartswithÚ iendswithzCREPLACE(REPLACE(REPLACE({}, '\\', '\\\\'), '%%', '\%%'), '_', '\_')z"LIKE BINARY CONCAT('%%', {}, '%%')zLIKE CONCAT('%%', {}, '%%')z LIKE BINARY CONCAT({}, '%%')zLIKE CONCAT({}, '%%')z LIKE BINARY CONCAT('%%', {})zLIKE CONCAT('%%', {}))rn ro rs ru rt rv NÚisolation_levelzread uncommittedzread committedzrepeatable readZ serializable)r> Úkwargsr+ c sj t j|| | j d¡}|rV| dt ¡| _| dt¡}t|tsLtd| | _ nt | _ t | _d S )NÚOPTIONSÚuse_pureÚconverter_classzXConverter class should be a subclass of mysql.connector.django.base.DjangoMySQLConverter)
|
Úsuperr= Ú settings_dictÚgetr3 Ú _use_pureÚDjangoMySQLConverterÚ
|
issubclassÚProgrammingErrorÚ converter)r< r> rx Úoptionsr{ ©Ú __class__r5 r6 r= < s þ
|
ÿ
|
zDatabaseWrapper.__init__rS c C s | d¡rdS td S )NZmysql_isF)rs ÚAttributeErrorrV r5 r5 r6 rW P s
|
zDatabaseWrapper.__getattr__rX c C sf ddddd}| j }|d r(|d |d< |d r<|d |d< |d rP|d |d
|
< |d d ¡rl|d |d < n|d r|d |d< |d rt|d |d< | di ¡ d¡rº|d d |d< tj|d< tjjj j
|
g|d< zt|d ¡ }| d¡}|r8| ¡ }|| jkr8d dd t| jD ¡}td| d| d|| _| |¡ W n tk
|
r` Y nX |S ) NÚutf8TF)ÚcharsetZ use_unicodeZbufferedZconsume_resultsÚUSERÚuserÚNAMEZdatabaseZPASSWORDÚpasswdZHOSTú/Z unix_socketÚhostZPORTÚportry Z init_commandZraise_on_warningsZ client_flagsrw z, c s s | ]}d | d V qdS )ú'Nr5 )Ú.0Úlevelr5 r5 r6 Ú <genexpr>| s z8DatabaseWrapper.get_connection_params.<locals>.<genexpr>z%Invalid transaction isolation level 'z' specified.
|
Use one of z
|
, or None.)r} rs Úintr~ r ÚDEBUGrM rN Ú constantsZ
|
ClientFlagZ
|
FOUND_ROWSÚcopyÚpopÚlowerÚisolation_levelsÚjoinÚsortedr rw ÚupdateÚKeyError)r< rx r} r rw Z valid_levelsr5 r5 r6 Úget_connection_paramsU sP ü
|
|
þ
|
|
ÿÿz%DatabaseWrapper.get_connection_params)Ú conn_paramsr+ c C s" d|krt |d< tjjf |}|S )Nr{ )r rM rN Úconnect)r< r¡ Zcnxr5 r5 r6 Úget_new_connection s z"DatabaseWrapper.get_new_connectionc C s¢ g }| j jr| d¡ | jr2| d| j ¡ ¡ |rZ| ¡ }| d |¡¡ W 5 Q R X d| jkrz| | jd ¡ W n$ t
|
k
|
r | | jd ¡ Y nX d S )NzSET SQL_AUTO_IS_NULL = 0z(SET SESSION TRANSACTION ISOLATION LEVEL z; Z
|
AUTOCOMMIT) ÚfeaturesZis_sql_auto_is_null_enabledÚappendrw Úupperr9 rL r r} Zset_autocommitr Ú_set_autocommit)r< Z assignmentsr9 r5 r5 r6 Úinit_connection_state s
|
ÿ
|
|
z%DatabaseWrapper.init_connection_state)Únamer+ c C s | j ¡ }t|S r: )Ú
|
connectionr9 r8 )r< r© r9 r5 r5 r6 Ú create_cursor¬ s
|
z DatabaseWrapper.create_cursorc C s( zt | ¡ W n tk
|
r" Y nX d S r: )r Ú _rollbackÚNotSupportedErrorrZ r5 r5 r6 r¬ ° s zDatabaseWrapper._rollback)Ú
|
autocommitr+ c C s | j || j_W 5 Q R X d S r: )Zwrap_database_errorsrª r® )r< r® r5 r5 r6 r§ ¶ s z DatabaseWrapper._set_autocommitc C s" | ¡ }| d¡ W 5 Q R X dS )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)r9 rL r; r5 r5 r6 Údisable_constraint_checkingº s
|
z+DatabaseWrapper.disable_constraint_checkingc C s> d| j | _ }z"| ¡ }| d¡ W 5 Q R X W 5 || _ X dS )zM
|
Re-enable foreign key checks after they have been disabled.
|
FzSET foreign_key_checks=1N)Úneeds_rollbackr9 rL )r< r° r9 r5 r5 r6 Úenable_constraint_checkingÄ s
|
|
z*DatabaseWrapper.enable_constraint_checking)Ú table_namesr+ c
|
C sî | ¡ Ü}|dkr | j |¡}|D ]¼}| j ||¡}|s:q"| j ||¡}|D ]\}}}| d| d| d| d| d| d| d| d | d
|
¡ | ¡ D ]@} td | d | d d| d| d| d d| d| dqqLq"W 5 Q R X dS )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 'r z ' has an invalid foreign key: Ú.z contains a value 'r! z.' that does not have a corresponding value in )r9 Ú introspectionr² Zget_primary_key_columnZget_key_columnsrL Zfetchallr )
|
r< r² r9 Z
|
table_nameZprimary_key_column_nameZ key_columnsZ column_nameZreferenced_table_nameZreferenced_column_nameZbad_rowr5 r5 r6 Úcheck_constraintsÑ sN
|
ÿüÿþýüþùþùÿ 6ÿz!DatabaseWrapper.check_constraintsc C s* z| j ¡ W n tk
|
r$ Y dS X dS )NFT)rª ZpingÚErrorrZ r5 r5 r6 Ú is_usable s
|
zDatabaseWrapper.is_usablec C s dS )z Display name.ZMySQLr5 r5 r5 r5 r6 Ú display_name s z DatabaseWrapper.display_namec C s | j jrdddd}|S i S )z<Mapping of Field objects to their SQL for CHECK constraints.z`%(column)s` >= 0)ri rj rk )r¤ Z!supports_column_check_constraints)r< rµ r5 r5 r6 Údata_type_check_constraints s ýz+DatabaseWrapper.data_type_check_constraintsc C s\ | ¡ }| d¡ | ¡ }W 5 Q R X |d |d |d t|d t|d t|d dS ) 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
|
r r! é é é é )ÚversionÚsql_modeZdefault_storage_engineZsql_auto_is_nullZlower_case_table_namesZhas_zoneinfo_database)Útemporary_connectionrL Úfetchonerd )r< r9 Úrowr5 r5 r6 Úmysql_server_data s
|
ÿ
|
|
|
|
úz!DatabaseWrapper.mysql_server_datac
|
C s6 | ¡ $}| d¡ | ¡ d W 5 Q R £ S Q R X dS )úReturn MySQL version.zSELECT VERSION()r N)rÀ rL rÁ r; r5 r5 r6 Úmysql_server_info5 s
|
|
z!DatabaseWrapper.mysql_server_info.c C s. | ¡ }tjjf |}| ¡ }W 5 Q R X |S )rÄ )r rM rN r¢ Zget_server_version)r< ÚconfigÚconnZserver_versionr5 r5 r6 Ú mysql_version< s z DatabaseWrapper.mysql_versionc C s@ | ¡ }| d¡ | ¡ }W 5 Q R X t|r:|d d¡ndS )zReturn SQL mode.zSELECT @@sql_moder ú,r5 )r9 rL rÁ ÚsetÚsplit)r< r9 r¿ r5 r5 r6 r¿ D s
|
|
zDatabaseWrapper.sql_modec C s
|
| j }|S )z1Return True if pure Python version is being used.)r )r< Zansr5 r5 r6 rz L s zDatabaseWrapper.use_pure)N)N)Cr\ r] r^ r_ ÚvendorÚ
|
data_typesZ_limited_data_typesÚ operatorsZ pattern_escZ pattern_opsrw r ra Ú__annotations__r rM rN ZDatabaser' ZSchemaEditorClassr" Z client_classr# Zcreation_classr$ Zfeatures_classr% Zintrospection_classr& Z ops_classr( Zvalidation_classr r= rd rW r r r r r r r£ r¨ r8 r« r¬ r§ r¯ r± r rµ r· r r` r¸ r¹ rà rÅ r r rÈ r
|
r¿ Úpropertyrz Ú __classcell__r5 r5 r
r6 rb Ï sÄ
|
ä$ òú ü6
|
þ
|
0 rb c @ s e Zd ZdZedeeee dddZ edeeee
|
dddZ e e eef dd d
|
Ze e eef dd d Zeedd dZdS )r z Custom converter for Django.N)r* Údscr+ c C s t | d¡¡S )zXReturn MySQL TIME data type as datetime.time()
|
|
Returns datetime.time()
|
zutf-8)r Z
|
parse_timeÚdecode©r* rÒ r5 r5 r6 Ú_time_to_pythonX s z$DjangoMySQLConverter._time_to_pythonc C s | rt | ¡S dS )ao Connector/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_pythonrÔ r5 r5 r6 rÖ ` s z(DjangoMySQLConverter._datetime_to_pythonr) c C s
|
| |¡S r: ©Z _str_to_mysql©r< r* r5 r5 r6 Ú_safestring_to_mysqlu s z)DjangoMySQLConverter._safestring_to_mysqlc C s
|
| |¡S r: r× rØ r5 r5 r6 Ú_safetext_to_mysqlx s z'DjangoMySQLConverter._safetext_to_mysqlc C s
|
| |¡S r: )Z_bytes_to_mysqlrØ r5 r5 r6 Ú_safebytes_to_mysql{ s z(DjangoMySQLConverter._safebytes_to_mysql)N)N)r\ r] r^ r_ r` Úbytesr r r rÕ r rÖ ra r r rÙ rÚ rÛ r5 r5 r5 r6 r S s r )Nr_ r- r r Útypingr r r r r r r
|
r r Z django.confr Zdjango.core.exceptionsr Z django.dbr Z django.db.backends.base.baser Z django.utilsr r Zdjango.utils.functionalr Zmysql.connectorrM Zmysql.connector.connectionr Z mysql.connector.connection_cextr Zmysql.connector.conversionr Zmysql.connector.cursorr Zmysql.connector.cursor_cextr Z mysql.connector.custom_typesr Zmysql.connector.poolingr Zmysql.connector.typesr r r r r Ú ImportErrorÚerrZ_mysql_connectorr r3 Úclientr" Zcreationr# r¤ r$ r´ r% Ú
|
operationsr& Zschemar' Z
|
validationr( rN r¶ Z DatabaseErrorr rO r r7 r8 rb r r5 r5 r5 r6 Ú<module> sZ , "
|
[
|
