YtjLvdZddlmZddlZddlZddlmZddlmZddl 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-d dl.m/Z/m0Z0d dl1m2Z2d dl3m4Z4m5Z5m6Z6d dl3m7Z7d dl8m9Z9d dl:m;Z;d dlm?Z?d dl@mAZAd dlBmCZCd dlDmEZEmFZFmGZGe rd dlHmIZIdZJejKjLZLejKjMZMejNjOZOejNjPZPejNjQZQeRZSejTd ZUGd!d"eEe$ZVdS)#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?psycopgceZdZUdZdZded<ded<ded<d ed <eeeefd|fd Z e d}ddddddd~d!Z dd"Z dd*Z e dd-Zdd.Zedd/dd2Zedd/dd5Zedddd6dd<Zedddd6dd>Z d}ddddd?ddBZe ddddCddIZedddCddKZ ddddCddMZddNZddOZdPdQddTZdUdQddVZe ddd[Zddd\dd`ZeddbZeddcZefddhZddjZddkZddmZ ddnZ!ddoZ"ddpZ#ddqZ$ddrZ%dduZ&ddvZ'dddxZ(dddyZ)dd{Z*xZ+S) Connectionz3 Wrapper for a connection to the database. r2ztype[Cursor[Row]]cursor_factoryztype[ServerCursor[Row]]server_cursor_factoryRowFactory[Row] row_factoryzPipeline | None _pipelinepgconnr1ct|||_t|_t |_t|_dSN) super__init__r8r#lockr r5r,r6)selfr:r8 __class__s P/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/psycopg/connection.pyr>zConnection.__init__FsF    &FF $%1"""FN) autocommitprepare_thresholdcontextr8r5conninfostrrFboolrG int | NonerHAdaptContext | NoneRowFactory[Row] | Nonetype[Cursor[Row]] | Nonekwargsrreturnr!c |j|fi|}t|} d} t|} g} | D]?} | d| d| df}d|z}td| t di| }||| }tj |t } td |n#tj $rK}td |t|| ||fYd}~d}~wtj$r}|dd}~wwxYw| s| d d }t#| dkr|dt|g}|d|d| Dt'|d||j}|dt-jr5| jjr)t3|st5jdt8t;|| _|r|| _|r|| _ |rtC|j"| _#|| _$| S)zV Connect to a database server and return a new `Connection` instance. Nhostporthostaddrz host: %r, port: %r, hostaddr: %rzconnection attempt: %srDtimeoutintervalzconnection succeeded: %szconnection failed: %s: %srr z7Multiple connection attempts failed. All failures were:c3,K|]\}}d|d|VdS)z- z: N).0errordescrs rB z%Connection.connect..s7PPLE5/u////PPPPPPrC )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)%_get_connection_paramsr'r$getloggerdebugr& _connect_genr wait_conn_WAIT_INTERVALeErrorrJappend _NO_TRACEBACKwith_tracebacklenextendtypejoinr:r+has_used_gssapi used_gssapir-warningswarnRuntimeWarningrK _autocommitr8r5radapters _adaptersrG)clsrIrFrGrHr8r5rPparamsrWrvattempts conn_errorsattempttdescrr_genexlast_exlinesnew_exs rBconnectzConnection.connectQs ,+H????'// $V,,13   Gkk&))7;;v+>+> J@W@WXF6?E LL15 9 9 9 (77w77&&x&AA&s^DDD 7???7 0 0 0 8%RIII""B;////////? . . .''--- .  .!"oa(G;1$$,,T222\\NE LLR S S S LLPPKPPP Q Q Q"T']]499U#3#3GNKKKF''-- -  ( * *  % &f--  MH    j))  )(BN  / .B   9&w'788BL0 s%>C00E1?AEE1E,,E1c|Sr<r\r@s rB __enter__zConnection.__enter__s rCexc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | NoneNonec$|jrdS|rI |nG#t$r&}td||Yd}~nd}~wwxYw|t |dds|dSdS)Nz#error ignored in rollback on %s: %s_pool)closedrollback Exceptionrewarningcommitgetattrclose)r@rrrexc2s rB__exit__zConnection.__exit__s ;  F   R  R R RDdDQQQQQQQQ R KKMMMtWd++  JJLLLLL  s" AA  Arrc t|fi|S)z3Manipulate connection parameters before connecting.)r%)r{rIrPs rBrcz!Connection._get_connection_paramss 33F333rCc|jrdSt|dd}|r(t|ddr||dSd|_|jdS)zClose the database connection.Nr close_returnsFT)rrputconn_closedr:finish)r@pools rBrzConnection.closesw ;  FtWd++  GD/599  LL    F  rC)binaryr Cursor[Row]cdSr<r\)r@rs rBcursorzConnection.cursors>AcrCRowFactory[CursorRow]Cursor[CursorRow]cdSr<r\)r@rr8s rBrzConnection.cursors  CrC)r scrollablewithholdnamer bool | NonerServerCursor[Row]cdSr<r\)r@rrrrs rBrzConnection.cursors  CrCServerCursor[CursorRow]cdSr<r\)r@rrr8rrs rBrzConnection.cursors #&#rC)rr8rrRowFactory[Any] | NoneCursor[Any] | ServerCursor[Any]c||s|j}|r||||||}n|||}|r t|_|S)zW Return a new `Cursor` to send commands and queries to the connection. )rr8rrr8)_check_connection_okr8r6r5BINARYformat)r@rrr8rrcurs rBrzConnection.cursors !!### +*K  E,,'%! -CC%%d %DDC  CJ rC)preparerqueryrr| Params | NonercdSr<r\)r@rr|rrs rBexecutezConnection.executes crCr"cdSr<r\)r@rrrs rBrzConnection.executes crCrcJ |}|r t|_t|tr(|t d|||S||||S#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) rrr isinstancer" TypeErrorrrjrmrn)r@rr|rrrrs rBrzConnection.executes *++--C $# %** C%#[{{5'{:::{{5&'{BBB * * *##D)) ) *sAA9!A99B"BB"c|j5||ddddS#1swxYwYdS)z/Commit any pending transaction to the database.N)r?wait _commit_genrs rBrzConnection.commit.s Y * * IId&&(( ) ) ) * * * * * * * * * * * * * * * * * *(=AAc|j5||ddddS#1swxYwYdS)z2Roll back to the start of any pending transaction.N)r?r _rollback_genrs rBrzConnection.rollback3s Y , , IId((** + + + , , , , , , , , , , , , , , , , , ,rg>@rVrWfloatc|sdStjr1tj||t dS|dS)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()`. NrVrX)_should_cancelr+has_cancel_saferrh _cancel_genricancel)r@rWs rB cancel_safezConnection.cancel_safe8s{ ""$$  F  ' ) )      11N       KKMMMMMrC@c ||dS#t$r&}td|Yd}~dSd}~wwxYw)NrVzquery cancellation failed: %s)rrrer)r@rWrs rB _try_cancelzConnection._try_cancelRso @   W  - - - - - @ @ @ NN:B ? ? ? ? ? ? ? ? ? @s A AA savepoint_name str | Noneforce_rollbackIterator[Transaction]c#jKt|||}|jry|5|5|5|Vdddn #1swxYwYdddn #1swxYwYddddS#1swxYwYdS|5|VddddS#1swxYwYdS)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*r9pipeline)r@rrtxs rB transactionzConnection.transactionXs~~ > > >   "  dmmoo                                                                      sjBA/A A/A A/A A/# B/A3 3B6A3 7BB B B((B,/B,)rW stop_after float | NonerGenerator[Notify]c#^K|'t|z}t|t}n d}t}d}|jrt jdt |j5|jj }d|j c|_ } |r |r| V|dz }|n | t|j|}n,#tj$r} | dd} ~ wwxYw|D]O} t#| j|| j|| jV|dz }P|||krn/|r+tt|tz }|dkrn||_ n #||_ wxYw ddddS#1swxYwYdS)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 rXg)rminri_notify_handlersrurvrwr?r: _encoding_notifies_backlogpopleftrr)rjrmrnr0relnamedecodeextrabe_pid) r@rWrdeadlinerY nreceivedencdpgnsrpgns rBr)zConnection.notifiesmsb   {{W,H7N33HHH%H    MR    Y( +( ++'C*.t/E %D "A! +"++"#))++---%NI +:#'99Xdk-B-BX9#V#VDD :::"$"3"3D"9"99:$(++C"( # 2 23 7 7 # 0 0 5 5 # ## &NII"-)z2I2I "#&~x)++7M#N#N#c>>!="@*+&&&****&Q( +( +( +( +( +( +( +( +( +( +( +( +( +( +( +( +( +( +sOF"<#F )C  F C3C..C33B FF" FF""F&)F&Iterator[Pipeline]c#K|j5||jx}t|x}|_dddn #1swxYwY |5|Vdddn #1swxYwY|jdkr4|j5||jusJd|_ddddS#1swxYwYdSdS#|jdkr2|j5||jusJd|_dddw#1swxYwYwwxYw)z  ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; *                 ~""Y**#t~5555%)DN******************#"x~""Y**#t~5555%)DN****************#sw4A  AAB5A) B5)A--B50A-1B5B&&B*-B*5C4C' C4'C+ +C4.C+ /C4c#K|jrJt|dx}|_ |5|Vdddn #1swxYwY|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_nolockzConnection._pipeline_nolocks>!!!$,TD$A$A$AA4> "                 >Q&&&&t~----!DNNN>Q&&&&t~----!DN ! ! ! !s'A$8 A$<A$<A$$!Br PQGen[RV]rYrc* tj||jj|S#t$re|jjt krN|d tj||jj|n#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). rXrrV) rrr:socket _INTERRUPTEDtransaction_statusACTIVErrj QueryCanceled)r@rrYs rBrzConnection.waits <T[%7(KKK K   {-77   ---Ldk&88LLLLLD  s- #5B!A;:B;B  B B  Bvaluec0||dSr<)set_autocommitr@rs rB_set_autocommitzConnection._set_autocommit E"""""rCc|j5|||ddddS#1swxYwYdS)z6Method version of the `~Connection.autocommit` setter.N)r?r_set_autocommit_genrs rBrzConnection.set_autocommit Y 7 7 IId..u55 6 6 6 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7)>AAIsolationLevel | Nonec0||dSr<)set_isolation_levelrs rB_set_isolation_levelzConnection._set_isolation_levels   '''''rCc|j5|||ddddS#1swxYwYdS)z;Method version of the `~Connection.isolation_level` setter.N)r?r_set_isolation_level_genrs rBr zConnection.set_isolation_levels Y < < IId33E:: ; ; ; < < < < < < < < < < < < < < < < <  A AA AA B"A<<BXid | str | Nonec|j5||d|ddddS#1swxYwYdS)z: Commit a prepared two-phase transaction. COMMITNr?r_tpc_finish_genrs rB tpc_commitzConnection.tpc_commit!sY ; ; IId**8S99 : : : ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ;*?AAc|j5||d|ddddS#1swxYwYdS)z= Roll back a prepared two-phase transaction. ROLLBACKNr%rs rB tpc_rollbackzConnection.tpc_rollback(sY = = IId**:s;; < < < = = = = = = = = = = = = = = = = = =r( list[Xid]c||jj}|t t j5}|t j| }dddn #1swxYwY|tkr)|jjtkr| |S)Nr) _check_tpcinforrrr _from_recordr_get_recover_queryfetchallIDLEINTRANSr)r@statusrress rB tpc_recoverzConnection.tpc_recover/s - [[Xc.>%?%?[ @ @ !C KK.00 1 1 1,,..C ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! T>>di:gEE MMOOO s;BBB)r:r1r8r7rb)rIrJrFrKrGrLrHrMr8rNr5rOrPrrQr!)rQr!)rrrrrrrQr)rIrJrPrrQr)rQr)rrKrQr)rrKr8rrQr) rrJrrKrrrrKrQr) rrJrrKr8rrrrrKrQr) rrJrrKr8rrrrrKrQrr<) rrr|rrrrrKrQr)rr"rrrrKrQr) rrr|rrrrrKrQr)rWrrQr)NF)rrrrKrQr)rWrrrLrQr)rQr)rrrYrrQr)rrKrQr)rrrQr)rrrQr)rrrQr)rr"rQr)rQr,),__name__ __module__ __qualname____doc____annotations__rrrrr> classmethodrrrrcrr rrrrrrr rr)rrrirrrr r rrrrrr!r'r+r7 __classcell__)rAs@rBr4r4:sJ%%%%2222     (,tJsOY'G'G 2 2 2 2 2 2 2D!()'+.237DDDDD[DL.444[4 ',AAAAAXA %     X  "&      X  "&&&&&&X& .2"&      D!% $ X9=eX!%* $ ******2**** ,,,, /34/2@@@@@@ HM^**.E+E+E+E+E+E+N***^*$"""^"(6D(####7777 ((((<<<< """"6666 ####7777 00009999;;;;;=====        rCr4)Wr; __future__rloggingrutimertypesrtypingrrrr contextlibr collections.abcr r rDrrjrrabcrrrrrrrr_tpcrrowsrrrradaptr_enumsrrr _compatr!r"_acompatr#rIr$r%r&r'r9r( generatorsr)rr* _capabilitiesr+_server_cursorr,_conninfo_utilsr-_connection_baser.r/r0pq.abcr1riFormatTEXTrTransactionStatusr3rr4KeyboardInterruptr getLoggerrer4r\rCrBrXs #"""""555555555555%%%%%%////////LLLLLLLLLLLLLLLLLL 666666666666""""""########HHHHHHHHHH++++++ $$$$$$''''''((((((------?????????? y~      $  &  9 % %$rC