Evgq<ddlZddlmZmZddlmZddlmZddlm Z m Z m Z m Z m Z ddlmZddlmZddlmZdd lmZed ZGd d eZdS) N) lru_cachepartial)settings)BaseDatabaseOperations)InetJsonberrors is_psycopg3mogrifysplit_tzname_delta) OnConflict)Cast)_lazy_re_compilecT| tjSttj|S)N)cls)jsondumpsr)encoders e/var/www/pixelcanvas.ch/venv/lib/python3.11/site-packages/django/db/backends/postgresql/operations.pyget_json_dumpsrs$z 4:7 + + ++ceZdZdZdZegdZddddZer-dd l m Z e j e j e j e j e j e j d Zd Zed Zd Zd7dZdZdZdZdZdZdZdZd7dZdZdZd7dZdZdZ dZ!dZ"dZ#d d d!d"Z$d#Z%d8d$Z&d%Z'd&Z(d'Z)d(Z*erd)Z+nd*Z+d+Z,erd,Z-d-Z.d.Z/d/Z0d9d0Z1d1Z2d2Z3fd3Z4d7fd4 Z5fd5Z6fd6Z7xZ8S):DatabaseOperationsvarcharEXPLAIN) ANALYZEBUFFERSCOSTS GENERIC_PLANSETTINGSSUMMARYTIMINGVERBOSEWALintegerbigintsmallint) AutoField BigAutoFieldSmallAutoFieldr)numeric)SmallIntegerField IntegerFieldBigIntegerFieldPositiveSmallIntegerFieldPositiveIntegerFieldPositiveBigIntegerFieldc|}|dvr6d||jddzSdS)N)GenericIPAddressFieldIPAddressField TimeField UUIDFieldzCAST(%%s AS %s)(r%s)get_internal_typedb_type connectionsplit)self output_field internal_types runification_cast_sqlz'DatabaseOperations.unification_cast_sql<s`$6688    "L$8$8$I$I$O$OPS$T$TUV$WW trz[A-Z_]+c|dkrd|d|fS|dkrd|d|fS|dkrd|d|fS|}|j|std |d |d |d|fS) Nweek_dayzEXTRACT(DOW FROM z) + 1 iso_week_dayzEXTRACT(ISODOW FROM )iso_yearzEXTRACT(ISOYEAR FROM zInvalid lookup type: zEXTRACT(z FROM )upper_extract_format_re fullmatch ValueErrorr> lookup_typesqlparamss rdate_extract_sqlz#DatabaseOperations.date_extract_sqlSs * $ $1s11169 9 N * *0#000&8 8 J & &1311169 9!'')) &00== FD[DDEE E3+33S333V;;rNcN||||\}}d|d|g|RfSNDATE_TRUNC(%s, rE_convert_sql_to_tzr>rLrMrNtznames rdate_trunc_sqlz!DatabaseOperations.date_trunc_sqlb>--c66BB V''''+)?)?)???rcTt|\}}}|r|dkrdnd}|||S|S)N+-r )r>rVsignoffsets r_prepare_tzname_deltaz(DatabaseOperations._prepare_tzname_deltagsJ1&99f  -#++333D,d,F,, , rch|r-tjr!||}|dg||RfS||fS)Nz AT TIME ZONE %s)rUSE_TZr^)r>rMrNrV tzname_params rrTz%DatabaseOperations._convert_sql_to_tznsT  Eho E55f==L+++-Dv-D|-D-DD DF{rcF||||\}}d|d|fS)Nr8z)::daterSr>rMrNrVs rdatetime_cast_date_sqlz)DatabaseOperations.datetime_cast_date_sqlt3--c66BB V3''rcF||||\}}d|d|fS)Nr8)::timerSrcs rdatetime_cast_time_sqlz)DatabaseOperations.datetime_cast_time_sqlxrerc||||\}}|dkr d|ddg|RfS||||SNsecondz#EXTRACT(SECOND FROM DATE_TRUNC(%s, )))rTrOrUs rdatetime_extract_sqlz'DatabaseOperations.datetime_extract_sql|sa--c66BB V ( " "@@@@8BUfBUBUU U$$[#v>>>rcN||||\}}d|d|g|RfSrQrSrUs rdatetime_trunc_sqlz%DatabaseOperations.datetime_trunc_sqlrXrcT|dkr d|ddg|RfS||||Srj)rOrKs rtime_extract_sqlz#DatabaseOperations.time_extract_sqlsF ( " "@@@@8BUfBUBUU U$$[#v>>>rcN||||\}}d|d|g|RfS)NrRrgrSrUs rtime_trunc_sqlz!DatabaseOperations.time_trunc_sqls>--c66BB V---- /Ef/E/EEErcdS)Nz DEFERRABLE INITIALLY DEFERREDr>s rdeferrable_sqlz!DatabaseOperations.deferrable_sqls//rc*|S)z Given a cursor object that has just performed an INSERT...RETURNING statement into a table, return the tuple of returned data. )fetchall)r>cursors rfetch_returned_insert_rowsz-DatabaseOperations.fetch_returned_insert_rowss    rc6d}|dvr |dvrd}nd}|dvrd|z}|S)Nr9) iexactcontains icontains startswith istartswithendswith iendswithregexiregex)r5r4zHOST(%s)z%s::text)r}rrrz UPPER(%s)ru)r>rLr@lookups r lookup_castzDatabaseOperations.lookup_castsP    KKK## M M M 6)F rcdSNrurvs rno_limit_valuez!DatabaseOperations.no_limit_valuestrc|gSrru)r>rMs rprepare_sql_scriptz%DatabaseOperations.prepare_sql_scripts u rcd|dr|dr|Sd|zS)N"z"%s")rr)r>names r quote_namezDatabaseOperations.quote_names8 ??3   DMM#$6$6 K}rc.t|||jSr)r r<)r>rMrNs r compose_sqlzDatabaseOperations.compose_sqlssFDO444rcdS)Nz(SELECT set_config('TimeZone', %s, false)rurvs rset_time_zone_sqlz$DatabaseOperations.set_time_zone_sqls99rF)reset_sequences allow_cascadecV|sgSddfd|Dg}|r(|d|r(|ddd|zgS)NTRUNCATE, c3hK|],}|V-dSr) SQL_FIELDr).0tabler>styles r z/DatabaseOperations.sql_flush..s;RR%eoodooe&<&<==RRRRRRrzRESTART IDENTITYCASCADEz%s; ) SQL_KEYWORDjoinappend)r>rtablesrr sql_partss`` r sql_flushzDatabaseOperations.sql_flushs I   j ) ) IIRRRRR6RRR R R   D   U../ABB C C C  ;   U..y99 : : :+++,,rc  g}|D]~}|d}|dpd}||dd|||d||d|S)NrcolumnidSELECT setval(pg_get_serial_sequence('','z'), 1, false);)rr SQL_TABLErr)r>r sequencesrM sequence_info table_name column_names rsequence_reset_by_name_sqlz-DatabaseOperations.sequence_reset_by_name_sqls&  M&w/J(19TK JJ%%h////OODOOJ$?$?@@@@OOK0000      rcf|rd||zSd||zS)NzUSING INDEX TABLESPACE %sz TABLESPACE %s)r)r> tablespaceinlines rtablespace_sqlz!DatabaseOperations.tablespace_sqls9  A.1L1LL L"T__Z%@%@@ @rcddlm}g}|j}|D]8}|jjD]'}t ||jr||dd| ||jj d| |j d| ||j d| ||j d|d d |d d | ||jj d n):|S)Nr)modelsrrrz'), coalesce(max(z ), 1), max(z) zIS NOTz null) FROMr;) django.dbrr_meta local_fields isinstancer)rrrdb_tablerr)r>r model_listroutputqnmodelfs rsequence_reset_sqlz%DatabaseOperations.sequence_reset_sqlsm$$$$$$ _  E[-  a!122MM"--h7777!OOBBu{/C,D,DEEEE!OOAH5555!OOBBqxLL9999!OOBBqxLL9999!--h7777!--f5555!OOBBu{/C,D,DEEEE     E#$ rc|Srru)r>xs rprep_for_iexact_queryz(DatabaseOperations.prep_for_iexact_querysrcdS)a Return the maximum length of an identifier. The maximum length of an identifier is 63 by default, but can be changed by recompiling PostgreSQL after editing the NAMEDATALEN macro in src/include/pg_config_manual.h. This implementation returns 63, but can be overridden by a custom database backend that inherits most of its behavior from this one. ?rurvs rmax_name_lengthz"DatabaseOperations.max_name_lengths rrc^|r'd|D}dd|zg|fSdggfS)Ncg|] }|D]}| Sruru)r param_listparams r z3DatabaseOperations.distinct_sql..#s%MMM *MMeMMMMrzDISTINCT ON (%s)rDISTINCTr)r>fieldsrNs r distinct_sqlzDatabaseOperations.distinct_sql!sI  $MMfMMMF'$))F*;*;;rzrMrNs rlast_executed_queryz&DatabaseOperations.last_executed_query*s'@  ++C888'   44 =8V]%8%D!=.55777ts )<<cF|j|jSdSr)rrrs rrz&DatabaseOperations.last_executed_query7s%|'|**,,,4rc\|sdSfd|D}dd|zdfS)N)rucg|]C}|jjjd|jDS).)rrrrr)rfieldr>s rrz.As^    1 :;;;; ---    rz RETURNING %srrur)r>rcolumnss` rreturn_insert_columnsz(DatabaseOperations.return_insert_columns>sX 6         ' 2 22B66rcV|t|dr|S|j||S)Nresolve_expression)hasattrintegerfield_type_map)r>valuer@s radapt_integerfield_valuez+DatabaseOperations.adapt_integerfield_valueMs3}/C D D} <4-mrs radapt_datefield_valuez(DatabaseOperations.adapt_datefield_valueR rc|Srrurs radapt_datetimefield_valuez,DatabaseOperations.adapt_datetimefield_valueUrrc|Srrurs radapt_timefield_valuez(DatabaseOperations.adapt_timefield_valueXrrc|Srru)r>r max_digitsdecimal_placess radapt_decimalfield_valuez+DatabaseOperations.adapt_decimalfield_value[rrc(|rt|SdSr)rrs radapt_ipaddressfield_valuez-DatabaseOperations.adapt_ipaddressfield_value^s  ;; trc>t|t|S)N)r)rr)r>rrs radapt_json_valuez#DatabaseOperations.adapt_json_valuecsU."9"9::::rc|dkr|\}}|\}}g||R}d|d|d|fSt|||S)N DateFieldz(interval '1 day' * (z - rl)supersubtract_temporals) r>r@lhsrhslhs_sql lhs_paramsrhs_sql rhs_paramsrN __class__s rrz%DatabaseOperations.subtract_temporalsfsj K ' '"% GZ"% GZ/z/J//FF7>wwH&P Pww))-cBBBrc Ni}|rEd|D}|jD]}||d}||||< tj|fi|}|r||d<|r7|ddd|Dzz }|S)NcFi|]\}}||rdndS)truefalse)rG)rrrs r z;DatabaseOperations.explain_query_prefix..rs?D% :ff7rFORMATz (%s)rc3 K|] }d|zV dS)z%s %sNru)ris rrz:DatabaseOperations.explain_query_prefix..~s&)M)M!'A+)M)M)M)M)M)Mr)itemsexplain_optionspoprexplain_query_prefixr)r>formatoptionsextra valid_optionrprefixrs rrz'DatabaseOperations.explain_query_prefixns  0#*==??G!% 4 0 0  L$77$*/E,'--f@@@@  %$E(O  N g )M)Mu{{}})M)M)M M MM MF rc L|tjkrdS|tjkr^ddt |j|dddt |j|DSt ||||S)NzON CONFLICT DO NOTHINGz ON CONFLICT(rz) DO UPDATE SET cg|] }|d| S)z = EXCLUDED.ru)rrs rrz=DatabaseOperations.on_conflict_suffix_sql..s6!!55e55r)rIGNOREUPDATErmaprron_conflict_suffix_sql)r>r on_conflict update_fields unique_fieldsrs rrz)DatabaseOperations.on_conflict_suffix_sqls *+ + +++ *+ + + + #do}==>>>> %(-%H%H ww--        rct||||\}}||j||jkrt ||}||fSr)rprepare_join_on_clauser;r<r)r> lhs_table lhs_field rhs_table rhs_fieldlhs_exprrhs_exprrs rr#z)DatabaseOperations.prepare_join_on_clausesq"WW;; y)Y  (   T_ - -1B1B4?1S1S S SHi00H!!rr)F)NN)9__name__ __module__ __qualname__"cast_char_field_without_max_lengthexplain_prefix frozensetrcast_data_typesr psycopg.typesr,Int2Int4Int8rrArrHrOrWr^rTrdrhrmrorqrsrwr{rrrrrrrrrrrrrrrrrrrrrrrrrr# __classcell__)rs@rrrs)2&Ni   O $O   ))))))")#L&|)0$+L'.| ! ! **)*55 < < <@@@@  ((((((???@@@ ??? FFFF000!!!2 555:::;@u----- &AAAA   D   $$$        7 7 7D D D D  ;;;CCCCC&     ("""""""""rr)r functoolsrr django.confr"django.db.backends.base.operationsr)django.db.backends.postgresql.psycopg_anyrrr r r django.db.backends.utilsr django.db.models.constantsrdjango.db.models.functionsrdjango.utils.regex_helperrrrrurrr>s4 (((((((( EEEEEE877777111111++++++666666 ,, , C"C"C"C"C"/C"C"C"C"C"r