관리-도구
편집 파일: base.cpython-38.pyc
U )�e�P � @ s� d Z ddlmZ ddlmZ ddlZddlZddlZddlmZ z(ddl Z ddl m Z m Z ddlmZ W n< ek r� Z z ddlmZ ed �e���W 5 dZ[X Y nX ze jjdd � ZW n, ek r� dd lmZ edd � ZY nX zdd lm Z m Z W n ek �r d Z Y nX dZ edk �rBddlmZ ede jj ��ddl m!Z! ejdk �rhddl"m#Z# n ddl"m!Z$ ejdk�r�ddl%m&Z& n ddl"m&Z& ddl'm(Z( ddl)m*Z*m+Z+m,Z, ddl-m.Z. ddl/m0Z0 ddl1m2Z2 ddl3m4Z4 dd l5m6Z6 dd l7m8Z8 dd l9m:Z: ejdk�r&dd l;m<Z< e jj=Z=e jj>Z>e jj?Z?d d!� Z@G d"d#� d#e �ZAG d$d%� d%e �ZBG d&d'� d'eC�ZDG d(d)� d)e&�ZEdS )*a� Django database Backend using MySQL Connector/Python This Django database backend is heavily based on the MySQL backend coming with 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 v1.1 and later: http://dev.mysql.com/downloads/connector/python/ � )�unicode_literals)�datetimeN)�cached_property)�MySQLConverter�MySQLConverterBase)�PY2)�ImproperlyConfiguredz)Error loading mysql.connector module: {0}� )�VERSION)�datetime_to_mysql� time_to_mysqlFT)� r z?MySQL Connector/Python v1.1.0 or newer is required; you have %s)�utils)r � )�util)r � )�BaseDatabaseWrapper)�connection_created)�six�timezone� dateparse)�settings)�DatabaseClient)�DatabaseCreation)�DatabaseIntrospection)�DatabaseValidation)�DatabaseFeatures)�DatabaseOperations��DatabaseSchemaEditorc C sb t jrHt�| �r4t�d| t� t�� }t�| |�} | � tj �j d d�} t rTt | �S | �d�S d S )NzGMySQL received a naive datetime (%s) while time zone support is active.��tzinfoz%Y-%m-%d %H:%M:%S.%f)r �USE_TZr �is_naive�warnings�warn�RuntimeWarningZget_default_timezoneZ make_aware� astimezone�utc�replace� HAVE_CEXTr �strftime)�valueZdefault_timezone� r- �p/opt/hc_python/lib64/python3.8/site-packages/../../../lib/python3.8/site-packages/mysql/connector/django/base.py�$adapt_datetime_with_timezone_supportT s �� r/ c @ s4 e Zd ZdZd dd�Zd dd�Zdd� Zd d � ZdS ) �DjangoMySQLConverterz/Custom converter for Django for MySQLConnectionNc C s t �|�d��S )�XReturn MySQL TIME data type as datetime.time() Returns datetime.time() zutf-8)r � parse_time�decode��selfr, �dscr- r- r. �_TIME_to_pythonf s z$DjangoMySQLConverter._TIME_to_pythonc C sB |sdS t �| |�}|dkr dS tjr>t�|�r>|jtjd�}|S �a Connector/Python always returns naive datetime.datetime Connector/Python always returns naive timestamps since MySQL has no time zone support. Since Django needs non-naive, we need to add the UTC time zone. Returns datetime.datetime() Nr )r �_DATETIME_to_pythonr r" r r# r) r( )r5 r, r6 �dtr- r- r. r9 m s z(DjangoMySQLConverter._DATETIME_to_pythonc C s t r| �|�S | �|�S d S �N)r Z_unicode_to_mysqlZ _str_to_mysql�r5 r, r- r- r. �_safetext_to_mysql s z'DjangoMySQLConverter._safetext_to_mysqlc C s | � |�S r; )Z_bytes_to_mysqlr< r- r- r. �_safebytes_to_mysql� s z(DjangoMySQLConverter._safebytes_to_mysql)N)N)�__name__� __module__� __qualname__�__doc__r7 r9 r= r> r- r- r- r. r0 d s r0 c @ s$ e Zd ZdZddd�Zddd�ZdS ) �DjangoCMySQLConverterz0Custom converter for Django for CMySQLConnectionNc C s t �t|��S )r1 )r r2 �strr4 r- r- r. r7 � s z%DjangoCMySQLConverter._TIME_to_pythonc C s* |sdS t jr&t�|�r&|jtjd�}|S r8 )r r" r r# r) r( r4 r- r- r. r9 � s z)DjangoCMySQLConverter._DATETIME_to_python)N)N)r? r@ rA rB r7 r9 r- r- r- r. rC � s rC c @ sf e Zd ZdZdZdd� Zdd� Zdd� Zd d � Zdd d �Z dd� Z dd� Z dd� Z dd� Z dd� Zd S )� 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 c C s || _ d S r; )�cursor�r5 rF r- r- r. �__init__� s zCursorWrapper.__init__c C s\ z |||�W S t jjk rT } z$t�tjt�|j�t�� d � W 5 d}~X Y �n t jj k r� } z$t�tj t� |j�t�� d � W 5 d}~X Y n� t jj k �r } zV|j d | j kr�t�tj t� |j�t�� d � n t�tj t� |j�t�� d � W 5 d}~X Y nH t jj k �rV } z$t�tj t� |j�t�� d � W 5 d}~X Y nX dS )z*Wrapper around execute() and executemany()� Nr )�mysql� connectorZProgrammingErrorr �reraiser �msg�sys�exc_info�IntegrityErrorZOperationalError�args�codes_for_integrityerror� DatabaseError)r5 �method�queryrQ �errr- r- r. �_execute_wrapper� s6 � � � � �z CursorWrapper._execute_wrapperc C s< |s|S t |�}|�� D ] \}}t|t�rt|�||< q|S r; )�dict�items� isinstancer r/ )r5 rQ �new_args�keyr, r- r- r. �_adapt_execute_args_dict� s z&CursorWrapper._adapt_execute_args_dictc C s@ |s|S t |�}t|�D ] \}}t|t�rt|�||< qt|�S r; )�list� enumeraterZ r r/ �tuple)r5 rQ r[ �i�argr- r- r. �_adapt_execute_args� s z!CursorWrapper._adapt_execute_argsNc C s2 t |t�r| �|�}n | �|�}| �| jj||�S )z�Executes the given operation This wrapper method around the execute()-method of the cursor is mainly needed to re-raise using different exceptions. )rZ rX r] rc rW rF �execute)r5 rU rQ r[ r- r- r. rd � s zCursorWrapper.executec C s | � | jj||�S )z�Executes the given operation This wrapper method around the executemany()-method of the cursor is mainly needed to re-raise using different exceptions. )rW rF � executemany)r5 rU rQ r- r- r. re � s zCursorWrapper.executemanyc C s t | j|�S )z"Return attribute of wrapped cursor)�getattrrF )r5 �attrr- r- r. � __getattr__� s zCursorWrapper.__getattr__c C s t | j�S )z$Returns iterator over wrapped cursor)�iterrF �r5 r- r- r. �__iter__� s zCursorWrapper.__iter__c C s | S r; r- rj r- r- r. � __enter__� s zCursorWrapper.__enter__c C s | � � d S r; )�close)r5 �exc_type� exc_value� exc_tracebackr- r- r. �__exit__� s zCursorWrapper.__exit__)N)r? r@ rA rB rR rH rW r] rc rd re rh rk rl rq r- r- r- r. rE � s rE c s< e Zd ZdZddddddddd ddd d d d d dd dddddddd�Zedd� �Zddddddd d d d ddddd �Zd!Zd"d#d$d%d&d'd(�Z e Z e j Z� fd)d*�Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Zd5d6� Z� fd7d8�Zd9d:� Zd;d<� Zd=d>� ZdNd@dA�ZdBdC� ZdDdE� Z dFdG� Z dHdI� Z edJdK� �Z e dLdM� �Z!� Z"S )O�DatabaseWrapperrJ zinteger AUTO_INCREMENTZlongblob�boolzvarchar(%(max_length)s)�dater z+numeric(%(max_digits)s, %(decimal_places)s)Zbigintzdouble precision�integerzchar(15)zchar(39)zinteger UNSIGNEDzsmallint UNSIGNEDZsmallintZlongtext�timezchar(32))Z AutoFieldZ BinaryFieldZ BooleanFieldZ CharFieldZCommaSeparatedIntegerFieldZ DateField� DateTimeFieldZ DecimalFieldZ DurationFieldZ FileFieldZ FilePathFieldZ FloatFieldZ IntegerFieldZBigIntegerFieldZIPAddressFieldZGenericIPAddressFieldZNullBooleanFieldZ OneToOneFieldZPositiveIntegerFieldZPositiveSmallIntegerFieldZ SlugFieldZSmallIntegerFieldZ TextField� TimeFieldZ UUIDFieldc C s" | j jrt| jddd�S | jS d S )Nz datetime(6)ztime(6))rw rx )�featuresZ supports_microsecond_precisionrX � _data_typesrj r- r- r. � data_types s �zDatabaseWrapper.data_typesz= %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('%%', {}))r} r~ r� r� r� r� c s� t t| �j||� z| jd d | _W n tk r@ d| _Y nX | jsRt� | _nt � | _t | �| _ t | �| _ t| �| _t| �| _t| �| _t| �| _d S )N�OPTIONS�use_pureT)�superrr rH � settings_dict� _use_pure�KeyErrorr� rC � converterr0 r Zopsr ry r �clientr Zcreationr � introspectionr Z validation�r5 rQ �kwargs�� __class__r- r. rH O s zDatabaseWrapper.__init__c C s | j r| j �� S dS )NF�� connectionZ is_connectedrj r- r- r. �_valid_connectionb s z!DatabaseWrapper._valid_connectionc C s� 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 r�t|d �|d< tj|d< tjjjj g|d< z|� |d � W n t k r� Y nX |S )N�utf8TF)�charsetZ use_unicode�bufferedZconsume_results�USER�user�NAMEZdatabaseZPASSWORD�passwdZHOST�/Z unix_socket�hostZPORT�portZraise_on_warningsZ client_flagsr� ) r� r� �intr �DEBUGrJ rK � constantsZ ClientFlagZ FOUND_ROWS�updater� )r5 r� r� r- r- r. �get_connection_paramsg s4 � �z%DatabaseWrapper.get_connection_paramsc C s* | j st|d< nt|d< tjjf |�}|S )NZconverter_class)r� rC r0 rJ rK �connect)r5 Z conn_paramsZcnxr- r- r. �get_new_connection� s z"DatabaseWrapper.get_new_connectionc C s^ | j dk r| j�d� d| jkrZz| �| jd � W n$ tk rX | �| jd � Y nX d S )N)� r� r zSET SQL_AUTO_IS_NULL = 0Z AUTOCOMMIT)� mysql_versionr� Z cmd_queryr� Zset_autocommit�AttributeError�_set_autocommitrj r- r- r. �init_connection_state� s z%DatabaseWrapper.init_connection_statec C s | j �� }t|�S r; )r� rF rE rG r- r- r. � create_cursor� s z DatabaseWrapper.create_cursorc C s, | � | �� �| _tj| j| d� | �� dS )z Setup the connection with MySQL)Zsenderr� N)r� r� r� r �sendr� r� rj r- r- r. �_connect� s zDatabaseWrapper._connectc s@ zt t| ��� W S tk r: | js.| �� | �� Y S X dS )zGReturn a CursorWrapper object Returns a CursorWrapper N)r� rr �_cursorr� r� r� r� rj r� r- r. r� � s zDatabaseWrapper._cursorc C s: z | � � W n" tk r. | js*| �� Y nX | j�� S )zXReturns the MySQL server version of current connection Returns a tuple )Zensure_connectionr� r� r� �get_server_versionrj r- r- r. r� � s z"DatabaseWrapper.get_server_versionc C s | � � �d� dS )z�Disables foreign key checks Disables foreign key checks, primarily for use in adding rows with forward references. Always returns True, to indicate constraint checks need to be re-enabled. Returns True z$SET @@session.foreign_key_checks = 0T)rF rd rj r- r- r. �disable_constraint_checking� s z+DatabaseWrapper.disable_constraint_checkingc C sB t jdkrd| j | _}z| �� �d� W 5 t jdkr<|| _X dS )zjRe-enable foreign key checks Re-enable foreign key checks after they have been disabled. )r � Fz$SET @@session.foreign_key_checks = 1N)�djangor �needs_rollbackrF rd )r5 r� r- r- r. �enable_constraint_checking� s z*DatabaseWrapper.enable_constraint_checkingNc C s� d}| � � }|dkr | j�|�}|D ]�}| j�||�}|s<q$| j�||�}|D ]^\}}} |�|�|||||| || �� |�� D ],} d�|| d ||| d || �} t� | ��q~qNq$dS )a� Check rows in tables for invalid foreign key references Checks 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. Raises an IntegrityError on the first invalid foreign key reference encountered (if any) and provides 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") z� SELECT REFERRING.`{0}`, REFERRING.`{1}` FROM `{2}` as REFERRING LEFT JOIN `{3}` as REFERRED ON (REFERRING.`{4}` = REFERRED.`{5}`) WHERE REFERRING.`{6}` IS NOT NULL AND REFERRED.`{7}` IS NULLNz�The row in table '{0}' with primary key '{1}' has an invalid foreign key: {2}.{3} contains a value '{4}' that does not have a corresponding value in {5}.{6}.r r ) rF r� � table_namesZget_primary_key_columnZget_key_columnsrd �formatZfetchallr rP ) r5 r� Z ref_queryrF Z table_nameZprimary_key_column_nameZ key_columnsZ column_nameZreferenced_table_nameZreferenced_column_nameZbad_rowrM r- r- r. �check_constraints� sD ��� � �z!DatabaseWrapper.check_constraintsc C s( zt �| � W n tk r" Y nX d S r; )r � _rollback�NotSupportedErrorrj r- r- r. r� s zDatabaseWrapper._rollbackc C s | j � || j_W 5 Q R X d S r; )Zwrap_database_errorsr� � autocommit)r5 r� r- r- r. r� s z DatabaseWrapper._set_autocommitc O s t | f|�|�S )z5Returns a new instance of this backend's SchemaEditorr r� r- r- r. � schema_editor# s z DatabaseWrapper.schema_editorc C s | j �� S r; r� rj r- r- r. � is_usable( s zDatabaseWrapper.is_usablec C s* | � � }tjjf |�}|�� }|�� |S r; )r� rJ rK r� r� rm )r5 �configZ temp_connZserver_versionr- r- r. r� , s z DatabaseWrapper.mysql_versionc C s t p | jS r; )r* r� rj r- r- r. r� 5 s zDatabaseWrapper.use_pure)N)#r? r@ rA �vendorrz r r{ � operatorsZ pattern_escZ pattern_opsr ZSchemaEditorClassrJ rK ZDatabaserH r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� �propertyr� � __classcell__r- r- r� r. rr � s� � �� ' 2 rr )FrB � __future__r r rN r$ r� Zdjango.utils.functionalr Zmysql.connectorrJ Zmysql.connector.conversionr r Zmysql.connector.catch23r � ImportErrorrV Zdjango.core.exceptionsr r� rK �__version_info__�versionr� Zmysql.connector.versionr Z_mysql_connectorr r r* � __version__Z django.dbr Zdjango.db.backendsr Z backend_utilsZ django.db.backends.base.baser Zdjango.db.backends.signalsr Z django.utilsr r r Z django.confr Z mysql.connector.django.clientr Z mysql.connector.django.creationr Z$mysql.connector.django.introspectionr Z!mysql.connector.django.validationr Z mysql.connector.django.featuresr Z!mysql.connector.django.operationsr Z mysql.connector.django.schemar rS rP r� r/ r0 rC �objectrE rr r- r- r- r. �<module> st � �� %Z