]jLSrSSKJr SSKrSSKrSSKJr SSKJr SSK J r J r J r J r SSKJr SSKJrJr S S KJr S S KJrJr S S KJrJrJrJrJrJrJr S S KJ r S SK!J"r" S SK#J$r$J%r%J&r&J'r' S SK(J)r) S SK*J+r+ S SK,J-r- S SK.J/r/J0r0 S SK1J2r2 S SK3J4r4J5r5J6r6 S SK3J7r7 S SK8J9r9 S SK:J;r; S SKJ?r? S SK@JArA S SKBJCrC S SKDJErEJFrFJGrG \ (aS SKHJIrI SrJ\RRrL\RRrM\RRrO\RRrP\RRrQ\RrS\R"S 5rU"S!S"\E\$5rVg)#z* Psycopg connection object (sync version) ) annotationsN) monotonic) TracebackType) TYPE_CHECKINGAnycastoverload)contextmanager) GeneratorIterator)errors)pqwaiting)RV AdaptContextConnDict ConnParamParamsPQGenQuery)QueryNoTemplate)Xid)Row RowFactoryargs_row tuple_row) AdaptersMap)IsolationLevel)Cursor)SelfTemplate)Lock)conninfo_attemptsconninfo_to_dict make_conninfo)timeout_from_conninfo)Pipeline)notifies) Transaction) capabilities) ServerCursor)gssapi_requested)BaseConnection CursorRowNotify)PGconng?psycopgc^\rSrSr%SrSrS\S'S\S'S\S 'S \S '\"\\\ 54S=U4S jjjr \ S>S SSSSS.S?Sjjj5r S@Sjr SASjr\ SBSj5rSCSjr\S S.SDSjj5r\S S.SESjj5r\S SS S.SFSjj5r\S SS S.SGSjj5rS>S SSS S.SHSjjjr\SISS S.SJSjjj5r\SS S.SKS jj5rSISS S.SLS!jjjrSCS"jrSCS#jrS$S%.SMS&jjrS'S%.SMS(jjr\SNSOS)jj5rSSS*.SPS+jjr\SQS,j5r\SQS-j5r\4SRS.jjrSSS/jrSSS0jr STS1jr!STS2jr"SUS3jr#SUS4jr$SUS5jr%SUS6jr&SVS7jr'SCS8jr(SISWS9jjr)SISWS:jjr*SXS;jr+S[TU]U5 X l[5Ul[ Ul[UlgN) super__init__r9r#lockr r6r,r7)selfpgconnr9 __class__s O/home/mande/repo/quber/.venv/lib/python3.13/site-packages/psycopg/connection.pyr>Connection.__init__Fs1  &F $%1"FN) autocommitprepare_thresholdcontextr9r6c :UR"U40UD6n[U5n Sn [U5n /n U Hn U RS5U RS5U RS54nSU-n[R SU5 [ S0U D6nURXS9n[R"U[S9n [R S U5 O U (dU S S n[#U 5S :XaUR!S5e[U5/nURS5 UR%SU 55 ['U5"SR)U5UR*S9nUR!S5e[,R."5(aFU R*R0(a+[3U5(d6"S[85 [;U5U lU(aXZlU(aXjl U(a[CURD5U l#X:l$U $![Ra?n[R S U[U55 U RUU45 SnAGM=SnAf[RanUR!S5eSnAff=f)zF Connect to a database server and return a new `Connection` instance. Nhostporthostaddrz host: %r, port: %r, hostaddr: %rzconnection attempt: %stimeoutintervalzconnection succeeded: %szconnection failed: %s: %srr z7Multiple connection attempts failed. All failures were:c36# UHupSUSU3v M g7f)z- z: N).0errordescrs rC %Connection.connect..sPKLEBugRw/Ks )rAauthe connection was obtained using the GSSAPI relying on the 'gssencmode=prefer' libpq default. The value for this default might be 'disable' instead, in certain psycopg[binary] implementations. If you wish to interact with the GSSAPI reliably please set the 'gssencmode' parameter in the connection string or the 'PGGSSENCMODE' environment variable to 'prefer' or 'require')%_get_connection_paramsr'r$getloggerdebugr& _connect_genr wait_conn_WAIT_INTERVALeErrorstrappend _NO_TRACEBACKwith_tracebacklenextendtypejoinrAr+has_used_gssapi used_gssapir-warningswarnRuntimeWarningbool _autocommitr9r6radapters _adaptersrH)clsconninforGrHrIr9r6kwargsparamsrOrvattempts conn_errorsattempttdescrrWgenexlast_exlinesnew_exs rCconnectConnection.connectQs3 ++H??'/ $V,13 Gkk&)7;;v+> J@WXF6?E LL15 9 (7w7&&x&A&&s^D 7? "!"oa(G;1$,,T22\NE LLR S LLPKP Q']499U#3GNNKF''- -  ( ( * * %%%f-- MMH  j) (N  .  &w'7'78BL0 Q77 0 8%RI""B;//?? .''-- .s$3HJ33I--JJJcU$r<rTr@s rC __enter__Connection.__enter__s rEcUR(agU(aUR5 OUR 5 [ USS5(dUR5 gg![a n[R SX5 SnANISnAff=f)Nz#error ignored in rollback on %s: %s_pool)closedrollback Exceptionr_warningcommitgetattrclose)r@exc_typeexc_valexc_tbexc2s rC__exit__Connection.__exit__sp ;;   R  KKMtWd++ JJL,  RDdQQ RsA B *BB c [U40UD6$)z3Manipulate connection parameters before connecting.)r%)rwrxrys rCr]!Connection._get_connection_paramss 3F33rEcUR(ag[USS5nU(a$[USS5(aURU5 gSUlURR 5 g)zClose the database connection.Nr close_returnsFT)rrputconn_closedrAfinish)r@pools rCrConnection.closesS ;; tWd+ GD/599 LL    rE)binarycgr<rT)r@rs rCcursorConnection.cursors>ArEcgr<rT)r@rr9s rCrrs rE)r scrollablewithholdcgr<rT)r@namerrrs rCrrs rEcgr<rT)r@rrr9rrs rCrrs#&rE)rr9rrcUR5 U(d URnU(aURUUUUUS9nOURXS9nU(a [UlU$)zG Return a new `Cursor` to send commands and queries to the connection. )rr9rrr9)_check_connection_okr9r7r6BINARYformat)r@rrr9rrcurs rCrrsk !!#**K ,,'%! -C%%d%DC CJ rE)preparercgr<rT)r@queryrzrrs rCexecuteConnection.executesrEcgr<rT)r@rrrs rCrrsrEc&UR5nU(a [Ul[U[5(aUb [ S5eUR XS9$UR XUS9$![RanURS5eSnAff=f)z8Execute a query and return a cursor to read its results.NzA'execute()' with string template query doesn't support parameters)r) rrr isinstancer" TypeErrorrrdrhri)r@rrzrrrrs rCrrs *++-C# %**%#[{{5{::{{5'{BB *##D) ) *sAA&A&&B:B  BcUR URUR55 SSS5 g!,(df  g=f)z/Commit any pending transaction to the database.N)r?wait _commit_genrs rCrConnection.commit.s( YY IId&&( )YY 6 AcUR URUR55 SSS5 g!,(df  g=f)z2Roll back to the start of any pending transaction.N)r?r _rollback_genrs rCrConnection.rollback3s( YY IId((* +YYrg>@rNcUR5(dg[R"5(a'[R"UR US9[ S9 gUR5 g)akCancel the current operation on the connection. :param timeout: raise a `~errors.CancellationTimeout` if the cancellation request does not succeed within `timeout` seconds. Note that a successful cancel attempt on the client is not a guarantee that the server will successfully manage to cancel the operation. This is a non-blocking version of `~Connection.cancel()` which leverages a more secure and improved cancellation feature of the libpq, which is only available from version 17. If the underlying libpq is older than version 17, the method will fall back to using the same implementation of `!cancel()`. NrNrP)_should_cancelr+has_cancel_saferrb _cancel_genrccancel)r@rOs rC cancel_safeConnection.cancel_safe8sQ ""$$   ' ' ) )      1N  KKMrE@c~URUS9 g![a n[RSU5 SnAgSnAff=f)NrNzquery cancellation failed: %s)rrr_r)r@rOrs rC _try_cancelConnection._try_cancelRs= @   W  - @ NN:B ? ? @s <7<c#p# [XU5nUR(aBUR5 U UR5 Uv SSS5 SSS5 SSS5 gU Uv SSS5 g!,(df  N/=f!,(df  N8=f!,(df  g=f!,(df  g=f7f)af Start a context block with a new transaction or nested transaction. :param savepoint_name: Name of the savepoint used to manage a nested transaction. If `!None`, one will be chosen automatically. :param force_rollback: Roll back the transaction at the end of the block even if there were no error (e.g. to try a no-op process). :rtype: Transaction N)r*r:pipeline)r@savepoint_nameforce_rollbacktxs rC transactionConnection.transactionXsg~ > >>"dmmo'6"'6o""sc.B6BBA2 BB B6$B%) B62 B <B B B B"B6% B3/B6)rO stop_afterc## Ub[5U-n[U[5nOSn[nSnUR(a[R "S[ 5 UR URRnSURsUl nU(a(U(a UR5v US- nU(aM O}UR[UR5US9nUHSn [#U R$R'U5U R(R'U5U R*5v US- nMU UbXR:aO+U(a"[[U[5- 5nUS:aOMXpl SSS5 g![Ran U R!S5eSn A ff=f!Xpl f=f!,(df  g=f7f)ac Yield `Notify` objects as soon as they are received from the database. :param timeout: maximum amount of time to wait for notifications. `!None` means no timeout. :param stop_after: stop after receiving this number of notifications. You might actually receive more than this number if more than one notifications arrives in the same packet. Nrzusing 'notifies()' together with notifies handlers on the same connection is not reliable. Please use only one of these methodsr rPg)rminrc_notify_handlersrprqrrr?rA _encoding_notifies_backlogpopleftrr)rdrhrir0relnamedecodeextrabe_pid) r@rOrdeadlinerQ nreceivedencdpgnsrpgns rCr)Connection.notifiesms   {W,H7N3HH%H  MMR  YY++''C*.t/E/E %D "A! +"#))+-%NI a:#'99Xdkk-BX9#VD$(C"( # 2 23 7 # 0 0 5 # # &NI $("-)2I #&~x)+7M#N#c>!=@*+&QY$ !:"$"3"3D"99:,*+&QYsaA$G &+F;-F0F0#F&B F03F;: G F-F((F--F00F88F;; G G c#<# UR UR5 UR=nc[U5=olSSS5 W Uv SSS5 URS:Xa-UR XRLdeSUlSSS5 gg!,(df  N\=f!,(df  N]=f!,(df  g=f!WRS:Xa>UR XRLdeSUlSSS5 f!,(df  f=ff=f7f)z  *~~"YY#~~555%)DNY#YY~~"YY#~~555%)DNYY#s| D1BD C B'C D4B8 D B$ D' B51C 8 CD D&D> D D DDc#B# UR(ae[USS9=olU Uv SSS5 URS:XdeXRLdeSUlg!,(df  N8=f!URS:XdeXRLdeSUlf=f7f)zWlike pipeline() but don't acquire a lock. Assume that the caller is holding the lock. T)_no_lockNr)r:r(rrs rC_pipeline_nolockConnection._pipeline_nolocks>>!!$,TD$AA> ">>Q& &&~~- --!DN >>Q& &&~~- --!DNs1$BA1A A1*B A.*A11+BBcX[R"XRRUS9$![at URR [ :XaTURSS9 [R"XRRUS9 e![Ra ef=fef=f)z Consume a generator operating on the connection. The function must be used on generators that don't change connection fd (i.e. not on connect and reset). rPrrN) rrrAsocket _INTERRUPTEDtransaction_statusACTIVErrd QueryCanceled)r@rrQs rCrConnection.waits <<[[%7%7(K K {{--7   -LLkk&8&88L    s-(+7B)#)B  B) B$!B)#B$$B)c&URU5 gr<)set_autocommitr@values rC_set_autocommitConnection._set_autocommit E"rEcUR URURU55 SSS5 g!,(df  g=f)z6Method version of the `~Connection.autocommit` setter.N)r?r_set_autocommit_genrs rCrConnection.set_autocommit* YY IId..u5 6YY !7 Ac&URU5 gr<)set_isolation_levelrs rC_set_isolation_levelConnection._set_isolation_levels   'rEcUR URURU55 SSS5 g!,(df  g=f)z;Method version of the `~Connection.isolation_level` setter.N)r?r_set_isolation_level_genrs rCrConnection.set_isolation_levels* YY IId33E: ;YYrc&URU5 gr<) set_read_onlyrs rC_set_read_onlyConnection._set_read_onlys 5!rEcUR URURU55 SSS5 g!,(df  g=f)z5Method version of the `~Connection.read_only` setter.N)r?r_set_read_only_genrs rCr Connection.set_read_onlys* YY IId--e4 5YYrc&URU5 gr<)set_deferrablers rC_set_deferrableConnection._set_deferrablerrEcUR URURU55 SSS5 g!,(df  g=f)z6Method version of the `~Connection.deferrable` setter.N)r?r_set_deferrable_genrs rCrConnection.set_deferrable rrcUR URURU55 SSS5 g!,(df  g=f)z? Begin a TPC transaction with the given transaction ID `!xid`. N)r?r_tpc_begin_genr@xids rC tpc_beginConnection.tpc_begins,YY IId))#. /YYrcUR URUR55 SSS5 g!,(df  g=f![Ra%n[R "[ U55SeSnAff=f)zF Perform the first phase of a transaction started with `tpc_begin()`. N)r?r_tpc_prepare_genrdObjectNotInPrerequisiteStateNotSupportedErrorrf)r@rs rC tpc_prepareConnection.tpc_preparesY 9 $//12-- 9%%c"g.D 8 9s1 A 7A AAAB A<<BcUR URURSU55 SSS5 g!,(df  g=f)z* Commit a prepared two-phase transaction. COMMITNr?r_tpc_finish_genrs rC tpc_commitConnection.tpc_commit!s.YY IId**8S9 :YY "8 AcUR URURSU55 SSS5 g!,(df  g=f)z- Roll back a prepared two-phase transaction. ROLLBACKNr&rs rC tpc_rollbackConnection.tpc_rollback(s.YY IId**:s; <YYr*cUR5 URRnUR[ [ R 5S9nUR[ R"55 UR5nSSS5 U[:Xa.URR[:XaUR5 W$!,(df  NH=f)Nr) _check_tpcinforrrr _from_recordr_get_recover_queryfetchallIDLEINTRANSr)r@statusrress rC tpc_recoverConnection.tpc_recover/s -- [[Xc.>.>%?[ @C KK..0 1,,.CA T>dii::gE MMO A @s 5C C)rrr:r6r?r9r7)rAr1r9r8r[)rxrfrGrsrH int | NonerIzAdaptContext | Noner9zRowFactory[Row] | Noner6ztype[Cursor[Row]] | Noneryrreturnr!)r<r!)rztype[BaseException] | NonerzBaseException | NonerzTracebackType | Noner<None)rxrfryrr<r)r<r=)rrsr< Cursor[Row])rrsr9RowFactory[CursorRow]r<zCursor[CursorRow]) rrfrrsr bool | Nonerrsr<zServerCursor[Row]) rrfrrsr9r?rr@rrsr<zServerCursor[CursorRow]) rrfrrsr9zRowFactory[Any] | Nonerr@rrsr<zCursor[Any] | ServerCursor[Any]r<) rrrz Params | Nonerr@rrsr<r>)rr"rr@rrsr<r>) rrrzrArr@rrsr<r>)rOfloatr<r=)NF)rz str | Nonerrsr<zIterator[Transaction])rOz float | Nonerr;r<zGenerator[Notify])r<zIterator[Pipeline])rz PQGen[RV]rQrBr<r)rrsr<r=)rzIsolationLevel | Noner<r=)rr@r<r=)rz Xid | strr<r=)rzXid | str | Noner<r=)r<z list[Xid]).__name__ __module__ __qualname____firstlineno____doc____annotations__rrrrr> classmethodrrrr]rr rrrrrrr rr)rrrcrrrrrr r rrrr"r(r-r9__static_attributes__ __classcell__)rBs@rCr4r4:s+J%%22   (,JsOY'G 2 2% 2 2D!()'+.237DD D & D % D,D1DD DDL,&%   .44 ',AA %  4I    "&             "&&& & + &  && !&& .2"&    ,     ) D!% $      9=e+6GK !%* $ ***  *  * *2* , /34/2@ HM(AE **.E+&E+;EE+ E+N**$""(6D(#7 (< "6 #7 09;=  rEr4)WrG __future__rloggingrptimertypesrtypingrrrr contextlibr collections.abcr r r\rrdrrabcrrrrrrrr_tpcrrowsrrrradaptr_enumsrrr _compatr!r"_acompatr#rxr$r%r&r'r:r( generatorsr)rr* _capabilitiesr+_server_cursorr,_conninfo_utilsr-_connection_baser.r/r0pq.abcr1rcFormatTEXTrTransactionStatusr5rr6KeyboardInterruptr getLoggerr_r4rTrErCres #55%/LLL 66"#HH+ $'(-?? yy~~         $ $   & &   9 %$rE