,hISrSSKJr SSKrSSKrSSKJr SSKJr SSK J r J r J r J r JrJr SSKJr SSKJr S S KJr S S KJrJr S S KJrJrJrJrJrJrJ r S S K!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/ S SK0J1r1J2r2J3r3 S SK0J4r4 S SK5J6r6 S SK7J8r8 S SK9J:r: S SK;Jr> S SK?J@r@ S SKAJBrBJCrCJDrD \ (aS SKEJFrF SrG\RRrI\RRrJ\RRrL\RRrM\RRrN\OrP\R"S5rR"SS \B\$5rSg)!z* Psycopg connection object (sync version) ) annotationsN) monotonic) TracebackType) TYPE_CHECKINGAny GeneratorIteratorcastoverload)Lock)contextmanager)errors)pqwaiting)RV AdaptContextConnDict ConnParamParamsPQGenQuery)Xid)Row RowFactoryargs_row tuple_row) AdaptersMap)IsolationLevel)Cursor)Self)conninfo_attemptsconninfo_to_dict make_conninfo)timeout_from_conninfo)Pipeline)notifies) Transaction) capabilities) ServerCursor)gssapi_requested)BaseConnection CursorRowNotify)PGconng?psycopgcN^\rSrSr%SrSrS\S'S\S'S\S 'S \S '\"\\\ 54S;U4S jjjr \ SSjr S?Sjr\ S@Sj5rSASjr\S S.SBSjj5r\S S.SCSjj5r\S SS S.SDSjj5r\S SS S.SESjj5rS[TU]U5 X l[5Ul[ Ul[UlgN) super__init__r7r lockr r4r*r5)selfpgconnr7 __class__s M/var/www/html/Ai_home/venv/lib/python3.13/site-packages/psycopg/connection.pyr<Connection.__init__Ds1  &F $%1"FN) autocommitprepare_thresholdcontextr7r4c "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)U55R!S5e[*R,"5S: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 SnAGM1SnAf[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: %srrz7Multiple connection attempts failed. All failures were:c34# UHupSUSU3v M g7f)z- z: N).0errordescrs rA %Connection.connect..~sPKLEBugRw/Ks iqaathe connection was obtained using the GSSAPI relying on the 'gssencmode=prefer' libpq default. In a future psycopg[binary] version this default will be changed to 'disable'. 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_tracebacklenextendtypejoinrversionr? used_gssapir+warningswarnDeprecationWarningbool _autocommitr7r4radapters _adaptersrF)clsconninforErFrGr7r4kwargsparamsrMrvattempts conn_errorsattempttdescrrUgenexlast_exliness rAconnectConnection.connectOs' ++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 Qw- % 01@@F F JJLF " %%%f-- MMt"  j) (N  .  &w'7'78BL0 O77 0 8%RI""B;//?? .''-- .s$3HJ'3I!!J8J  JcU$r:rRr>s rA __enter__Connection.__enter__s rCcUR(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 rA__exit__Connection.__exit__sp ;;   R  KKMtWd++ JJL,  RDdQQ RsA B *BB c [U40UD6$)z3Manipulate connection parameters before connecting.)r#)rurvrws rAr[!Connection._get_connection_paramss 3F33rCcjUR(agSUlURR5 g)zClose the database connection.NT)r_closedr?finishrs rArConnection.closes% ;;   rC)binarycgr:rR)r>rs rAcursorConnection.cursors>ArCcgr:rR)r>rr7s rArrs rC)r scrollablewithholdcgr:rR)r>namerrrs rArrs rCcgr:rR)r>rrr7rrs rArrs#&rC)rr7rrcUR5 U(d URnU(aURUUUUUS9nOURXS9nU(a [UlU$)zG Return a new `Cursor` to send commands and queries to the connection. )rr7rrr7)_check_connection_okr7r5r4BINARYformat)r>rrr7rrcurs rArrsk !!#**K ,,'%! -C%%d%DC CJ rC)preparercUR5nU(a [UlURXUS9$![R anUR S5eSnAff=f)z8Execute a query and return a cursor to read its results.)rN)rrrexecuterbrfrg)r>queryrxrrrrs rArConnection.executesT *++-C# ;;ug;> > *##D) ) *s14AAAcUR URUR55 SSS5 g!,(df  g=f)z/Commit any pending transaction to the database.N)r=wait _commit_genrs rArConnection.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_genrs rArConnection.rollbacks( YY IId((* +YYrg>@rLcUR5(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()`. NrLrN)_should_cancelr)has_cancel_saferr` _cancel_genracancel)r>rMs rA cancel_safeConnection.cancel_safesQ ""$$   ' ' ) )      1N  KKMrC@c~URUS9 g![a n[RSU5 SnAgSnAff=f)NrLzquery cancellation failed: %s)rrr]r)r>rMrs rA _try_cancelConnection._try_cancel3s= @   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(r8pipeline)r>savepoint_nameforce_rollbacktxs rA transactionConnection.transaction9sg~ > >>"dmmo'6"'6o""sc.B6BBA2 BB B6$B%) B62 B <B B B B"B6% B3/B6)rM 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 thees methodsrrNg)rminra_notify_handlersrnroRuntimeWarningr=r? _encoding_notifies_backlogpopleftrr'rbrfrgr.relnamedecodeextrabe_pid) r>rMrdeadlinerO nreceivedencdpgnsrpgns rAr'Connection.notifiesNs   {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)zrs rArConnection.pipelinesYY  % % ' NN*3,4TN:>  *~~"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)r8r&rrs rA_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). rNrrL) rrr?socket _INTERRUPTEDtransaction_statusACTIVErrb QueryCanceled)r>r~rOs rArConnection.waits <<[[%7%7(K K {{--7   -LLkk&8&88L    s-(+7B)#)B  B) B$!B)#B$$B)c&URU5 gr:)set_autocommitr>values rA_set_autocommitConnection._set_autocommit E"rCcUR URURU55 SSS5 g!,(df  g=f)z6Method version of the `~Connection.autocommit` setter.N)r=r_set_autocommit_genrs rArConnection.set_autocommit* YY IId..u5 6YY !7 Ac&URU5 gr:)set_isolation_levelrs rA_set_isolation_levelConnection._set_isolation_levels   'rCcUR URURU55 SSS5 g!,(df  g=f)z;Method version of the `~Connection.isolation_level` setter.N)r=r_set_isolation_level_genrs rArConnection.set_isolation_levels* YY IId33E: ;YYrc&URU5 gr:) set_read_onlyrs rA_set_read_onlyConnection._set_read_onlys 5!rCcUR URURU55 SSS5 g!,(df  g=f)z5Method version of the `~Connection.read_only` setter.N)r=r_set_read_only_genrs rArConnection.set_read_onlys* YY IId--e4 5YYrc&URU5 gr:)set_deferrablers rA_set_deferrableConnection._set_deferrablerrCcUR URURU55 SSS5 g!,(df  g=f)z6Method version of the `~Connection.deferrable` setter.N)r=r_set_deferrable_genrs rAr Connection.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 rA 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_genrbObjectNotInPrerequisiteStateNotSupportedErrorrd)r>rs rA 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 rA 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 rA 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 rA tpc_recoverConnection.tpc_recovers -- [[Xc.>.>%?[ @C KK..0 1,,.CA T>dii::gE MMO A @s 5C C)rrr8r4r=r7r5)r?r/r7r6rY)rvrdrErqrF int | NonerGzAdaptContext | Noner7zRowFactory[Row] | Noner4ztype[Cursor[Row]] | Nonerwrreturnr!)r3r!)rztype[BaseException] | NonerzBaseException | NonerzTracebackType | Noner3None)rvrdrwrr3r)r3r4)rrqr3 Cursor[Row])rrqr7RowFactory[CursorRow]r3zCursor[CursorRow]) rrdrrqr bool | Nonerrqr3zServerCursor[Row]) rrdrrqr7r6rr7rrqr3zServerCursor[CursorRow]) rrdrrqr7zRowFactory[Any] | Nonerr7rrqr3zCursor[Any] | ServerCursor[Any]r:) rrrxz Params | Nonerr7rrqr3r5)rMfloatr3r4)NF)rz str | Nonerrqr3zIterator[Transaction])rM float | Nonerr2r3zGenerator[Notify, None, None])r3zIterator[Pipeline])r~z PQGen[RV]rOr9r3r)rrqr3r4)rzIsolationLevel | Noner3r4)rr7r3r4)rz Xid | strr3r4)rzXid | str | Noner3r4)r3z list[Xid]).__name__ __module__ __qualname____firstlineno____doc____annotations__r rrrr< classmethodrrrr[rr rrrrrrr rr'rrrarrrrrrrr r rrrr$r0__static_attributes__ __classcell__)r@s@rAr2r28sJ%%22   (,JsOY'G 2 2% 2 2C!()'+.237CC C & C % C,C1CC CCJ,&%   .44',AA %  4I    "&             "&&& & + &  && !&& .2"&    ,     ) J!%* $ ***  *  * *$* , /34/2@ HM(AE **.E+&E+;EE+ &E+N**$""(=K(#7 (< "6 #7 09;=  rCr2)Tr> __future__rloggingrntimertypesrtypingrrrr r r threadingr contextlibr rZrrbrrabcrrrrrrr_tpcrrowsrrrradaptr_enumsrrr _compatr!rvr"r#r$r%r8r& generatorsr'rr( _capabilitiesr)_server_cursorr*_conninfo_utilsr+_connection_baser,r-r.pq.abcr/raFormatTEXTrTransactionStatusr,rr-KeyboardInterruptr getLoggerr]r2rRrCrAr[s #JJ%LLL66"HH+ $'(-?? yy~~         $ $   & &   9 %b$brC