YtjUdZddlmZddlZddlZddlmZddlmZddl m Z m Z m Z m Z ddlmZddlmZmZd d lmZd d lmZmZd d lmZmZmZmZmZmZmZd d lm Z d dl!m"Z"d dl#m$Z$m%Z%m&Z&m'Z'd dl(m)Z)d dl*m+Z+d dl,m-Z-m.Z.d dl/m0Z0d dl1m2Z2m3Z3m4Z4d dl1m5Z5d dl6m7Z7d dl8m9Z9d dl:m;Z;d dlm?Z?d dl@mAZAd dlBmCZCmDZDmEZEd dlFmGZG ddlHZHddlIZIe rd dlJmKZKd ZLejMjNZNejMjOZOejPjQZQejPjRZRejPjSZS eIjTeUfZVejWd!ZXGd"d#eCe%ZYdS)$z+ Psycopg connection object (async version) ) annotationsN) monotonic) TracebackType) TYPE_CHECKINGAnycastoverload)asynccontextmanager)AsyncGenerator AsyncIterator)errors)pqwaiting)RV AdaptContextConnDict ConnParamParamsPQGenQuery)QueryNoTemplate)Xid)AsyncRowFactoryRowargs_row tuple_row) AdaptersMap)IsolationLevel)SelfTemplate)ALock)conninfo_attempts_asyncconninfo_to_dict make_conninfo)timeout_from_conninfo)notifies)AsyncTransaction) AsyncCursor) capabilities)gssapi_requested) AsyncPipeline)BaseConnection CursorRowNotify)AsyncServerCursorT)PGconng?psycopgceZdZUdZdZded<ded<ded<d ed <eeeefdfd Z e ddddddddd!Z dd"Z dd*Z e dd-Zdd.Zedd/dd2Zedd/dd5Zedddd6dd<Zedddd6dd>Z dddddd?ddBZe ddddCddIZedddCddKZ ddddCddMZddNZddOZdPdQddTZdUdQddVZe ddd[Zddd\dd`ZeddbZeddcZefddhZddjZddkZddmZ ddnZ!ddoZ"ddpZ#ddqZ$ddrZ% dduZ&ddxZ'ddyZ(ddd{Z)ddd|Z*dd~Z+xZ,S)AsyncConnectionz3 Wrapper for a connection to the database. r2ztype[AsyncCursor[Row]]cursor_factoryztype[AsyncServerCursor[Row]]server_cursor_factoryAsyncRowFactory[Row] row_factoryzAsyncPipeline | None _pipelinepgconnr1ct|||_t|_t |_t|_dSN) super__init__r8r"lockr)r5r0r6)selfr:r8 __class__s V/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/psycopg/connection_async.pyr>zAsyncConnection.__init__JsF    &GG )%6"""FN) autocommitprepare_thresholdcontextr8r5conninfostrrFboolrG int | NonerHAdaptContext | NoneAsyncRowFactory[Row] | Nonetype[AsyncCursor[Row]] | Nonekwargsrreturnr c vK tjdkrMtj}t |tjr ddlm} tj dd| z|j |fi|d{V} t| } d} t| d{V} g}| D]E}| d| d | d f}d |z}td | t!di|}||| }t%j|t(d{V} td|n#tj$rK}td|t-||||fYd}~d}~wtj$r}|dd}~wwxYw| s|dd}t5|dkr|dt-|g}|d|d|Dt9|d||j}|dt?j r5| jj!r)tE| stGj$dtJtM|| _'|r|| _(|r|| _)|rtU|j+| _,|| _-| S)z[ Connect to a database server and return a new `AsyncConnection` instance. Twin32r )_asyncio_run_snippetztPsycopg cannot use the 'ProactorEventLoop' to run in async mode. Please use a compatible event loop, for instance by Nhostporthostaddrz host: %r, port: %r, hostaddr: %rzconnection attempt: %srDtimeoutintervalzconnection succeeded: %szconnection failed: %s: %srz7Multiple connection attempts failed. All failures were:c3,K|]\}}d|d|VdS)z- z: N).0errordescrs rB z*AsyncConnection.connect..s7OO<5%.e..u..OOOOOOrC )r:authe 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'rD).sysplatformasyncioget_running_loop isinstanceProactorEventLoop_compatrTeInterfaceError_get_connection_paramsr&r#getloggerdebugr% _connect_genrwait_conn_async_WAIT_INTERVALErrorrJappend _NO_TRACEBACKwith_tracebacklenextendtypejoinr:r*has_used_gssapi used_gssapir+warningswarnRuntimeWarningrK _autocommitr8r5radapters _adaptersrG)clsrIrFrGrHr8r5rPlooprTparamsrZrvattempts conn_errorsattempttdescrrbgenexlast_exlinesnew_exs rBconnectzAsyncConnection.connectUs |w&&/11dG$=>>======*U42445 2s1(EEfEEEEEEEE'// 08888888813   Gkk&))7;;v+>+> J@W@WXF6?E LL15 9 9 9 (77w77&&x&AA"23PPPPPPPPP 7???7 0 0 0 8%RIII""B;////////? . . .''--- .  .!"oa(G;1$$,,T222\\NE LLR S S S LLOO;OOO O O O"T']]499U#3#3GNKKKF''-- -  ( * *  % %V,,  MP    j))  )(BN  / .B   9&w'788BL0 s&AE""G#1AF77G# GG#c K|Sr<r_r@s rB __aenter__zAsyncConnection.__aenter__s  rCexc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | NoneNonecLK|jrdS|rO |d{VnM#t$r&}td||Yd}~n"d}~wwxYw|d{Vt |dds|d{VdSdS)Nz#error ignored in rollback on %s: %s_pool)closedrollback Exceptionrqwarningcommitgetattrclose)r@rrrexc2s rB __aexit__zAsyncConnection.__aexit__s ;  F   Rmmoo%%%%%%%% R R RDdDQQQQQQQQ R++--       tWd++ **,,           s* AAArrc Kt|fi|S)z3Manipulate connection parameters before connecting.)r$)rrIrPs rBroz&AsyncConnection._get_connection_paramss 33F333rCcK|jrdSt|dd}|r.t|ddr||d{VdSd|_|jdS)zClose the database connection.Nr close_returnsFT)rrputconn_closedr:finish)r@pools rBrzAsyncConnection.closes ;  FtWd++  GD/599 ,,t$$ $ $ $ $ $ $ $ F  rC)binaryrAsyncCursor[Row]cdSr<r_)r@rs rBcursorzAsyncConnection.cursorsCF3rCAsyncRowFactory[CursorRow]AsyncCursor[CursorRow]cdSr<r_)r@rr8s rBrzAsyncConnection.cursors "%rC)r scrollablewithholdnamer bool | NonerAsyncServerCursor[Row]cdSr<r_)r@rrrrs rBrzAsyncConnection.cursors "%rCAsyncServerCursor[CursorRow]cdSr<r_)r@rrr8rrs rBrzAsyncConnection.cursors (+srC)rr8rrAsyncRowFactory[Any] | None)AsyncCursor[Any] | AsyncServerCursor[Any]c||s|j}|r||||||}n|||}|r t|_|S)z\ Return a new `AsyncCursor` to send commands and queries to the connection. )rr8rrr8)_check_connection_okr8r6r5BINARYformat)r@rrr8rrcurs rBrzAsyncConnection.cursors !!### +*K  E,,'%! -CC%%d %DDC  CJ rC)preparerqueryrr Params | Nonerc KdSr<r_)r@rrrrs rBexecutezAsyncConnection.executes 3rCr!c KdSr<r_)r@rrrs rBrzAsyncConnection.execute%s 3rCrcfK |}|r t|_t|tr.|t d|||d{VS||||d{VS#tj$r}| dd}~wwxYw)z8Execute a query and return a cursor to read its results.NzA'execute()' with string template query doesn't support parameters)r) rrrrjr! TypeErrorrrmrxry)r@rrrrrrs rBrzAsyncConnection.execute.s *++--C $# %** I%#6![[[@@@@@@@@@ [[[HHHHHHHHH * * *##D)) ) *sA$B)BB0B++B0cK|j4d{V||d{Vdddd{VdS#1d{VswxYwYdS)z/Commit any pending transaction to the database.N)r?wait _commit_genrs rBrzAsyncConnection.commitIs9 0 0 0 0 0 0 0 0))D,,..// / / / / / / / 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0.A AAcK|j4d{V||d{Vdddd{VdS#1d{VswxYwYdS)z2Roll back to the start of any pending transaction.N)r?r _rollback_genrs rBrzAsyncConnection.rollbackNs9 2 2 2 2 2 2 2 2))D..0011 1 1 1 1 1 1 1 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2rg>@rYrZfloatc K|sdStjr7tj||t d{VdS tj|j d{VdS)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()`. NrYr[) _should_cancelr*has_cancel_saferrt _cancel_genrurh to_threadcancel)r@rZs rB cancel_safezAsyncConnection.cancel_safeSs ""$$  F  ' ) ) )   11N          ' 44444444444rC@cK ||d{VdS#t$r&}td|Yd}~dSd}~wwxYw)NrYzquery cancellation failed: %s)rrrqr)r@rZrs rB _try_cancelzAsyncConnection._try_cancelps @""7"33 3 3 3 3 3 3 3 3 3 @ @ @ NN:B ? ? ? ? ? ? ? ? ? @s" AA  Asavepoint_name str | Noneforce_rollbackAsyncIterator[AsyncTransaction]cKt|||}|jr|4d{V|4d{V|4d{V|WVdddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwYdddd{VdS#1d{VswxYwYdS|4d{V|WVdddd{VdS#1d{VswxYwYdS)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: AsyncTransaction N)r(r9pipeline)r@rrtxs rB transactionzAsyncConnection.transactionvs;dNN C C > }}                DMMOO                                                                                                                                  sj B8BA1B1 A; ;B>A; ?BB8 B B8!B "B88 CCC,, C69C6)rZ stop_after float | NonerAsyncGenerator[Notify]cK|'t|z}t|t}n d}t}d}|jrt jdt |j4d{V|jj }d|j c|_ } |r!|r| WV|dz }|n | t|j|d{V}n,#tj$r} | dd} ~ wwxYw|D]P} t#| j|| j|| jWV|dz }Q|||krn/|r+tt|tz }|dkrn ||_ n #||_ wxYw dddd{VdS#1d{VswxYwYdS)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 these methodsTr r[g)rminru_notify_handlersrrrr?r: _encoding_notifies_backlogpopleftrr'rmrxryr/relnamedecodeextrabe_pid) r@rZrdeadliner\ nreceivedencdpgnsrpgns rBr'zAsyncConnection.notifiess   {{W,H7N33HHH%H    M8    9+ ++ ++ ++ ++ ++ ++ ++ ++'C)-d.D %D "A$ +!"++"#))++----%NI +:)- ( 5 5*3**$$$$$$DD !:::"$"3"3D"9"99:$(++C"( # 2 23 7 7 # 0 0 5 5 # ## &NII"-)z2I2I "#&~x)++7M#N#N#c>>!C!"F*+&&&*****W+ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ ++ +sO%F6$F'/CFD&C;;DBFF6 FF66 GGAsyncIterator[AsyncPipeline]cK|j4d{V||jx}t|x}|_ dddd{Vn#1d{VswxYwY |4d{V|WVdddd{Vn#1d{VswxYwY|jdkrF|j4d{V||jusJd|_dddd{VdS#1d{VswxYwYdSdS#|jdkrD|j4d{V||jusJd|_dddd{Vw#1d{VswxYwYwwxYw)z?  @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ *                                   ~""9********#t~5555%)DN******************************#"x~""9********#t~5555%)DN****************************#sw4A A!$A!)C-1B 7C- BC-BC-2C C"%C"-D>D+D>+ D5 5D>8D5 9D>c6K|jrJt|dx}|_ |4d{V|WVdddd{Vn#1d{VswxYwY|jdksJ||jusJd|_dS#|jdksJ||jusJd|_wxYw)zglike pipeline() but don't acquire a lock. Assume that the caller is holding the lock. T)_no_lockNr)r9r,rrs rB_pipeline_nolockz AsyncConnection._pipeline_nolocksc>!!!$1$$F$F$FF4> "                                   >Q&&&&t~----!DNNN>Q&&&&t~----!DN ! ! ! !s-A7AA7 AA7AA77!Br PQGen[RV]r\rcRK tj||jj|d{VS#t$rq|jjt krZ|dd{V tj||jj|d{Vn#tj $rYnwxYwwxYw)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). r[NrrY) r wait_asyncr:socket _INTERRUPTEDtransaction_statusACTIVErrm QueryCanceled)r@rr\s rBrzAsyncConnection.waits  +C1ChWWWWWWWWW W   {-77&&s&333333333!,S$+2DxXXXXXXXXXXXD  s-&+;B&''BB&B!B& B!!B&valuec2 |ddS)NTrF) _no_set_asyncset_autocommitr@r s rB_set_autocommitzAsyncConnection._set_autocommit! '   | , , , , ,rCcK|j4d{V|||d{Vdddd{VdS#1d{VswxYwYdS)z6Method version of the `~Connection.autocommit` setter.N)r?r_set_autocommit_genrs rBr zAsyncConnection.set_autocommit9 = = = = = = = =))D44U;;<< < < < < < < < = = = = = = = = = = = = = = = = = = = = = = = = = = = = = =/A AAIsolationLevel | Nonec2 |ddS)NTisolation_level)r set_isolation_levelrs rB_set_isolation_levelz$AsyncConnection._set_isolation_levels" ,   0 1 1 1 1 1rCcK|j4d{V|||d{Vdddd{VdS#1d{VswxYwYdS)z;Method version of the `~Connection.isolation_level` setter.N)r?r_set_isolation_level_genrs rBrz#AsyncConnection.set_isolation_level$s$9 B B B B B B B B))D99%@@AA A A A A A A A B B B B B B B B B B B B B B B B B B B B B B B B B B B B B Brc2 |ddS)NT read_only)r  set_read_onlyrs rB_set_read_onlyzAsyncConnection._set_read_only)s! &   { + + + + +rCcK|j4d{V|||d{Vdddd{VdS#1d{VswxYwYdS)z5Method version of the `~Connection.read_only` setter.N)r?r_set_read_only_genrs rBrzAsyncConnection.set_read_only/s9 < < < < < < < <))D33E::;; ; ; ; ; ; ; ; < < < < < < < < < < < < < < < < < < < < < < < < < < < < < >di:gEE--// ! ! ! ! ! ! ! sAB// B9<B9)r:r1r8r7re)rIrJrFrKrGrLrHrMr8rNr5rOrPrrQr )rQr )rrrrrrrQr)rIrJrPrrQr)rQr)rrKrQr)rrKr8rrQr) rrJrrKrrrrKrQr) rrJrrKr8rrrrrKrQr) rrJrrKr8rrrrrKrQrr<) rrrrrrrrKrQr)rr!rrrrKrQr) rrrrrrrrKrQr)rZrrQr)NF)rrrrKrQr)rZrrrLrQr)rQr)rrr\rrQr)r rKrQr)r rrQr)r rrQr)r(rJrQr)r+r,rQr)r+r6rQr)rQr@)-__name__ __module__ __qualname____doc____annotations__rrrrr> classmethodrrrrorr rrrrrrr rr'rrrurrr rrrrr%r$r r0r5r;r?rK __classcell__)rAs@rBr4r4>s.J****7777%%%%#### -1D1Ey,Q,Q 7 7 7 7 7 7 7U!()'+378<UUUUU[Un.444[4 ',FFFFFXF %%%%%%X% "& %%%%%X% "&+++++X+ 37"&      D!% $ X $ X!%* $ ******60000 2222 59:58@@@@@@ HM**.J+J+J+J+J+J+X****$""""(rns= #"""""555555555555******99999999LLLLLLLLLLLLLLLLLL ;;;;;;;;;;;;""""""########NNNNNNNNNN++++++ ))))))%%%%%%''''''------******??????????333333JJJNNN y~      $  &%*,=>L  9 % %rrrrrnS)rrrrrrC