EvgdZddlmZddlmZmZmZddlmZgdZ GddeZ Gdd eZ Gd d eZ Gd d eZ dS)zR Query subclasses which provide extra functionality beyond simple data retrieval. ) FieldError)CURSORGET_ITERATOR_CHUNK_SIZE NO_RESULTS)Query) DeleteQuery UpdateQuery InsertQueryAggregateQueryc"eZdZdZdZdZdZdS)rzA DELETE SQL query.SQLDeleteCompilerc||j|i|_||_||t}|r!|5|jcdddS#1swxYwYdS)Nr) alias_mapwhere get_compiler execute_sqlrrowcount)selftablerusingcursors \/var/www/pixelcanvas.ch/venv/lib/python3.11/site-packages/django/db/models/sql/subqueries.pydo_queryzDeleteQuery.do_querys!67 ""5))55f==  ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' 'qs A!!A%(A%czd}|j}tdt|tD]{}|||jd|||tz|||j |j |z }||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) get_metapkrangelenr clear_where add_filterattnamerdb_tabler)rpk_listr num_deletedfieldoffsets r delete_batchzDeleteQuery.delete_batchs  "As7||-DEE  F       OO=&&&*A!AAB    4== ($*E) KKN)__name__ __module__ __qualname____doc__compilerrr(r)rrr s="Hr)rcTeZdZdZdZfdZdZfdZdZdZ dZ d Z d Z xZ S) r zAn UPDATE SQL query.SQLUpdateCompilercbtj|i||dSN)super__init__ _setup_query)rargskwargs __class__s rr5zUpdateQuery.__init__5s7$)&))) r)c0g|_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_idsrelated_updates)rs rr6zUpdateQuery._setup_query9s!  !r)ct}|j|_|Sr3)r4cloner=copy)robjr9s rr?zUpdateQuery.cloneBs0ggmmoo"27799 r)cJ||tdt|tD]i}||d|||tz||tjdS)Nrpk__in) add_update_valuesrrrr r!rrr)rr$r;rr's r update_batchzUpdateQuery.update_batchGs v&&&As7||-DEE = =F       OO'&64K+K"KL      e $ $ 0 0 < < < <  = =r)cg}|D]\}}||}|jo|j p|j }|jjj}|r|jr|j rtd|z||jur| |||| |||f| |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_createdconcretemodel_metaconcrete_model is_relation many_to_manyradd_related_updateappendadd_update_fields)rr; values_seqnamevalr&directrKs rrDzUpdateQuery.add_update_valuesPs   3 3ID#MMOO--d33E'>,>?Uu~CU K%4E e/ E4F  /167DMMOO:::''uc:::   ueS1 2 2 2 2%%j111r)c|D]S\}}}|jrt|dr||dd}|j|||fTdS)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_joinsfor_saveN) generatedhasattrrXr;rQ)rrSr&rKrUs rrRzUpdateQuery.add_update_fieldshs ", 4 4 E5# s011 U,,Tut,TT K  uc2 3 3 3 3 4 4r)ch|j|g|d|fdS)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= setdefaultrQ)rrKr&values rrPzUpdateQuery.add_related_updatews8 ''r22995$:NOOOOOr)c|jsgSg}|jD]X\}}t|}||_|j!|d|j|||Y|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. NrC)r=rGr r;r<r!rQ)rresultrKr;querys rget_related_updateszUpdateQuery.get_related_updatess # I!17799 ! !ME6&&E!EL+  4+;E+BCCC MM%  r))r*r+r,r-r.r5r6r?rErDrRrPrc __classcell__r9s@rr r 0s"H""" ===2220 4 4 4PPPr)r c4eZdZdZddddfd ZddZxZS)r SQLInsertCompilerN) on_conflict update_fields unique_fieldsctj|i|g|_g|_||_|pg|_|pg|_dSr3)r4r5fieldsobjsrhrirj)rrhrirjr7r8r9s rr5zInsertQuery.__init__sW $)&)))  &*0b*0br)Fc0||_||_||_dSr3)rlrmraw)rrlrmros r insert_valueszInsertQuery.insert_valuess  r))F)r*r+r,r.r5rprdres@rr r sd"H"&T1111111r)r c&eZdZdZdZfdZxZS)r zu Take another query as a parameter to the FROM clause and only select the elements in the provided list. SQLAggregateCompilercX||_t|dSr3) inner_queryr4r5)rrKrtr9s rr5zAggregateQuery.__init__s)& r))r*r+r,r-r.r5rdres@rr r sI &H         r)r N)r-django.core.exceptionsrdjango.db.models.sql.constantsrrrdjango.db.models.sql.queryr__all__rr r r r/r)rrys.-----VVVVVVVVVV,,,,,, I I I!!!!!%!!!H^^^^^%^^^B%&      U      r)