jdZddlZddlZddlZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZdd lmZdd lmZdd lmZdd lmZdd lmZ ddlZn#e$rddlZYnwxYwn#e$r e dwxYwdZedkre dej decxkrdkrnne dej ddl!m"Z"m#Z#e#r)ddlm$Z$m%Z%ddl&m'Z'ddl!m(Z(m)Z)e$j*dj+Z,nddl-Zddl.Zej/0eej/j1ej23dZ4ej/5e4fdej/j6Z7ej/8e7ddl9m:Z:ddl;mZ>dd l?m@Z@dd!lAmBZBdd"lCmDZDd#ZEGd$d%eZFe#rEGd&d'ZGGd(d)eGejHZIGd*d+eGejJZHGd,d-eZdSej/jKZHGd.d-eZdS)/zY PostgreSQL database backend for Django. Requires psycopg2 >= 2.8.4 or psycopg >= 3.1.8 N)contextmanager)settings)ImproperlyConfigured) DatabaseError) connections)BaseDatabaseWrapperCursorDebugWrapper) async_unsafe)cached_property) SafeString)get_version_tuplez(Error loading psycopg2 or psycopg modulecltjddd}t|S)N r)Database __version__splitr)versions q/var/www/finuniver-perm.ru/html/portfolio/venv/lib/python3.11/site-packages/django/db/backends/postgresql/base.pypsycopg_versionr s-"((a003G W % %%)z6psycopg2 version 2.8.4 or newer is required; you have ))rrrz5psycopg version 3.1.8 or newer is required; you have r)IsolationLevel is_psycopg3)adapterssql)Format)get_adapters_templateregister_tzloader timestamptzi INETARRAY)DatabaseClient)DatabaseCreation)DatabaseFeatures)DatabaseIntrospection)DatabaseOperations)DatabaseSchemaEditorc |ddSd|zS)N max_lengthvarcharvarchar(%(max_length)s))datas r_get_varchar_columnr2Ss L!y $t ++rceZdZdZdZiddddddd d d ed d dddddddddddddddddddddddddd dd d d!d"d#d$ Zd%d%d%d&Zd'd'd'd(Zd)d*d+d,d-d.d/d0d1d2d+d+d,d,d3Z d4Z d5d6d7d8d9d:d;Z e Z e ZeZeZeZeZeZdZed?Zd@ZdAZfdBZ edMdDZ!dEZ"edFZ#dGZ$dMdHZ%dIZ&e'fdJZ(e)dKZ*dLZ+xZ,S)NDatabaseWrapper postgresql PostgreSQL AutoFieldinteger BigAutoFieldbigint BinaryFieldbytea BooleanFieldboolean CharField DateFielddate DateTimeFieldztimestamp with time zone DecimalFieldz+numeric(%(max_digits)s, %(decimal_places)s) DurationFieldinterval FileFieldr/ FilePathField FloatFieldzdouble precision IntegerFieldBigIntegerFieldIPAddressFieldinetGenericIPAddressField JSONFieldjsonbsmallinttexttimeuuid) OneToOneFieldPositiveBigIntegerFieldPositiveIntegerFieldPositiveSmallIntegerField SlugFieldSmallAutoFieldSmallIntegerField TextField TimeField UUIDFieldz"%(column)s" >= 0)rUrVrWz GENERATED BY DEFAULT AS IDENTITY)r7r9rYz= %sz = UPPER(%s)zLIKE %szLIKE UPPER(%s)z~ %sz~* %sz> %sz>= %sz< %sz<= %s)exactiexactcontains icontainsregexiregexgtgteltlte startswithendswith istartswith iendswithzKREPLACE(REPLACE(REPLACE({}, E'\\', E'\\\\'), E'%%', E'\\%%'), E'_', E'\\_')zLIKE '%%' || {} || '%%'zLIKE '%%' || UPPER({}) || '%%'zLIKE {} || '%%'zLIKE UPPER({}) || '%%'zLIKE '%%' || {}zLIKE '%%' || UPPER({}))r`rarhrjrirkrc,t|jdS)zo Return a tuple of the database's version. E.g. for pg_version 120004, return (12, 4). i')divmod pg_versionselfs rget_database_versionz$DatabaseWrapper.get_database_versions dou---rcV|j}|ddkr8|didstdt|dpd|jkrEtd|dt|d|jfz|drd|di|d}nI|d7|diddddi|d}n i|d}d |d <|d d|d d|d d}|dtr |durtnt|dr |d|d<|dr |d|d<|dr |d|d<|dr |d|d<tr;ttj |j|d<|dd|d<|S)NNAMEOPTIONSservicez`settings.DATABASES is improperly configured. Please supply the NAME or OPTIONS['service'] value.zThe database name '%s' (%d characters) is longer than PostgreSQL's limit of %d characters. Supply a shorter NAME in settings.DATABASES.dbnamepostgresUTF8client_encoding assume_roleisolation_levelserver_side_bindingcursor_factoryTUSERuserPASSWORDpasswordHOSThostPORTportcontextprepare_threshold) settings_dictgetrlenopsmax_name_lengthpop setdefaultrServerBindingCursorCursorr"rUSE_TZtimezone)rpr conn_paramsr}s rget_connection_paramsz%DatabaseWrapper.get_connection_paramss*  B & &}/@/@B/O/O/S/S 0 0 &'F  }V$* + +dh.F.F.H.H H H&)"&) f-..H,,..     7-/ *KK6 " *   i , , 0 0D A A A#ZL=3KLKK6]956K)/ %& t,,,)4000)oo.CTJJ #6$#>#>$#       8"/"7K   $ @&3J&?K #   8"/"7K    8"/"7K   %:&&K " 0;#T00K+ ,rc||jd}d} |d} t||_d}nB#t$rt d|dwxYw#t $rtj|_YnwxYw|jjd i|}|r |j|_ts"tj |d|S) NruFr|Tz$Invalid transaction isolation level z9 specified. Use one of the psycopg.IsolationLevel values.c|SNr0)xs rz4DatabaseWrapper.get_new_connection..sr) conn_or_cursloadsr0) rrr| ValueErrorrKeyErrorREAD_COMMITTEDrconnectrpsycopg2extrasregister_default_jsonb)rproptionsset_isolation_levelisolation_level_value connections rget_new_connectionz"DatabaseWrapper.get_new_connections($Y/# $+,=$> !  '56K'L'L$&*##   *P;PPPP  A A A#1#@D  A+T]*99[99  >)-)=J &  O 2 2'{{ 3   sA1AA0/A0c6|jdS|jjd}|j}|rg||kra|j5}||j|gdddn #1swxYwYdSdS)NFTimeZoneT)rinfoparameter_status timezone_namecursorexecuterset_time_zone_sql)rpconn_timezone_namerrs rensure_timezonezDatabaseWrapper.ensure_timezone!s ? "5!_1BB:NN*  /=@@'')) NVtx99;;m_MMM N N N N N N N N N N N N N N N4us/B  BBc@|jdS|jdidx}rd|j5}|jd|g}||dddn #1swxYwYdSdS)NFrur{z SET ROLE %sT)rrrrr compose_sqlr)rpnew_rolerr s r ensure_rolezDatabaseWrapper.ensure_role,s ? "5)--i<<@@OO O8 '')) $Vh**=8*EEs### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $4us2BBBct|}|}|s|r1|s|jdSdSdSr)superinit_connection_staterrget_autocommitrcommit)rp commit_tz commit_role __class__s rrz%DatabaseWrapper.init_connection_state6s %%'''((** &&((  %9 %d.A.A.C.C % O " " $ $ $ $ $ % % % %rNcx|r(|j|d|jj}n|j}trU|jjt tj}|j |j krt|j |ntj r|j nd|_ |S)NF) scrollablewithhold)rr autocommitrr get_loaderTIMESTAMPTZ_OIDr!TEXTrr#rrtzinfo_factory)rpnamertzloaders r create_cursorzDatabaseWrapper.create_cursorCs  ._++1K,FF_++--F  U/::?FKXXH} 111!$-888;C?$TD$7$7PTF ! rc|jSr)r)rpoffsets rrzDatabaseWrapper.tzinfo_factoryXs }rc |xjdz c_ tj}n#t$rd}YnwxYw|rt t |}nd}|dtjj ||jfzS)Nrsyncz_django_curs_%d_%s_%d)r) _named_cursor_idxasyncio current_task RuntimeErrorstrid_cursor threadingcurrent_threadident)rpr task_idents rchunked_cursorzDatabaseWrapper.chunked_cursor[s !#  "/11LL   LLL   R --..JJJ||((**0&    s & 55c^|j5||j_ddddS#1swxYwYdSr)wrap_database_errorsrr)rprs r_set_autocommitzDatabaseWrapper._set_autocommitwsy  & 4 4)3DO & 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4s "&&c|5}|d|dddddS#1swxYwYdS)zl Check constraints by setting them to immediate. Return them to deferred afterward. zSET CONSTRAINTS ALL IMMEDIATEzSET CONSTRAINTS ALL DEFERREDN)rr)rp table_namesrs rcheck_constraintsz!DatabaseWrapper.check_constraints{s [[]] ;f NN: ; ; ; NN9 : : : ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ;s+A  AAc |j5}|ddddn #1swxYwYdS#tj$rYdSwxYw)NzSELECT 1TF)rrrrErrorrprs r is_usablezDatabaseWrapper.is_usables '')) +Vz*** + + + + + + + + + + + + + + + 4~   55 s1A = A AA AA AAc#Kd} t5}|VddddS#1swxYwYdS#tjtf$r|t jdttj D]}|j dkr|j ddkr| i|j d|j di|j } |5}|Vdddn #1swxYwY|n#|wxYwYdSwxYw)Na8Normally Django will use a connection to the 'postgres' database to avoid running initialization queries against the production database when it's not needed (for example, when running tests). Django was unable to create a connection to the 'postgres' database and will use the first PostgreSQL database instead.r5rsrx)alias)r _nodb_cursorrrWrappedDatabaseErrorwarningswarnRuntimeWarningrallvendorrrrrclose)rprrconnrs rrzDatabaseWrapper._nodb_cursors! %%'' 6                   &(<=   ! MF     *o//   %55"08JFF>>"0"J$>>@  \ D    % % % % %\(  \ 6444;;;;####^#J77_70000000rr4ceZdZdZddZdS) CursorMixinzE A subclass of psycopg cursor implementing callproc. Nct|tjstj|}tjd|tjdg}|rV|D]P}|tj||tjdQ|d=|tjdtj|}|||S)NzSELECT * FROM (,)) isinstancer IdentifierSQLappendLiteralComposedr)rprargsqpartsitemstmts rcallproczCursorMixin.callprocsdCN33 ,~d++g.//sws||DF  00DMM#+d"3"3444MM#'#,,////2J MM#'#,, ' ' '<''D LL   Krr)rrr__doc__rr0rrrrs2        rrceZdZdS)rNrrrr0rrrr rrceZdZdS)rNrr0rrrrrrrceZdZdZdS)r c||5|j|cdddS#1swxYwYdSr) debug_sqlrcopy)rp statements rrzCursorDebugWrapper.copys ** 3 3{'' 22 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s=AAN)rrrrr0rrr r s# 3 3 3 3 3rr ceZdZdZdZdS)r c||5|jj||g|RcdddS#1swxYwYdSr)rr copy_expert)rpr filers rr#zCursorDebugWrapper.copy_experts$$ A A.t{.sD@4@@@ A A A A A A A A A A A A A A A A A As 7;;c|d|z5|jj||g|Ri|cdddS#1swxYwYdS)NzCOPY %s TO STDOUT)r )rrcopy_to)rpr$tablerkwargss rr&zCursorDebugWrapper.copy_tos$7%$?@@ I I*t{*4HHHHHH I I I I I I I I I I I I I I I I I Is>AAN)rrrr#r&r0rrr r s: A A A I I I I Ir)Lrrrr contextlibr django.confrdjango.core.exceptionsr django.dbrrrdjango.db.backends.base.baserdjango.db.backends.utilsr BaseCursorDebugWrapperdjango.utils.asyncior django.utils.functionalr django.utils.safestringr django.utils.versionrpsycopgr ImportErrorrrr psycopg_anyrrrr psycopg.pqr!r"r#typesoidrpsycopg2.extensionspsycopg2.extras extensionsregister_adapter QuotedStringr register_uuid INETARRAY_OIDnew_array_typeUNICODEr% register_typeclientr&creationr'featuresr( introspectionr) operationsr*schemar+r2r4rrr ClientCursorrr0rrrKs %%%%%% 777777;;;;;;!!!!!!<<<<<<QQQQQQ------333333......222222K$""""" $$$######$KKK  I J JJK&&& ?y   WAUWW  ??  ((((y(((((  V@TVV   544444441%%%%%%%%!!!!!!EEEEEEEEn]37OO ((X5H5UVVV O!!###M#22 #I  %%i000#"""""&&&&&&&&&&&&000000******((((((,,, a0a0a0a0a0)a0a0a0H ,I*     k8?        h3   33333333333  'FIIIII3IIIIIs*AA( A$!A(#A$$A((A9