File manager - Edit - /usr/local/CyberCP/lib/python3.10/site-packages/django/db/backends/postgresql/__pycache__/operations.cpython-310.pyc
Back
o �hI; � @ s� d dl Z d dlmZmZ d dlmZ d dlmZ d dlm Z m Z m Z m Z m Z d dlmZ d dlmZ d dlmZ ed d � �ZG d d � d e�ZdS ) � N)� lru_cache�partial)�settings)�BaseDatabaseOperations)�Inet�Jsonb�errors� is_psycopg3�mogrify��split_tzname_delta)� OnConflict)�_lazy_re_compilec C s | d u rt jS tt j| d�S )N)�cls)�json�dumpsr )�encoder� r �[/usr/local/CyberCP/lib/python3.10/site-packages/django/db/backends/postgresql/operations.py�get_json_dumps s r c s� e Zd ZdZdZeg d��Zdddd�Zer+dd l m Z e j e j e j e j e j e j d �Zd d � Zed �Zdd� Zd^dd�Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd^d!d"�Zd#d$� Z d%d&� Z d^d'd(�Z d)d*� Z d+d,� Z d-d.� Z!d/d0� Z"d1d2� Z#d3d3d4�d5d6�Z$d7d8� Z%d_d9d:�Z&d;d<� Z'd=d>� Z(d?d@� Z)dAdB� Z*er�dCdD� Z+ndEdD� Z+dFdG� Z,dHdI� Z-er�dJdK� Z.dLdM� Z/dNdO� Z0dPdQ� Z1d`dRdS�Z2dTdU� Z3dVdW� Z4� fdXdY�Z5d^� fdZd[� Z6� fd\d]�Z7� Z8S )a�DatabaseOperations�varchar�EXPLAIN)�ANALYZE�BUFFERS�COSTS�SETTINGS�SUMMARY�TIMING�VERBOSE�WAL�integer�bigint�smallint)� AutoField� BigAutoField�SmallAutoFieldr )�numeric)�SmallIntegerField� IntegerField�BigIntegerField�PositiveSmallIntegerField�PositiveIntegerField�PositiveBigIntegerFieldc 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_typer r r �unification_cast_sql: s �z'DatabaseOperations.unification_cast_sqlz[A-Z_]+c C s� |dkr d|� d�|fS |dkrd|� d�|fS |dkr$d|� d�|fS |� � }| j�|�s5td |����d |� d |� d�|fS ) N�week_dayzEXTRACT(DOW FROM z) + 1� iso_week_dayzEXTRACT(ISODOW FROM �)�iso_yearzEXTRACT(ISOYEAR FROM zInvalid lookup type: zEXTRACT(z FROM )�upper�_extract_format_re� fullmatch� ValueError�r8 � lookup_type�sql�paramsr r r �date_extract_sqlQ s z#DatabaseOperations.date_extract_sqlNc C �* | � |||�\}}d|� d�|g|�R fS �N�DATE_TRUNC(%s, r> ��_convert_sql_to_tz�r8 rE rF rG �tznamer r r �date_trunc_sql` � z!DatabaseOperations.date_trunc_sqlc C s6 t |�\}}}|r|dkrdnd}|� |� |� �S |S )N�+�-r )r8 rO �sign�offsetr r r �_prepare_tzname_deltae s z(DatabaseOperations._prepare_tzname_deltac C s4 |rt jr| �|�}|� d�g |�|�R fS ||fS )Nz AT TIME ZONE %s)r �USE_TZrV )r8 rF rG rO � tzname_paramr r r rM l s z%DatabaseOperations._convert_sql_to_tzc C �" | � |||�\}}d|� d�|fS )Nr2 z)::daterL �r8 rF rG rO r r r �datetime_cast_date_sqlr � z)DatabaseOperations.datetime_cast_date_sqlc C rY )Nr2 �)::timerL rZ r r r �datetime_cast_time_sqlv r\ z)DatabaseOperations.datetime_cast_time_sqlc C s@ | � |||�\}}|dkrd|� d�dg|�R fS | �|||�S �N�secondz#EXTRACT(SECOND FROM DATE_TRUNC(%s, z)))rM rH rN r r r �datetime_extract_sqlz s z'DatabaseOperations.datetime_extract_sqlc C rI rJ rL rN r r r �datetime_trunc_sql� rQ z%DatabaseOperations.datetime_trunc_sqlc C s. |dkrd|� d�dg|�R fS | � |||�S r_ )rH rD r r r �time_extract_sql� s z#DatabaseOperations.time_extract_sqlc C rI )NrK r] rL rN r r r �time_trunc_sql� s z!DatabaseOperations.time_trunc_sqlc C � dS )Nz DEFERRABLE INITIALLY DEFERREDr �r8 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)r8 �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 ) Nr3 ) �iexact�contains� icontains� startswith� istartswith�endswith� iendswith�regex�iregex)r/ r. zHOST(%s))� CICharField� CIEmailField� CITextFieldz %s::citextz%s::text)rl rn rp rr z UPPER(%s)r )r8 rE r: �lookupr r r � lookup_cast� s z DatabaseOperations.lookup_castc C s d S �Nr rf r r r �no_limit_value� rh z!DatabaseOperations.no_limit_valuec C s |gS rz r )r8 rF r r r �prepare_sql_script� s z%DatabaseOperations.prepare_sql_scriptc C s |� d�r |�d�r |S d| S )N�"z"%s")ro rq )r8 �namer r r � quote_name� s z DatabaseOperations.quote_namec C s t ||| j�S rz )r r6 )r8 rF rG r r r � compose_sql� s z DatabaseOperations.compose_sqlc C re )Nz(SELECT set_config('TimeZone', %s, false)r rf r r r �set_time_zone_sql� rh 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 rz )� SQL_FIELDr )�.0�table�r8 �styler r � <genexpr>� s � z/DatabaseOperations.sql_flush.<locals>.<genexpr>zRESTART IDENTITY�CASCADEz%s;� )� SQL_KEYWORD�join�append)r8 r� �tablesr� r� � sql_partsr r� r � sql_flush� s �z DatabaseOperations.sql_flushc C sR g }|D ]"}|d }|d pd}|� d|�d�|�| �|��|�|�f � q|S )Nr� �column�idz7%s setval(pg_get_serial_sequence('%s','%s'), 1, false);�SELECT)r� r� � SQL_TABLEr r� )r8 r� � sequencesrF � 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 )r8 � 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;r� zIS NOT�FROM) � django.dbr� r �_meta� local_fields� isinstancer$ r� r� r� �db_tabler� r� )r8 r� � model_listr� �output�qn�model�fr r r �sequence_reset_sql� s. �����z%DatabaseOperations.sequence_reset_sqlc C � |S rz r )r8 �xr r r �prep_for_iexact_query rh z(DatabaseOperations.prep_for_iexact_queryc C re )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 rf 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 )r� � param_list�paramr r r � <listcomp>$ s z3DatabaseOperations.distinct_sql.<locals>.<listcomp>zDISTINCT ON (%s)r� �DISTINCT�r� )r8 �fieldsrG r r r � distinct_sql" s z DatabaseOperations.distinct_sqlc C s& z| � ||�W S tjy Y d S w rz )r� r � DataError�r8 rj rF rG r r r �last_executed_query+ s �z&DatabaseOperations.last_executed_queryc C s |j d ur |j �� S d S rz )�query�decoder� r r r r� 3 s c s, |sdS � fdd�|D �}dd� |� dfS )N)� r c s, g | ]}d � � |jjj�� � |j�f �qS )z%s.%s)r r� r� r� r� �r� �fieldrf r r r� = s � ���z<DatabaseOperations.return_insert_columns.<locals>.<listcomp>z RETURNING %sr� r r� )r8 r� �columnsr rf 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 )r� Nr� )r� �rowr r r r� H s � z5DatabaseOperations.bulk_insert_sql.<locals>.<genexpr>r� c s � � | ]}d | V qdS )z(%s)Nr )r� rF r r r r� I � � zVALUES r� )r8 r� �placeholder_rows�placeholder_rows_sql� values_sqlr r r �bulk_insert_sqlG s z"DatabaseOperations.bulk_insert_sqlc C s$ |d u s t |d�r |S | j| |�S )N�resolve_expression)�hasattr�integerfield_type_map)r8 �valuer: r r r �adapt_integerfield_valueN s z+DatabaseOperations.adapt_integerfield_valuec C r� rz r �r8 r� r r r �adapt_datefield_valueS rh z(DatabaseOperations.adapt_datefield_valuec C r� rz r r� r r r �adapt_datetimefield_valueV rh z,DatabaseOperations.adapt_datetimefield_valuec C r� rz r r� r r r �adapt_timefield_valueY rh z(DatabaseOperations.adapt_timefield_valuec C r� rz r )r8 r� � max_digits�decimal_placesr r r �adapt_decimalfield_value\ rh z+DatabaseOperations.adapt_decimalfield_valuec C s |rt |�S d S rz )r r� r r r �adapt_ipaddressfield_value_ s z-DatabaseOperations.adapt_ipaddressfield_valuec C s t |t|�d�S )N)r )r r )r8 r� r r r r �adapt_json_valued s z#DatabaseOperations.adapt_json_valuec sF |dkr|\}}|\}}g |�|�R }d||f |fS t � �|||�S )N� DateFieldz (interval '1 day' * (%s - %s)))�super�subtract_temporals) r8 r: �lhs�rhs�lhs_sql� lhs_params�rhs_sql� rhs_paramsrG �� __class__r r r� g s z%DatabaseOperations.subtract_temporalsc s� i }|r!dd� |� � D �}| jD ]}|�|d �}|d ur |||< qt� j|fi |��}|r1||d< |rC|dd�dd� |� � D �� 7 }|S )Nc S s" i | ] \}}|� � |r d nd�qS )�true�false)r@ )r� r~ r� r r r � <dictcomp>s s ��z;DatabaseOperations.explain_query_prefix.<locals>.<dictcomp>�FORMATz (%s)r� c s r� )z%s %sNr )r� �ir r r r� r� z:DatabaseOperations.explain_query_prefix.<locals>.<genexpr>)�items�explain_options�popr� �explain_query_prefixr� )r8 �format�options�extra� valid_optionr� �prefixr� r r r� o s � � z'DatabaseOperations.explain_query_prefixc s\ |t jkrdS |t jkr%dd�t| j|��d�dd� t| j|�D ��f S t� �||||�S )NzON CONFLICT DO NOTHINGz ON CONFLICT(%s) DO UPDATE SET %sr� c S s g | ] }|� d |� ��qS )z = EXCLUDED.r r� r r r r� � s ��z=DatabaseOperations.on_conflict_suffix_sql.<locals>.<listcomp>)r �IGNORE�UPDATEr� �mapr r� �on_conflict_suffix_sql)r8 r� � on_conflict� update_fields� unique_fieldsr� r r r� � s" ��� �z)DatabaseOperations.on_conflict_suffix_sqlrz )F)NN)9�__name__� __module__� __qualname__�"cast_char_field_without_max_length�explain_prefix� frozensetr� �cast_data_typesr � psycopg.typesr' �Int2�Int4�Int8r� r; r rA rH rP rV rM r[ r^ ra rb rc rd rg rk ry r{ r| r r� r� r� r� r� 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 � functoolsr r � django.confr �"django.db.backends.base.operationsr �)django.db.backends.postgresql.psycopg_anyr r r r r �django.db.backends.utilsr �django.db.models.constantsr �django.utils.regex_helperr r r r r r r �<module> s
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings