|
Server : Apache System : Linux cvar2.toservers.com 3.10.0-962.3.2.lve1.5.73.el7.x86_64 #1 SMP Wed Aug 24 21:31:23 UTC 2022 x86_64 User : njnconst ( 1116) PHP Version : 8.4.18 Disable Function : NONE Directory : /usr/lib64/python2.7/site-packages/django/db/models/sql/ |
Upload File : |
�
r�\c @ s� d Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m
Z
m Z m Z d d l
Td d l m Z m Z d d l m Z d d
l m Z m Z d d l m Z d d l m Z d d
l m Z d d l m Z d d d d d d g Z d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ! d e! f d � � YZ" d e f d � � YZ# d S( sR
Query subclasses which provide extra functionality beyond simple data retrieval.
i����( t settings( t
FieldError( t connections( t
LOOKUP_SEP( t DateFieldt
DateTimeFieldt FieldDoesNotExist( t *( t Datet DateTime( t Query( t ANDt
Constraint( t Promise( t
force_text( t six( t timezonet DeleteQueryt UpdateQueryt InsertQueryt DateQueryt
DateTimeQueryt AggregateQueryc B s2 e Z d Z d Z d � Z d d � Z d � Z RS( so
Delete queries are done through this class, since they are more constrained
than general queries.
t SQLDeleteCompilerc C s/ | g | _ | | _ | j | � j d � d S( N( t tablest wheret get_compilert execute_sqlt None( t selft tableR t using( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyt do_query s c C s� | s | j � j } n x~ t d t | � t � D]d } | j � } | j t d | j | � d | | | t !f t
� | j | j � j | d | �q1 Wd S( s�
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.
i t inR N(
t get_metat pkt ranget lent GET_ITERATOR_CHUNK_SIZEt where_classt addR R t columnR R t db_table( R t pk_listR t fieldt offsetR ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyt delete_batch$ s c C s^ | j } | j � | j � g | j D] } | j | r' | ^ q' } | s\ | | j k r{ t | j � r{ | j | _ n� | j j j } t
| j j s� t
| j d d t �� } | s� d S| j | | � d S| j � t | j � | j f d � g | _ | } | j � } | j t d | j | � d | f t � | | _ | j | � j d � d S( s�
Delete the queryset in one SQL query (if possible). For simple queries
this is done by copying the query.query.where to self.query, for
complex queries by using subquery.
R# t flatNR! ( t queryt get_initial_aliasR t alias_refcountR% t havingR t modelt _metaR# R t featurest update_can_self_selectt listt values_listt TrueR. t clear_select_clauset
SelectInfoR) R t selectR' R( R R R R ( R R0 R t innerqt tt innerq_used_tablesR# t valuesR ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyt delete_qs3 s,
$ ( N( t __name__t
__module__t __doc__t compilerR R R. RB ( ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyR s
c B s_ e Z d Z d Z d � Z d � Z d
d � Z d � Z d � Z d � Z
d � Z d � Z RS( s+
Represents an "update" SQL query.
t SQLUpdateCompilerc O s' t t | � j | | � | j � d S( N( t superR t __init__t _setup_query( R t argst kwargs( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyRI _ s c C s1 g | _ d | _ t | d � s- i | _ n d S( s�
Runs on initialization and after cloning. Any attributes that would
normally be set in __init__ should go in here, instead, so that they
are also set up after a clone() call.
t related_updatesN( RA R t related_idst hasattrRM ( R ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyRJ c s c K s( t t | � j | d | j j � | �S( NRM ( RH R t cloneRM t copy( R t klassRL ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyRP n s c C s� | j � j } | j | � x{ t d t | � t � D]a } | j � | _ | j j t d | j | � d | | | t !f t � | j
| � j d � q5 Wd S( Ni R! ( R" R# t add_update_valuesR$ R% R& R' R R( R R R) R R R ( R R+ RA R t pk_fieldR- ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyt update_batchr s
c C s� g } x� t j | � D]� \ } } | j � j | � \ } } } } | sP | rc t d | � � n | r� | j | | | � q n | j | | | f � q W| j | � S( s�
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.
sM Cannot update model field %r (only non-relations and foreign keys permitted).( R t iteritemsR" t get_field_by_nameR t add_related_updatet appendt add_update_fields( R RA t
values_seqt namet valR, R4 t directt m2m( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyRS | s !
c C sa g | D]@ } t | d t � rA | d | d t | d � f n | ^ q } | j j | � d S( s�
Turn a sequence of (field, model, value) triples into an update query.
Used by add_update_values() as well as the "fast" update path when
saving models.
i i i N( t
isinstanceR
R RA t extend( R R[ t value( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyRZ � s Jc C sR y! | j | j | d | f � Wn* t k
rM | d | f g | j | <n Xd S( s�
Adds (name, value) to an update query for an ancestor model.
Updates are coalesced so that we only run one update query per ancestor.
N( RM RY R t KeyError( R R4 R, Rb ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyRX � s !
c C s� | j s
g Sg } xj t j | j � D]V \ } } t | � } | | _ | j d k ro | j d | j f � n | j | � q& W| S( s�
Returns 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.
t pk__inN( RM R RV R RA RN R t
add_filterRY ( R t resultR4 RA R0 ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyt get_related_updates� s N(
RC RD RE RF RI RJ R RP RU RS RZ RX Rg ( ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyR X s
c B s/ e Z d Z d � Z d d � Z e d � Z RS( t SQLInsertCompilerc O s/ t t | � j | | � g | _ g | _ d S( N( RH R RI t fieldst objs( R RK RL ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyRI � s c K sL i | j d 6| j d 6| j d 6} | j | � t t | � j | | � S( NRi Rj t raw( Ri Rj Rk t updateRH R RP ( R RR RL t extras( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyRP � s
c C s~ | | _ x\ | D]T } xK | D]C } t | | j � } t | t � r t | | j t | � � q q Wq W| | _ | | _ d S( s�
Set up the insert query from the 'insert_values' dictionary. The
dictionary gives the model field names and their target values.
If 'raw_values' is True, the values in the 'insert_values' dictionary
are inserted directly into the query, rather than passed as SQL
parameters. This provides a way to insert NULL and DEFAULT keywords
into the query, for example.
N( Ri t getattrt attnameR` R
t setattrR Rj Rk ( R Ri Rj Rk R, t objRb ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyt
insert_values� s
$ N( RC RD RF RI R RP t FalseRr ( ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyR � s c B s2 e Z d Z d Z d d � Z d � Z d � Z RS( s�
A DateQuery is a normal query, except that it specifically selects a single
date field. This requires some special handling when converting the results
back to Python objects, so we put it in a separate class.
t SQLDateCompilert ASCc C s y. | j | j t � | j � | j � � } Wn0 t k
r` t d | j � j | f � � n X| d } | j | � | d d } | j | | j
f | � } | j � t | d � g | _ t | _ | d k r� d g n d g | _ | j r
| j d | t f � n d S( s>
Converts the query into an extraction query.
s %s has no field named '%s'i i i����Ru i s
%s__isnullN( t setup_joinst splitR R" R1 R R t object_namet _check_fieldt _get_selectR) R; R< R R= R: t distinctt order_byt nullRe Rs ( R t
field_namet lookup_typet orderRf R, t aliasR= ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyt
add_select� s$
! c C sU t | t � s" t d | j � � t j rQ t | t � sQ t d | j � � n d S( Ns %r isn't a DateField.s' %r is a DateTimeField, not a DateField.( R` R t AssertionErrorR\ R t USE_TZR ( R R, ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyRy � s
c C s
t | | � S( N( R ( R t colR ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyRz s ( RC RD RE RF R� Ry Rz ( ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyR � s
c B s5 e Z d Z d Z d d d � Z d � Z d � Z RS( s�
A DateTimeQuery is like a DateQuery but for a datetime field. If time zone
support is active, the tzinfo attribute contains the time zone to use for
converting the values before truncating them. Otherwise it's set to None.
t SQLDateTimeCompilerc K sG d | k r+ t | d � r+ | j | d <n t t | � j | | | � S( Nt tzinfo( RO R� RH R RP ( R RR t memoRL ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyRP s c C s& t | t � s" t d | j � � d S( Ns %r isn't a DateTimeField.( R` R R� R\ ( R R, ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyRy s c C s: | j d k r d } n t j | j � } t | | | � S( N( R� R R t _get_timezone_nameR ( R R� R t tzname( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyRz s N( RC RD RE RF R RP Ry Rz ( ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyR s
c B s e Z d Z d Z d � Z RS( s�
An AggregateQuery takes another query as a parameter to the FROM
clause and only selects the elements in the provided list.
t SQLAggregateCompilerc C s+ | j | � j d t � \ | _ | _ d S( Nt with_col_aliases( R t as_sqlR: t subqueryt
sub_params( R R0 R ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyt add_subquery( s ( RC RD RE RF R� ( ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyR s N($ RE t django.confR t django.core.exceptionsR t django.dbR t django.db.models.constantsR t django.db.models.fieldsR R R t django.db.models.sql.constantst# django.db.models.sql.datastructuresR R t django.db.models.sql.queryR
t django.db.models.sql.whereR R t django.utils.functionalR
t django.utils.encodingR t django.utilsR R t __all__R R R R R R ( ( ( sA /tmp/pip-install-XxeQeY/django/django/db/models/sql/subqueries.pyt <module> s*
A]%-