
    2i                       U d Z ddlmZ ddlmZmZmZmZmZ ddl	m
Z
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d
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 G d de      Zy)zP
Protocol objects to represent objects exposed by different pq implementations.
    )annotations)TYPE_CHECKINGAnyProtocol	TypeAliasUnion)CallableSequence   )FormatTrace   )Self)ConninfoOptionPGnotifyPGresAttDescr   Bufferc                  x   e Zd ZU ded<   ded<   edOd       ZedOd       ZdPdZdQdZe	dRd	       Z
dQd
ZdQdZdPdZedSd       Ze	dTd       Ze	dTd       Ze	dTd       Ze	dTd       Ze	dTd       Ze	dTd       Ze	dTd       Ze	dTd       Ze	dPd       Ze	dPd       ZdUdZe	dTd       ZdVdWdZe	dXd       Ze	dPd       Ze	dPd       Ze	dPd       Ze	dPd       Z e	dPd        Z!e	dYd!       Z"e	dYd"       Z#e	dYd#       Z$e	dYd$       Z%dZd%Z&d[d&Z'd'd'e(jR                  f	 	 	 	 	 	 	 	 	 	 	 d\d(Z*d'd'e(jR                  f	 	 	 	 	 	 	 	 	 	 	 d]d)Z+	 d^	 	 	 	 	 	 	 d_d*Z,d'e(jR                  f	 	 	 	 	 	 	 	 	 d`d+Z-	 d^	 	 	 	 	 	 	 dad,Z.	 	 db	 	 	 	 	 	 	 	 	 dcd-Z/ddd.Z0ded/Z1ddd0Z2ded1Z3ddd2Z4ded3Z5ddd4Z6ded5Z7dfd6Z8dQd7Z9dPd8Z:e	dPd9       Z;e;jx                  dgd:       Z;dPd;Z=dQd<Z>dhd=Z?did>Z@djd?ZAdkd@ZBdldAZCd^dmdBZDdndCZEdodDZFdpdEZGdQdFZH	 d^	 	 	 	 	 	 	 dqdGZIdrdHZJdsdIZKe	dPdJ       ZLdQdKZMdQdLZNdQdMZOdQdNZPy')tPGconnz!Callable[[PGresult], None] | Nonenotice_handlerz!Callable[[PGnotify], None] | Nonenotify_handlerc                     y N clsconninfos     M/var/www/html/secretsanta/venv/lib/python3.12/site-packages/psycopg/pq/abc.pyconnectzPGconn.connect   s    /2    c                     y r   r   r   s     r   connect_startzPGconn.connect_start   s    58r    c                     y r   r   selfs    r   connect_pollzPGconn.connect_poll        r    c                     y r   r   r$   s    r   finishzPGconn.finish"   r'   r    c                     y r   r   r$   s    r   infozPGconn.info$       ,/r    c                     y r   r   r$   s    r   resetzPGconn.reset'   r'   r    c                     y r   r   r$   s    r   reset_startzPGconn.reset_start)   r'   r    c                     y r   r   r$   s    r   
reset_pollzPGconn.reset_poll+   r'   r    c                     y r   r   )r%   r   s     r   pingzPGconn.ping-   r,   r    c                     y r   r   r$   s    r   dbz	PGconn.db0   s    r    c                     y r   r   r$   s    r   userzPGconn.user3        r    c                     y r   r   r$   s    r   passwordzPGconn.password6       !$r    c                     y r   r   r$   s    r   hostzPGconn.host9   r9   r    c                     y r   r   r$   s    r   hostaddrzPGconn.hostaddr<   r<   r    c                     y r   r   r$   s    r   portzPGconn.port?   r9   r    c                     y r   r   r$   s    r   ttyz
PGconn.ttyB   s    r    c                     y r   r   r$   s    r   optionszPGconn.optionsE        #r    c                     y r   r   r$   s    r   statuszPGconn.statusH   r9   r    c                     y r   r   r$   s    r   transaction_statuszPGconn.transaction_statusK   s    ),r    c                     y r   r   r%   names     r   parameter_statuszPGconn.parameter_statusN   r'   r    c                     y r   r   r$   s    r   error_messagezPGconn.error_messageP       &)r    c                     y r   r   r%   encodings     r   get_error_messagezPGconn.get_error_messageS   r'   r    c                     y r   r   r$   s    r   	_encodingzPGconn._encodingU   rG   r    c                     y r   r   r$   s    r   protocol_versionzPGconn.protocol_versionX   s    '*r    c                     y r   r   r$   s    r   full_protocol_versionzPGconn.full_protocol_version[   r,   r    c                     y r   r   r$   s    r   server_versionzPGconn.server_version^       %(r    c                     y r   r   r$   s    r   socketzPGconn.socketa   r9   r    c                     y r   r   r$   s    r   backend_pidzPGconn.backend_pidd       "%r    c                     y r   r   r$   s    r   needs_passwordzPGconn.needs_passwordg   rR   r    c                     y r   r   r$   s    r   used_passwordzPGconn.used_passwordj   r_   r    c                     y r   r   r$   s    r   used_gssapizPGconn.used_gssapim   s    #&r    c                     y r   r   r$   s    r   
ssl_in_usezPGconn.ssl_in_usep   rd   r    c                     y r   r   r%   commands     r   exec_zPGconn.exec_s   r'   r    c                     y r   r   rn   s     r   
send_queryzPGconn.send_queryu   r'   r    Nc                     y r   r   r%   ro   param_valuesparam_typesparam_formatsresult_formats         r   exec_paramszPGconn.exec_paramsw   s     r    c                     y r   r   rt   s         r   send_query_paramszPGconn.send_query_params   s     r    c                     y r   r   r%   rN   ro   rv   s       r   send_preparezPGconn.send_prepare   s    
 r    c                     y r   r   r%   rN   ru   rw   rx   s        r   send_query_preparedzPGconn.send_query_prepared   s     r    c                     y r   r   r}   s       r   preparezPGconn.prepare   s    
 r    c                     y r   r   r   s        r   exec_preparedzPGconn.exec_prepared   s     r    c                     y r   r   rM   s     r   describe_preparedzPGconn.describe_prepared   r'   r    c                     y r   r   rM   s     r   send_describe_preparedzPGconn.send_describe_prepared   r'   r    c                     y r   r   rM   s     r   describe_portalzPGconn.describe_portal   r'   r    c                     y r   r   rM   s     r   send_describe_portalzPGconn.send_describe_portal   r'   r    c                     y r   r   rM   s     r   close_preparedzPGconn.close_prepared   r'   r    c                     y r   r   rM   s     r   send_close_preparedzPGconn.send_close_prepared   r'   r    c                     y r   r   rM   s     r   close_portalzPGconn.close_portal   r'   r    c                     y r   r   rM   s     r   send_close_portalzPGconn.send_close_portal   r'   r    c                     y r   r   r$   s    r   
get_resultzPGconn.get_result   r'   r    c                     y r   r   r$   s    r   consume_inputzPGconn.consume_input   r'   r    c                     y r   r   r$   s    r   is_busyzPGconn.is_busy   r'   r    c                     y r   r   r$   s    r   nonblockingzPGconn.nonblocking   rd   r    c                     y r   r   )r%   args     r   r   zPGconn.nonblocking   s    -0r    c                     y r   r   r$   s    r   flushzPGconn.flush   r'   r    c                     y r   r   r$   s    r   set_single_row_modezPGconn.set_single_row_mode   r'   r    c                     y r   r   )r%   sizes     r   set_chunked_rows_modezPGconn.set_chunked_rows_mode   r'   r    c                     y r   r   r$   s    r   cancel_connzPGconn.cancel_conn   r'   r    c                     y r   r   r$   s    r   
get_cancelzPGconn.get_cancel   r'   r    c                     y r   r   r$   s    r   notifieszPGconn.notifies   r'   r    c                     y r   r   )r%   buffers     r   put_copy_datazPGconn.put_copy_data   r'   r    c                     y r   r   )r%   errors     r   put_copy_endzPGconn.put_copy_end   r'   r    c                     y r   r   )r%   async_s     r   get_copy_datazPGconn.get_copy_data   r'   r    c                     y r   r   )r%   filenos     r   tracezPGconn.trace   r'   r    c                     y r   r   )r%   flagss     r   set_trace_flagszPGconn.set_trace_flags   r'   r    c                     y r   r   r$   s    r   untracezPGconn.untrace   r'   r    c                     y r   r   )r%   passwdr8   	algorithms       r   encrypt_passwordzPGconn.encrypt_password   s    r    c                     y r   r   )r%   r8   r   s      r   change_passwordzPGconn.change_password   r'   r    c                     y r   r   )r%   exec_statuss     r   make_empty_resultzPGconn.make_empty_result   r'   r    c                     y r   r   r$   s    r   pipeline_statuszPGconn.pipeline_status   rR   r    c                     y r   r   r$   s    r   enter_pipeline_modezPGconn.enter_pipeline_mode   r'   r    c                     y r   r   r$   s    r   exit_pipeline_modezPGconn.exit_pipeline_mode   r'   r    c                     y r   r   r$   s    r   pipeline_synczPGconn.pipeline_sync   r'   r    c                     y r   r   r$   s    r   send_flush_requestzPGconn.send_flush_request   r'   r    )r   bytesreturnr   r   intr   Noner   list[ConninfoOption])r   r   r   r   r   r   )rN   r   r   bytes | None.rU   strr   r   )r   r   )r   bool)ro   r   r   PGresult)ro   r   r   r   )ro   r   ru   Sequence[Buffer | None] | Nonerv   Sequence[int] | Nonerw   r   rx   r   r   r   )ro   r   ru   r   rv   r   rw   r   rx   r   r   r   r   )rN   r   ro   r   rv   r   r   r   )
rN   r   ru   r   rw   r   rx   r   r   r   )rN   r   ro   r   rv   r   r   r   )Nr   )
rN   r   ru   zSequence[Buffer] | Nonerw   r   rx   r   r   r   )rN   r   r   r   )rN   r   r   r   )r   zPGresult | None)r   r   r   r   )r   r   r   r   )r   PGcancelConn)r   PGcancel)r   zPGnotify | None)r   r   r   r   )r   r   r   r   )r   r   r   ztuple[int, memoryview])r   r   r   r   )r   r   r   r   )r   r   r8   r   r   r   r   r   )r8   r   r   r   r   r   )r   r   r   r   )Q__name__
__module____qualname____annotations__classmethodr   r"   r&   r)   propertyr+   r.   r0   r2   r4   r6   r8   r;   r>   r@   rB   rD   rF   rI   rK   rO   rQ   rV   rX   rZ   r\   r^   ra   rc   rf   rh   rj   rl   rp   rr   r   TEXTry   r{   r~   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   setterr   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   55552 28 8&!/ / &$/ /    $ $   $ $    # #   , ,@) )@# #* */ /( (   % %) )( (& &% %45 -1.2#[[ 5 *	
 ,  
 -1.2#[[ 5 *	
 ,  
 -1	  *	
 
 /3#[[ 5 ,	
  
 -1	  *	
 
 /3 . ,	
  
 >>;<:;890(!% %0 0.;.).7BG-8" EI#(5A	 GB) ).-(-r    r   c                     e Zd ZddZedd       Zedd       ZdddZddZedd       Z	edd       Z
ddZdd	Zdd
ZddZddZddZddZedd       Zd dZedd       Zd!dZed"d       Zed#d       Zedd       Zd$dZy)%r   c                     y r   r   r$   s    r   clearzPGresult.clear   r'   r    c                     y r   r   r$   s    r   rI   zPGresult.status   r9   r    c                     y r   r   r$   s    r   rQ   zPGresult.error_message   rR   r    c                     y r   r   rT   s     r   rV   zPGresult.get_error_message   r'   r    c                     y r   r   )r%   	fieldcodes     r   error_fieldzPGresult.error_field   r'   r    c                     y r   r   r$   s    r   ntupleszPGresult.ntuples       !r    c                     y r   r   r$   s    r   nfieldszPGresult.nfields   r   r    c                     y r   r   r%   column_numbers     r   fnamezPGresult.fname  r'   r    c                     y r   r   r   s     r   ftablezPGresult.ftable  r'   r    c                     y r   r   r   s     r   	ftablecolzPGresult.ftablecol  r'   r    c                     y r   r   r   s     r   fformatzPGresult.fformat  r'   r    c                     y r   r   r   s     r   ftypezPGresult.ftype
  r'   r    c                     y r   r   r   s     r   fmodzPGresult.fmod  r'   r    c                     y r   r   r   s     r   fsizezPGresult.fsize  r'   r    c                     y r   r   r$   s    r   binary_tupleszPGresult.binary_tuples  s    $'r    c                     y r   r   )r%   
row_numberr   s      r   	get_valuezPGresult.get_value  r'   r    c                     y r   r   r$   s    r   nparamszPGresult.nparams  r   r    c                     y r   r   )r%   param_numbers     r   
param_typezPGresult.param_type  r'   r    c                     y r   r   r$   s    r   command_statuszPGresult.command_status  s    .1r    c                     y r   r   r$   s    r   command_tupleszPGresult.command_tuples  r,   r    c                     y r   r   r$   s    r   	oid_valuezPGresult.oid_value   rG   r    c                     y r   r   )r%   descriptionss     r   set_attributeszPGresult.set_attributes#  r'   r    Nr   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   r   )r   r   )r   z
int | None)r  zlist[PGresAttDesc]r   r   )r   r   r   r   r   rI   rQ   rV   r   r   r   r   r   r  r  r  r  r	  r  r  r  r  r  r  r  r  r   r    r   r   r      s        ) )@>! !! !<475323' 'Q! !71 1/ /# #Kr    r   c                  t    e Zd ZddZddZddZedd       Zedd       Zedd       Z	dddZ
ddZdd	Zy
)r   c                     y r   r   r$   s    r   startzPGcancelConn.start'  r'   r    c                     y r   r   r$   s    r   blockingzPGcancelConn.blocking)  r'   r    c                     y r   r   r$   s    r   pollzPGcancelConn.poll+  r'   r    c                     y r   r   r$   s    r   rI   zPGcancelConn.status-  r9   r    c                     y r   r   r$   s    r   ra   zPGcancelConn.socket0  r9   r    c                     y r   r   r$   s    r   rQ   zPGcancelConn.error_message3  rR   r    c                     y r   r   rT   s     r   rV   zPGcancelConn.get_error_message6  r'   r    c                     y r   r   r$   s    r   r.   zPGcancelConn.reset8  r'   r    c                     y r   r   r$   s    r   r)   zPGcancelConn.finish:  r'   r    Nr   r   r   r   r   )r   r   r   r  r!  r#  r   rI   ra   rQ   rV   r.   r)   r   r    r   r   r   &  s>     #      ) )@ !r    r   c                      e Zd ZddZddZy)r   c                     y r   r   r$   s    r   freezPGcancel.free>  r'   r    c                     y r   r   r$   s    r   cancelzPGcancel.cancel@  r'   r    Nr   )r   r   r   r,  r.  r   r    r   r   r   =  s    !r    r   c                  B    e Zd Zedd       Zedd       Zedd       Zy)Conninfoc                     y r   r   )r   s    r   get_defaultszConninfo.get_defaultsD  s    36r    c                     y r   r   r   s     r   parsezConninfo.parseG  s    =@r    c                     y r   r   )r   optss     r   _options_from_arrayzConninfo._options_from_arrayJ  s    ORr    Nr   )r   r   r   r   )r6  zSequence[Any]r   r   )r   r   r   r   r2  r4  r7  r   r    r   r0  r0  C  s,    6 6@ @R Rr    r0  c                  >    e Zd Zdd	dZd
dZd
dZd
dZd
dZd
dZy)EscapingNc                     y r   r   )r%   conns     r   __init__zEscaping.__init__O  r'   r    c                     y r   r   r%   datas     r   escape_literalzEscaping.escape_literalQ  r'   r    c                     y r   r   r>  s     r   escape_identifierzEscaping.escape_identifierS  r'   r    c                     y r   r   r>  s     r   escape_stringzEscaping.escape_stringU  r'   r    c                     y r   r   r>  s     r   escape_byteazEscaping.escape_byteaW  r'   r    c                     y r   r   r>  s     r   unescape_byteazEscaping.unescape_byteaY  r'   r    r   )r;  zPGconn | None)r?  r   r   r   )	r   r   r   r<  r@  rB  rD  rF  rH  r   r    r   r9  r9  N  s    78;768r    r9  N) __doc__
__future__r   typingr   r   r   r   r   collections.abcr	   r
   _enumsr   r   _compatr   miscr   r   r   r   	bytearray
memoryviewr   r   r   r   r   r   r0  r9  r   r    r   <module>rR     s    # A A . ! << %J67	 7V.X V.r4Lx 4Ln"8 "."x "Sx S9x 9r    