ho6SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ r SSK J r SSK J r SSKJr SSKJrJrJr SSKJr SSKJr SS KJr SS KJr SS KJr SS KJrJ r SS K!J"r" SSK#J$r$ Sr%\&"5q'\RP"S5r)"SS5r*g)N)deque)contextmanager)settings)ImproperlyConfigured)DEFAULT_DB_ALIAS DatabaseErrorNotSupportedError)utils)BaseDatabaseValidation)connection_created)debug_transaction)TransactionManagementError)DatabaseErrorWrapperProgrammingError) async_unsafe)cached_property __no_db__zdjango.db.backends.basec\rSrSrSr0r0r0rSrSr Sr Sr Sr Sr SrSrSr\rSr\4SjrSrSr\S 5r\S 5r\S 5r\S 5rS rSrSr Sr!Sr"SFSjr#\$S5r%Sr&\$S5r'Sr(SFSjr)Sr*Sr+Sr,\$S5r-\$S5r.\$S5r/\$S5r0Sr1S r2S!r3S"r4\$S#5r5\$S$5r6\$S%5r7\$S&5r8S'r9S(r:SGS)jr;S*rS-r?\@S.5rAS/rBS0rCSFS1jrDS2rES3rFS4rG\S55rHS6rIS7rJS8rKS9rL\S:5rMS;rNS<rOS=rP\@S>5rQ\@S?5rRS@rSSGSAjrTSBrU\@SC5rVSFSDjrWSErXg)HBaseDatabaseWrapperz Represent a database connection.Nunknowni(#cSUlXlX l[URS9UlSUlSUlSUlSUl /Ul /Ul SUl SUl SUlSUlSUlSUlSUlSUl[(R*"5UlSUl[0R2"5Ul/UlSUl/UlUR=U5UlURAU5Ul!UREU5Ul#URIU5Ul%URMU5Ul'URQU5Ul)g)N)maxlenFrT)* connection settings_dictaliasr queries_limit queries_logforce_debug_cursor autocommitin_atomic_blocksavepoint_state savepoint_ids atomic_blockscommit_on_exitneeds_rollback rollback_excclose_atclosed_in_transactionerrors_occurredhealth_check_enabledhealth_check_done threadingLock_thread_sharing_lock_thread_sharing_count_thread get_ident _thread_ident run_on_commit%run_commit_hooks_on_set_autocommit_onexecute_wrappers client_classclientcreation_classcreationfeatures_classfeaturesintrospection_class introspection ops_classopsvalidation_class validation)selfrrs N/var/www/html/env/lib/python3.13/site-packages/django/db/backends/base/base.py__init__BaseDatabaseWrapper.__init__5sT+  (:(:;"'  $ #$  %*"$$)!!&%.NN$4!%&"$..0  6;2 !#''- ++D1 ++D1 !55d;>>$'//5cnSURRSUR<SUR<S3$)N) __class__ __qualname__vendorrrCs rD__repr__BaseDatabaseWrapper.__repr__ys8++,-kk_GDJJ> < rGcg)zg Ensure the connection's timezone is set to `self.timezone_name` and return whether it changed or not. FrNs rDensure_timezone#BaseDatabaseWrapper.ensure_timezones rGc[R(dgURSc[RR $[ R"URS5$)a/ Return a tzinfo of the database connection time zone. This is only used when time zone support is enabled. When a datetime is read from the database, it is always returned in this time zone. When the database backend supports time zones, it doesn't matter which time zone Django uses, as long as aware datetimes are used everywhere. Other users connecting to the database can choose their own time zone. When the database backend doesn't support time zones, the time zone Django uses may be constrained by the requirements of other users of the database. N TIME_ZONE)rUSE_TZrdatetimetimezoneutczoneinfoZoneInforNs rDrYBaseDatabaseWrapper.timezonesM     , 4$$(( ($$T%7%7 %DE ErGc[R(d[R$URScgURS$)z3 Name of the time zone of the database connection. rVUTC)rrWrVrrNs rD timezone_name!BaseDatabaseWrapper.timezone_names< %% %    , 4%%k2 2rGcHUR=(d [R$N)rrDEBUGrNs rDqueries_logged"BaseDatabaseWrapper.queries_loggeds&&8(..8rGc[UR5URR:Xa9[R"SR URR55 [ UR5$)NzLLimit for query logging exceeded, only the last {} queries will be returned.)lenrrwarningswarnformatlistrNs rDqueriesBaseDatabaseWrapper.queriess[ t D$4$4$;$; ; MM$$*F4+;+;+B+B$C D$$%%rGc[S5e)z)Return a tuple of the database's version.zNsubclasses of BaseDatabaseWrapper may require a get_database_version() method.NotImplementedErrorrNs rDget_database_version(BaseDatabaseWrapper.get_database_versions!   rGcURRbUR5URR:a~SR[ [ UR555nSR[ [ URR55n[ URSUSUS35egg)zS Raise an error if the database version isn't supported by this version of Django. N. z or later is required (found z).)r<minimum_database_versionrrjoinmapstrr display_name)rC db_versionmin_db_versions rD check_database_version_supported4BaseDatabaseWrapper.check_database_version_supporteds MM 2 2 >))+dmm.T.TT#c4+D+D+F"GHJ XXc#t}}/U/U&VWN#$$%Q~&67$R)  U ?rGc[S5e)zConnect to the database. Assume that the connection is closed.FCONN_HEALTH_CHECKS CONN_MAX_AGENT AUTOCOMMIT)senderr)check_settingsr!r#r$r&rr+time monotonicr(r)r*r,rrrset_autocommitrr sendrKr4)rCmax_agers rDconnectBaseDatabaseWrapper.connects $#$($6$67K$L!$$^4 'T^^5E5O %*"$!%002 11+> D..|<= ""$t~~$GrGcURSb.[R(d[SUR-5egg)NrVz=Connection '%s' cannot set TIME_ZONE because USE_TZ is False.)rrrWrrrNs rDr"BaseDatabaseWrapper.check_settingss?   k * 6x&O** @O 6rGcURcSUR(aUR(a [S5eUR UR 5 SSS5 gg!,(df  g=f)z;Guarantee that a connection to the database is established.Nz0Cannot open a new connection in an atomic block.)rr!r)rwrap_database_errorsrrNs rDensure_connection%BaseDatabaseWrapper.ensure_connectionsY ?? "##(B(B&F** +* # +*s A"" A0cUR5 UR(aURU5nU$URU5nU$)zI Validate the connection is usable and perform database cursor wrapping. )validate_thread_sharingremake_debug_cursor make_cursor)rCcursorwrapped_cursors rD_prepare_cursor#BaseDatabaseWrapper._prepare_cursorsI $$&   !33F;N"--f5NrGcUR5 UR5 UR URUR U55sSSS5 $!,(df  g=frc)close_if_health_check_failedrrrrrs rD_cursorBaseDatabaseWrapper._cursor&sH ))+   & &''(:(:4(@A' & &s A A%cURbF[US5 UR URR5sSSS5 sSSS5 $g!,(df  O=fSSS5 g!,(df  g=f)NCOMMIT)rr rcommitrNs rD_commitBaseDatabaseWrapper._commit,sS ?? &"42D4M4M--/5N4M22 '4M4M222" A/A A/ A# A// A=cURbF[US5 UR URR5sSSS5 sSSS5 $g!,(df  O=fSSS5 g!,(df  g=f)NROLLBACK)rr rrollbackrNs rD _rollbackBaseDatabaseWrapper._rollback1sS ?? &"44d6O6O//17P6O44 '6O6O444rcURb0UR URR5sSSS5 $g!,(df  g=frc)rrcloserNs rD_closeBaseDatabaseWrapper._close6s9 ?? &**,,.+* '**s ? A c"UR5$)z3Create a cursor, opening a connection if necessary.)rrNs rDrBaseDatabaseWrapper.cursor=s||~rGcUR5 UR5 UR5 SUlSUlg)z.Commit a transaction and reset the dirty flag.FTN)rvalidate_no_atomic_blockrr*r5rNs rDrBaseDatabaseWrapper.commitBs5 $$& %%' $592rGcUR5 UR5 UR5 SUlSUl/Ulg)z1Roll back a transaction and reset the dirty flag.FN)rrrr*r&r4rNs rDrBaseDatabaseWrapper.rollbackLs> $$& %%' $#rGc8UR5 /UlUR(d URcgUR 5 UR (aSUlSUlgSUlg!UR (aSUlSUlfSUlf=f)z%Close the connection to the database.NT)rr4r)rrr!r&rNs rDrBaseDatabaseWrapper.closeWs $$&  % %)@  ' KKM##-1*&*#"& ##-1*&*#"&s A00)BcUR5nURURRU55 SSS5 g!,(df  g=frc)rexecuter@savepoint_create_sqlrCsidrs rD _savepointBaseDatabaseWrapper._savepointm2 [[]f NN48888= >]] +A AcUR5nURURRU55 SSS5 g!,(df  g=frc)rrr@savepoint_rollback_sqlrs rD_savepoint_rollback'BaseDatabaseWrapper._savepoint_rollbackqs2 [[]f NN488::3? @]]rcUR5nURURRU55 SSS5 g!,(df  g=frc)rrr@savepoint_commit_sqlrs rD_savepoint_commit%BaseDatabaseWrapper._savepoint_commiturrcfURR=(a UR5(+$rc)r<uses_savepointsget_autocommitrNs rD_savepoint_allowed&BaseDatabaseWrapper._savepoint_allowedys#}},,JT5H5H5J1JJrGcUR5(dg[R"5n[U5R SS5nU=R S- slSX R 4-nUR 5 URU5 U$)z Create a savepoint inside the current transaction. Return an identifier for the savepoint that will be used for the subsequent rollback or commit. Do nothing if savepoints are not supported. N-zs%s_x%d)rr1r2rzreplacer"rr)rC thread_identtidrs rD savepointBaseDatabaseWrapper.savepoints|&&(( ((* ,''R0 !3 4 455 $$&  rGcUR5(dgUR5 URU5 URVVVs/sHup#nX;dM X#U4PM snnnUlgs snnnf)zG Roll back to a savepoint. Do nothing if savepoints are not supported. N)rrrr4)rCrsidsfuncrobusts rDsavepoint_rollback&BaseDatabaseWrapper.savepoint_rollbacksn &&((  $$&   % )-(:(: (:$V !T (:  s  A+A+crUR5(dgUR5 URU5 g)zB Release a savepoint. Do nothing if savepoints are not supported. N)rrr)rCrs rDsavepoint_commit$BaseDatabaseWrapper.savepoint_commits0 &&((  $$& s#rGcSUlg)zI Reset the counter used to generate unique savepoint ids in this thread. rN)r"rNs rDclean_savepoints$BaseDatabaseWrapper.clean_savepointss !rGc[S5e)zB Backend-specific implementation to enable or disable autocommit. zHsubclasses of BaseDatabaseWrapper may require a _set_autocommit() methodrp)rCr s rD_set_autocommit#BaseDatabaseWrapper._set_autocommits" V  rGc:UR5 UR$)zGet the autocommit state.)rr rNs rDr"BaseDatabaseWrapper.get_autocommits  rGcUR5 UR5 UR5 U=(a U(+=(a [US5nU(aUR 5 O?U(aUR U5 O&[ US5 UR U5 SSS5 XlU(a*UR(aUR5 SUlggg!,(df  NF=f)a Enable or disable autocommit. The usual way to start a transaction is to turn autocommit off. SQLite does not properly start a transaction when disabling autocommit. To avoid this buggy behavior and to actually enter a new transaction, an explicit BEGIN is required. Using force_begin_transaction_with_broken_autocommit=True will issue an explicit BEGIN with SQLite. This option will be ignored for other backends. #_start_transaction_under_autocommitBEGINNF) rrrhasattrrrr r r5run_and_clear_commit_hooks)rCr .force_begin_transaction_with_broken_autocommit"start_transaction_under_autocommits rDr"BaseDatabaseWrapper.set_autocommits %%' ))+   ; E ECD + .  4 4 6    ,"41$$Z02$ $DD  + + -9>D 6E: 21s C## C1cRUR(d [S5eUR$)z9Get the "needs rollback" flag -- for *advanced use* only.>##+0D(-1D*JJL}}(T^^-=-N .O(% 'rGcnUR URS:sSSS5 $!,(df  g=f)Nrr/r0rNs rDallow_thread_sharing(BaseDatabaseWrapper.allow_thread_sharingls%  & &--1' & &s& 4czUR U=RS- slSSS5 g!,(df  g=f)Nrr&rNs rDinc_thread_sharing&BaseDatabaseWrapper.inc_thread_sharingqs(  & &  & &! + &' & &s, :cUR URS::a [S5eU=RS-slSSS5 g!,(df  g=f)Nrz5Cannot decrement the thread sharing count below zero.r)r/r0 RuntimeErrorrNs rDdec_thread_sharing&BaseDatabaseWrapper.dec_thread_sharingusH  & &))Q."K  & &! + & ' & &s 1A Ac UR(dcUR[R"5:Xd?[ SUR <SUR<S[R"5<S35egg)a  Validate that the connection isn't accessed by another thread than the one which originally created it, unless the connection was explicitly authorized to be shared between threads (via the `inc_thread_sharing()` method). Raise an exception if the validation fails. ziDatabaseWrapper objects created in a thread can only be used in that same thread. The object with alias 'z' was created in thread id z and this is thread id ruN)r'r3r1r2rrrNs rDr+BaseDatabaseWrapper.validate_thread_sharing}s[))T-?-?7CTCTCV-V$(::t/A/A7CTCTCVX .W)rGcg)zf Hook to do any database check or preparation, generally called before migrating a project or an app. NrRrNs rDprepare_database$BaseDatabaseWrapper.prepare_databaserrGc[U5$)zs Context manager and decorator that re-throws backend-specific database exceptions using Django's common wrappers. )rrNs rDr(BaseDatabaseWrapper.wrap_database_errorss $D))rGc"UR5$)z Return a cursor that tries to avoid caching in the database (if supported by the database), otherwise return a regular cursor. )rrNs rDchunked_cursor"BaseDatabaseWrapper.chunked_cursors {{}rGc.[R"X5$)z:Create a cursor that logs all queries in self.queries_log.)r CursorDebugWrapperrCrs rDr%BaseDatabaseWrapper.make_debug_cursors''55rGc.[R"X5$)z&Create a cursor without debug logging.)r CursorWrapperr<s rDrBaseDatabaseWrapper.make_cursors""600rGc## URSLnUR5nUv SSS5 U(aUR5 gg!,(df  N'=f!U(aUR5 ff=f7f)a Context manager that ensures that a connection is established, and if it opened one, closes it to avoid leaving a dangling connection. This is useful for operations outside of the request-response cycle. Provide a cursor: with self.temporary_connection() as cursor: ... N)rrr)rC must_closers rDtemporary_connection(BaseDatabaseWrapper.temporary_connections]__,  &   s1A6AAAA6 AAA33A6c## UR0URESS0E[S9nUR5nUv SSS5 UR 5 g!,(df  N=f!UR 5 f=f7f)aA Return a cursor from an alternative connection to be used when there is no need to access the main database, specifically for test db creation/deletion. This also prevents the production database from being exposed to potential child threads while (or after) the test database is destroyed. Refs #10868, #17786, #16969. NAMEN)r)rKr NO_DB_ALIASrr)rCconnrs rD _nodb_cursor BaseDatabaseWrapper._nodb_cursorsd~~B!3!3BVTB+~V &  JJL JJLs2%A<A'AA'A< A$ A''A99A<c^URc [S5eUR"U/UQ70UD6$)z7 Return a new instance of this backend's SchemaEditor. zFThe SchemaEditorClass attribute of this database wrapper is still None)SchemaEditorClassrq)rCargskwargss rD schema_editor!BaseDatabaseWrapper.schema_editors=  ! ! )%X %%d&M N$$&&,M  F!LL():):(;;PQ!%!sB C  #CC c6UR5 URn/UlU(a5URS5up#nU(a U"5 OU"5 U(aM4gg![a-n[R SUR S3USS9 SnAN=SnAff=f)NrrRz( in on_commit() during transaction (%s).TrS)rr4poprYrZr[rL)rCcurrent_run_on_commit_rrr\s rDr.BaseDatabaseWrapper.run_and_clear_commit_hookss %%' $ 2 2#377:OAVF$# !LL():):(;<,-!% !sA!! B+#BBc## URRU5 Sv URR5 g!URR5 f=f7f)zd Return a context manager under which the wrapper is applied to suitable database query executions. N)r6rWr`)rCwrappers rDexecute_wrapper#BaseDatabaseWrapper.execute_wrappersG $$W- (   ! ! % % 'D ! ! % % 'sA>AAAc[R"UR5nUc URn[ U5"X!5$)za Return a copy of this connection. For tests that require two connections to the same database. )copydeepcopyrrtype)rCrrs rDriBaseDatabaseWrapper.copys5  d&8&89 =JJEDz-//rG)r3r0r/rr$r r8r(r)r%rr:r*r6r<rr,r+r!r>r&r@rr'r5r4r#r"rrBrc)F)Y__name__ __module__rL__firstlineno____doc__ data_typesdata_types_suffixdata_type_check_constraintsr@rMr{rLr7r9r;r=r?r rArrrErOrSrrYr`propertyrermrrr~rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr rrrrrrrr#r'r*r.rr3rr8rrrCrIrOr]rrfri__static_attributes__rRrGrDrrs*J"$ C FLLNNI-M,<B6H FF, 3 399&& $  1   4 B 0 2 /::  ''*?A?K (  "$$!!  JO#?J#'% 2 2     &:22,, " **61   =2& ( ( 0rGr)+r1rirXloggingr-rrir[ collectionsr contextlibr django.confrdjango.core.exceptionsr django.dbrrr django.db.backendsr "django.db.backends.base.validationr django.db.backends.signalsr django.db.backends.utilsr django.db.transactionrdjango.db.utilsrrdjango.utils.asynciordjango.utils.functionalrrGrXr getLoggerrZrrRrGrDrsq  % 7HH$E96<B-3 u   4 5z 0z 0rG