Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
django
/
db
/
backends
/
postgresql
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: operations.cpython-310.pyc
o x�g�. � @ s8 d dl mZ d dlmZ d dlmZ G dd� de�ZdS )� ��Inet)�settings)�BaseDatabaseOperationsc sj e Zd ZdZdZeg d��Zdddd�Zdd � Zd d � Z dQd d�Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� ZdQdd �Zd d � Zd d � ZdQd!d"�Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d+d,�d-d.�Zd/d0� ZdRd1d2�Zd3d4� Z d5d6� Z d7d8� Z d9d:� Z d;d<� Z d=d>� Z!d?d@� Z"dAdB� Z#dCdD� Z$dEdF� Z%dSdGdH�Z&dIdJ� Z'� fdKdL�Z(dQ� fdMdN� Z)dQ� fdOdP� Z*� Z+S )T�DatabaseOperations�varchar�EXPLAIN)�ANALYZE�BUFFERS�COSTS�SETTINGS�SUMMARY�TIMING�VERBOSE�WAL�integer�bigint�smallint)� AutoField� BigAutoField�SmallAutoFieldc C s. |� � }|dv rd|�| j��d�d S dS )N)�GenericIPAddressField�IPAddressField� TimeField� UUIDFieldzCAST(%%s AS %s)�(r �%s)�get_internal_type�db_type� connection�split)�self� output_field� internal_type� r$ �J/usr/lib/python3/dist-packages/django/db/backends/postgresql/operations.py�unification_cast_sql s z'DatabaseOperations.unification_cast_sqlc C s< |dkrd| S |dkrd| S |dkrd| S d||f S )N�week_dayzEXTRACT('dow' FROM %s) + 1� iso_week_dayzEXTRACT('isodow' FROM %s)�iso_yearzEXTRACT('isoyear' FROM %s)zEXTRACT('%s' FROM %s)r$ )r! � lookup_type� field_namer$ r$ r% �date_extract_sql) s z#DatabaseOperations.date_extract_sqlNc C � | � ||�}d||f S �NzDATE_TRUNC('%s', %s)��_convert_field_to_tz�r! r* r+ �tznamer$ r$ r% �date_trunc_sql5 � z!DatabaseOperations.date_trunc_sqlc C s, d|v r |� dd�S d|v r|� dd�S |S )N�+�-)�replace)r! r2 r$ r$ r% �_prepare_tzname_delta: s z(DatabaseOperations._prepare_tzname_deltac C s |rt jrd|| �|�f }|S )Nz%s AT TIME ZONE '%s')r �USE_TZr8 �r! r+ r2 r$ r$ r% r0 A s z'DatabaseOperations._convert_field_to_tzc C � | � ||�}d| S )Nz (%s)::dater/ r: r$ r$ r% �datetime_cast_date_sqlF � z)DatabaseOperations.datetime_cast_date_sqlc C r; )Nz (%s)::timer/ r: r$ r$ r% �datetime_cast_time_sqlJ r= z)DatabaseOperations.datetime_cast_time_sqlc C s | � ||�}| �||�S �N)r0 r, r1 r$ r$ r% �datetime_extract_sqlN � z'DatabaseOperations.datetime_extract_sqlc C r- r. r/ r1 r$ r$ r% �datetime_trunc_sqlR r4 z%DatabaseOperations.datetime_trunc_sqlc C r- )NzDATE_TRUNC('%s', %s)::timer/ r1 r$ r$ r% �time_trunc_sqlW rA z!DatabaseOperations.time_trunc_sqlc C � dS )Nz DEFERRABLE INITIALLY DEFERREDr$ �r! r$ r$ r% �deferrable_sql[ � z!DatabaseOperations.deferrable_sqlc C s |� � S )z� Given a cursor object that has just performed an INSERT...RETURNING statement into a table, return the tuple of returned data. )�fetchall)r! �cursorr$ r$ r% �fetch_returned_insert_rows^ s z-DatabaseOperations.fetch_returned_insert_rowsc C s@ d}|dv r|dv r d}n |dv rd}nd}|dv r d | }|S ) Nr ) �iexact�contains� icontains� startswith� istartswith�endswith� iendswith�regex�iregex)r r zHOST(%s))� CICharField� CIEmailField� CITextFieldz %s::citextz%s::text)rK rM rO rQ z UPPER(%s)r$ )r! r* r# �lookupr$ r$ r% � lookup_caste s z DatabaseOperations.lookup_castc C s d S r? r$ rE r$ r$ r% �no_limit_valuex rG z!DatabaseOperations.no_limit_valuec C s |gS r? r$ )r! �sqlr$ r$ r% �prepare_sql_script{ s z%DatabaseOperations.prepare_sql_scriptc C s |� d�r |�d�r |S d| S )N�"z"%s")rN rP )r! �namer$ r$ r% � quote_name~ s z DatabaseOperations.quote_namec C rD )NzSET TIME ZONE %sr$ rE r$ r$ r% �set_time_zone_sql� rG z$DatabaseOperations.set_time_zone_sqlF)�reset_sequences� allow_cascadec sd |sg S �� d�d�� �fdd�|D ��g}|r |��� d�� |r*|��� d�� dd�|� gS ) N�TRUNCATE�, c 3 s � | ] }�� � �|��V qd S r? )� SQL_FIELDr^ )�.0�table�r! �styler$ r% � <genexpr>� s � z/DatabaseOperations.sql_flush.<locals>.<genexpr>zRESTART IDENTITY�CASCADEz%s;� )� SQL_KEYWORD�join�append)r! rh �tablesr` ra � sql_partsr$ rg r% � sql_flush� s �z DatabaseOperations.sql_flushc C sR g }|D ]"}|d }|d pd}|� d|�d�|�| �|��|�|�f � q|S )Nrf �column�idz7%s setval(pg_get_serial_sequence('%s','%s'), 1, false);�SELECT)rn rl � SQL_TABLEr^ rd )r! rh � sequencesrZ � sequence_info� table_name� column_namer$ r$ r% �sequence_reset_by_name_sql� s �z-DatabaseOperations.sequence_reset_by_name_sqlc C s |r d| � |� S d| � |� S )NzUSING INDEX TABLESPACE %sz TABLESPACE %s)r^ )r! � tablespace�inliner$ r$ r% �tablespace_sql� s z!DatabaseOperations.tablespace_sqlc C s� ddl m} g }| j}|D ]G}|jjD ]@}t||j�rS|�d|�d�|� ||jj ��|� |j �|� ||j ��|� ||j ��|�d�|�d�|� ||jj ��f � nqq |S )Nr )�modelszZ%s setval(pg_get_serial_sequence('%s','%s'), coalesce(max(%s), 1), max(%s) %s null) %s %s;rt zIS NOT�FROM) � django.dbr~ r^ �_meta� local_fields� isinstancer rn rl ru �db_tablerd rr )r! rh � model_listr~ �output�qn�model�fr$ r$ r% �sequence_reset_sql� s. ��� ��z%DatabaseOperations.sequence_reset_sqlc C � |S r? r$ )r! �xr$ r$ r% �prep_for_iexact_query� rG z(DatabaseOperations.prep_for_iexact_queryc C rD )a� Return the maximum length of an identifier. The maximum length of an identifier is 63 by default, but can be changed by recompiling PostgreSQL after editing the NAMEDATALEN macro in src/include/pg_config_manual.h. This implementation returns 63, but can be overridden by a custom database backend that inherits most of its behavior from this one. �? r$ rE r$ r$ r% �max_name_length� s z"DatabaseOperations.max_name_lengthc C s0 |rdd� |D �}dd� |� g|fS dgg fS )Nc S s g | ] }|D ]}|�qqS r$ r$ )re � param_list�paramr$ r$ r% � <listcomp>� s z3DatabaseOperations.distinct_sql.<locals>.<listcomp>zDISTINCT ON (%s)rc �DISTINCT�rm )r! �fields�paramsr$ r$ r% � distinct_sql� s z DatabaseOperations.distinct_sqlc C s |j d ur |j �� S d S r? )�query�decode)r! rI rZ r� r$ r$ r% �last_executed_query� s z&DatabaseOperations.last_executed_queryc s, |sdS � fdd�|D �}dd� |� dfS )N)� r$ c s, g | ]}d � � |jjj�� � |j�f �qS )z%s.%s)r^ r� r� r� rr )re �fieldrE r$ r% r� � s � ��z<DatabaseOperations.return_insert_columns.<locals>.<listcomp>z RETURNING %src r$ r� )r! r� �columnsr$ rE r% �return_insert_columns� s �z(DatabaseOperations.return_insert_columnsc C s* dd� |D �}d� dd� |D ��}d| S )Nc s s � | ]}d � |�V qdS )rc Nr� )re �rowr$ r$ r% ri � s � z5DatabaseOperations.bulk_insert_sql.<locals>.<genexpr>rc c s � � | ]}d | V qdS )z(%s)Nr$ )re rZ r$ r$ r% ri � � � zVALUES r� )r! r� �placeholder_rows�placeholder_rows_sql� values_sqlr$ r$ r% �bulk_insert_sql� s z"DatabaseOperations.bulk_insert_sqlc C r� r? r$ �r! �valuer$ r$ r% �adapt_datefield_value� rG z(DatabaseOperations.adapt_datefield_valuec C r� r? r$ r� r$ r$ r% �adapt_datetimefield_value� rG z,DatabaseOperations.adapt_datetimefield_valuec C r� r? r$ r� r$ r$ r% �adapt_timefield_value� rG z(DatabaseOperations.adapt_timefield_valuec C r� r? r$ )r! r� � max_digits�decimal_placesr$ r$ r% �adapt_decimalfield_value rG z+DatabaseOperations.adapt_decimalfield_valuec C s |rt |�S d S r? r r� r$ r$ r% �adapt_ipaddressfield_value s z-DatabaseOperations.adapt_ipaddressfield_valuec sF |dkr|\}}|\}}g |�|�R }d||f |fS t � �|||�S )N� DateFieldz (interval '1 day' * (%s - %s)))�super�subtract_temporals) r! r# �lhs�rhs�lhs_sql� lhs_params�rhs_sql� rhs_paramsr� �� __class__r$ r% r� s z%DatabaseOperations.subtract_temporalsc s� i }|r#dd� |� � D �}| jD ]}|�|d �}|d ur"|||�� < qt� j|fi |��}|r3||d< |rE|dd�dd� |� � D �� 7 }|S )Nc S s" i | ] \}}|� � |r d nd�qS )�true�false)�upper)re r] r� r$ r$ r% � <dictcomp> s ��z;DatabaseOperations.explain_query_prefix.<locals>.<dictcomp>�FORMATz (%s)rc c s r� )z%s %sNr$ )re �ir$ r$ r% ri r� z:DatabaseOperations.explain_query_prefix.<locals>.<genexpr>)�items�explain_options�popr� r� �explain_query_prefixrm )r! �format�options�extra� valid_optionr� �prefixr� r$ r% r� s � � z'DatabaseOperations.explain_query_prefixc s |rdS t � �|�S )NzON CONFLICT DO NOTHING)r� �ignore_conflicts_suffix_sql)r! �ignore_conflictsr� r$ r% r� # s z.DatabaseOperations.ignore_conflicts_suffix_sqlr? )F)NN),�__name__� __module__� __qualname__�"cast_char_field_without_max_length�explain_prefix� frozensetr� �cast_data_typesr& r, r3 r8 r0 r< r> r@ rB rC rF rJ rX rY r[ r^ r_ rq rz r} r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� � __classcell__r$ r$ r� r% r sZ � � r N)�psycopg2.extrasr � django.confr �"django.db.backends.base.operationsr r r$ r$ r$ r% �<module> s
Save
Cancel