o FhZ>dd!l?m@Z@dd"lAmBZBdd#lCmDZDd$d%ZEGd&d'd'eZFe#r@Gd(d)d)ZGGd*d+d+eGejHZIGd,d-d-eGejJZHGd.d/d/eZdSej/jKZHGd0d/d/eZdS)1zY 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 modulecCstjddd}t|S)N r)Database __version__splitr )versionr[/var/www/html/loop/nvenv/lib/python3.10/site-packages/django/db/backends/postgresql/base.pypsycopg_version sr)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)DatabaseSchemaEditorcCs|ddurdSd|S)N max_lengthvarcharvarchar(%(max_length)s)r)datarrr_get_varchar_columnSs r.cseZdZdZdZiddddddd 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 ZeZeZeZeZeZdZd?d@ZedAdBZdCdDZdEdFZfdGdHZ ed\dJdKZ!dLdMZ"edNdOZ#dPdQZ$d\dRdSZ%dTdUZ&e'fdVdWZ(e)dXdYZ*dZd[Z+Z,S)]DatabaseWrapper 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)rPrQrRz GENERATED BY DEFAULT AS IDENTITY)r2r4rTz= %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[r\rcrerdrfrcCs t|jdS)zo Return a tuple of the database's version. E.g. for pg_version 120004, return (12, 4). i')divmod pg_versionselfrrrget_database_versions z$DatabaseWrapper.get_database_versioncCs|j}|ddkr|didstdt|dpd|jkr5td|dt|d|jf|drDd|di|d}n|ddur]|diddddi|d}ni|d}d |d <|d d|d d|d d}|dtr|durt nt |dr|d|d<|dr|d|d<|dr|d|d<|dr|d|d<trt t j |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)rjr conn_paramsrvrrrget_connection_paramssj           z%DatabaseWrapper.get_connection_paramscCs|jd}d}z|d}Wn tytj|_Ynwz t||_d}Wnty3td|dw|jjd i|}|rC|j|_t sOt j j |ddd |S) NrnFruTz$Invalid transaction isolation level z9 specified. Use one of the psycopg.IsolationLevel values.cSs|SNr)xrrrsz4DatabaseWrapper.get_new_connection..) conn_or_cursloadsr) rKeyErrorrREAD_COMMITTEDru ValueErrorrrconnectrpsycopg2extrasregister_default_jsonb)rjroptionsset_isolation_levelisolation_level_value connectionrrrget_new_connections.       z"DatabaseWrapper.get_new_connectioncCsv|jdurdS|jjd}|j}|r9||kr9|j}||j|gWddS1s2wYdSdS)NFTimeZoneT)rinfoparameter_status timezone_namecursorexecuterset_time_zone_sql)rjconn_timezone_namerrrrrensure_timezone!s    zDatabaseWrapper.ensure_timezonecCst|jdurdS|jdid}r8|j}|jd|g}||WddS1s1wYdSdS)NFrnrtz SET ROLE %sT)rrrrr compose_sqlr)rjnew_rolerrrrr ensure_role,s    zDatabaseWrapper.ensure_rolecs@t|}|}|s|r|s|jdSdSdSr)superinit_connection_staterrget_autocommitrcommit)rj commit_tz commit_role __class__rrr6s z%DatabaseWrapper.init_connection_stateNcCsn|r|jj|d|jjd}n|j}tr,|jjttj}|j |j kr*t |j ||St j r2|j nd|_ |S)NF) scrollablewithhold)rr autocommitrr get_loaderTIMESTAMPTZ_OIDrTEXTrr!rrtzinfo_factory)rjnamertzloaderrrr create_cursorCs    zDatabaseWrapper.create_cursorcCs|jSr)r)rjoffsetrrrrXszDatabaseWrapper.tzinfo_factorycCsf|jd7_zt}Wn tyd}Ynw|r"tt|}nd}|jdtj ||jfdS)Nrsyncz_django_curs_%d_%s_%d)r) _named_cursor_idxasyncio current_task RuntimeErrorstrid_cursor threadingcurrent_threadident)rjr task_identrrrchunked_cursor[s"  zDatabaseWrapper.chunked_cursorcCs4|j ||j_WddS1swYdSr)wrap_database_errorsrr)rjrrrr_set_autocommitws "zDatabaseWrapper._set_autocommitcCsB|}|d|dWddS1swYdS)zl Check constraints by setting them to immediate. Return them to deferred afterward. zSET CONSTRAINTS ALL IMMEDIATEzSET CONSTRAINTS ALL DEFERREDN)rr)rj table_namesrrrrcheck_constraints{s   "z!DatabaseWrapper.check_constraintscCsVz|j}|dWdWdS1swYWdStjy*YdSw)NzSELECT 1FT)rrrrErrorrjrrrr is_usables   zDatabaseWrapper.is_usablec #sd}zt }|VWdWdS1swYWdStjtfy|dur/tdtt D]G}|j dkr|j ddkr|j i|j d|j di|j d}z| }|VWdn1slwYW|n|wYdSq9w)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.r0rlrq)alias)r _nodb_cursorrrWrappedDatabaseErrorwarningswarnRuntimeWarningrallvendorrrrrclose)rjrrconnrrrrsD &    zDatabaseWrapper._nodb_cursorcCs6| |jjjWdS1swYdSr)temporary_connectionrrserver_versionrirrrrhs $zDatabaseWrapper.pg_versioncCs t||Srrrrrrmake_debug_cursors z!DatabaseWrapper.make_debug_cursorr)-__name__ __module__ __qualname__r display_namer. data_typesdata_type_check_constraintsdata_types_suffix operators pattern_esc pattern_opsrr)SchemaEditorClassr$ client_classr%creation_classr&features_classr'introspection_classr( ops_classrrkrr rrrrrrrrrrrrr rhr __classcell__rrrrr/Ys      @ "      % r/c@seZdZdZdddZdS) CursorMixinzE A subclass of psycopg cursor implementing callproc. NcCst|tjs t|}td|tdg}|r0|D]}|t||tdq|d=|tdt|}|||S)NzSELECT * FROM (,)) isinstancer IdentifierSQLappendLiteralComposedr)rjrargsqpartsitemstmtrrrcallprocs    zCursorMixin.callprocr)rrr__doc__rrrrrrsrc@ eZdZdS)rNrrrrrrrrrc@r)rNrrrrrrrrc@seZdZddZdS)r cCs:|||j|WdS1swYdSr) debug_sqlrcopy)rj statementrrrrs  $zCursorDebugWrapper.copyN)rrrrrrrrr s r c@seZdZddZddZdS)r cGsD|||jj||g|RWdS1swYdSr)rr copy_expert)rjrfilerrrrrs $zCursorDebugWrapper.copy_expertcOsP|jd|d|jj||g|Ri|WdS1s!wYdS)NzCOPY %s TO STDOUT)r)rrcopy_to)rjr tablerkwargsrrrr s$zCursorDebugWrapper.copy_toN)rrrrr rrrrr s )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.versionr psycopgr ImportErrorrrr psycopg_anyrrrr psycopg.pqrr r!typesoidrpsycopg2.extensionspsycopg2.extras extensionsregister_adapter QuotedStringr register_uuid INETARRAY_OIDnew_array_typeUNICODEr# register_typeclientr$creationr%featuresr& introspectionr' operationsr(schemar)r.r/rrr ClientCursorrrrrrs                           f