/usr/local/lib/python3.9/site-packages/django/db/backends/sqlite3/__pycache__
a Ӱ�hAB � @ s� d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dl m Z d dl m Z m Z mZ d dlmZ d dlmZ d d lmZ d d lmZ d d lmZmZmZ d d lm Z G d d� de�Z dS )� N)� lru_cache)�chain)�settings)� FieldError)� DatabaseError�NotSupportedError�models)�BaseDatabaseOperations)� OnConflict)�Col)�timezone)� parse_date�parse_datetime� parse_time)�cached_propertyc s� e Zd ZdZddd�ZdZeg d��Zdd� Zdd � Z d d � Z d d � Z dd� Z dWdd�Z dXdd�Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zed-d.� �Z d/d/d0�d1d2�Z d3d4� Z d5d6� Z d7d8� Z � fd9d:�Z!d;d<� Z"d=d>� Z#d?d@� Z$dAdB� Z%dCdD� Z&dEdF� Z'dGdH� Z(� fdIdJ�Z)dKdL� Z*dMdN� Z+dOdP� Z,dY� fdQdR� Z-dSdT� Z.� fdUdV�Z/� Z0S )Z�DatabaseOperations�textZTEXT)� DateField� DateTimeFieldzEXPLAIN QUERY PLAN)�null�false�truec C s: t |�dkrdS t |�dkr.| jjjt |� S t |�S dS )z� SQLite has a compile-time default (SQLITE_LIMIT_VARIABLE_NUMBER) of 999 variables per query. If there's only a single field to insert, the limit is 500 (SQLITE_MAX_COMPOUND_SELECT). � i� N)�len� connection�featuresZmax_query_params)�self�fieldsZobjs� r �O/usr/local/lib/python3.9/site-packages/django/db/backends/sqlite3/operations.py�bulk_batch_size s z"DatabaseOperations.bulk_batch_sizec C s� t jt jt jf}t jt jt jt jf}t||�rp|� � D ]8}z |j }W n t t fyZ Y q60 t||�r6t d��q6t|t j�r�|jr�t|j�dkr�t d��d S )Nz{You cannot use Sum, Avg, StdDev, and Variance aggregations on date/time fields in sqlite3 since date/time is saved as text.r zTSQLite doesn't support DISTINCT on aggregate functions accepting multiple arguments.)r r r � TimeFieldZSumZAvgZVarianceZStdDev� isinstanceZget_source_expressions� output_field�AttributeErrorr r Z AggregateZdistinctr Zsource_expressions)r � expressionZ bad_fieldsZbad_aggregates�exprr# r r r �check_expression_support, s* � �� ��z+DatabaseOperations.check_expression_supportc C s d|� d�|� � g|�R fS )z� Support EXTRACT with a user-defined function django_date_extract() that's registered in connect(). Use single quotes because this is a string and could otherwise cause a collision with a field name. zdjango_date_extract(%s, �)��lower�r � lookup_type�sql�paramsr r r �date_extract_sqlH s z#DatabaseOperations.date_extract_sqlc C s |� � S )z� Given a cursor object that has just performed an INSERT...RETURNING statement into a table, return the list of returned data. )�fetchall)r �cursorr r r �fetch_returned_insert_rowsP s z-DatabaseOperations.fetch_returned_insert_rowsc C s |S )z>Do nothing since formatting is handled in the custom function.r )r r- r r r � format_for_duration_arithmeticW s z1DatabaseOperations.format_for_duration_arithmeticNc C s& d|� d�|� � g|�| �|��R fS )Nzdjango_date_trunc(%s, � , %s, %s)�r* �_convert_tznames_to_sql�r r, r- r. �tznamer r r �date_trunc_sql[ s ���z!DatabaseOperations.date_trunc_sqlc C s& d|� d�|� � g|�| �|��R fS )Nzdjango_time_trunc(%s, r4 r5 r7 r r r �time_trunc_sqlb s ���z!DatabaseOperations.time_trunc_sqlc C s |rt jr|| jjfS dS �N)NN)r �USE_TZr Z timezone_name)r r8 r r r r6 i s z*DatabaseOperations._convert_tznames_to_sqlc C s d|� d�g |�| � |��R fS )Nzdjango_datetime_cast_date(r4 �r6 �r r- r. r8 r r r �datetime_cast_date_sqln s ��z)DatabaseOperations.datetime_cast_date_sqlc C s d|� d�g |�| � |��R fS )Nzdjango_datetime_cast_time(r4 r= r> r r r �datetime_cast_time_sqlt s ��z)DatabaseOperations.datetime_cast_time_sqlc C s& d|� d�|� � g|�| �|��R fS )Nz django_datetime_extract(%s, r4 r5 r7 r r r �datetime_extract_sqlz s ���z'DatabaseOperations.datetime_extract_sqlc C s& d|� d�|� � g|�| �|��R fS )Nzdjango_datetime_trunc(%s, r4 r5 r7 r r r �datetime_trunc_sql� s ���z%DatabaseOperations.datetime_trunc_sqlc C s d|� d�|� � g|�R fS )Nzdjango_time_extract(%s, r( r) r+ r r r �time_extract_sql� s z#DatabaseOperations.time_extract_sqlc C s dS )NZNULLr �r r r r �pk_default_value� s z#DatabaseOperations.pk_default_valuec C s� d}t |�|krLd}tdt |�|�D ]"}|||| � }|| �|�7 }q$|S dd�dgt |� � }| jj�� }z|�||��� W |�� S |�� 0 dS )zV Only for last_executed_query! Don't use this to execute SQL queries! i� r r zSELECT �, zQUOTE(?)N) r �range�%_quote_params_for_last_executed_query�joinr r1 �executeZfetchone�close)r r. Z BATCH_SIZE�results�index�chunkr- r1 r r r rH � s �z8DatabaseOperations._quote_params_for_last_executed_queryc C sR |rJt |ttf�r | �|�}n$t|�� �}| �|�}tt||��}|| S |S d S �N)r" �list�tuplerH �values�dict�zip)r r1 r- r. rR r r r �last_executed_query� s z&DatabaseOperations.last_executed_queryc C s |� d�r|�d�r|S d| S )N�"z"%s")� startswith�endswith)r �namer r r � quote_name� s z DatabaseOperations.quote_namec C s dS )N���r rD r r r �no_limit_value� s z!DatabaseOperations.no_limit_valuec C sZ d}|ddf}| j �� �.}|�||�}dd� |�� D �W d � S 1 sL0 Y d S )Nz� WITH tables AS ( SELECT %s name UNION SELECT sqlite_master.name FROM sqlite_master JOIN tables ON (sql REGEXP %s || tables.name || %s) ) SELECT name FROM tables; z(?i)\s+references\s+("|\')?z ("|\')?\s*\(c S s g | ] }|d �qS )r r ��.0�rowr r r � <listcomp>� � z9DatabaseOperations.__references_graph.<locals>.<listcomp>)r r1 rJ r0 )r Z table_name�queryr. r1 rL r r r Z__references_graph� s � z%DatabaseOperations.__references_graphc C s t dd�| j�S )Ni )�maxsize)r �%_DatabaseOperations__references_graphrD r r r �_references_graph� s z$DatabaseOperations._references_graphF)�reset_sequences� allow_cascadec s` |r$|r$t t�� fdd�|D ���}� �fdd�|D �}|r\dd� |D �}|�� ��|�� |S )Nc 3 s | ]}� � |�V qd S rO )re �r^ �tablerD r r � <genexpr>� ra z/DatabaseOperations.sql_flush.<locals>.<genexpr>c s2 g | ]*}d �� d��� d���� �|��f �qS )z %s %s %s;�DELETEZFROM)� SQL_KEYWORD� SQL_FIELDrZ rh �r �styler r r` � s ���z0DatabaseOperations.sql_flush.<locals>.<listcomp>c S s g | ] }d |i�qS )ri r rh r r r r` � ra )�setr � from_iterable�extend�sequence_reset_by_name_sql)r ro Ztablesrf rg r- � sequencesr rn r � sql_flush� s � � z DatabaseOperations.sql_flushc C sn |sg S d|� d�|�| �d��|� d�|�| �d��|� d�|�| �d��|� d�d �d d � |D ��f gS ) Nz %s %s %s %s = 0 %s %s %s (%s);�UPDATEZsqlite_sequenceZSET�seqZWHERErY �INrF c S s g | ]}d |d �qS )�'%s'ri r )r^ Z sequence_infor r r r` � ra zADatabaseOperations.sequence_reset_by_name_sql.<locals>.<listcomp>)rl Z SQL_TABLErZ rm rI )r ro rt r r r rs � s ����z-DatabaseOperations.sequence_reset_by_name_sqlc C sL |d u r d S t |d�r|S t�|�rDtjr<t�|| jj�}ntd��t|�S )N�resolve_expressionzNSQLite backend does not support timezone-aware datetimes when USE_TZ is False.) �hasattrr �is_awarer r< Z make_naiver � ValueError�str�r �valuer r r �adapt_datetimefield_value s �z,DatabaseOperations.adapt_datetimefield_valuec C s4 |d u r d S t |d�r|S t�|�r,td��t|�S )Nrz z5SQLite backend does not support timezone-aware times.)r{ r r| r} r~ r r r r �adapt_timefield_value s z(DatabaseOperations.adapt_timefield_valuec s� t � �|�}|j�� }|dkr,|�| j� np|dkrB|�| j� nZ|dkrX|�| j� nD|dkrr|�| �|�� n*|dkr�|�| j � n|dkr�|�| j � |S )Nr r r! Z DecimalFieldZ UUIDFieldZ BooleanField) �super�get_db_convertersr# Zget_internal_type�append�convert_datetimefield_value�convert_datefield_value�convert_timefield_value�get_decimalfield_converter�convert_uuidfield_value�convert_booleanfield_value)r r% � converters� internal_type�� __class__r r r� & s z$DatabaseOperations.get_db_convertersc C s@ |d ur<t |tj�s t|�}tjr<t�|�s<t�|| jj�}|S rO ) r" �datetimer r r< r r| Z make_awarer �r r� r% r r r r r� 7 s z.DatabaseOperations.convert_datetimefield_valuec C s |d ur t |tj�s t|�}|S rO )r" r� �dater r� r r r r� ? s z*DatabaseOperations.convert_datefield_valuec C s |d ur t |tj�s t|�}|S rO )r" r� �timer r� r r r r� E s z*DatabaseOperations.convert_timefield_valuec sN t jdd�j� t|t�r>t �d��|jj ��� �fdd�}n � fdd�}|S )N� )�precr c s" | d ur � | �j �|jjd�S d S )N)�context)�quantizer# r� �r� r% r ��create_decimalZquantize_valuer r � converterT s �z@DatabaseOperations.get_decimalfield_converter.<locals>.converterc s | d ur� | �S d S rO r r� )r� r r r� \ s ) �decimal�Context�create_decimal_from_floatr" r �Decimal�scalebr# Zdecimal_places)r r% r� r r� r r� K s � z-DatabaseOperations.get_decimalfield_converterc C s |d urt �|�}|S rO )�uuid�UUIDr� r r r r� b s z*DatabaseOperations.convert_uuidfield_valuec C s |dv rt |�S |S )N)r r )�boolr� r r r r� g s z-DatabaseOperations.convert_booleanfield_valuec C s, dd� |D �}d� dd� |D ��}d|� �S )Nc s s | ]}d � |�V qdS )rF N�rI r] r r r rj k ra z5DatabaseOperations.bulk_insert_sql.<locals>.<genexpr>rF c s s | ]}d |� d�V qdS )�(r( Nr )r^ r- r r r rj l ra zVALUES r� )r r Zplaceholder_rowsZplaceholder_rows_sqlZ values_sqlr r r �bulk_insert_sqlj s z"DatabaseOperations.bulk_insert_sqlc s: |dkrdd� |� S |dkr,dd� |� S t� �||�S )N�^z POWER(%s)�,�#z BITXOR(%s))rI r� �combine_expression)r � connector�sub_expressionsr� r r r� o s z%DatabaseOperations.combine_expressionc C sD |dvrt d| ��d| g| }t|�dkr6td��dd�|� S )N)�+�-�*�/z$Invalid connector for timedelta: %s.ry � z)Too many params for timedelta operations.zdjango_format_dtdelta(%s)rF )r r r} rI )r r� r� Z fn_paramsr r r �combine_duration_expressionx s z.DatabaseOperations.combine_duration_expressionc C s dS r; r )r r� r r r �integer_field_range� s z&DatabaseOperations.integer_field_rangec C sF |\}}|\}}g |�|�R }|dkr6d||f |fS d||f |fS )Nr! zdjango_time_diff(%s, %s)z django_timestamp_diff(%s, %s)r ) r r� �lhs�rhsZlhs_sqlZ lhs_paramsZrhs_sqlZ rhs_paramsr. r r r �subtract_temporals� s z%DatabaseOperations.subtract_temporalsc s |t jkrdS t� j|d�S )NzINSERT OR IGNORE INTO)� on_conflict)r ZIGNOREr� �insert_statement)r r� r� r r r� � s z#DatabaseOperations.insert_statementc s, |sdS � fdd�|D �}dd� |� dfS )N)� r c s, g | ]$}d � � |jjj�� � |j�f �qS )z%s.%s)rZ �model�_metaZdb_table�column�r^ �fieldrD r r r` � s � ��z<DatabaseOperations.return_insert_columns.<locals>.<listcomp>z RETURNING %srF r r� )r r �columnsr rD r �return_insert_columns� s �z(DatabaseOperations.return_insert_columnsc sX |t jkrF| jjjrFdd�t| j|��d�dd� t| j|�D ��f S t� � ||||�S )Nz ON CONFLICT(%s) DO UPDATE SET %srF c S s g | ]}|� d |� ��qS )z = EXCLUDED.r r� r r r r` � s �z=DatabaseOperations.on_conflict_suffix_sql.<locals>.<listcomp>) r rv r r Z%supports_update_conflicts_with_targetrI �maprZ r� �on_conflict_suffix_sql)r r r� Z update_fieldsZ unique_fieldsr� r r r� � s$ �� ��� �z)DatabaseOperations.on_conflict_suffix_sql)N)N)N)1�__name__� __module__� __qualname__Z"cast_char_field_without_max_lengthZcast_data_typesZexplain_prefix� frozensetZjsonfield_datatype_valuesr r' r/ r2 r3 r9 r: r6 r? r@ rA rB rC rE rH rU rZ r\ rd r re ru rs r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� � __classcell__r r r� r r s\ � r ) r� r� r� � functoolsr � itertoolsr Z django.confr Zdjango.core.exceptionsr Z django.dbr r r Z"django.db.backends.base.operationsr Zdjango.db.models.constantsr Z django.db.models.expressionsr Z django.utilsr Zdjango.utils.dateparser r r Zdjango.utils.functionalr r r r r r �<module> s
.
Edit
..
Edit
__init__.cpython-39.pyc
Edit
_functions.cpython-39.pyc
Edit
base.cpython-39.pyc
Edit
client.cpython-39.pyc
Edit
creation.cpython-39.pyc
Edit
features.cpython-39.pyc
Edit
introspection.cpython-39.pyc
Edit
operations.cpython-39.pyc
Edit
schema.cpython-39.pyc
Edit