OwlCyberSecurity - MANAGER
Edit File: subqueries.cpython-39.pyc
a kH�f/ � @ s| d Z ddlmZ ddlmZmZmZ ddlmZ g d�Z G dd� de�Z G dd � d e�Z G d d � d e�Z G d d � d e�Z dS )zR Query subclasses which provide extra functionality beyond simple data retrieval. � )� FieldError)�CURSOR�GET_ITERATOR_CHUNK_SIZE� NO_RESULTS)�Query)� DeleteQuery� UpdateQuery� InsertQuery�AggregateQueryc @ s$ e Zd ZdZdZdd� Zdd� ZdS )r zA DELETE SQL query.ZSQLDeleteCompilerc C sX || j | i| _ || _| �|��t�}|rT|� |jW d � S 1 sJ0 Y dS )Nr )Z alias_map�where� get_compiler� execute_sqlr Zrowcount)�self�tabler �using�cursor� r �a/home/gouroczh/virtualenv/test/3.9/lib/python3.9/site-packages/django/db/models/sql/subqueries.py�do_query s $zDeleteQuery.do_queryc C sl d}| � � j}tdt|�t�D ]H}| �� | �|j� d�|||t � � || 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 Z__in)r ) �get_meta�pk�range�lenr � clear_where� add_filterZattnamer Zdb_tabler )r �pk_listr Z 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.ZSQLUpdateCompilerc s t � j|i |�� | �� d S �N)�super�__init__� _setup_query)r �args�kwargs�� __class__r r r& 5 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 r' 9 s zUpdateQuery._setup_queryc s t � �� }| j�� |_|S r$ )r% �cloner. �copy)r �objr* r r r/ B s zUpdateQuery.clonec C sT | � |� tdt|�t�D ]4}| �� | �d|||t � � | �|��t� qd S )Nr �pk__in) �add_update_valuesr r r r r r r r )r r r, r r r r r � update_batchG s �zUpdateQuery.update_batchc C s� g }|� � D ]�\}}| �� �|�}|jo.|j p8|j }|jjj}|rT|jr`|j r`t 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_fieldZ auto_createdZconcrete�model�_metaZconcrete_modelZ is_relationZ many_to_manyr �add_related_update�append�add_update_fields)r r, � values_seq�name�valr �directr7 r r r r3 P s" � ��z UpdateQuery.add_update_valuesc C s@ |D ]6\}}}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)Z allow_joinsZfor_saveN)�hasattrr@ r, r: )r r< r r7 r> r r r r; h 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)r. � setdefaultr: )r r7 r �valuer r r r9 t s z UpdateQuery.add_related_updatec C sZ | j s g S g }| j �� D ]<\}}t|�}||_| jdurJ|�d| j| � |�|� 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. Nr2 )r. r5 r r, r- r r: )r �resultr7 r, �queryr r r �get_related_updates| s z UpdateQuery.get_related_updates)r r r! r" r# r& r' r/ r4 r3 r; r9 rF � __classcell__r r r* r r 0 s r c s4 e Zd ZdZdddd�� fdd� Zd dd�Z� ZS ) r ZSQLInsertCompilerN)� on_conflict� update_fields� unique_fieldsc s< t � j|i |�� g | _g | _|| _|p*g | _|p4g | _d S r$ )r% r& �fields�objsrH rI rJ )r rH rI rJ r( r) r* r r r& � s zInsertQuery.__init__Fc C s || _ || _|| _d S r$ )rK rL �raw)r rK rL rM r r r � insert_values� s zInsertQuery.insert_values)F)r r r! r# r& rN rG r r r* 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. ZSQLAggregateCompilerc s || _ t� �|� d S r$ )� inner_queryr% r& )r r7 rO r* r r r& � s zAggregateQuery.__init__)r r r! r" r# r& rG r r r* r r � s r N)r" Zdjango.core.exceptionsr Z django.db.models.sql.constantsr r r Zdjango.db.models.sql.queryr �__all__r r r r r r r r �<module> s $^