HEX
Server: Apache
System: Linux pdx1-shared-a1-38 6.6.104-grsec-jammy+ #3 SMP Tue Sep 16 00:28:11 UTC 2025 x86_64
User: mmickelson (3396398)
PHP: 8.1.31
Disabled: NONE
$ pwd: /lib/python3/dist-packages/django/db/models/__pycache__/
Upload Files
File: //lib/python3/dist-packages/django/db/models/__pycache__/query.cpython-310.pyc
o

/�hI�@sdZddlZddlZddlZddlmZddlZddlmZddl	m
Z
ddlmZm
Z
mZmZmZmZddlmZmZmZmZddlmZdd	lmZdd
lmZmZmZmZm Z m!Z!ddl"m#Z#m$Z$ddl%m&Z&m'Z'dd
l(m)Z)m*Z*ddl+m,Z,m-Z-ddl.m/Z/ddl0m1Z1m2Z2dZ3dZ4Gdd�d�Z5Gdd�de5�Z6Gdd�de5�Z7Gdd�de5�Z8Gdd�de8�Z9Gdd�de5�Z:Gdd �d �Z;Gd!d"�d"e<�Z=Gd#d$�d$e=d%�Z>Gd&d'�d'�Z?Gd(d)�d)�Z@d6d*d+�ZAd,d-�ZBd.d/�ZCd0d1�ZDGd2d3�d3�ZEd4d5�ZFdS)7zM
The main QuerySet implementation. This provides the public API for the ORM.
�N)�chain)�settings)�
exceptions)�DJANGO_VERSION_PICKLE_KEY�IntegrityError�NotSupportedError�connections�router�transaction)�	AutoField�	DateField�
DateTimeField�sql��
LOOKUP_SEP)�	Collector)�Case�
Expression�F�Ref�Value�When)�Cast�Trunc)�FilteredRelation�Q)�CURSOR�GET_ITERATOR_CHUNK_SIZE)�create_namedtuple_class�resolve_callables)�timezone)�cached_property�	partition��c@seZdZdefdd�ZdS)�BaseIterableFcCs||_||_||_dS�N)�queryset�
chunked_fetch�
chunk_size)�selfr'r(r)�r+�8/usr/lib/python3/dist-packages/django/db/models/query.py�__init__$s
zBaseIterable.__init__N)�__name__�
__module__�__qualname__rr-r+r+r+r,r%#sr%c@�eZdZdZdd�ZdS)�
ModelIterablez3Iterable that yields a model instance for each row.c
#sb�|j��j}�jj|d�}|j|j|jd�}|j|j|j	}}}|d}|d}|d|dd}	}
dd	�||	|
�D�}t
|||�}�fd
d	��j��D�}
|�
|�D]W}|�||||	|
��}|D]}|�||�qf|r�|��D]\}}t||||�qu|
D]&\}}}|�|�r�q�||�}z||}Wn	ty�Yq�wt||j|�q�|VqWdS)N��using�r(r)�model�
select_fieldsr����cS�g|]}|djj�qS�r��target�attname��.0�fr+r+r,�
<listcomp>9s�z*ModelIterable.__iter__.<locals>.<listcomp>cs2g|]\�}�|tj��fdd��jD��f�qS)cs*g|]}|dkr�jn�jj�|�j�qS�r*)r>r6�_meta�	get_field)r@�
from_field)�fieldr'r+r,rB=s���z5ModelIterable.__iter__.<locals>.<listcomp>.<listcomp>)�operator�
attrgetter�from_fields)r@�related_objs�r')rGr,rB<s���)r'�db�query�get_compiler�execute_sqlr(r)�select�
klass_info�annotation_col_map�get_related_populators�_known_related_objects�items�results_iter�from_db�populate�setattr�	is_cached�KeyError�name)r*rM�compiler�resultsrQrRrS�	model_clsr7�model_fields_start�model_fields_end�	init_list�related_populators�known_related_objects�row�obj�
rel_populator�	attr_name�col_posrG�rel_objs�
rel_getter�
rel_obj_id�rel_objr+rLr,�__iter__-sJ�
�
�
�
��zModelIterable.__iter__N�r.r/r0�__doc__ror+r+r+r,r2*sr2c@r1)�ValuesIterablezQ
    Iterable returned by QuerySet.values() that yields a dict for each row.
    c#sn�|j}|j}|�|j�}g|j�|j�|j��tt���}|j	|j
|jd�D]
���fdd�|D�Vq'dS)Nr5csi|]	}�|�|�qSr+r+�r@�i��namesrfr+r,�
<dictcomp>n�z+ValuesIterable.__iter__.<locals>.<dictcomp>)r'rNrOrM�extra_select�
values_select�annotation_select�range�lenrWr(r))r*r'rNr^�indexesr+rur,roas�����zValuesIterable.__iter__Nrpr+r+r+r,rr\srrc@r1)�ValuesListIterableze
    Iterable returned by QuerySet.values_list(flat=False) that yields a tuple
    for each row.
    cs�|j��j}|��j�}�jrNg|j�|j�|j�}g�j��fdd�|jD��}||krNdd�t|�D��t	j
�fdd�|D��}t||j|j
|jd��S|jd|j
|jd	�S)
Nc3s�|]
}|�jvr|VqdSr&)�_fieldsr?rLr+r,�	<genexpr>���z.ValuesListIterable.__iter__.<locals>.<genexpr>cSsi|]\}}||�qSr+r+)r@�idxr]r+r+r,rw�sz/ValuesListIterable.__iter__.<locals>.<dictcomp>c�g|]}�|�qSr+r+r?)�	index_mapr+r,rB��z/ValuesListIterable.__iter__.<locals>.<listcomp>r5T)�tuple_expectedr(r))r'rNrOrMr�ryrzr{�	enumeraterH�
itemgetter�maprWr(r))r*rNr^rv�fields�
rowfactoryr+)r�r'r,rows(����zValuesListIterable.__iter__Nrpr+r+r+r,rq�rcs eZdZdZ�fdd�Z�ZS)�NamedValuesListIterablezj
    Iterable returned by QuerySet.values_list(named=True) that yields a
    namedtuple for each row.
    c#s`�|j}|jr|j}n|j}g|j�|j�|j�}t|�}tj}t	��
�D]}|||�Vq%dSr&)r'r�rNryrzr{r�tuple�__new__�superro)r*r'rvrN�tuple_class�newrf��	__class__r+r,ro�s��z NamedValuesListIterable.__iter__)r.r/r0rqro�
__classcell__r+r+r�r,r��sr�c@r1)�FlatValuesListIterablez]
    Iterable returned by QuerySet.values_list(flat=True) that yields single
    values.
    ccs<�|j}|j�|j�}|j|j|jd�D]}|dVqdS)Nr5r)r'rNrOrMrWr(r))r*r'r^rfr+r+r,ro�s��zFlatValuesListIterable.__iter__Nrpr+r+r+r,r��r�r�c@sZeZdZdZd�dd�Zedd��Zejdd��Zdd	�Zd
e_	e
e�Zdd�Zd
d�Zdd�Z
dd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd �Zd!d"�Zd�d$d%�Zd&d'�Zd(d)�Zd*d+�Zd,d-�Zd.d/�Zd�d1d2�Zd�d3d4�Zd
e_d�d5d6�Z d�d7d8�Z!d9d:�Z"d;d<�Z#d=d>�Z$d?d@�Z%dAdB�Z&dCdD�Z'd�dEdF�dGdH�Z(dIdJ�Z)d
e)_d
e)_	dKdL�Z*d
e*_dMdN�Z+d
e+_dOdP�Z,d
e,_d0e,_	dQdR�Z-dSdT�Z.ddU�dVdW�Z/d�dYdZ�Z0d[d\�Z1d]d^�Z2d0d0d_�d`da�Z3d�dcdd�Z4d�dedf�Z5dgdh�Z6didj�Z7dkdl�Z8dmdn�Z9dodp�Z:dqdr�Z;dsdt�Z<d0du�dvdw�Z=d0du�dxdy�Z>dzd{�Z?d|d}�Z@d�d~d�ZAd�d��ZBd�d��ZCd�d��ZDd�d��ZEd�d�d��ZFd�d��ZGd�d��ZH		d�d�d��ZId�d��ZJd�d��ZKd�d��ZLd�d��ZMed�d���ZNed�d���ZOd�d�d��ZPd
eP_d0eP_	d�d�d��ZQd�d��ZRd�d��ZSd�d��ZTd�d��ZUd�d��ZVd�d��ZWd�d��ZXd
eX_	d�d��ZYd�d��ZZe[d�d���Z\d�d��Z]dS)��QuerySetz6Represent a lazy database lookup for a set of objects.NcCsh||_||_|p	i|_|pt�|j�|_d|_d|_d|_d|_	d|_
i|_t|_
d|_d|_d|_dS)NFr+)r6�_db�_hintsr�Query�_query�
_result_cache�_sticky_filter�
_for_write�_prefetch_related_lookups�_prefetch_donerUr2�_iterable_classr��_defer_next_filter�_deferred_filter)r*r6rNr4�hintsr+r+r,r-�s

zQuerySet.__init__cCs,|jr|j\}}}|�|||�d|_|jSr&)r��_filter_or_exclude_inplacer��r*�negate�args�kwargsr+r+r,rN�s
zQuerySet.querycCs|jrt|_||_dSr&)rzrrr�r�)r*�valuer+r+r,rN�s
cCs"ddlm}|�|��}d|_|S)Nr)�ManagerT)�django.db.models.managerr��
from_queryset�_built_with_as_manager)�clsr��managerr+r+r,�
as_manager�szQuerySet.as_managerTcCsF|��}|j��D]\}}|dkrd|j|<q	t�||�|j|<q	|S)z$Don't populate the QuerySet's cache.r�N)r��__dict__rV�copy�deepcopy)r*�memorg�k�vr+r+r,�__deepcopy__�szQuerySet.__deepcopy__cCs|��i|j�ttji�Sr&)�
_fetch_allr�r�django�__version__rCr+r+r,�__getstate__�szQuerySet.__getstate__cCsT|�t�}|r|tjkrtjd|tjftdd�ntjdtdd�|j�|�dS)NzTPickled queryset instance's Django version %s does not match the current version %s.�)�
stacklevelz<Pickled queryset instance's Django version is not specified.)	�getrr�r��warnings�warn�RuntimeWarningr��update)r*�state�pickled_versionr+r+r,�__setstate__�s"

����zQuerySet.__setstate__cCs8t|dtd��}t|�tkrd|d<d|jj|fS)Nr9z$...(remaining elements truncated)...r8z<%s %r>)�list�REPR_OUTPUT_SIZEr}r�r.)r*�datar+r+r,�__repr__�szQuerySet.__repr__cC�|��t|j�Sr&�r�r}r�rCr+r+r,�__len__�
zQuerySet.__len__cCr�)a�
        The queryset iterator protocol uses three nested iterators in the
        default case:
            1. sql.compiler.execute_sql()
               - Returns 100 rows at time (constants.GET_ITERATOR_CHUNK_SIZE)
                 using cursor.fetchmany(). This part is responsible for
                 doing some column masking, and returning the rows in chunks.
            2. sql.compiler.results_iter()
               - Returns one row at time. At this point the rows are still just
                 tuples. In some cases the return values are converted to
                 Python values at this location.
            3. self.iterator()
               - Responsible for turning the rows into model objects.
        �r��iterr�rCr+r+r,ro	s
zQuerySet.__iter__cCr�r&�r��boolr�rCr+r+r,�__bool__r�zQuerySet.__bool__cCst|ttf�stdt|�j��t|t�s|dks6t|t�r2|jdus(|jdkr2|jdus6|jdks6Jd��|jdur@|j|St|t�ry|�	�}|jdurTt|j�}nd}|jdurat|j�}nd}|j
�||�|jrwt
|�dd|j�S|S|�	�}|j
�||d�|��|jdS)z2Retrieve an item or slice from the set of results.z4QuerySet indices must be integers or slices, not %s.rNz#Negative indexing is not supported.r9)�
isinstance�int�slice�	TypeError�typer.�start�stopr��_chainrN�
set_limits�stepr�r�)r*r��qsr�r�r+r+r,�__getitem__s:����





zQuerySet.__getitem__cOs|Sr&r+)r�r�r�r+r+r,�__class_getitem__@szQuerySet.__class_getitem__cCsN|�|�t|t�r|St|t�r|S|��}|�|�|j�|jtj�|Sr&)	�_merge_sanity_checkr��
EmptyQuerySetr��_merge_known_related_objectsrN�combiner�AND)r*�other�combinedr+r+r,�__and__Cs



zQuerySet.__and__cCs�|�|�t|t�r|St|t�r|S|j��r|n
|jjj|�d�d�}|�	�}|�
|�|j��s>|jjj|�d�d�}|j�|jtj
�|S)N�pk��pk__in)r�r�r�rN�
can_filterr6�
_base_manager�filter�valuesr�r�r�r�OR)r*r�rNr�r+r+r,�__or__Ns


$

zQuerySet.__or__ccs�|j|||d�EdHdS)Nr5)r�)r*�use_chunked_fetchr)r+r+r,�	_iterator`s�zQuerySet._iterator��cCs0|dkrtd��t|jj�d�}|�||�S)zc
        An iterator over the results from applying this QuerySet to the
        database.
        rz%Chunk size must be strictly positive.�DISABLE_SERVER_SIDE_CURSORS)�
ValueErrorrrM�
settings_dictr�r�)r*r)r�r+r+r,�iteratorcszQuerySet.iteratorc

Os|jjrtd��|jg|�|���Rdd�|D]}z|jWn
ttfy,td��w|||j<q|j��}|�	�D]<\}}|j
||dd�|j|}|jsVtd|��|�
�D]}|jrwt|t�rw|j|vrw|j}	t�d|j|	|	f��qZq<|�|j|�S)	z�
        Return a dictionary containing the calculations (aggregation)
        over the current queryset.

        If args is present the expression is passed as a kwarg using
        the Aggregate object's default alias.
        z/aggregate() + distinct(fields) not implemented.�	aggregate��method_namez#Complex aggregates require an aliasT)�
is_summaryz!%s is not an aggregate expressionz-Cannot compute %s('%s'): '%s' is an aggregate)rN�distinct_fields�NotImplementedError� _validate_values_are_expressionsr��
default_alias�AttributeErrorr�rrV�add_annotation�annotations�contains_aggregate�get_source_expressionsr�r�refsr�
FieldErrorr]�get_aggregationrM)
r*r�r��argrN�alias�aggregate_expr�
annotation�exprr]r+r+r,r�ms6
�


����zQuerySet.aggregatecCs$|jdur
t|j�S|jj|jd�S)z�
        Perform a SELECT COUNT() and return the number of records as an
        integer.

        If the QuerySet is already fully cached, return the length of the
        cached results set to avoid multiple SELECT COUNT(*) calls.
        Nr3)r�r}rN�	get_countrMrCr+r+r,�count�s

zQuerySet.countcOs�|jjr|s|rtd|jj��|jjr|��n|j|i|��}|j��r-|jjs-|��}d}|jjr:t	|j
jjrCt
}|jj|d�t|�}|dkrP|jdS|s]|j�d|jjj��|j�d|jjj|rk||krp|f��d|df��)	zl
        Perform the query and return a single object matching the given
        keyword arguments.
        zCCalling QuerySet.get(...) with filters after %s() is not supported.N��highr9rz!%s matching query does not exist.z2get() returned more than one %s -- it returned %s!zmore than %s)rN�
combinatorrr�r�r�r��order_by�select_for_updaterrM�features�%supports_select_for_update_with_limit�MAX_GET_RESULTSr�r}r�r6�DoesNotExistrD�object_name�MultipleObjectsReturned)r*r�r��clone�limit�numr+r+r,r��s>�� 
����
��zQuerySet.getcKs*|jdi|��}d|_|jd|jd�|S)z�
        Create a new object with the given kwargs, saving it to the database
        and returning the created object.
        T)�force_insertr4Nr+)r6r��saverM�r*r�rgr+r+r,�create�szQuerySet.createcCs4|D]}|jdur|jj�|�|_|jdd�qdS)N�bulk_create)�operation_name)r�rD�get_pk_value_on_save� _prepare_related_fields_for_save)r*�objsrgr+r+r,�_prepare_for_bulk_create�s

�z!QuerySet._prepare_for_bulk_createFcCs�|dus
|dks
J�|jj��D]}|jj|jjjurtd��q|s$|Sd|_t|j}|jj}|j}t	|�}|�
|�tj|jdd���t
dd�|�\}}	|r�|j||||d	�}
t||
�D]\}}t||j�D]\}
}||jkrxt||j|
�qhq^|D]}d|j_|j|j_q||	r�d
d�|D�}|j|	|||d	�}
|jjr�|s�t|
�t|	�ks�J�t|	|
�D]'\}}t||j�D]\}
}t||j|
�q�d|j_|j|j_q�Wd�|SWd�|S1s�wY|S)ab
        Insert each of the instances into the database. Do *not* call
        save() on each of the instances, do not send any pre/post_save
        signals, and do not set the primary key attribute if it is an
        autoincrement field (except if features.can_return_rows_from_bulk_insert=True).
        Multi-table models are not supported.
        Nrz/Can't bulk create a multi-table inherited modelTF�r4�	savepointcSs
|jduSr&�r�)�or+r+r,�<lambda>�s
z&QuerySet.bulk_create.<locals>.<lambda>��ignore_conflictscS�g|]	}t|t�s|�qSr+)r�rr?r+r+r,rBrxz(QuerySet.bulk_create.<locals>.<listcomp>)r6rD�get_parent_list�concrete_modelr�r�rrM�concrete_fieldsr�r(r
�atomicr"�_batched_insert�zip�db_returning_fieldsr�rZr>�_state�addingr� can_return_rows_from_bulk_insertr})r*r'�
batch_sizer/�parent�
connection�optsr��objs_with_pk�objs_without_pk�returned_columns�obj_with_pkr_�resultrG�obj_without_pkr+r+r,r#�s`�

�
����
��
��zQuerySet.bulk_createc	s��dur�dkrtd��|std��t���tdd��D��r#td���fdd	�|D�}td
d�|D��r9td��tdd�|D��rFtd
���sJdSt�jj�ddg|��}�r_t�|�n|�t�jjj	}��fdd�t
dt����D�}g}|D]K}i}	|D]8}
g}|D]}t||
j
�}
t|
t�s�t|
|
d�}
|�t|j|
d��q�t|d|
i�}|r�t||
d�}||	|
j
<q�|�dd	�|D�|	f�q|tj�jdd��|D]\}}	�j|d�jdi|	��q�Wd�dS1s�wYdS)zW
        Update the given fields in each of the given objects in the database.
        Nrz&Batch size must be a positive integer.z+Field names must be given to bulk_update().css�|]}|jduVqdSr&r+�r@rgr+r+r,r�s�z'QuerySet.bulk_update.<locals>.<genexpr>z6All bulk_update() objects must have a primary key set.csg|]	}�jj�|��qSr+)r6rDrE)r@r]rCr+r,rBrxz(QuerySet.bulk_update.<locals>.<listcomp>css�|]
}|jp
|jVqdSr&)�concrete�many_to_manyr?r+r+r,r�r�z4bulk_update() can only be used with concrete fields.cs��|]}|jVqdSr&)�primary_keyr?r+r+r,r���z5bulk_update() cannot be used with primary key fields.r�c3s �|]}�||��VqdSr&r+rs�r;r'r+r,r�&s���output_field)r��thenrMcS�g|]}|j�qSr+r+rEr+r+r,rB5�Fr)r�r+)r�r��anyrrM�ops�bulk_batch_size�minr�requires_casted_case_in_updatesr|r}�getattrr>r�rr�appendrr�rrr
r4r�r�)r*r'r�r;�max_batch_size�requires_casting�batches�updates�
batch_objs�
update_kwargsrG�when_statementsrg�attr�case_statement�pksr+)r;r'r*r,�bulk_updatesL 
�"�zQuerySet.bulk_updatecKs�d|_z|jdi|��dfWS|jjyq|j|fi|��}z.tj|jd��tt	|��}|j
di|��dfWd�WYS1sFwYWYdStypz|jdi|��dfWYYS|jjyoY�www)z�
        Look up an object with the given kwargs, creating one if necessary.
        Return a tuple of (object, created), where created is a boolean
        specifying whether an object was created.
        TFr3Nr+)r�r�r6r�_extract_model_paramsr
r4rM�dictrr"r)r*�defaultsr��paramsr+r+r,�
get_or_create;s&.����zQuerySet.get_or_createcKs�|pi}d|_tj|jd��;|��j|fi|��\}}|r)||fWd�St|�D]
\}}t|||�q-|j|jd�Wd�|dfS1sLwY|dfS)z�
        Look up an object with the given kwargs, updating one with defaults
        if it exists, otherwise create a new one.
        Return a tuple (object, created), where created is a boolean
        specifying whether an object was created.
        Tr3NF)	r�r
r4rMrrgrrZr )r*rer�rg�createdr�r�r+r+r,�update_or_createTs�
�	�	zQuerySet.update_or_createc	Ks�|pi}dd�|��D�}|�|�|jjj}g}|D]%}z	|jj�|�Wqtjy@||vr9t|j|�j	s>|�
|�Yqw|rTt�d|jjjd�
t|��f��|S)z
        Prepare `params` for creating a model instance based on the given
        kwargs; for use by get_or_create().
        cSsi|]\}}t|vr||�qSr+r)r@r�r�r+r+r,rwn�z2QuerySet._extract_model_params.<locals>.<dictcomp>z)Invalid field name(s) for model %s: '%s'.z', ')rVr�r6rD�_property_namesrEr�FieldDoesNotExistrV�fsetrWrr�join�sorted)r*rer�rf�property_names�invalid_params�paramr+r+r,rchs*


����zQuerySet._extract_model_paramscGs�|r|}nt|jjd�}|rt|ttf�s|f}|dur td��|jjr(Jd��|�	�}|jj
dd�|jjdd�|jj|�|�
�S)	zy
        Return the earliest object according to fields (if given) or by the
        model's Meta.get_latest_by.
        �
get_latest_byNzmearliest() and latest() require either fields as positional arguments or 'get_latest_by' in the model's Meta.z2Cannot change a query once a slice has been taken.r9rT��force)rVr6rDr�r�r�r�rN�	is_slicedr�r��clear_ordering�add_orderingr�)r*r�rrgr+r+r,�	_earliest�s"�
�zQuerySet._earliestcGs
|j|�Sr&)ry�r*r�r+r+r,�earliest��
zQuerySet.earliestcGs|��j|�Sr&)�reverseryrzr+r+r,�latest�szQuerySet.latestcCs,|jr|n|�d�dd�D]}|SdS)z@Return the first object of a query or None if no match is found.r�Nr9)�orderedr�r*rgr+r+r,�first�s �zQuerySet.firstcCs0|jr|��n|�d�dd�D]}|SdS)z?Return the last object of a query or None if no match is found.z-pkNr9)rr}rr�r+r+r,�last�s$�z
QuerySet.lastr���
field_namec
s|jjrJd��|jj}dd�|jD�}�dkr/|���js/�|vr/|jj�fkr/td���|dur�|s7iSd�	��}t
|jjj
}t|�}|ru|t|�krud}td	t|�|�D]}||||�}	|t|jdi||	i�����7}qYn|jdi||i����}n|��}�fd
d�|D�S)z�
        Return a dictionary mapping each of the given IDs to the object with
        that ID. If `id_list` isn't provided, evaluate the entire QuerySet.
        z+Cannot use 'limit' or 'offset' with in_bulkcSs$g|]}t|j�dkr|jd�qS)r9r)r}r�)r@�
constraintr+r+r,rB�s
�z$QuerySet.in_bulk.<locals>.<listcomp>r�z;in_bulk()'s field_name must be a unique field but %r isn't.Nz{}__inr+rcsi|]}t|��|�qSr+)rVrEr�r+r,rw��z$QuerySet.in_bulk.<locals>.<dictcomp>)rNrvr6rD�total_unique_constraintsrE�uniquer�r��formatrrMr�max_query_paramsr�r}r|r�rr�)
r*�id_listr�r>�
unique_fields�
filter_keyr;r��offset�batchr+r�r,�in_bulk�s8
��
�
"�zQuerySet.in_bulkcCs�|�d�|jjr
Jd��|jjs|jjrtd��|jdur"td��|��}d|_d|j_	d|j_
|jjdd�t|j
d	�}|�|�|��\}}d|_||fS)
z+Delete the records in the current QuerySet.�deletez+Cannot use 'limit' or 'offset' with delete.z'Cannot call delete() after .distinct().Nz6Cannot call delete() after .values() or .values_list()TFrtr3)�_not_support_combined_queriesrNrv�distinctr�r�r�r�r�r�select_relatedrwrrM�collectr�r�)r*�	del_query�	collector�deleted�_rows_countr+r+r,r��s$

�

zQuerySet.deletecCsT|j��}tj|_|�|��t�}|r(|�|jWd�S1s#wYdS)z�
        Delete objects found from the given queryset in single direct SQL
        query. No signals are sent and there is no protection for cascades.
        Nr)	rNrr�DeleteQueryr�rOrPr�rowcount)r*r4rN�cursorr+r+r,�_raw_delete�s
 �zQuerySet._raw_deletecKs�|�d�|jjr
Jd��d|_|j�tj�}|�|�i|_t	j
|jd��|�|j��
t�}Wd�n1s:wYd|_|S)z~
        Update all elements in the current QuerySet, setting all the given
        fields to the appropriate values.
        r��2Cannot update a query once a slice has been taken.Tr3N)r�rNrvr�rr�UpdateQuery�add_update_valuesrr
�mark_for_rollback_on_errorrMrOrPrr�)r*r�rN�rowsr+r+r,r�s

�
�zQuerySet.updatecCsF|jjrJd��|j�tj�}|�|�i|_d|_|�|j	��
t�S)a
        A version of update() that accepts field objects instead of field names.
        Used primarily for model saving and not intended for use by general
        code (it requires too much poking around at model internals to be
        useful at that level).
        r�N)rNrvrrr��add_update_fieldsrr�rOrMrPr)r*r�rNr+r+r,�_updates
�
zQuerySet._updatecCs$|jdur
|jj|jd�St|j�S)Nr3)r�rN�has_resultsrMr�rCr+r+r,�exists&s

zQuerySet.existscC�t|jg|j�R�d|_dS�NT��prefetch_related_objectsr�r�r�rCr+r+r,�_prefetch_related_objects+s
z"QuerySet._prefetch_related_objects)r�cKs|jjd|j|d�|��S)N)r4r�r+)rN�explainrM)r*r��optionsr+r+r,r�0szQuerySet.explainr+cCs6|dur|j}t||j|||d�}|jdd�|_|S)N)r6rf�translationsr4)rM�RawQuerySetr6r�)r*�	raw_queryrfr�r4r�r+r+r,�raw7s
zQuerySet.rawcOs2|��}|r|jdi|��}||_|j�|�|S)Nr+)r��annotater�rN�
set_values�r*r��expressionsrr+r+r,�_values>szQuerySet._valuescOs&|t|�7}|j|i|��}t|_|Sr&)r�r�rrr�r�r+r+r,r�FszQuerySet.values)�flat�namedcGs�|r|rtd��|rt|�dkrtd��dd�|D�}g}i}d}|D]1}t|d�rOt|d|jj���}		|	t|�}
|d7}|
|vrDnq5|||
<|�|
�q#|�|�q#|j	|i|��}|rdt
|_
|S|rkt|_
|St|_
|S)Nz*'flat' and 'named' can't be used together.r9zH'flat' is not valid when values_list is called with more than one field.cSsh|]	}t|d�s|�qS)�resolve_expression��hasattrr?r+r+r,�	<setcomp>Rrxz'QuerySet.values_list.<locals>.<setcomp>r�r)r�r}r�rVr�r.�lower�strrWr�r�r�rr�)r*r�r�r��field_namesr�r��counterrG�field_id_prefix�field_idrr+r+r,�values_listLs<
������zQuerySet.values_list�ASCcCsp|dvsJd��|dvsJd��|jt||t�d�t|�d�jddd	���jd
d��|dkr3d
d�Sdd�S)z�
        Return a list of date objects representing all available dates for
        the given field_name, scoped to 'kind'.
        )�year�month�week�dayz8'kind' must be one of 'year', 'month', 'week', or 'day'.�r��DESC�''order' must be either 'ASC' or 'DESC'.rL)�	datefield�plain_fieldr�T�r�F��plain_field__isnullr��-�)r�rrrr�r�r�r)r*r��kind�orderr+r+r,�datesks&
�
������zQuerySet.datescCs�|dvsJd��|dvsJd��tjr|durt��}nd}|jt||t�||d�t|�d�jdd	d
��	�j
dd��|d
krCdd�Sdd�S)z�
        Return a list of datetime objects representing all available
        datetimes for the given field_name, scoped to 'kind'.
        )r�r�r�r��hour�minute�secondzT'kind' must be one of 'year', 'month', 'week', 'day', 'hour', 'minute', or 'second'.r�r�N)rM�tzinfo�is_dst)�
datetimefieldr�r�Tr�Fr�r�r�r�)r�USE_TZr �get_current_timezoner�rr
rr�r�r�r)r*r�r�r�r�r�r+r+r,�	datetimes{s<
�
����	����zQuerySet.datetimescCs|��}|j��|S)zReturn an empty QuerySet.)r�rN�	set_empty�r*rr+r+r,�none�s
z
QuerySet.nonecCs|��S)z�
        Return a new QuerySet that is a copy of the current one. This allows a
        QuerySet to proxy for a model manager in some cases.
        )r�rCr+r+r,�all�szQuerySet.allcO�|�d�|�d||�S)za
        Return a new QuerySet instance with the args ANDed to the existing
        set.
        r�F�r��_filter_or_exclude�r*r�r�r+r+r,r���
zQuerySet.filtercOr�)zc
        Return a new QuerySet instance with NOT (args) ANDed to the existing
        set.
        �excludeTr�r�r+r+r,r��r�zQuerySet.excludecCsN|s|r|jjrJd��|��}|jrd|_|||f|_|S|�|||�|S)Nz2Cannot filter a query once a slice has been taken.F)rNrvr�r�r�r�)r*r�r�r�rr+r+r,r��s
��zQuerySet._filter_or_excludecCs:|r|j�t|i|���dS|j�t|i|���dSr&)r��add_qrr�r+r+r,r��sz#QuerySet._filter_or_exclude_inplacecCs2t|t�r|��}|j�|�|S|jdd|d�S)aB
        Return a new QuerySet instance with filter_obj added to the filters.

        filter_obj can be a Q object or a dictionary of keyword lookup
        arguments.

        This exists to support framework features such as 'limit_choices_to',
        and usually it will be more natural to use other methods.
        Fr+)r�r�)r�rr�rNr�r�)r*�
filter_objrr+r+r,�complex_filter�s


zQuerySet.complex_filter)r�cGsR|��}|jjdd�|j��|jftdd�|D��|j_||j_||j_|S)NTrtcsrHr&)rN)r@r�r+r+r,r��rJz-QuerySet._combinator_query.<locals>.<genexpr>)r�rNrw�clear_limitsr��combined_queriesr�combinator_all)r*rr��other_qsrr+r+r,�_combinator_query�s
zQuerySet._combinator_querycGspt|t�r,dd�|D�}|s|St|�dkr|dS|djdg|dd��Rd|i�S|jdg|�Rd|i�S)NcSr0r+)r�r�)r@�qr+r+r,rB�rxz"QuerySet.union.<locals>.<listcomp>r9r�unionr�)r�r�r}r�)r*r�r�r�r+r+r,r��s
$zQuerySet.unioncGs<t|t�r|S|D]}t|t�r|Sq	|jdg|�R�S)N�intersection�r�r�r�)r*r�r�r+r+r,r��s

�zQuerySet.intersectioncGs t|t�r|S|jdg|�R�S)N�
differencer�)r*r�r+r+r,r��s
zQuerySet.differencecCsJ|r|rtd��|��}d|_d|j_||j_||j_||j_||j_|S)zi
        Return a new QuerySet instance that will select objects with a
        FOR UPDATE lock.
        z2The nowait option cannot be used with skip_locked.T)	r�r�r�rNr�select_for_update_nowait�select_for_update_skip_locked�select_for_update_of�select_for_no_key_update)r*�nowait�skip_locked�of�no_keyrgr+r+r,rszQuerySet.select_for_updatecGsX|�d�|jdurtd��|��}|dkrd|j_|S|r&|j�|�|Sd|j_|S)a
        Return a new QuerySet instance that will select related objects.

        If fields are specified, they must be ForeignKey fields and only those
        related objects are included in the selection.

        If select_related(None) is called, clear the list.
        r�Nz>Cannot call select_related() after .values() or .values_list()r&FT)r�r�r�r�rNr��add_select_related)r*r�rgr+r+r,r�s
	
��zQuerySet.select_relatedcGsr|�d�|��}|dkrd|_|S|D]}t|t�r|j}|�td�d}||jj	vr0t
d��q|j||_|S)aN
        Return a new QuerySet instance that will prefetch the specified
        Many-To-One and Many-To-Many related objects when the QuerySet is
        evaluated.

        When prefetch_related() is called more than once, append to the list of
        prefetch lookups. If prefetch_related(None) is called, clear the list.
        �prefetch_relatedr&r+r9rz:prefetch_related() is not supported with FilteredRelation.)r�r�r�r��Prefetch�prefetch_to�splitrrN�_filtered_relationsr�)r*�lookupsr�lookupr+r+r,r�&s
		�
�zQuerySet.prefetch_relatedcO�|�d�|j||dd�S)z
        Return a query set in which the returned objects have been annotated
        with extra data or aggregations.
        r�T�rQ�r��	_annotater�r+r+r,r�=s
zQuerySet.annotatecOr)zW
        Return a query set with added aliases for extra data or aggregations.
        rFrrr�r+r+r,rEs
zQuerySet.aliasc
	CsJ|j|t|���dd�i}|D]!}z|j|vr td|j��Wnty,td��w|||j<q|�|�|��}|j}|durSt	t
�dd�|jj
��D���}|��D]%\}}	||vretd|��t|	t�rr|j�|	|�qW|jj|	|d|d	�qW|jj��D]\}}	||vr�|	jr�|jdur�d
|j_|S|j��|Sq�|S)Nr�r�zQThe named annotation '%s' conflicts with the default name for another annotation.z$Complex annotations require an aliascss.�|]}t|d�r|j|jfn|jfVqdS)r>N)r�r]r>)r@rGr+r+r,r�^s
��
�z%QuerySet._annotate.<locals>.<genexpr>z8The annotation '%s' conflicts with a field on the model.F)r�rQT)rr�r�rr�r�r�r�r��setr�
from_iterabler6rD�
get_fieldsrVr�rrN�add_filtered_relationrrr�group_by�set_group_by)
r*r�r�rQrr
rrvrr
r+r+r,r	LsR
���


��
�

��zQuerySet._annotatecGs8|jjrJd��|��}|jjddd�|jj|�|S)z9Return a new QuerySet instance with the ordering changed.z3Cannot reorder a query once a slice has been taken.TF)ru�
clear_default)rNrvr�rwrx�r*r�rgr+r+r,rws
�zQuerySet.order_bycGs2|�d�|jjr
Jd��|��}|jj|�|S)zX
        Return a new QuerySet instance that will select only distinct results.
        r�z:Cannot create distinct fields once a slice has been taken.)r�rNrvr��add_distinct_fieldsrr+r+r,r��s

�zQuerySet.distinctcCs<|�d�|jjr
Jd��|��}|j�||||||�|S)z%Add extra SQL fragments to the query.�extraz1Cannot change a query once a slice has been taken)r�rNrvr��	add_extra)r*rQ�whererf�tablesr�
select_paramsrr+r+r,r�s

�zQuerySet.extracCs*|jjrtd��|��}|jj|j_|S)z%Reverse the ordering of the QuerySet.z3Cannot reverse a query once a slice has been taken.)rNrvr�r��standard_orderingr�r+r+r,r}�s
zQuerySet.reversecGsJ|�d�|jdurtd��|��}|dkr|j��|S|j�|�|S)a%
        Defer the loading of data for certain fields until they are accessed.
        Add the set of deferred fields to any existing set of deferred fields.
        The only exception to this is if None is passed in as the only
        parameter, in which case removal all deferrals.
        �deferNz5Cannot call defer() after .values() or .values_list()r&)r�r�r�r�rN�clear_deferred_loading�add_deferred_loading)r*r�rr+r+r,r�s


�zQuerySet.defercGsr|�d�|jdurtd��|dkrtd��|D]}|�td�d}||jjvr,td��q|��}|j�	|�|S)	z�
        Essentially, the opposite of defer(). Only the fields passed into this
        method and that are not already specified as deferred are loaded
        immediately when the queryset is evaluated.
        �onlyNz4Cannot call only() after .values() or .values_list()r&z*Cannot pass None as an argument to only().r9rz.only() is not supported with FilteredRelation.)
r�r�r�rrrNrr�r��add_immediate_loading)r*r�rGrr+r+r,r�s

�z
QuerySet.onlycCs|��}||_|S)z;Select which database this QuerySet should execute against.)r�r�)r*rrr+r+r,r4�szQuerySet.usingcCsFt|t�rdS|jjs|jjrdS|jjr!|j��jr!|jjs!dSdS)z�
        Return True if the QuerySet is ordered -- i.e. has an order_by()
        clause or a default ordering on the model (or is empty).
        TF)	r�r�rN�extra_order_byr�default_ordering�get_meta�orderingrrCr+r+r,r�s
�
��zQuerySet.orderedcCs>|jr|jptj|jfi|j��S|jptj|jfi|j��S�z7Return the database used if this query is executed now.)r�r�r	�db_for_writer6r��db_for_readrCr+r+r,rM�szQuerySet.dbcCsFd|_|dur
|j}tj|j|d�}|j|||d�|j|d��|�S)z�
        Insert a new record for the given model. This provides an interface to
        the InsertQuery class and is how Model.save() is implemented.
        TNr.)r�r3)r�rMr�InsertQueryr6�
insert_valuesrOrP)r*r'r��returning_fieldsr�r4r/rNr+r+r,�_insert�szQuerySet._insertc

s�|r
t|jjjs
td��t|jj}t|�|��d�}�r#t�|�n|�g}t|jjj	}��fdd�t
dt����D�D]"}	|rV|sV|�|j
|	||j|jjj|d��q>|j
|	||j|d�q>|S)zU
        Helper method for bulk_create() to insert objs one batch at a time.
        z:This database backend does not support ignoring conflicts.r9csg|]
}�||���qSr+r+rsrKr+r,rBsz,QuerySet._batched_insert.<locals>.<listcomp>r)r�r4r'r/)r�r4r/)rrMr�supports_ignore_conflictsrrR�maxrSrTr:r|r}�extendr(r6rDr7)
r*r'r�r;r/rRrX�
inserted_rows�bulk_return�itemr+rKr,r5�s $
�zQuerySet._batched_insertcKs,|��}|jrd|j_d|_|j�|�|S)zc
        Return a copy of the current QuerySet that's ready for another
        operation.
        TF)�_cloner�rN�filter_is_stickyr�r�r!r+r+r,r�szQuerySet._chaincCsZ|j|j|j��|j|jd�}|j|_|j|_|jdd�|_|j	|_	|j
|_
|j|_|S)zi
        Return a copy of the current QuerySet. A lightweight alternative
        to deepcopy().
        )r6rNr4r�N)r�r6rNrr�r�r�r�r�rUr�r��r*�cr+r+r,r/szQuerySet._clonecCs:|jdur
t|�|��|_|jr|js|��dSdSdSr&)r�r�r�r�r�r�rCr+r+r,r�*s

�zQuerySet._fetch_allcCs
d|_|S)a

        Indicate that the next filter call and the one following that should
        be treated as a single filter. This is only important when it comes to
        determining when to reuse tables for many-to-many filters. Required so
        that we can filter naturally on the results of related managers.

        This doesn't return a clone of the current QuerySet (it returns
        "self"). The method is only used internally and should be immediately
        followed by a filter() that does create a clone.
        T)r�rCr+r+r,�_next_is_sticky0szQuerySet._next_is_stickycCsj|jdur1t|jj�t|jj�ks)t|jj�t|jj�ks)t|jj�t|jj�kr3td|jj��dSdS)z.Check that two QuerySet classes may be merged.Nz?Merging '%s' classes must involve the same values in each case.)	r�r
rNrzryr{r�r�r.�r*r�r+r+r,r�>s
���zQuerySet._merge_sanity_checkcCs,|j��D]\}}|j�|i��|�qdS)zX
        Keep track of all known related objects from either QuerySet instance.
        N)rUrV�
setdefaultr�)r*r�rG�objectsr+r+r,r�Is�z%QuerySet._merge_known_related_objectscOs:|jrt|j�dkrtd��|jj|i|��}|j|_|S)Nr9z0Cannot use multi-field values as a filter value.)r�r}r�rNr�r�)r*r�r�rNr+r+r,r�Ps
zQuerySet.resolve_expressioncKs|j�|�dS)z}
        Update hinting information for use by routers. Add new key/values or
        overwrite existing key/values.
        N)r�r�)r*r�r+r+r,�
_add_hintsZszQuerySet._add_hintscCs
|j��S)z�
        Check if this QuerySet has any filtering going on. This isn't
        equivalent with checking if all objects are present in results, for
        example, qs[1:]._has_filters() -> False.
        )rN�has_filtersrCr+r+r,�_has_filtersas
zQuerySet._has_filterscCs0tdd�|D��}|rtd|d�|�f��dS)Ncss"�|]}t|d�st|�VqdS)r�N)r�r�)r@r
r+r+r,r�ks� z<QuerySet._validate_values_are_expressions.<locals>.<genexpr>z-QuerySet.%s() received non-expression(s): %s.z, )ror�rn)r�r��invalid_argsr+r+r,ris���z)QuerySet._validate_values_are_expressionscCs |jjrtd||jjf��dS)Nz2Calling QuerySet.%s() after %s() is not supported.)rNrr)r*r$r+r+r,r�ts
���z&QuerySet._not_support_combined_queries)NNNN)r�)NFr&)r+NN)r�)r�NN)FFr+F)T)NNNNNN)NFNF)F)^r.r/r0rqr-�propertyrN�setterr��
queryset_only�classmethodr�r�r�r�r�ror�r�r�r�r�r�r�r�rr�r"r(r#rb�alters_datargrircryr{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�r�r�r�rr�r�r�rr	rr�rr}rrr4rrMr(r5r�r/r�r3r�r�r�r7r9�staticmethodrr�r+r+r+r,r��s�



!

$
 


@*

'




	

+	
�








r�c@seZdZdd�ZdS)�InstanceCheckMetacCst|t�o	|j��Sr&)r�r�rN�is_empty)r*�instancer+r+r,�__instancecheck__}sz#InstanceCheckMeta.__instancecheck__N)r.r/r0rDr+r+r+r,rA|srAc@r1)r�zz
    Marker class to checking if a queryset is empty by .none():
        isinstance(qs.none(), EmptyQuerySet) -> True
    cOstd��)Nz#EmptyQuerySet can't be instantiated)r�r�r+r+r,r-�szEmptyQuerySet.__init__N)r.r/r0rqr-r+r+r+r,r��r�r�)�	metaclassc@s�eZdZdZ		d$dd�Zdd�Zdd	�Zd
d�Zdd
�Zdd�Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zedd��Zdd�Zed d!��Zed"d#��ZdS)%r�zo
    Provide an iterator which converts the results of raw SQL queries into
    annotated model instances.
    Nr+cCsZ||_||_||_|pi|_|ptj||j|d�|_||_|p i|_	d|_
d|_d|_dS)N)rr4rfr+F)
r�r6r�r�r�RawQueryrMrNrfr�r�r�r�)r*r�r6rNrfr�r4r�r+r+r,r-�s


zRawQuerySet.__init__cslt�jjj���fdd��jjjD�}�fdd�t�j�D�}��fdd�|D�}dd�|D�}|||fS)z1Resolve the init field names and value positions.cs g|]}�|j��jvr|�qSr+)�column�columnsr?��	converterr*r+r,rB�s z8RawQuerySet.resolve_model_init_order.<locals>.<listcomp>cs"g|]
\}}|�jvr||f�qSr+)�model_fields)r@�posrGrCr+r,rB�s
�csg|]}�j��|j���qSr+)rH�indexrGr?rIr+r,rB�rjcSrOr+�r>r?r+r+r,rB�rP)	rrM�
introspection�identifier_converterr6rDr�r�rH)r*�model_init_fields�annotation_fields�model_init_order�model_init_namesr+rIr,�resolve_model_init_order�s
z$RawQuerySet.resolve_model_init_ordercGs*|��}|dkr
d|_|S|j||_|S)z#Same as QuerySet.prefetch_related()r&r+)r/r�)r*rrr+r+r,r��s�zRawQuerySet.prefetch_relatedcCr�r�r�rCr+r+r,r��s
z%RawQuerySet._prefetch_related_objectsc	Cs:|j|j|j|j|j|j|j|jd�}|jdd�|_|S)zSame as QuerySet._clone())r6rNrfr�r4r�N)	r�r�r6rNrfr�r�r�r�r1r+r+r,r/�s�zRawQuerySet._clonecCs8|jdurt|���|_|jr|js|��dSdSdSr&)r�r�r�r�r�r�rCr+r+r,r��s

�zRawQuerySet._fetch_allcCr�r&r�rCr+r+r,r��r�zRawQuerySet.__len__cCr�r&r�rCr+r+r,r��r�zRawQuerySet.__bool__cCr�r&r�rCr+r+r,ro�r�zRawQuerySet.__iter__c	#s>��j}t|j�d��jt||�}t�j�}zs���\}}}�jjj	j
|vr-t�d���j}�fdd��j
D�}|�dd�|D��}	|	rL|�||	�}|D]&��fdd�|D�}
|�|||
�}|rq|D]\}}
t||�|
�qd|VqNWt�jd�r��jjr��jj��dSdSdSt�jd�r��jjr��jj��www)N�SQLCompilerz&Raw query must include the primary keycsg|]}�j�|��qSr+)rKr�)r@r2rCr+r,rB�r�z(RawQuerySet.iterator.<locals>.<listcomp>cSs$g|]}|r|�|jjj�nd�qSr&)�get_colr6rD�db_tabler?r+r+r,rB�s�cr�r+r+)r@rL)r�r+r,rB�r�r�)rMrrRr^rNr�rUr6rDr�r>rrlrH�get_converters�apply_convertersrXrZr�r��close)r*rMr^rNrT�model_init_posrRr`r��
converters�model_init_valuesrCrGrLr+)r*r�r,r��s@��
�
��
��zRawQuerySet.iteratorcCsd|jj|jfS)Nz<%s: %s>)r�r.rNrCr+r+r,r��szRawQuerySet.__repr__cCst|�|Sr&)r�)r*r�r+r+r,r��szRawQuerySet.__getitem__cCs|jp
tj|jfi|j��Sr")r�r	r$r6r�rCr+r+r,rM�szRawQuerySet.dbcCs&t|j|j|jj|d�|j|j|d�S)z<Select the database this RawQuerySet should execute against.r3)r6rNrfr�r4)r�r�r6rNrrfr�)r*rr+r+r,r4�s�zRawQuerySet.usingc	CsL|j��}|j��D]\}}z|�|�}Wn	tyYq
w|||<q
|S)zg
        A list of model field names in the order they'll appear in the
        query results.
        )rN�get_columnsr�rVrMr�)r*rH�
query_name�
model_namerMr+r+r,rHs
�
zRawQuerySet.columnscCs>t|jjj}i}|jjjD]}|��\}}||||�<q|S)z1A dict mapping column names to model field names.)rrMrOrPr6rDr��get_attname_column)r*rJrKrGr]rGr+r+r,rKszRawQuerySet.model_fields)NNr+NNN)r.r/r0rqr-rUr�r�r/r�r�r�ror�r�r�r;rMr4r!rHrKr+r+r+r,r��s.
�

		#
	
r�c@sNeZdZddd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Zdd�Z	dd�Z
dS)rNcCsp||_||_|durt|t�st|d�rt|jt�std��|r0t	�
|�t	�dd�|g�|_||_||_
dS)Nr�zAPrefetch querysets cannot use raw(), values(), and values_list().r8)�prefetch_throughrr�r�r��
issubclassr�r2r�rrnrr'�to_attr)r*rr'rer+r+r,r-$s ��
�� 
zPrefetch.__init__cCs,|j��}|jdur|jjgdd�|d<|S)NT)r�r�r')r�r�r'r�)r*�obj_dictr+r+r,r�9s


�zPrefetch.__getstate__cCs$|t|j|_|t|j|_dSr&)rrcr)r*�prefixr+r+r,�
add_prefixCszPrefetch.add_prefixcCst�|j�t�d|d��S�Nr9)rrnrr�r*�levelr+r+r,�get_current_prefetch_toGsz Prefetch.get_current_prefetch_tocCs2|j�t�}||}|jo|t|�dk}||fSri)rrrrer})r*rk�partsre�as_attrr+r+r,�get_current_to_attrJszPrefetch.get_current_to_attrcCs|�|�|jkr|jSdSr&)rlrr'rjr+r+r,�get_current_querysetPszPrefetch.get_current_querysetcCst|t�stS|j|jkSr&)r�r�NotImplementedrr4r+r+r,�__eq__Us
zPrefetch.__eq__cCst|j|jf�Sr&)�hashr�rrCr+r+r,�__hash__ZszPrefetch.__hash__)NN)r.r/r0r-r�rhrlrorprrrtr+r+r+r,r#s

rcCs<g}|D]}t|t�st|�}|r|�|�|�|�q|S)z(Normalize lookups into Prefetch objects.)r�rrhrW)rrg�retrr+r+r,�normalize_prefetch_lookups^s

rvcsf|sdSi}t�}t�}tt|��}|�r1|��}|j|vr+|jdur*td|j��q|}|j�t	�}t
|�D]�\}	}
|s?n�|�|	�}||vrM||}q7d}|D]}
t|
d�slzi|
_
WqQttfykd}YnwqQ|sqn�|d}|�|	�d}t||
|�\}}}�|s�td|
|jj|jf��|	t|�dkr�|dur�td	|j��d}|dur��fd
d�|D�}|r�t||||	�\}}||vr�||vr�||vs�|||<tt|�|�}|�|�|�|�|�|�q7g}|D]=}
|
t|
dd�vr�t|
j
�|
��}nzt|
|
�}Wntj�yYq�w|du�rq�t|t��r$|�|�q�|�|�q�|}q7|sdSdS)
z|
    Populate prefetched object caches for a list of model instances based on
    the lookups/Prefetch instances given.
    Nzl'%s' lookup was already seen with a different queryset. You may need to adjust the ordering of your lookups.T�_prefetched_objects_cacheFrzQCannot find '%s' on %s object, '%s' is an invalid parameter to prefetch_related()r9zp'%s' does not resolve to an item that supports prefetching - this is an invalid parameter to prefetch_related().csg|]}�|�s|�qSr+r+rE��
is_fetchedr+r,rB�r�z,prefetch_related_objects.<locals>.<listcomp>r+) r
rv�reversed�poprr'r�rcrrr�rlr�rwrr�ro�get_prefetcherr�r.r}�prefetch_one_levelr�r+�addrVr�r�r�ObjectDoesNotExistr�rW)�model_instances�related_lookups�done_queries�auto_lookups�followed_descriptors�all_lookupsr�obj_list�
through_attrsrk�through_attrr�good_objectsrg�	first_objre�
prefetcher�
descriptor�
attr_found�obj_to_fetch�additional_lookups�new_lookups�new_obj_list�new_objr+rxr,r�js�

�


�����


	�
�r�cs��fdd�}d}|}t|j�d�}|durt|��}n:d}|rUt|d�r*|}|j}n+t|��}t|d�r6|}��krMtt|j�d�t�rL�fdd�}	|	}n�fdd	�}
|
}||||fS)
a�
    For the attribute 'through_attr' on the given instance, find
    an object that has a get_prefetch_queryset().
    Return a 4 tuple containing:
    (the object with get_prefetch_queryset (or None),
     the descriptor object representing this relationship (or None),
     a boolean that is False if the attribute was not found at all,
     a function that takes an instance and returns a boolean that is True if
     the attribute has already been fetched for that instance)
    cs
t|��Sr&r��rC�rer+r,�has_to_attr_attribute�r|z-get_prefetcher.<locals>.has_to_attr_attributeNT�get_prefetch_querysetc�
�|jvSr&)r�r�r�r+r,�has_cached_propertyr|z+get_prefetcher.<locals>.has_cached_propertycr�r&)rwr�)r�r+r,�in_prefetched_cache r|z+get_prefetcher.<locals>.in_prefetched_cache)rVr�r�r[r�r!)rCr�rer�r�ry�rel_obj_descriptorr�rnr�r�r+)r�rer,r|�s,


�r|cCs�|�||�|��\}}}}}}	dd�t|dd�D�}
|
rd|_t|�}i}|D]}
||
�}|�|g��|
�q'|�|�\}}|re|re|dj}z|j	�
|�Wn
tjyYYnwd}t
|�||j���t|j�t��d|k}|D]Z}||�}|�|g�}|r�|r�|dnd}|r�t|||�qs|	r�t|||�qs||jj|<qs|r�t|||�qst||�}|r�|jdur�|�|j�}n|��}||_d	|_||j|<qs||
fS)
aL
    Helper function for prefetch_related_objects().

    Run prefetches on all instances using the prefetcher object,
    assigning results to relevant caches in instance.

    Return the prefetched objects along with any additional prefetches that
    must be done due to prefetch_related lookups found from default managers.
    cSsg|]}t�|��qSr+)r�)r@�additional_lookupr+r+r,rBFs
�z&prefetch_one_level.<locals>.<listcomp>r�r+rz2to_attr={} conflicts with a field on the {} model.r9NT)r�rprVr�r�r5rWror�rDrErrlr�r�r.r}rcrrr�rZr8�fields_cacher'�_apply_rel_filters�get_querysetr�r�rw)�	instancesr�rrk�rel_qs�rel_obj_attr�
instance_attr�single�
cache_name�
is_descriptorr��all_related_objects�
rel_obj_cachern�rel_attr_valrernr6�msg�leafrg�instance_attr_val�vals�valr�r�r+r+r,r}'sV�
�
�
r}c@s eZdZdZdd�Zdd�ZdS)�RelatedPopulatora�
    RelatedPopulator is used for select_related() object instantiation.

    The idea is that each select_related() model will be populated by a
    different RelatedPopulator instance. The RelatedPopulator instances get
    klass_info and select (computed in SQLCompiler) plus the used db as
    input for initialization. That data is used to compute which columns
    to use, how to instantiate the model, and how to populate the links
    between the objects.

    The actual creation of the objects is done in populate() method. This
    method gets row and from_obj as input and populates the select_related()
    model instance.
    cs�||_|d}|d}|s+|d|_|dd|_dd��|j|j�D�|_d|_n,�fdd	�|D��d
d�|djjD�}�fd
d�|D�|_tj�fdd�|jD��|_|d|_	|j�
|j	jjj�|_
t|�|j�|_|d|_|d|_dS)Nr7�from_parentrr8r9cSr:r;r<r?r+r+r,rB�s�z-RelatedPopulator.__init__.<locals>.<listcomp>csi|]}�|djj|�qSr;r<)r@r�rr+r,rw�rjz-RelatedPopulator.__init__.<locals>.<dictcomp>csrHr&rNr?r+r+r,r��rJz,RelatedPopulator.__init__.<locals>.<genexpr>r6csg|]}|�vr|�qSr+r+�r@r>��attname_indexesr+r,rB�r�cr�r+r+r�r�r+r,rB�r��local_setter�
remote_setter)rM�
cols_start�cols_endrc�reorder_for_initrDr3rHr�r`rMr�r>�pk_idxrTrdr�r�)r*rRrQrMr7r��model_init_attnamesr+)r�rQr,r-�s&
�

zRelatedPopulator.__init__cCs�|jr	|�|�}n||j|j�}||jdurd}n|j�|j|j|�}|jD]}|�	||�q(|�
||�|durC|�||�dSdSr&)r�r�r�r�r`rXrMrcrdrYr�r�)r*rf�from_obj�obj_datarg�rel_iterr+r+r,rY�s
�zRelatedPopulator.populateN)r.r/r0rqr-rYr+r+r+r,r��s.r�cCs4g}|�dg�}|D]
}t|||�}|�|�q
|S)N�related_klass_infos)r�r�rW)rRrQrM�	iteratorsr��rel_klass_info�rel_clsr+r+r,rT�srTr&)Grqr�rHr��	itertoolsrr��django.confr�django.corer�	django.dbrrrrr	r
�django.db.modelsrrr
r�django.db.models.constantsr�django.db.models.deletionr�django.db.models.expressionsrrrrrr�django.db.models.functionsrr�django.db.models.query_utilsrr�django.db.models.sql.constantsrr�django.db.models.utilsrr�django.utilsr �django.utils.functionalr!r"rr�r%r2rrrr�r�r�r�rAr�r�rrvr�r|r}r�rTr+r+r+r,�<module>sb  2
V

;6dM
@ Telegram