Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
django
/
db
/
models
/
sql
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: subqueries.cpython-310.pyc
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
Save
Cancel