(ph\%SrSSKJr SSKrSSKrSSKJrJrJrJ r SSK J r J r SSK Jr SSKJr SS KJr SS KJr SS KJr SS KJr SS KJrJrJr SSKJrJr SSKJr SSK J!r! SSK"J#r# SSK$J%r% SSK&J'r'J(r(J)r)J*r* SSK+J,r, SSK-J.r. SSK/J0r0 SSK1J2r2 SSK3J4r4 \ (aSSK5J6r6J7r7 SSK8J9r9 \*"S5r:\RvRxr<\RvRzr=\R|R~r?\R|Rr@\RRrB\RRrC\RRrD\RRrF\RRrG\2R"5rI\R"S5rK"SS\5rLS\LlM\\R/S4rOS\PS '\\L/S4rQS\PS!'"S"S#\\!5rRg)$z psycopg connection objects ) annotationsN)CallableGeneric NamedTuple TYPE_CHECKING)ref ReferenceType)warn)partial)pq)errors)postgres) generators)PQGen PQGenConnQuery) ComposableSQL)Xid)Row) AdaptersMap)IsolationLevel) LiteralStringSelf TypeAliasTypeVar)connection_summary) BasePipeline)PrepareManager) capabilities)ConnectionInfo)PGconnPGresult)BasePool CursorRowpsycopgc<\rSrSr%SrS\S'S\S'S\S'Srg ) Notify;z8An asynchronous notification received from the database.strchannelpayloadintpidN)__name__ __module__ __qualname____firstlineno____doc____annotations____static_attributes__r0K/var/www/html/venv/lib/python3.13/site-packages/psycopg/_connection_base.pyr)r);sB LI L3 HEr8r)r NoticeHandler NotifyHandlerc\rSrSrSr\R r\Rr\Rr\Rr \Rr \Rr \Rr \Rr \Rr\RrS;SjrSSj5r\S>Sj5r\S>Sj5r\R.S?S j5rS?S jrS@S jr\SAS j5r\R.SBS j5rSBSjrSCSjr\SDSj5r\R.SESj5rSESjrSFSjr\SDSj5r \ R.SESj5r SESjr!SFSjr"SGSjr#\SHSj5r$\SISj5r%\SJSj5r&SKSjr'SSjr)SLSjr*SMS jr+SMS!jr,\-SNS"j5r.SOS#jr/SOS$jr0\-SPS%j5r1\SQS&j5r2\2R.SRS'j5r2\SQS(j5r3\3R.SRS)j5r3\4SSS*S+.STS,jjj5r5\64SUS-jjr7SVS.jr8SSZS5jr?SWS6jr@S[S7jrAS) __class__r2r3rr@id)rRclsinfos r9__repr__BaseConnection.__repr__sW**+1T^^-H-H,IJ!$++.3%qfRXaL22r8c<URR[:H$)z$`!True` if the connection is closed.)r@statusBADr[s r9rYBaseConnection.closeds{{!!S((r8clURR[:H=(a UR(+$)z `!True` if the connection was interrupted. A broken connection is always `closed`, but wasn't closed in a clean way, such as using `close()` or a `!with` block. )r@rkrlrFr[s r9brokenBaseConnection.brokens%{{!!S(=-==r8cUR$)z'The autocommit state of the connection.)rAr[s r9 autocommitBaseConnection.autocommitsr8c&URU5 gN)_set_autocommitrRvalues r9rrrs U#r8c[eruNotImplementedErrorrws r9rvBaseConnection._set_autocommit!!r8c#b# URS5ShvN [U5UlgN7f)Nrr)_check_intrans_genboolrArws r9_set_autocommit_gen"BaseConnection._set_autocommit_gens***<888; 9s /-/cUR$)zH The isolation level of the new transactions started on the connection. )rNr[s r9isolation_levelBaseConnection.isolation_levels $$$r8c&URU5 gru)_set_isolation_levelrws r9rrs !!%(r8c[erur{rws r9r#BaseConnection._set_isolation_levelr~r8c#z# URS5ShvN Ub [U5OSUlSUlgN!7f)Nrr8)rrrNrQrws r9_set_isolation_level_gen'BaseConnection._set_isolation_level_gens<**+<===9>9Ju 5PT # > ;9";cUR$)zH The read-only state of the new transactions started on the connection. )rOr[s r9 read_onlyBaseConnection.read_onlys r8c&URU5 gru)_set_read_onlyrws r9rrs E"r8c[erur{rws r9rBaseConnection._set_read_onlyr~r8c#z# URS5ShvN Ub [U5OSUlSUlgN!7f)Nrr8)rrrOrQrws r9_set_read_only_gen!BaseConnection._set_read_only_gens8**;777).):$u+ # 8rcUR$)zI The deferrable state of the new transactions started on the connection. )rPr[s r9 deferrableBaseConnection.deferrables r8c&URU5 gru)_set_deferrablerws r9rrryr8c[erur{rws r9rBaseConnection._set_deferrabler~r8c#z# URS5ShvN Ub [U5OSUlSUlgN!7f)Nrr8)rrrPrQrws r9_set_deferrable_gen"BaseConnection._set_deferrable_gens9**<888*/*;4; # 9rc## URRnU[:XaIUR(a8URR 5ShvN URRnU[:wagUR (a[ R"SU<S35e[ R"SU<S[R"U5R35egN7f)Nz can't change z2 now: connection.transaction() context in progressz' now: connection in transaction status ) r@transaction_statusIDLErM _sync_genrEeProgrammingErrorr TransactionStatusname)rR attributerks r9r!BaseConnection._check_intrans_gens// T>dnn~~//1 1 1[[33F T>%%((#I=1CC ((#I=18++F3889;  2sAC CB C c,[UR5$)z>A `ConnectionInfo` attribute to inspect connection properties.)r"r@r[s r9rgBaseConnection.infosdkk**r8cxUR(d[[R5UlUR$ru)rBrradaptersr[s r9rBaseConnection.adapters s%~~():):;DN~~r8cU$rur0r[s r9 connectionBaseConnection.connections  r8c.URR$)zReturn the file descriptor of the connection. This function allows to use the connection as file-like object in functions waiting for readiness, such as the ones defined in the `selectors` module. )r@socketr[s r9filenoBaseConnection.filenos{{!!!r8cUR5(a+URR5nUR5 gg)z/Cancel the current operation on the connection.N)_should_cancelr@ get_cancelcancel)rRcs r9rBaseConnection.cancel"s1     &&(A HHJ !r8cUR(agUR(a*URS(a[R"S5eg)zXCheck whether the current command should actually be cancelled when invoking cancel*(). Fr z=cancel() cannot be used with a prepared two-phase transactionT)rYrHrrr[s r9rBaseConnection._should_cancel(s: ;; 991$$O r8c## URR5nUR5 [R"X!S9ShvN gN7f)Ntimeout)r@ cancel_connstartrr)rRrrs r9 _cancel_genBaseConnection._cancel_gen7s7kk--/ $$[BBBsAA A A c:URRU5 g)z Register a callable to be invoked when a notice message is received. :param callback: the callback to call upon message received. :type callback: Callable[[~psycopg.errors.Diagnostic], None] N)rCappendrRcallbacks r9add_notice_handler!BaseConnection.add_notice_handler< $$X.r8c:URRU5 g)z Unregister a notice message callable previously registered. :param callback: the callback to remove. :type callback: Callable[[~psycopg.errors.Diagnostic], None] N)rCremovers r9remove_notice_handler$BaseConnection.remove_notice_handlerErr8c,U"5nU(aUR(dg[R"XRR5nURH nU"U5 M g![ a!n[ RSXE5 SnAM7SnAff=f)Nz)error processing notice callback '%s': %s)rCr Diagnosticr@ _encoding Exceptionlogger exception)rSresrRdiagcbexs r9rIBaseConnection._notice_handlerNsvw.. ||C!6!67''B V4( V  !LbUU VsA(( B2BBc:URRU5 g)z Register a callable to be invoked whenever a notification is received. :param callback: the callback to call upon notification received. :type callback: Callable[[~psycopg.Notify], None] N)rDrrs r9add_notify_handler!BaseConnection.add_notify_handler]rr8c:URRU5 g)z Unregister a notification callable previously registered. :param callback: the callback to remove. :type callback: Callable[[~psycopg.Notify], None] N)rDrrs r9remove_notify_handler$BaseConnection.remove_notify_handlerfrr8c8U"5nU(aUR(dgURRn[URR U5UR R U5UR5nURH nU"U5 M gru)rDr@rr)relnamedecodeextrabe_pid)rSpgnrRencnrs r9rKBaseConnection._notify_handlerosow.. kk## 3;;%%c*CII,<,> --+ C NN ( ( / / 4 NN ' ' . .t 4 D KK " "7 + KK ) )'4} ) U'// <D(BSD))$/ / /  !!# >> //C NN ( ( / / 4 NN ' ' . .t 4  ''-'// <>~~//1 1 1  D 1s$ABB2B B BBc"UR(a UR$S/nURb_[UR5nURS5 URURR SS5R 55 URb$URUR(aSOS5 URb$URUR(aSOS5 S RU5UlUR$) NsBEGINsISOLATION LEVEL_ras READ ONLYs READ WRITEs DEFERRABLEsNOT DEFERRABLE ) rQrrrrreplacerrrjoin)rRpartsvals r9r%$BaseConnection._get_tx_start_commands  (( (     + !5!56C LL+ , LL))#s3::< = >> % LL] K ?? & LL$//?P Q $ % 0$$$r8c## UR(a[R"S5eUR(a[R"S5eURR [ :XagURS5ShvN UR(a#URR5ShvN ggN9N7f)z-Generator implementing `Connection.commit()`.zExplicit commit() forbidden within a Transaction context. (Transaction will be automatically committed on successful exit from context.)z6commit() cannot be used during a two-phase transactionNsCOMMIT) rErrrHr@rrrrMrr[s r9 _commit_genBaseConnection._commit_gen2s  ! !$$4  99$$H  ;; ) )T 1 %%i000 >>~~//1 1 1  1 2s$BCB>2C7C8CCc#p# UR(a[R"S5eUR(a[R"S5eUR(a"URR 5ShvN UR R[:XagURS5ShvN URR5 URRU5ShvN UR(a#URR 5ShvN ggNNxN=N 7f)z/Generator implementing `Connection.rollback()`.zExplicit rollback() forbidden within a Transaction context. (Either raise Rollback() or allow an exception to propagate out of the context.)z8rollback() cannot be used during a two-phase transactionNsROLLBACK) rErrrHrMrr@rrrrGclear maintain_genr[s r9 _rollback_genBaseConnection._rollback_genFs  ! !$$A  99$$J  >>~~//1 1 1 ;; ) )T 1 %%k222 >>..t444 >>~~//1 1 1  2 34 2sHA=D6?D.7D67D08s r9_tpc_begin_genBaseConnection._tpc_begin_genns #s##//#&C ;; ) )T 1$$(()G)GHMMNP    $$E %L %%d&@&@&BCCCsC7D9C?:Dc## UR(d[R"S5eURS(a[R"S5eURSnUS4UlUR[ S5R [ U555ShvN UR(a#URR5ShvN ggN9N7f)Nz='tpc_prepare()' must be called inside a two-phase transactionr zF'tpc_prepare()' cannot be used during a prepared two-phase transactionrTzPREPARE TRANSACTION {}) rHrrrrformatr+rMrrBs r9_tpc_prepare_genBaseConnection._tpc_prepare_gensyy$$O  99Q<$$X iil$K %%c*B&C&J&J3s8&TUUU >>~~//1 1 1  V 1s$BC!C"2CCCCc## SUR5S3nUc:UR(d[R"US35eURSnOUUR(a[R"US35e[ U[ 5(d[ R "U5nUR(aIURS(d5[USUR5S35nSUlU"5ShvN gUR[S 5R[U5[U555ShvN SUlgNQN7f) Ntpc_z()z? without xid must must be called inside a two-phase transactionrz= with xid must must be called outside a two-phase transactionr r)_genz{} PREPARED {}) lowerrHrrrrrAgetattrrrrFr+)rRactionr>fnamemeths r9_tpc_finish_genBaseConnection._tpc_finish_gens'v||~&b) ;99((g==))A,Cyy((g77c3''ooc* 99TYYq\41V\\^$4D!9:DDIv  ))$%,,S[#c(C  DI  s%C;E=E>AEE EEcg)z0Raise NotSupportedError if TPC is not supported.Nr0r[s r9r9BaseConnection._check_tpcs r8)rBrArQrFrPrNrCrDrErMrGrOrHr@N)r@r#)returnNone)rUr+)rUr)rxrrUrV)rxrrU PQGen[None])rUIsolationLevel | None)rxrXrUrV)rxrXrUrW)rU bool | None)rxrYrUrV)rxrYrUrW)rr+rUrW)rUr")rUr)rUzBaseConnection[Row])rUr.)rfloatrUzPQGenConn[None])rr:rUrV)rS"ReferenceType[BaseConnection[Row]]rr$rUrV)rr;rUrV)rSr[rz pq.PGnotifyrUrV)rU int | None)rxr\rUrV))rr+rrZrUzPQGenConn[Self])rrrz pq.FormatrUzPQGen[PGresult | None])rz bytes | NonerUrW)rUrW)rUbytes)r;r.r<r+r=r+rUr)r>z Xid | strrUrW)rNrr>zXid | str | NonerUrW)Dr1r2r3r4r5rWarningErrorr DatabaseError DataErrorr"IntegrityError InternalErrorrNotSupportedErrorrTr\rhpropertyrYrorrsetterrvrrrrrrrrrrrrgrrrrrrrr staticmethodrIrrrKrr classmethodrr rrrr&r%r1r6r>rCrGrQr9r7r0r8r9r=r=NsViiG GGE%%NOOM I))%%NOOM))++!$F &3 ))>>  $$"'%% ))"$  ##"$   $$"$ &++ " C // V1 V8@ V  V V// 1 8C     0 01111,,58-2 :>,,-6, ,\%N   2%(2(26 7D( 2#*: > r8r=)Sr5 __future__rrloggingtypingrrrrweakrefrr warningsr functoolsr r]r rrrrabcrrrsqlrrrHrrowsradaptr_enumsr_compatrrrrpq.miscrrMr _preparingr _capabilitiesr!_connection_infor"pq.abcr#r$psycopg_pool.baser%r&Formatr BINARY ConnStatusr!rlrrrrrrINTRANShas_send_close_preparedr getLoggerrr)r2rr:r6r;r=r0r8r9rso # ??&(( "<<'#&',(* K  yy~~   ]]mm ]] % % MM # # mm''       & &668   9 % FZ F#Q\\ND$89 y9#VHdN3 y3e  WS\e  r8