
    *Jfo                     (   U d Z ddlmZmZmZmZmZmZ ddlmZm	Z	 ddl
mZ ddlmZmZ ddlmZ e	r
dd	lmZmZmZ eeeef         Zeed
<    G d de          Z G d de          Z G d de          Z G d de          Z G d de          ZdS )zP
Protocol objects to represent objects exposed by different pq implementations.
    )AnyCallableListOptionalSequenceTuple)UnionTYPE_CHECKING)	TypeAlias   )FormatTrace   )Protocol)PGnotifyConninfoOptionPGresAttDescBufferc                   .   e Zd ZU eedgdf                  ed<   eedgdf                  ed<   ededd fd            Zededd fd	            Z	de
fd
ZdXdZeded         fd            ZdXdZdXdZde
fdZedede
fd            Zedefd            Zedefd            Zedefd            Zedefd            Zedefd            Zedefd            Zedefd            Zedefd            Zede
fd            Zede
fd            Zdedee         fdZedefd            Zede
fd            Z ede
fd             Z!ede
fd!            Z"ede#fd"            Z$ede#fd#            Z%ede#fd$            Z&d%eddfd&Z'd%eddfd'Z(dde)j*        fd%ed(ee+ee,                           d)ee+e
                  d*ee+e
                  d+e
ddfd,Z-dde)j*        fd%ed(ee+ee,                           d)ee+e
                  d*ee+e
                  d+e
ddfd-Z.	 dYded%ed)ee+e
                  ddfd.Z/de)j*        fded(ee+ee,                           d*ee+e
                  d+e
ddf
d/Z0	 dYded%ed)ee+e
                  ddfd0Z1	 	 dZded(ee+e,                  d*ee+e
                  d+e
ddf
d2Z2deddfd3Z3deddfd4Z4deddfd5Z5deddfd6Z6ded         fd7Z7dXd8Z8de
fd9Z9ede
fd:            Z:e:j;        d;e
ddfd<            Z:de
fd=Z<dXd>Z=d[d@Z>ded         fdAZ?dBe,de
fdCZ@dYdDee         de
fdEZAdFe
deBe
eCf         fdGZDdHe
ddfdIZEdJeFddfdKZGdXdLZH	 dYdMedNedOee         defdPZIdQe
ddfdRZJede
fdS            ZKdXdTZLdXdUZMdXdVZNdXdWZOdS )\PGconnPGresultNnotice_handlerr   notify_handlerconninforeturnc                     d S N clsr   s     Q/home/alex/cs2snipeproduction/venv/lib/python3.11/site-packages/psycopg/pq/abc.pyconnectzPGconn.connect   s    363    c                     d S r   r   r   s     r!   connect_startzPGconn.connect_start   s    9<r#   c                     d S r   r   selfs    r!   connect_pollzPGconn.connect_poll         r#   c                     d S r   r   r'   s    r!   finishzPGconn.finish!   r*   r#   r   c                     d S r   r   r'   s    r!   infozPGconn.info#   s    .1cr#   c                     d S r   r   r'   s    r!   resetzPGconn.reset&   r*   r#   c                     d S r   r   r'   s    r!   reset_startzPGconn.reset_start(   r*   r#   c                     d S r   r   r'   s    r!   
reset_pollzPGconn.reset_poll*   r*   r#   c                     d S r   r   )r(   r   s     r!   pingzPGconn.ping,   s    ,/Cr#   c                     d S r   r   r'   s    r!   dbz	PGconn.db/   s    3r#   c                     d S r   r   r'   s    r!   userzPGconn.user2        Sr#   c                     d S r   r   r'   s    r!   passwordzPGconn.password5       !$r#   c                     d S r   r   r'   s    r!   hostzPGconn.host8   r;   r#   c                     d S r   r   r'   s    r!   hostaddrzPGconn.hostaddr;   r>   r#   c                     d S r   r   r'   s    r!   portzPGconn.port>   r;   r#   c                     d S r   r   r'   s    r!   ttyz
PGconn.ttyA   s    Cr#   c                     d S r   r   r'   s    r!   optionszPGconn.optionsD        #r#   c                     d S r   r   r'   s    r!   statuszPGconn.statusG   r;   r#   c                     d S r   r   r'   s    r!   transaction_statuszPGconn.transaction_statusJ   s    ),r#   namec                     d S r   r   r(   rN   s     r!   parameter_statuszPGconn.parameter_statusM   r*   r#   c                     d S r   r   r'   s    r!   error_messagezPGconn.error_messageO       &)cr#   c                     d S r   r   r'   s    r!   server_versionzPGconn.server_versionR       %(Sr#   c                     d S r   r   r'   s    r!   socketzPGconn.socketU   r;   r#   c                     d S r   r   r'   s    r!   backend_pidzPGconn.backend_pidX       "%#r#   c                     d S r   r   r'   s    r!   needs_passwordzPGconn.needs_password[   rT   r#   c                     d S r   r   r'   s    r!   used_passwordzPGconn.used_password^   rW   r#   c                     d S r   r   r'   s    r!   
ssl_in_usezPGconn.ssl_in_usea   r\   r#   commandc                     d S r   r   r(   rc   s     r!   exec_zPGconn.exec_d   r*   r#   c                     d S r   r   re   s     r!   
send_queryzPGconn.send_queryf   r*   r#   param_valuesparam_typesparam_formatsresult_formatc                     d S r   r   r(   rc   ri   rj   rk   rl   s         r!   exec_paramszPGconn.exec_paramsh   s	     Sr#   c                     d S r   r   rn   s         r!   send_query_paramszPGconn.send_query_paramsq   s	     sr#   c                     d S r   r   r(   rN   rc   rj   s       r!   send_preparezPGconn.send_preparez   s	    
 sr#   c                     d S r   r   r(   rN   ri   rk   rl   s        r!   send_query_preparedzPGconn.send_query_prepared   s	     sr#   c                     d S r   r   rs   s       r!   preparezPGconn.prepare   s	    
 Sr#   r   c                     d S r   r   rv   s        r!   exec_preparedzPGconn.exec_prepared   s	     Sr#   c                     d S r   r   rP   s     r!   describe_preparedzPGconn.describe_prepared   r*   r#   c                     d S r   r   rP   s     r!   send_describe_preparedzPGconn.send_describe_prepared   r*   r#   c                     d S r   r   rP   s     r!   describe_portalzPGconn.describe_portal   r*   r#   c                     d S r   r   rP   s     r!   send_describe_portalzPGconn.send_describe_portal   r*   r#   c                     d S r   r   r'   s    r!   
get_resultzPGconn.get_result   r*   r#   c                     d S r   r   r'   s    r!   consume_inputzPGconn.consume_input   r*   r#   c                     d S r   r   r'   s    r!   is_busyzPGconn.is_busy   r*   r#   c                     d S r   r   r'   s    r!   nonblockingzPGconn.nonblocking   r\   r#   argc                     d S r   r   )r(   r   s     r!   r   zPGconn.nonblocking   s    -0Sr#   c                     d S r   r   r'   s    r!   flushzPGconn.flush   r*   r#   c                     d S r   r   r'   s    r!   set_single_row_modezPGconn.set_single_row_mode   r*   r#   PGcancelc                     d S r   r   r'   s    r!   
get_cancelzPGconn.get_cancel   r*   r#   c                     d S r   r   r'   s    r!   notifieszPGconn.notifies   r*   r#   bufferc                     d S r   r   )r(   r   s     r!   put_copy_datazPGconn.put_copy_data   r*   r#   errorc                     d S r   r   )r(   r   s     r!   put_copy_endzPGconn.put_copy_end   r*   r#   async_c                     d S r   r   )r(   r   s     r!   get_copy_datazPGconn.get_copy_data   r*   r#   filenoc                     d S r   r   )r(   r   s     r!   tracezPGconn.trace   r*   r#   flagsc                     d S r   r   )r(   r   s     r!   set_trace_flagszPGconn.set_trace_flags   r*   r#   c                     d S r   r   r'   s    r!   untracezPGconn.untrace   r*   r#   passwdr:   	algorithmc                     d S r   r   )r(   r   r:   r   s       r!   encrypt_passwordzPGconn.encrypt_password   s    r#   exec_statusc                     d S r   r   )r(   r   s     r!   make_empty_resultzPGconn.make_empty_result   r*   r#   c                     d S r   r   r'   s    r!   pipeline_statuszPGconn.pipeline_status   rT   r#   c                     d S r   r   r'   s    r!   enter_pipeline_modezPGconn.enter_pipeline_mode   r*   r#   c                     d S r   r   r'   s    r!   exit_pipeline_modezPGconn.exit_pipeline_mode   r*   r#   c                     d S r   r   r'   s    r!   pipeline_synczPGconn.pipeline_sync   r*   r#   c                     d S r   r   r'   s    r!   send_flush_requestzPGconn.send_flush_request   r*   r#   r   Nr   )Nr   )r   r   )P__name__
__module____qualname__r   r   __annotations__classmethodbytesr"   r%   intr)   r,   propertyr   r.   r0   r2   r4   r6   r8   r:   r=   r@   rB   rD   rF   rH   rK   rM   rQ   rS   rV   rY   r[   boolr^   r`   rb   rf   rh   r   TEXTr   r   ro   rq   rt   rw   ry   r{   r}   r   r   r   r   r   r   r   setterr   r   r   r   r   r   r   
memoryviewr   r   r   r   r   r   r   r   r   r   r   r   r   r#   r!   r   r      s        XzlD&89::::XzlD&89::::6u6666 [6<U<x<<< [<&c&&&&!!!!1d+,111 X1    &&&&$C$$$$/U/s/// [/E X e    X $%$$$ X$ e    X $%$$$ X$ e    X U X#### X#     X ,C,,, X,CUCxCCCC)u))) X)(((( X(     X %S%%% X%)))) X)(t((( X(%D%%% X%6U6z66665%5D5555 0415#[  x(89: hsm,	
  .  
    0415#[  x(89: hsm,	
  .  
    04	   hsm,	
 
    26#[  x(89:  .	
  
    04	   hsm,	
 
    26  x/0  .	
  
    @e?
????>5>T>>>>=E=j====<<4<<<<5HZ05555((((!!!!!%S%%% X%0s0t000 0s....++++3(:.33337F7s7777EE(5/ESEEEEGCGE#z/,BGGGG-C-D----8U8t8888"""" HL #(5=e_	    ESDZDDDD)))) X)....----((((------r#   r   c                      e Zd ZddZedefd            Zedefd            Zdede	e         fdZ
edefd            Zedefd	            Zd
ede	e         fdZd
edefdZd
edefdZd
edefdZd
edefdZd
edefdZd
edefdZedefd            Zded
ede	e         fdZedefd            ZdedefdZede	e         fd            Zede	e         fd            Zedefd            Zded         ddfdZdS )r   r   Nc                     d S r   r   r'   s    r!   clearzPGresult.clear   r*   r#   c                     d S r   r   r'   s    r!   rK   zPGresult.status   r;   r#   c                     d S r   r   r'   s    r!   rS   zPGresult.error_message   rT   r#   	fieldcodec                     d S r   r   )r(   r   s     r!   error_fieldzPGresult.error_field   r*   r#   c                     d S r   r   r'   s    r!   ntupleszPGresult.ntuples       !cr#   c                     d S r   r   r'   s    r!   nfieldszPGresult.nfields   r   r#   column_numberc                     d S r   r   r(   r   s     r!   fnamezPGresult.fname   r*   r#   c                     d S r   r   r   s     r!   ftablezPGresult.ftable   r*   r#   c                     d S r   r   r   s     r!   	ftablecolzPGresult.ftablecol   r*   r#   c                     d S r   r   r   s     r!   fformatzPGresult.fformat   r*   r#   c                     d S r   r   r   s     r!   ftypezPGresult.ftype   r*   r#   c                     d S r   r   r   s     r!   fmodzPGresult.fmod   r*   r#   c                     d S r   r   r   s     r!   fsizezPGresult.fsize   r*   r#   c                     d S r   r   r'   s    r!   binary_tupleszPGresult.binary_tuples   s    $'Cr#   
row_numberc                     d S r   r   )r(   r   r   s      r!   	get_valuezPGresult.get_value   r*   r#   c                     d S r   r   r'   s    r!   nparamszPGresult.nparams   r   r#   param_numberc                     d S r   r   )r(   r   s     r!   
param_typezPGresult.param_type   r*   r#   c                     d S r   r   r'   s    r!   command_statuszPGresult.command_status   s    14r#   c                     d S r   r   r'   s    r!   command_tupleszPGresult.command_tuples   s    /2sr#   c                     d S r   r   r'   s    r!   	oid_valuezPGresult.oid_value  rI   r#   descriptionsr   c                     d S r   r   )r(   r   s     r!   set_attributeszPGresult.set_attributes  r*   r#   r   )r   r   r   r   r   r   rK   r   rS   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r#   r!   r   r      s                X )u))) X)ASAXe_AAAA!!!! X!!!!! X!?3?8E?????4C4C44447s7s77775S5S5555333333332#2#222233333333's''' X'TCTTTTTT!!!! X!7s7s77774444 X42222 X2#3### X#M4+?MDMMMMMMr#   r   c                       e Zd ZddZddZdS )r   r   Nc                     d S r   r   r'   s    r!   freezPGcancel.free  r*   r#   c                     d S r   r   r'   s    r!   cancelzPGcancel.cancel
  r*   r#   r   )r   r   r   r   r   r   r#   r!   r   r     s(        !!!!!!r#   r   c                       e Zd Zeded         fd            Zededed         fd            Zedee	         ded         fd            Z
dS )	Conninfor   r   c                     d S r   r   )r    s    r!   get_defaultszConninfo.get_defaults  s    58Sr#   r   c                     d S r   r   r   s     r!   parsezConninfo.parse  s    ?Bsr#   optsc                     d S r   r   )r    r  s     r!   _options_from_arrayzConninfo._options_from_array  s    QTQTr#   N)r   r   r   r   r   r   r   r   r   r   r  r   r#   r!   r   r     s        8T"23888 [8BUBt,<'=BBB [BTx}T>N9OTTT [TTTr#   r   c                   x    e Zd Zddee         fdZdedefdZdedefdZ	dedefdZ
dedefd	Zdedefd
ZdS )EscapingNconnc                     d S r   r   )r(   r  s     r!   __init__zEscaping.__init__  r*   r#   datar   c                     d S r   r   r(   r	  s     r!   escape_literalzEscaping.escape_literal  r*   r#   c                     d S r   r   r  s     r!   escape_identifierzEscaping.escape_identifier  r*   r#   c                     d S r   r   r  s     r!   escape_stringzEscaping.escape_string  r*   r#   c                     d S r   r   r  s     r!   escape_byteazEscaping.escape_bytea!  r*   r#   c                     d S r   r   r  s     r!   unescape_byteazEscaping.unescape_bytea#  r*   r#   r   )r   r   r   r   r   r  r   r   r  r  r  r  r  r   r#   r!   r  r    s        ::Xf-::::868e8888;f;;;;;7&7U777766E6666868e888888r#   r  N)__doc__typingr   r   r   r   r   r   r	   r
   typing_extensionsr   _enumsr   r   _compatr   miscr   r   r   r   	bytearrayr   r   r   r   r   r   r   r  r   r#   r!   <module>r     s     B A A A A A A A A A A A A A A A ' ' ' ' ' ' ' ' ' ' ' ' ' ' ! ! ! ! ! ! ! !       =<<<<<<<<<< %J67	 7 7 7z. z. z. z. z.X z. z. z.z2N 2N 2N 2N 2Nx 2N 2N 2Nj" " " " "x " " "U U U U Ux U U U9 9 9 9 9x 9 9 9 9 9r#   