j<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 w/var/www/finuniver-perm.ru/html/portfolio/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 Zd8dZdZdZdZdZdZdZdZd8dZdZdZd8dZdZdZ dZ!dZ"dZ#d d d!d"Z$d#Z%d9d$Z&d%Z'd&Z(d'Z)d(Z*erd)Z+nd*Z+d+Z,d,Z-erd-Z.d.Z/d/Z0d0Z1d:d1Z2d2Z3d3Z4fd4Z5d8fd5 Z6fd6Z7fd7Z8xZ9S);DatabaseOperationsvarcharEXPLAIN)ANALYZEBUFFERSCOSTSSETTINGSSUMMARYTIMINGVERBOSEWALintegerbigintsmallint) 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_sqlRs * $ $1s11169 9 N * *0#000&8 8 J & &1311169 9!'')) &00== FD[DDEE E3+33S333V;;rNcN||||\}}d|d|g|RfSNDATE_TRUNC(%s, rD_convert_sql_to_tzr=rKrLrMtznames rdate_trunc_sqlz!DatabaseOperations.date_trunc_sqla>--c66BB V''''+)?)?)???rcTt|\}}}|r|dkrdnd}|||S|S)N+-r )r=rUsignoffsets r_prepare_tzname_deltaz(DatabaseOperations._prepare_tzname_deltafsJ1&99f  -#++333D,d,F,, , rch|r-tjr!||}|dg||RfS||fS)Nz AT TIME ZONE %s)rUSE_TZr])r=rLrMrU tzname_params rrSz%DatabaseOperations._convert_sql_to_tzmsT  Eho E55f==L+++-Dv-D|-D-DD DF{rcF||||\}}d|d|fS)Nr7z)::daterRr=rLrMrUs rdatetime_cast_date_sqlz)DatabaseOperations.datetime_cast_date_sqls3--c66BB V3''rcF||||\}}d|d|fS)Nr7)::timerRrbs rdatetime_cast_time_sqlz)DatabaseOperations.datetime_cast_time_sqlwrdrc||||\}}|dkr d|ddg|RfS||||SNsecondz#EXTRACT(SECOND FROM DATE_TRUNC(%s, )))rSrNrTs rdatetime_extract_sqlz'DatabaseOperations.datetime_extract_sql{sa--c66BB V ( " "@@@@8BUfBUBUU U$$[#v>>>rcN||||\}}d|d|g|RfSrPrRrTs rdatetime_trunc_sqlz%DatabaseOperations.datetime_trunc_sqlrWrcT|dkr d|ddg|RfS||||Sri)rNrJs rtime_extract_sqlz#DatabaseOperations.time_extract_sqlsF ( " "@@@@8BUfBUBUU U$$[#v>>>rcN||||\}}d|d|g|RfS)NrQrfrRrTs 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    rcDd}|dvr|dvrd}n |dvrd}nd}|dvrd |z}|S) Nr8) iexactcontains icontains startswith istartswithendswith iendswithregexiregex)r4r3zHOST(%s)) CICharField CIEmailField CITextFieldz %s::citextz%s::text)r|r~rrz UPPER(%s)rt)r=rKr?lookups r lookup_castzDatabaseOperations.lookup_castsc    KKK#"PPP%# M M M 6)F rcdSNrtrus rno_limit_valuez!DatabaseOperations.no_limit_valuestrc|gSrrt)r=rLs 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=rLrMs r compose_sqlzDatabaseOperations.compose_sqlssFDO444rcdS)Nz(SELECT set_config('TimeZone', %s, false)rtrus 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 sequencesrL 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|Srrt)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. ?rtrus rmax_name_lengthz"DatabaseOperations.max_name_lengths rrc^|r'd|D}dd|zg|fSdggfS)Ncg|] }|D]}| Srtrt)r param_listparams r z3DatabaseOperations.distinct_sql..%s%MMM *MMeMMMMrzDISTINCT ON (%s)rDISTINCTr)r=fieldsrMs r distinct_sqlzDatabaseOperations.distinct_sql#sI  $MMfMMMF'$))F*;*;;.>s^    1 :;;;; ---    rz RETURNING %srrtr)r=rcolumnss` rreturn_insert_columnsz(DatabaseOperations.return_insert_columns;sX 6         ' 2 22B66rcbd|D}dd|D}d|zS)Nc3@K|]}d|VdS)rNr)rrows rrz5DatabaseOperations.bulk_insert_sql..Is,KK3 #KKKKKKrrc3 K|] }d|zV dS)z(%s)Nrt)rrLs rrz5DatabaseOperations.bulk_insert_sql..Js&LLv|LLLLLLrzVALUES r)r=rplaceholder_rowsplaceholder_rows_sql values_sqls rbulk_insert_sqlz"DatabaseOperations.bulk_insert_sqlHsCKK:JKKKYYLL7KLLLLL :%%rcV|t|dr|S|j||S)Nresolve_expression)hasattrintegerfield_type_map)r=valuer?s radapt_integerfield_valuez+DatabaseOperations.adapt_integerfield_valueOs3}/C D D} <4-mt|t|S)N)r)rr)r=rrs radapt_json_valuez#DatabaseOperations.adapt_json_valueesU."9"9::::rc|dkr|\}}|\}}g||R}d|d|d|fSt|||S)N DateFieldz(interval '1 day' * (z - rk)supersubtract_temporals) r=r?lhsrhslhs_sql lhs_paramsrhs_sql rhs_paramsrM __class__s rrz%DatabaseOperations.subtract_temporalshsj 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)rF)rrrs r z;DatabaseOperations.explain_query_prefix..ts?D% :ff7rFORMATz (%s)rc3 K|] }d|zV dS)z%s %sNrt)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_prefixps  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.rt)rrs rrz=DatabaseOperations.on_conflict_suffix_sql..s6!!55e55r)rIGNOREUPDATErmaprron_conflict_suffix_sql)r=r on_conflict update_fields unique_fieldsrs rr%z)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):__name__ __module__ __qualname__"cast_char_field_without_max_lengthexplain_prefix frozensetrcast_data_typesr psycopg.typesr+Int2Int4Int8rr@rrGrNrVr]rSrcrgrlrnrprrrvrzrrrrrrrrrrrrrrrrrrrrrrrrrr%r* __classcell__)rs@rrrs)2&Ni   O $O   ))))))")#L&|)0$+L'.| ! ! **)*55 < < <@@@@  ((((((???@@@ ??? FFFF000!!!8 555:::;@u----- &AAAA   D   $$$        7 7 7&&& D 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_helperrrrrtrrrEs4 (((((((( EEEEEE877777111111++++++666666 ,, , E"E"E"E"E"/E"E"E"E"E"r