(phI=SrSSKJr SSKrSSKJr SSKJr SSKJ r J r J r J r J r Jr SSKJr SS KJr SS KJr SS KJr SS KJrJrJrJrJrJrJr SS KJr SSK J!r!J"r"J#r#J$r$ SSK%J&r& SSK'J(r( SSK)J*r* SSK+J,r,J-r- SSK+J.r.J/r/ SSK0J1r1 SSK2J3r3 SSK4J5r5 SSK6J7r7 SSK8J9r9 SSK:J;r; SSKr>J?r? SSK@JArA \(aSSKBJCrC SrD\RRrF\RRrG\RRrI\RRrJ\RRrK\LrM\R"S5rO"SS \=\!5rPg)!z* Psycopg connection object (sync version) ) annotationsN) monotonic) TracebackType)Any GeneratorIteratorcastoverload TYPE_CHECKING)contextmanager)pq)errors)waiting) AdaptContextConnDict ConnParamParamsPQGenQueryRV)Xid)Row RowFactory tuple_rowargs_row) AdaptersMap)IsolationLevel)Self) make_conninfoconninfo_to_dict)conninfo_attemptstimeout_from_conninfo)Pipeline)notifies) Transaction)Cursor) capabilities) ServerCursor)BaseConnection CursorRowNotify)Lock)PGconng?psycopgc:^\rSrSr%SrSrS\S'S\S'S\S 'S \S '\"\\\ 54S:U4S jjjr \ S;S SSSSS.SSjr\ S?Sj5rS@Sjr\S S.SASjj5r\S S.SBSjj5r\S SS S.SCSjj5r\S SS S.SDSjj5rS;S SSS S.SESjjjrSFSS S.SGSjjjrS@S jrS@S!jrS"S#.SHS$jjrS%S#.SHS&jjr\SISJS'jj5rSSS(.SKS)jjr\SLS*j5r\4SMS+jjrSNS,jrSNS-jrSOS.jr SOS/jr!SPS0jr"SPS1jr#SPS2jr$SPS3jr%SQS4jr&S@S5jr'SFSRS6jjr(SFSRS7jjr)SSS8jr*S9r+U=r,$)T Connection8z+ Wrapper for a connection to the database. r/ztype[Cursor[Row]]cursor_factoryztype[ServerCursor[Row]]server_cursor_factoryRowFactory[Row] row_factoryzPipeline | None _pipelinecz>[TU]U5 X l[5Ul[ Ul[UlgN) super__init__r6r-lockr'r3r)r4)selfpgconnr6 __class__s E/var/www/html/venv/lib/python3.13/site-packages/psycopg/connection.pyr;Connection.__init__Ds1  &F $%1"FN) autocommitprepare_thresholdcontextr6r3c UR"U40UD6n[U5n Sn [U5n U H7n [S 0U D6nUR XS9n [ R "U [S9n O U (dW(deURS5e[!U5U lU(aXZlU(aXjlU(a[)UR*5U lX:lU $![Raln[U 5S:aO[RSU RS5U RS5U RS5[U55 UnSnAGM*SnAff=f) zF Connect to a database server and return a new `Connection` instance. Ntimeoutintervalr z=connection attempt failed: host: %r port: %r, hostaddr %r: %shostporthostaddr)_get_connection_paramsr#r"r _connect_genr wait_conn_WAIT_INTERVALe _NO_TRACEBACKlenloggerdebuggetstrwith_tracebackbool _autocommitr6r3radapters _adaptersrE)clsconninforDrErFr6r3kwargsparamsrIrvattemptsattemptgenexlast_exs r@connectConnection.connectOs5 ++H??'/ $V,G (7w7&&x&A&&s^D! $N7((. .j) (N  .  &w'7'78BL0 3?? x=1$LLW F+ F+ J/B  s3CE1A EEcU$r9r=s r@ __enter__Connection.__enter__s rBcUR(agU(aUR5 OUR 5 [ USS5(dUR5 gg![a n[R SX5 SnANISnAff=f)Nz#error ignored in rollback on %s: %s_pool)closedrollback ExceptionrXwarningcommitgetattrclose)r=exc_typeexc_valexc_tbexc2s r@__exit__Connection.__exit__sp ;;   R  KKMtWd++ JJL,  RDdQQ RsA B *BB c [U40UD6$)z3Manipulate connection parameters before connecting.)r!)rarbrcs r@rQ!Connection._get_connection_paramss 3F33rBcjUR(agSUlURR5 g)zClose the database connection.NT)rt_closedr>finishros r@rzConnection.closes% ;;   rB)binarycgr9rn)r=rs r@cursorConnection.cursors>ArBcgr9rn)r=rr6s r@rrs rB)r scrollablewithholdcgr9rn)r=namerrrs r@rrs rBcgr9rn)r=rrr6rrs r@rrs#&rB)rr6rrcUR5 U(d URnU(aURUUUUUS9nOURXS9nU(a [UlU$)zG Return a new `Cursor` to send commands and queries to the connection. )rr6rrr6)_check_connection_okr6r4r3BINARYformat)r=rrr6rrcurs r@rrsk !!#**K ,,'%! -C%%d%DC CJ rB)preparercUR5nU(a [UlURXUS9$![R anUR S5eSnAff=f)z8Execute a query and return a cursor to read its results.)rN)rrrexecuterUrVr\)r=queryrdrrrris r@rConnection.executesT *++-C# ;;ug;> > *##D) ) *s14AAAcUR URUR55 SSS5 g!,(df  g=f)z/Commit any pending transaction to the database.N)r<wait _commit_genros r@rxConnection.commits( YY IId&&( )YY 6 AcUR URUR55 SSS5 g!,(df  g=f)z2Roll back to the start of any pending transaction.N)r<r _rollback_genros r@ruConnection.rollbacks( YY IId((* +YYrg>@rHcUR5(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()`. NrHrJ)_should_cancelr(has_cancel_saferrS _cancel_genrTcancel)r=rIs r@ cancel_safeConnection.cancel_safesQ ""$$   ' ' ) )      1N  KKMrB@c~URUS9 g![a n[RSU5 SnAgSnAff=f)NrHzquery cancellation failed: %s)rrvrXrw)r=rIris r@ _try_cancelConnection._try_cancel!s= @   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&r7pipeline)r=savepoint_nameforce_rollbacktxs r@ transactionConnection.transaction'sg~ > >>"dmmo'6"'6o""sc.B6BBA2 BB B6$B%) B62 B <B B B B"B6% B3/B6)rI stop_afterc## Ub[5U-n[U[5nOSn[nSnUR URR nUR [UR5US9nUHUn [U RRU5U RRU5U R5n U v US- nMW UbXR:aO+U(a"[[U[5- 5nUS:aOMSSS5 g![RanURS5eSnAff=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. NrrJr g)rminrTr<r> _encodingrr%rUrVr\r,relnamedecodeextrabe_pid) r=rIrdeadlinerK nreceivedencnsripgnns r@r%Connection.notifies<s(   {W,H7N3HH%H YY++''C28DKK#88LB C **3/1A1A#1F AGNI )i.E">8ik3IJH#~/Y 2++D112 YsA8E D;#D6BD; E D8"D33D88D;; E E c#<# UR UR5 URnUc[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 DDcX[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). rJrrH) rrr>socket _INTERRUPTEDtransaction_statusACTIVErrU QueryCanceled)r=rhrKs r@rConnection.waits <<[[%7%7(K K {{--7   -LLkk&8&88L    s-(+7B)#)B  B) B$!B)#B$$B)c&URU5 gr9)set_autocommitr=values r@_set_autocommitConnection._set_autocommit E"rBcUR URURU55 SSS5 g!,(df  g=f)z6Method version of the `~Connection.autocommit` setter.N)r<r_set_autocommit_genrs r@rConnection.set_autocommit* YY IId..u5 6YY !7 Ac&URU5 gr9)set_isolation_levelrs r@_set_isolation_levelConnection._set_isolation_levels   'rBcUR URURU55 SSS5 g!,(df  g=f)z;Method version of the `~Connection.isolation_level` setter.N)r<r_set_isolation_level_genrs r@rConnection.set_isolation_levels* YY IId33E: ;YYrc&URU5 gr9) set_read_onlyrs r@_set_read_onlyConnection._set_read_onlys 5!rBcUR URURU55 SSS5 g!,(df  g=f)z5Method version of the `~Connection.read_only` setter.N)r<r_set_read_only_genrs r@rConnection.set_read_onlys* YY IId--e4 5YYrc&URU5 gr9)set_deferrablers r@_set_deferrableConnection._set_deferrablerrBcUR URURU55 SSS5 g!,(df  g=f)z6Method version of the `~Connection.deferrable` setter.N)r<r_set_deferrable_genrs r@rConnection.set_deferrablerrcUR URURU55 SSS5 g!,(df  g=f)z? Begin a TPC transaction with the given transaction ID `!xid`. N)r<r_tpc_begin_genr=xids r@ 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_genrUObjectNotInPrerequisiteStateNotSupportedErrorr[)r=ris r@ 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 r@ tpc_commitConnection.tpc_commits.YY IId**8S9 :YY "8 AcUR URURSU55 SSS5 g!,(df  g=f)z- Roll back a prepared two-phase transaction. ROLLBACKNrrs r@ tpc_rollbackConnection.tpc_rollbacks.YY IId**:s; <YYrcUR5 URRnUR[ [ R 5S9nUR[ R"55 UR5nSSS5 U[:Xa.URR[:XaUR5 W$!,(df  NH=f)Nr) _check_tpcinforrrr _from_recordr_get_recover_queryfetchallIDLEINTRANSru)r=statusrress r@ tpc_recoverConnection.tpc_recovers -- [[Xc.>.>%?[ @C KK..0 1,,.CA T>dii::gE MMO A @s 5C C)rr7r3r<r6r4)r>r.r6r5rO)rbr[rDr]rE int | NonerFzAdaptContext | Noner6zRowFactory[Row] | Noner3ztype[Cursor[Row]] | Nonercrreturnr)rr)r{ztype[BaseException] | Noner|zBaseException | Noner}zTracebackType | NonerNone)rbr[rcrrr)rr)rr]r Cursor[Row])rr]r6RowFactory[CursorRow]rzCursor[CursorRow]) rr[rr]r bool | Nonerr]rzServerCursor[Row]) rr[rr]r6rrrrr]rzServerCursor[CursorRow]) rr[rr]r6zRowFactory[Any] | Nonerrrr]rzCursor[Any] | ServerCursor[Any]r9) rrrdz Params | Nonerrrr]rr)rIfloatrr)NF)rz str | Nonerr]rzIterator[Transaction])rI float | NonerrrzGenerator[Notify, None, None])rzIterator[Pipeline])rhz PQGen[RV]rKrrr)rr]rr)rzIsolationLevel | Nonerr)rrrr)rz Xid | strrr)rzXid | str | Nonerr)rz list[Xid])-__name__ __module__ __qualname____firstlineno____doc____annotations__r rrrr; classmethodrkrprrQrzr rrrxrurrr rr%rrTrrrrrrrrrrrrrr__static_attributes__ __classcell__)r?s@r@r1r18syJ%%22   (,JsOY'G 2 2% 2 21!()'+.23711 1 & 1 % 1,1111 11f,&%   .44',AA %  4I    "&             "&&& & + &  && !&& .2"&    ,     ) J!%* $ ***  *  * *$* , /34/2@ HM(AE **.0&0;E0 &0d**&=K(#7 (< "6 #7 09;=  rBr1)Qr __future__rloggingtimertypesrtypingrrrr r r contextlibr rPrrrUrabcrrrrrrr_tpcrrowsrrrradaptr_enumsr_compatrrbr r!r"r#r7r$ generatorsr%rr&rr' _capabilitiesr( server_cursorr)_connection_baser*r+r, threadingr-pq.abcr.rTFormatTEXTrTransactionStatusr rrKeyboardInterruptr getLoggerrXr1rnrBr@r;s #JJ%LLL66"5> $''?? yy~~         $ $   & &   9 %g$grB