,h]%SrSSKJr SSKrSSKrSSKJrJrJrJ r J r SSK J r J r SSKJr SSKJr SS KJr SS KJrJrJr SS KJrJrJr SS KJrJr SS KJ r SSK!J"r" SSK#J$r$ SSK%J&r& SSK'J(r(J)r)J*r*J+r+J,r, SSK-J.r. SSK/J0r0 SSK1J2r2 SSK3J4r4 SSK5J6r6 \(aSSK7J8r8 SSK9J:r:J;r; \,"S5r<\RzR|r>\RzR~r?\RRrA\RRrB\RRrD\RRrE\RRrF\RRrH\RRrI\2R"5rK\R"S5rM"SS\ 5rNS\NlO\\R/S4rQS\RS'\\N/S4rSS\RS'"S S!\ \"5rTg)"z psycopg connection objects ) annotationsN) TYPE_CHECKINGAnyCallableGeneric NamedTuple) ReferenceTyperef)warn)partial)errors) generatorspostgrespq)PQGen PQGenConnQuery)SQL Composable)Xid)Row) AdaptersMap)IsolationLevel)Deque LiteralStringSelf TypeAliasTypeVar)connection_summary)PrepareManager) capabilities) BasePipeline)ConnectionInfo)BasePool)PGconnPGresult 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__r2S/var/www/html/Ai_home/venv/lib/python3.13/site-packages/psycopg/_connection_base.pyr+r+:sB LI L3 HEr:r+r NoticeHandler NotifyHandlerc\rSrSrSr\R r\Rr\Rr\Rr \Rr \Rr \Rr \Rr \Rr\RrS;Sjr\4SSj5r\S>Sj5r\S>Sj5r\R0S?S j5rS?S jrS@S jr\SAS j5r\R0SBS j5rSBSjrSCSjr\SDSj5r\R0SESj5rSESjrSFSjr \SDSj5r!\!R0SESj5r!SESjr"SFSjr#SGSjr$\SHSj5r%\SISj5r&\SJSj5r'SKSjr(SLSjr)S>Sjr*SMSjr+SNS jr,SNS!jr-\.SOS"j5r/SPS#jr0SPS$jr1\.SQS%j5r2\SRS&j5r3\3R0SSS'j5r3\SRS(j5r4\4R0SSS)j5r4\5STS*S+.SUS,jjj5r6\74SVS-jjr8SWS.jr9SLS/jr:SXS0jr;SYS1jrSZS4jr?S[S5jr@SXS6jrAS\S7jrBSLS8jrCS9rDg:)]BaseConnectionMz Base class for different types of connections. Share common functionalities such as access to the wrapped PGconn, but allow different interfaces (sync/async). cXlSUlSUl/Ul/UlSUlSUl[5UlSUl [5Ul [U5n[[RU5Ul[[R"U5UlU SUlU SUlSUlSUlSUlg)NFrr:)pgconn _autocommit _adapters_notice_handlers_notify_handlers_num_transactions_closedr! _prepared_tpcr_notifies_backlogr r r?_notice_handlernotice_handler_notify_handlernotify_handler _pipeline_isolation_level _read_only _deferrable_begin_statement)selfrBwselfs r;__init__BaseConnection.__init__as  .25757"# )7)9-1 8=wD  '(F(F N '(F(F N .2 7;'+(, #r:c[US5(dgUR(ag[US5(agU"[RU5S3[5 g)NrB_poolz_ was deleted while still open. Please use 'with' or '.close()' to close the connection properly)hasattrclosedobject__repr__ResourceWarning)rU_BaseConnection__warns r;__del__BaseConnection.__del__sVtX&&  ;;  4 ! ! t$%&P P  r:cURRSURR3n[UR5nSUSUS[ U5SS3$)N.< z at 0xx>) __class__r4r5r rBid)rUclsinfos r;r^BaseConnection.__repr__sW**+1T^^-H-H,IJ!$++.3%qfRXaL22r:c<URR[:H$)z$`!True` if the connection is closed.)rBstatusBADrUs r;r\BaseConnection.closeds{{!!S((r:clURR[: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. )rBrorprHrqs r;brokenBaseConnection.brokens%{{!!S(=-==r:cUR$)z'The autocommit state of the connection.)rCrqs r; autocommitBaseConnection.autocommitsr:c&URU5 gN)_set_autocommitrUvalues r;rwrx U#r:c[erzNotImplementedErrorr|s r;r{BaseConnection._set_autocommit!!r:c#b# URS5ShvN [U5UlgN7f)Nrw)_check_intrans_genboolrCr|s r;_set_autocommit_gen"BaseConnection._set_autocommit_gens***<888; 9s /-/cUR$)zH The isolation level of the new transactions started on the connection. )rQrqs r;isolation_levelBaseConnection.isolation_levels $$$r:c&URU5 grz)_set_isolation_levelr|s r;rrs !!%(r:c[erzrr|s r;r#BaseConnection._set_isolation_levelrr:c#z# URS5ShvN Ub [U5OSUlSUlgN!7f)Nrr:)rrrQrTr|s r;_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. )rRrqs r; read_onlyBaseConnection.read_onlys r:c&URU5 grz)_set_read_onlyr|s r;rrs E"r:c[erzrr|s r;rBaseConnection._set_read_onlyrr:c#z# URS5ShvN Ub [U5OSUlSUlgN!7f)Nrr:)rrrRrTr|s r;_set_read_only_gen!BaseConnection._set_read_only_gens8**;777).):$u+ # 8rcUR$)zI The deferrable state of the new transactions started on the connection. )rSrqs r; deferrableBaseConnection.deferrables r:c&URU5 grz)_set_deferrabler|s r;rrr~r:c[erzrr|s r;rBaseConnection._set_deferrablerr:c#z# URS5ShvN Ub [U5OSUlSUlgN!7f)Nrr:)rrrSrTr|s r;_set_deferrable_gen"BaseConnection._set_deferrable_gens9**<888*/*;4; # 9rc## URR=n[: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 ) rBtransaction_statusIDLErP _sync_genrGeProgrammingErrorrTransactionStatusname)rU attributeros r;r!BaseConnection._check_intrans_genskk44 4F =$..~~//1 1 1[[33F T>%%((#I=1CC ((#I=18++F3889;  2sAC CB C c,[UR5$)z>A `ConnectionInfo` attribute to inspect connection properties.)r$rBrqs r;rlBaseConnection.info sdkk**r:cxUR(d[[R5UlUR$rz)rDrradaptersrqs r;rBaseConnection.adapterss%~~():):;DN~~r:cU$rzr2rqs r; connectionBaseConnection.connections  r:c.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. )rBsocketrqs r;filenoBaseConnection.filenos{{!!!r:cUR5(a+URR5nUR5 gg)z/Cancel the current operation on the connection.N)_should_cancelrB get_cancelcancel)rUcs r;rBaseConnection.cancel$s1     &&(A HHJ !r:cUR(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)r\rJrrrqs r;rBaseConnection._should_cancel*s: ;; 991$$O r:c## URR5nUR5 [R"X!S9ShvN gN7f)Ntimeout)rB cancel_connstartrr)rUrrs r; _cancel_genBaseConnection._cancel_gen9s7kk--/ $$[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)rEappendrUcallbacks r;add_notice_handler!BaseConnection.add_notice_handler> $$X.r:c:URRU5 g)z Unregister a notice message callable previously registered. :param callback: the callback to remove. :type callback: Callable[[~psycopg.errors.Diagnostic], None] N)rEremovers r;remove_notice_handler$BaseConnection.remove_notice_handlerGrr:c,U"5nU(aUR(dg[R"XRR5nURH nU"U5 M g![ a!n[ RSXE5 SnAM7SnAff=f)Nz)error processing notice callback '%s': %s)rEr DiagnosticrB _encoding Exceptionlogger exception)rVresrUdiagcbexs r;rLBaseConnection._notice_handlerPsvw.. ||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)rFrrs r;add_notify_handler!BaseConnection.add_notify_handler_rr:c:URRU5 g)z Unregister a notification callable previously registered. :param callback: the callback to remove. :type callback: Callable[[~psycopg.Notify], None] N)rFrrs r;remove_notify_handler$BaseConnection.remove_notify_handlerhrr:c|U"5=n(dgURRn[URR U5UR R U5UR 5nUR(aURH nU"U5 M gUR=nbURU5 ggrz) rBrr+relnamedecodeextrabe_pidrFrKr)rVpgnrUencnrds r;rNBaseConnection._notify_handlerqs kk## 3;;%%c*CII,<,> --+ C NN ( ( / / 4 NN ' ' . .t 4 D KK " "7 + KK ) )'4} ) U'1'9'9$++'FFK ==J &6==I+E}} +))&;;;P;PQQ&&(v}})E)J)J(K$W^^%5$8: GsEHHCHc#B# Ub [(d$UbSU-OSnURU5ShvN gUR5 UR(ak[ UR R U5nURRRU5 URRRS5 gUR R U5 [R"UR 5ShvN SnUR[:wa~UR[:Xa([R "X@R R"S9e[R$"S[&R("UR5R*S35egGNkN7f)a5 Deallocate one, or all, prepared statement in the session. ``name == None`` stands for DEALLOCATE ALL. If possible, use protocol-level commands; otherwise use SQL statements. Note that PgBouncer doesn't support DEALLOCATE name, but it supports protocol-level Close from 1.21 and DEALLOCATE ALL from 1.22. Ns DEALLOCATE sDEALLOCATE ALLrrr z0 from sending closing prepared statement message)_HAS_SEND_CLOSErr rPr rBsend_close_preparedrrrrrrorrrrrrrrr)rUrstmtrrs r; _deallocateBaseConnection._deallocates< <,0,<>D(BSD))$/ / /  !!# >>$++994@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_rfs READ ONLYs READ WRITEs DEFERRABLEsNOT DEFERRABLE ) rTrrrrreplacer rrjoin)rUpartsvals r;r+$BaseConnection._get_tx_start_command"s  (( (     + !5!56C LL+ , LL))#s3::< = >> % LL] K ?? & LL$//?P Q $ % 0$$$r:c## 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) rGrrrJrBrrrrPrrqs r; _commit_genBaseConnection._commit_gen6s  ! !$$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) rGrrrJrPrrBrrrrIclear maintain_genrqs r; _rollback_genBaseConnection._rollback_genJs  ! !$$A  99$$J  >>~~//1 1 1 ;; ) )T 1 %%k222 >>..t444 >>~~//1 1 1  2 34 2sHA=D6?D.7D67D08>~~//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 {}) lowerrJrrr rrGgetattrrrrLr-)rUactionrDfnamemeths r;_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.Nr2rqs r;r?BaseConnection._check_tpcs r:)rDrCrTrHrSrQrErKrFrGrPrIrRrJrBN)rBr&)r`rreturnNone)r[r-)r[r)r}rr[r\)r}rr[ PQGen[None])r[IsolationLevel | None)r}r^r[r\)r}r^r[r])r[ bool | None)r}r_r[r\)r}r_r[r])rr-r[r])r[r$)r[r)r[zBaseConnection[Row])r[r0)r[r\)rfloatr[zPQGenConn[None])rr<r[r\)rV"ReferenceType[BaseConnection[Row]]rr'r[r\)rr=r[r\)rVrarz pq.PGnotifyr[r\)r[ int | None)r}rbr[r\))rr-rr`r[zPQGenConn[Self])rrrz pq.Formatr[zPQGen[PGresult | None])rz bytes | Noner[r])r[r])r[bytes)rAr0rBr-rCr-r[r)rDz Xid | strr[r])rTrrDzXid | str | Noner[r])Er3r4r5r6r7rWarningErrorr DatabaseError DataErrorr(IntegrityError InternalErrorrNotSupportedErrorrWr rar^propertyr\rtrwsetterr{rrrrrrrrrrrrlrrrrrrrr staticmethodrLrrrNrr classmethodrrrr$r r,r+r7r<rDrIrMrWr?r9r2r:r;r?r?Ms[iiG GGE%%NOOM I))%%NOOM))++%$N%) &3 ))>>  $$"'%% ))"$  ##"$   $$"$ $++ " C // V1 V8@ V  V V//18C " 0 01111,,58-2 :>,,-6, ,\"H   2%(2(26 7D( 2#*: > r:r?)Ur7 __future__rrloggingtypingrrrrrweakrefr r warningsr functoolsr rcrrrrrabcrrrsqlrrrJrrowsradaptr_enumsr_compatrrrrrpq.miscr _preparingr! _capabilitiesr"_pipeline_baser#_connection_infor$psycopg_pool.baser%pq.abcr&r'r(FormatrBINARY ConnStatusr'rprrrrrrINTRANShas_send_close_preparedr! getLoggerrr+r4rr<r8r=r?r2r:r;rsl # DD&&&(( "CC'&'(,*( K  yy~~   ]]mm ]] % % MM # # mm''       & &668   9 % FZ F#Q\\ND$89 y9#VHdN3 y3j  WS\j  r: