iIdZddlmZddlZddlZddlmZddlmZddl m Z m Z m Z m Z mZmZddlmZddlmZd d lmZd d lmZmZd d lmZmZmZmZmZmZm Z d d l!m"Z"d dl#m$Z$m%Z%m&Z&m'Z'd dl(m)Z)d dl*m+Z+d dl,m-Z-d dl.m/Z/d dl0m1Z1m2Z2m3Z3d dl0m4Z4d dl5m6Z6d dl7m8Z8d dl9m:Z:d dl;mZ>d dl?m@Z@d dlAmBZBmCZCmDZDe rd dlEmFZFdZGejjZIejjZJejjZLejjZMejjZNeOZPejdZRGdd eBe$ZSy)!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?psycopgceZdZUdZdZded<ded<ded<d ed <eeeef d9fd Z e d:d d dddd d;dZ ddZd?dZed dd@dZed d dAdZed dd d dBdZed dd d dCdZ d:d ddd d dDdZ dEdd d dFdZd?dZd?d Zd!d"dGd#Zd$d"dGd%Ze dH dId&Zddd' dJd(ZedKd)ZedKd*ZefdLd+ZdMd,ZdMd-ZdNd.Z dNd/Z!dOd0Z"dOd1Z#dOd2Z$dOd3Z%dPd4Z&d?d5Z'dEdQd6Z(dEdQd7Z)dRd8Z*xZ+S)S Connectionz3 Wrapper for a connection to the database. r0ztype[Cursor[Row]]cursor_factoryztype[ServerCursor[Row]]server_cursor_factoryRowFactory[Row] row_factoryzPipeline | None _pipelinec|t||||_t|_t |_t|_yN) super__init__r6r lockr r3r*r4)selfpgconnr6 __class__s r/var/www/html/hwPaymentPortal-be-dev/hw-payment-portal-api/venv/lib/python3.12/site-packages/psycopg/connection.pyr;zConnection.__init__Ds3  &F $%1"FN) autocommitprepare_thresholdcontextr6r3c |j|fi|}t|} d} t|} g} | D]} | jd| jd| jdf}d|z}tj d| t di| }|j|| }tj|t} tj d |n| s| d d }t#| d k(r|j!dt|g}|jd|j%d| Dt'|dj)|j!dt+j,dk\r;| j.j0r%t3|st5j6dt8t;|| _|r|| _|r|| _ |rtC|jD| _#|| _$| S#tj$r>}tj d |t|| j||fYd}~d}~wtj$r}|j!dd}~wwxYw)zV 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:c32K|]\}}d|d|yw)z- z: N).0errordescrs r@ z%Connection.connect..~s!PLE5BugRw/Ps 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 _autocommitr6r3radapters _adaptersrD)clsconninforCrDrEr6r3kwargsparamsrKrvattempts conn_errorsattempttdescrrSgenexlast_exliness r@connectzConnection.connectOs5 ,++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$w- % 01@@F F JJLF " %%%f- MMt"  j) (BN  .B  &w'7'78BL0 O77 0 8%RI""B;//?? .''-- .s$9G99I1 3II1I,,I1c|Sr9rPr=s r@ __enter__zConnection.__enter__s rAc|jry|r |jn|j t |dds|jyy#t$r!}tj d||Yd}~Dd}~wwxYw)Nz#error ignored in rollback on %s: %s_pool)closedrollback ExceptionrZwarningcommitgetattrclose)r=exc_typeexc_valexc_tbexc2s r@__exit__zConnection.__exit__so ;;   R  KKMtWd+ JJL,  RDdDQQ RsA A;A66A;c t|fi|S)z3Manipulate connection parameters before connecting.)r#)rrrsrts r@rXz!Connection._get_connection_paramss 3F33rAc`|jryd|_|jjy)zClose the database connection.NT)r_closedr>finishrs r@rzConnection.closes% ;;   rA)binarycyr9rP)r=rs r@cursorzConnection.cursors>ArAcyr9rP)r=rr6s r@rzConnection.cursors rA)r scrollablewithholdcyr9rP)r=namerrrs r@rzConnection.cursors rAcyr9rP)r=rrr6rrs r@rzConnection.cursors#&rA)rr6rrc|j|s |j}|r|j|||||}n|j||}|r t|_|S)zW Return a new `Cursor` to send commands and queries to the connection. )rr6rrr6)_check_connection_okr6r4r3BINARYformat)r=rrr6rrcurs r@rzConnection.cursorsm !!#**K ,,'%! -C%%d %DC CJ rA)preparerc |j}|r t|_|j|||S#tj $r}|j dd}~wwxYw)z8Execute a query and return a cursor to read its results.)rN)rrrexecuter_rcrd)r=queryrurrrr|s r@rzConnection.executesV *++-C# ;;ufg;> > *##D) ) *s03AAAc|j5|j|jdddy#1swYyxYw)z/Commit any pending transaction to the database.N)r<wait _commit_genrs r@rzConnection.commits3 YY * IId&&( ) * * * 6?c|j5|j|jdddy#1swYyxYw)z2Roll back to the start of any pending transaction.N)r<r _rollback_genrs r@rzConnection.rollbacks3 YY , IId((* + , , ,rg>@rJc|jsytjr,tj|j |t y|jy)aCancel 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()`. NrJrL)_should_cancelr)has_cancel_saferr] _cancel_genr^cancel)r=rKs r@ cancel_safezConnection.cancel_safesK ""$   ' ' )      1N  KKMrA@c |j|y#t$r }tjd|Yd}~yd}~wwxYw)NrJzquery cancellation failed: %s)rrrZr)r=rKr|s r@ _try_cancelzConnection._try_cancel3s= @   W  - @ NN:B ? ? @s >9>c#@Kt|||}|jrB|j5|5|j5|dddddddddy|5|dddy#1swY*xYw#1swY.xYw#1swYyxYw#1swYyxYww)a 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@ transactionzConnection.transaction9s~~ > >> " dmmo                sc*BBA:A.A: B B B% B.A7 3A::B ?BB BBB)rK stop_afterc#XK|t|z}t|t}nd}t}d}|jrt j dt |j5|jj}d|jc|_ } |r|r|j|dz }|rn~ |jt|j|}|D]R} t#| j$j'|| j(j'|| j*|dz }T|||k\rn$|r!tt|tz }|dkrn||_ dddy#tj$r} | j!dd} ~ wwxYw#||_ wxYw#1swYyxYww)a 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 methodsrrLg)rminr^_notify_handlersrkrlRuntimeWarningr<r> _encoding_notifies_backlogpopleftrr'r_rcrdr.relnamedecodeextrabe_pid) r=rKrdeadlinerM nreceivedencdpgnsr|pgns r@r'zConnection.notifiesNs   {W,H7N3HH%H  MMR  YY( +++''C*.t/E/E %D "A! +"#))+-%NI :#'99Xdkk-BX9#VD$(+C"( # 2 23 7 # 0 0 5 # # &NI +"-)z2I #&~x)+7M#N#c>!=@*+&Q( +( +$ !:"$"3"3D"99:,*+&Q( +( +saAF*+F F*F,&E&BFF F*&F9F  FF FFF'#F*c#K|j5|j|jx}t|x}|_ddd 5|ddd|jdk(r-|j5||jusJd|_dddyy#1swYVxYw#1swYRxYw#1swYyxYw#jdk(r9|j5||jusJd|_dddw#1swYwxYwwxYww)z  ; *  ~~"YY*#t~~555%)DN**# ; ;  **~~"YY*#t~~555%)DN***#s| D1BD B9 B!B9D3B- DBD!B*&B9-B62D9DC6- D6C? ;DDc#2K|jrJt|dx}|_ |5|ddd|jdk(sJ||jusJd|_y#1swY2xYw#|jdk(sJ||jusJd|_wxYww)zglike pipeline() but don't acquire a lock. Assume that the caller is holding the lock. T)_no_lockNr)r7r&rrs r@_pipeline_nolockzConnection._pipeline_nolocks>>!!$,TD$AA4> "  >>Q& &&t~~- --!DN   >>Q& &&t~~- --!DNs1#BA*AA*)BA'#A***BBcd tj||jj|S#t$rx|jj t k(rY|jd tj||jj|#tj$rYwxYwwxYw)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). rLrrJ) rrr>socket _INTERRUPTEDtransaction_statusACTIVErr_ QueryCanceled)r=r{rMs r@rzConnection.waits <<T[[%7%7(K K {{--7   -LLdkk&8&88L    s-+.8B/',BB/B*'B/)B**B/c&|j|yr9)set_autocommitr=values r@_set_autocommitzConnection._set_autocommit E"rAc|j5|j|j|dddy#1swYyxYw)z6Method version of the `~Connection.autocommit` setter.N)r<r_set_autocommit_genrs r@rzConnection.set_autocommit5 YY 7 IId..u5 6 7 7 7 !7Ac&|j|yr9)set_isolation_levelrs r@_set_isolation_levelzConnection._set_isolation_levels   'rAc|j5|j|j|dddy#1swYyxYw)z;Method version of the `~Connection.isolation_level` setter.N)r<r_set_isolation_level_genrs r@rzConnection.set_isolation_levels5 YY < IId33E: ; < < .>%?[ @ !C KK..0 1,,.C ! T>dii::gE MMO  ! !s 4CC )r>r/r6r5rV)rsrarCrnrD int | NonerEzAdaptContext | Noner6zRowFactory[Row] | Noner3ztype[Cursor[Row]] | Nonertrreturnr!)rr!)rztype[BaseException] | NonerzBaseException | NonerzTracebackType | NonerNone)rsrartrrr)rr)rrnr Cursor[Row])rrnr6RowFactory[CursorRow]rzCursor[CursorRow]) rrarrnr bool | NonerrnrzServerCursor[Row]) rrarrnr6rrrrrnrzServerCursor[CursorRow]) rrarrnr6zRowFactory[Any] | NonerrrrnrzCursor[Any] | ServerCursor[Any]r9) rrruz Params | Nonerrrrnrr)rKfloatrr)NF)rz str | NonerrnrzIterator[Transaction])rK float | NonerrrzGenerator[Notify, None, None])rzIterator[Pipeline])r{z PQGen[RV]rMrrr)rrnrr)rzIsolationLevel | Nonerr)rrrr)rz Xid | strrr)rzXid | str | Nonerr)rz list[Xid]),__name__ __module__ __qualname____doc____annotations__r rrrr; classmethodrrrrXrr rrrrrrr rr'rrr^rrrrrrrrrrrrrr __classcell__)r?s@r@r2r28sJ%%22   (,JsOY'G 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;= rAr2)Tr __future__rloggingrktimertypesrtypingrrrr r r threadingr contextlibr rWrr_rrabcrrrrrrr_tpcrrowsrrrradaptr_enumsrrr _compatr!rsr"r#r$r%r7r& generatorsr'rr( _capabilitiesr)_server_cursorr*_conninfo_utilsr+_connection_baser,r-r.pq.abcr/r^FormatTEXTrTransactionStatusr rrKeyboardInterruptr getLoggerrZr2rPrAr@r9s #JJ%LLL66"HH+ $'(-?? yy~~         $ $   & &   9 %b$brA