|
Server : Apache System : Linux iad1-shared-b8-43 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64 User : dh_edsupp ( 6597262) PHP Version : 8.2.26 Disable Function : NONE Directory : /lib/python3/dist-packages/django/db/models/sql/__pycache__/ |
Upload File : |
o
3�ap � @ s� d Z ddlmZ ddlmZ ddlmZmZmZ ddl m
Z
g d�Z G dd� de
�Z G d d
� d
e
�Z
G d d � d e
�ZG d
d� de
�ZdS )zR
Query subclasses which provide extra functionality beyond simple data retrieval.
� )�
FieldError)�Q)�CURSOR�GET_ITERATOR_CHUNK_SIZE�
NO_RESULTS)�Query)� DeleteQuery� UpdateQuery� InsertQuery�AggregateQueryc @ s$ e Zd ZdZdZdd� Zdd� ZdS )r zA DELETE SQL query.�SQLDeleteCompilerc C sX || j | i| _ || _| �|��t�}|r*|� |jW d � S 1 s%w Y dS )Nr )� alias_map�where� get_compiler� execute_sqlr �rowcount)�self�tabler �using�cursor� r �A/usr/lib/python3/dist-packages/django/db/models/sql/subqueries.py�do_query s �zDeleteQuery.do_queryc C sx d}| � � j}tdt|�t�D ]*}| �� | _| �tdi |j d |||t � i��� || j
| � � j | j|d�7 }q|S )z�
Set up and execute delete queries for all the objects in pk_list.
More than one physical query may be executed if there are a
lot of values in pk_list.
r �__in)r Nr ) �get_meta�pk�range�lenr � where_classr �add_qr �attnamer �db_table)r �pk_listr � num_deleted�field�offsetr r r � delete_batch s
� zDeleteQuery.delete_batchN)�__name__�
__module__� __qualname__�__doc__�compilerr r& r r r r r s
r c s` e Zd ZdZdZ� fdd�Zdd� Z� fdd�Zd d
� Zd d � Z d
d� Z
dd� Z dd� Z � Z
S )r zAn UPDATE SQL query.�SQLUpdateCompilerc s t � j|i |�� | �� d S �N)�super�__init__� _setup_query)r �args�kwargs�� __class__r r r/ 4 s zUpdateQuery.__init__c C s g | _ d| _i | _dS )z�
Run on initialization and at the end of chaining. Any attributes that
would normally be set in __init__() should go here instead.
N)�values� related_ids�related_updates)r r r r r0 8 s
zUpdateQuery._setup_queryc s t � �� }| j�� |_|S r- )r. �cloner7 �copy)r �objr3 r r r8 A s
zUpdateQuery.clonec C sZ | � |� tdt|�t�D ] }| �� | _| �t|||t � d�� | �|�� t
� q
d S )Nr )�pk__in) �add_update_valuesr r r r r r r r r r )r r" r5 r r% r r r � update_batchF s
�zUpdateQuery.update_batchc C s� g }|� � D ]A\}}| �� �|�}|jo|j p |j }|jjj}|r*|jr0|j r0t
d| ��|| �� jur?| � |||� q|� |||f� q| �
|�S )z�
Convert a dictionary of field name to value mappings into an update
query. This is the entry point for the public update() method on
querysets.
zMCannot update model field %r (only non-relations and foreign keys permitted).)�itemsr � get_field� auto_created�concrete�model�_meta�concrete_model� is_relation� many_to_manyr �add_related_update�append�add_update_fields)r r5 �
values_seq�name�valr$ �directrB r r r r< M s
��
z UpdateQuery.add_update_valuesc C s@ |D ]\}}}t |d�r|j| ddd�}| j�|||f� qdS )z�
Append a sequence of (field, model, value) triples to the internal list
that will be used to generate the UPDATE query. Might be more usefully
called add_update_targets() to hint at the extra information here.
�resolve_expressionFT)� allow_joins�for_saveN)�hasattrrN r5 rH )r rJ r$ rB rL r r r rI c s
�z UpdateQuery.add_update_fieldsc C s | j �|g ��|d|f� dS )z�
Add (name, value) to an update query for an ancestor model.
Update are coalesced so that only one update query per ancestor is run.
N)r7 �
setdefaultrH )r rB r$ �valuer r r rG o s z UpdateQuery.add_related_updatec C sX | j sg S g }| j �� D ] \}}t|�}||_| jdur$|�d| jf� |�|� q |S )z�
Return a list of query objects: one for each update required to an
ancestor model. Each query will have the same filtering conditions as
the current query but will only update a single table.
Nr; )r7 r> r r5 r6 �
add_filterrH )r �resultrB r5 �queryr r r �get_related_updatesw s
z UpdateQuery.get_related_updates)r' r( r) r* r+ r/ r0 r8 r= r< rI rG rW �
__classcell__r r r3 r r / s r c s0 e Zd ZdZdd�� fdd�
Zddd�Z� ZS ) r
�SQLInsertCompilerF)�ignore_conflictsc s( t � j|i |�� g | _g | _|| _d S r- )r. r/ �fields�objsrZ )r rZ r1 r2 r3 r r r/ � s
zInsertQuery.__init__c C s || _ || _|| _d S r- )r[ r\ �raw)r r[ r\ r] r r r �
insert_values� s
zInsertQuery.insert_values)F)r' r( r) r+ r/ r^ rX r r r3 r r
� s r
c s$ e Zd ZdZdZ� fdd�Z� ZS )r zu
Take another query as a parameter to the FROM clause and only select the
elements in the provided list.
�SQLAggregateCompilerc s || _ t� �|� d S r- )� inner_queryr. r/ )r rB r` r3 r r r/ � s zAggregateQuery.__init__)r' r( r) r* r+ r/ rX r r r3 r r � s r N)r* �django.core.exceptionsr � django.db.models.query_utilsr � django.db.models.sql.constantsr r r �django.db.models.sql.queryr �__all__r r r
r r r r r �<module> s Z