R jo^SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSK J r SSK J r SSK r SSKJr SSKJr SSKJrJrJr SS KJr SS KJr SS KJr SS KJr SS K J!r! SSK"J#r# SSK$J%r% Sr&\'"5q(\RR"S5r*Sr+"SS5r,g!\a SSKJ r Nwf=f)N)deque)contextmanager)debug_transaction)zoneinfo)settings)ImproperlyConfigured)DEFAULT_DB_ALIAS DatabaseErrorNotSupportedError)utils)BaseDatabaseValidation)connection_created)TransactionManagementErrorDatabaseErrorWrapper) async_unsafe)cached_property __no_db__zdjango.db.backends.basec[R(aSSKnURU5$[R "U5$Nr)rUSE_DEPRECATED_PYTZpytztimezonerZoneInfo)tznamers HD:\diplom_project\venv\Lib\site-packages\django/db/backends/base/base.pytimezone_constructorr$s.##}}V$$   V $$c\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)HBaseDatabaseWrapper,z 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)selfr&r's r__init__BaseDatabaseWrapper.__init__CsT+  (:(:;"'  $ #$  %*"$$)!!&%.NN$4!%&"$..0  6;2 !#''- ++D1 ++D1 !55d;>>$'//5rcnSURRSUR<SUR<S3$)N) __class__ __qualname__vendorr'rNs r__repr__BaseDatabaseWrapper.__repr__s8++,-kk_GDJJ> < rcg)zg Ensure the connection's timezone is set to `self.timezone_name` and return whether it changed or not. FrWs rensure_timezone#BaseDatabaseWrapper.ensure_timezones rc[R(dgURSc[RR $[ 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_TZr&datetimerutcrrWs rrBaseDatabaseWrapper.timezonesG     , 4$$(( ('(:(:;(GH Hrc[R(d[R$URScgURS$)z3 Name of the time zone of the database connection. r_UTC)rr`r_r&rWs r timezone_name!BaseDatabaseWrapper.timezone_names< %% %    , 4%%k2 2rcHUR=(d [R$N)r*rDEBUGrWs rqueries_logged"BaseDatabaseWrapper.queries_loggeds&&8(..8rc[UR5URR:Xa9[R"SR URR55 [ UR5$)NzLLimit for query logging exceeded, only the last {} queries will be returned.)lenr)r$warningswarnformatlistrWs rqueriesBaseDatabaseWrapper.queriess[ t D$4$4$;$; ; MM$$*F4+;+;+B+B$C D$$%%rc[S5e)z)Return a tuple of the database's version.zNsubclasses of BaseDatabaseWrapper may require a get_database_version() method.NotImplementedErrorrWs rget_database_version(BaseDatabaseWrapper.get_database_versions!   rcURRbUR5URR: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).)rGminimum_database_versionrxjoinmapstrr display_name)rN db_versionmin_db_versions r 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 ?rc[S5e)zConnect to the database. Assume that the connection is closed.FCONN_HEALTH_CHECKS CONN_MAX_AGENT AUTOCOMMIT)senderr%)check_settingsr,r.r/r1r&r6time monotonicr3r4r5r7rrr%set_autocommitrrsendrTr?)rNmax_agers rconnectBaseDatabaseWrapper.connects $#$($6$67K$L!$$^4 'T^^5E5O %*"$!%002 11+> D..|<= ""$t~~$GrcURSb.[R(d[SUR-5egg)Nr_z=Connection '%s' cannot set TIME_ZONE because USE_TZ is False.)r&rr`rr'rWs rr"BaseDatabaseWrapper.check_settingss?   k * 6x&O** @O 6rcURc&UR UR5 SSS5 gg!,(df  g=f)z;Guarantee that a connection to the database is established.N)r%wrap_database_errorsrrWs rensure_connection%BaseDatabaseWrapper.ensure_connections4 ?? "** +* #**s 5 AcUR5 UR(aURU5nU$URU5nU$)zI Validate the connection is usable and perform database cursor wrapping. )validate_thread_sharingrkmake_debug_cursor make_cursor)rNcursorwrapped_cursors r_prepare_cursor#BaseDatabaseWrapper._prepare_cursor%sI $$&   !33F;N"--f5NrcUR5 UR5 UR URUR U55sSSS5 $!,(df  g=fri)close_if_health_check_failedrrrrrs r_cursorBaseDatabaseWrapper._cursor0sH ))+   & &''(:(:4(@A' & &s A A%cURbF[US5 UR URR5sSSS5 sSSS5 $g!,(df  O=fSSS5 g!,(df  g=f)NCOMMIT)r%rrcommitrWs r_commitBaseDatabaseWrapper._commit6sS ?? &"42D4M4M--/5N4M22 '4M4M222" A/A A/ A# A// A=cURbF[US5 UR URR5sSSS5 sSSS5 $g!,(df  O=fSSS5 g!,(df  g=f)NROLLBACK)r%rrrollbackrWs r _rollbackBaseDatabaseWrapper._rollback;sS ?? &"44d6O6O//17P6O44 '6O6O444rcURb0UR URR5sSSS5 $g!,(df  g=fri)r%rcloserWs r_closeBaseDatabaseWrapper._close@s9 ?? &**,,.+* '**s ? A c"UR5$)z3Create a cursor, opening a connection if necessary.)rrWs rrBaseDatabaseWrapper.cursorGs||~rcUR5 UR5 UR5 SUlSUlg)z.Commit a transaction and reset the dirty flag.FTN)rvalidate_no_atomic_blockrr5r@rWs rrBaseDatabaseWrapper.commitLs5 $$& %%' $592rcUR5 UR5 UR5 SUlSUl/Ulg)z1Roll back a transaction and reset the dirty flag.FN)rrrr5r1r?rWs rrBaseDatabaseWrapper.rollbackVs> $$& %%' $#rc8UR5 /UlUR(d URcgUR 5 UR (aSUlSUlgSUlg!UR (aSUlSUlfSUlf=f)z%Close the connection to the database.NT)rr?r4r%rr,r1rWs rrBaseDatabaseWrapper.closeas $$&  % %)@  ' KKM##-1*&*#"& ##-1*&*#"&s A00)BcUR5nURURRU55 SSS5 g!,(df  g=fri)rexecuterKsavepoint_create_sqlrNsidrs r _savepointBaseDatabaseWrapper._savepointw2 [[]f NN48888= >]] +A AcUR5nURURRU55 SSS5 g!,(df  g=fri)rrrKsavepoint_rollback_sqlrs r_savepoint_rollback'BaseDatabaseWrapper._savepoint_rollback{s2 [[]f NN488::3? @]]rcUR5nURURRU55 SSS5 g!,(df  g=fri)rrrKsavepoint_commit_sqlrs r_savepoint_commit%BaseDatabaseWrapper._savepoint_commitrrcfURR=(a UR5(+$ri)rGuses_savepointsget_autocommitrWs r_savepoint_allowed&BaseDatabaseWrapper._savepoint_alloweds#}},,JT5H5H5J1JJrcUR5(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)rr<r=rreplacer-rr)rN thread_identtidrs r savepointBaseDatabaseWrapper.savepoints|&&(( ((* ,''R0 !3 4 455 $$&  rcUR5(dgUR5 URU5 URVVVs/sHup#nX;dM X#U4PM snnnUlgs snnnf)zG Roll back to a savepoint. Do nothing if savepoints are not supported. N)rrrr?)rNrsidsfuncrobusts rsavepoint_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)rNrs rsavepoint_commit$BaseDatabaseWrapper.savepoint_commits0 &&((  $$& s#rcSUlg)zI Reset the counter used to generate unique savepoint ids in this thread. rN)r-rWs rclean_savepoints$BaseDatabaseWrapper.clean_savepointss !rc[S5e)zB Backend-specific implementation to enable or disable autocommit. zHsubclasses of BaseDatabaseWrapper may require a _set_autocommit() methodrv)rNr+s r_set_autocommit#BaseDatabaseWrapper._set_autocommits" V  rc:UR5 UR$)zGet the autocommit state.)rr+rWs rr"BaseDatabaseWrapper.get_autocommits  rcUR5 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) rrrhasattrrrrr+r@run_and_clear_commit_hooks)rNr+.force_begin_transaction_with_broken_autocommit"start_transaction_under_autocommits rr"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(% 'rcnUR URS:sSSS5 $!,(df  g=frr:r;rWs rallow_thread_sharing(BaseDatabaseWrapper.allow_thread_sharingvs%  & &--1' & &s& 4czUR U=RS- slSSS5 g!,(df  g=f)Nrr,rWs rinc_thread_sharing&BaseDatabaseWrapper.inc_thread_sharing{s(  & &  & &! + &' & &s, :cUR URS::a [S5eU=RS-slSSS5 g!,(df  g=f)Nrz5Cannot decrement the thread sharing count below zero.r)r:r; RuntimeErrorrWs rdec_thread_sharing&BaseDatabaseWrapper.dec_thread_sharingsH  & &))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 r{N)r-r>r<r=r r'rWs rr+BaseDatabaseWrapper.validate_thread_sharings[))T-?-?7CTCTCV-V$(::t/A/A7CTCTCVX .W)rcg)zf Hook to do any database check or preparation, generally called before migrating a project or an app. Nr[rWs rprepare_database$BaseDatabaseWrapper.prepare_databaserrc[U5$)zs Context manager and decorator that re-throws backend-specific database exceptions using Django's common wrappers. rrWs rr(BaseDatabaseWrapper.wrap_database_errorss $D))rc"UR5$)z Return a cursor that tries to avoid caching in the database (if supported by the database), otherwise return a regular cursor. )rrWs rchunked_cursor"BaseDatabaseWrapper.chunked_cursors {{}rc.[R"X5$)z:Create a cursor that logs all queries in self.queries_log.)r CursorDebugWrapperrNrs rr%BaseDatabaseWrapper.make_debug_cursors''55rc.[R"X5$)z&Create a cursor without debug logging.)r CursorWrapperrBs rrBaseDatabaseWrapper.make_cursors""600rc## 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)r%rr)rN must_closers rtemporary_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')rTr& NO_DB_ALIASrr)rNconnrs r _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)SchemaEditorClassrw)rNargskwargss r 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)NrrXz( in on_commit() during transaction (%s).TrY)rr?popr_r`rarU)rNcurrent_run_on_commit_rrrbs rr.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)rAr]rf)rNwrappers rexecute_wrapper#BaseDatabaseWrapper.execute_wrapper sG $$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. )copydeepcopyr&r'type)rNr'r&s rroBaseDatabaseWrapper.copys5  d&8&89 =JJEDz-//r)r>r;r:r'r/r+rCr3r4r0r%rEr5rArGr*r7r6r,rIr1rKr)r2r@r?r.r-r&rMri)F)Y__name__ __module__rU__firstlineno____doc__ data_typesdata_types_suffixdata_type_check_constraintsrKrVrrRrBrDrFrHrJr rLr(r rOrXr\rrrfpropertyrkrsrxrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr r rrrrrrr!r$rr)r-r0r4rr9rr>rrrIrOrUrcrrlro__static_attributes__r[rrr r ,s*J"$ C FLLNNI-M,<B6H II, 3 399&& $  1   4 B 0 2 /::  ''*?A?K (  "$$!!  JO#?J#'% 2 2     &:22,, " **61   =2& ( ( 0rr )-r<roraloggingr8rro collectionsr contextlibrdjango.db.backends.utilsrr ImportError backports django.confrdjango.core.exceptionsr django.dbr r r django.db.backendsr "django.db.backends.base.validationr django.db.backends.signalsrdjango.db.transactionrdjango.db.utilsrdjango.utils.asynciordjango.utils.functionalrrMr^r getLoggerr`rr r[rrrs  %6#!7HH$E9<0-3 u   4 5%v 0v 0;#"#sB B,+B,