
    (ph                       % S r SSKJr  SSKJrJrJrJrJr  SSK	J
r
Jr  SSKJrJr  \(       a
  SSKJrJrJr  S	rS
\S'    " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      rg)zP
Protocol objects to represent objects exposed by different pq implementations.
    )annotations)AnyCallableProtocolSequenceTYPE_CHECKING   )FormatTrace   )Self	TypeAlias)PGnotifyConninfoOptionPGresAttDesczbytes | bytearray | memoryviewr   Bufferc                     \ rS rSr% S\S'   S\S'   \SNS j5       r\SNS j5       rSOS jrSPS	 jr	\
SQS
 j5       rSPS jrSPS jrSOS jr\SRS j5       r\
SSS j5       r\
SSS j5       r\
SSS j5       r\
SSS j5       r\
SSS j5       r\
SSS j5       r\
SSS j5       r\
SSS j5       r\
SOS j5       r\
SOS j5       rSTS jr\
SSS j5       rSUSVS jjr\
SWS j5       r\
SOS j5       r\
SOS j5       r\
SOS j5       r \
SXS  j5       r!\
SXS! j5       r"\
SXS" j5       r#SYS# jr$SZS$ jr%S%S%\&RN                  4           S[S& jjr(S%S%\&RN                  4           S\S' jjr) S]       S^S( jjr*S%\&RN                  4         S_S) jjr+ S]       S`S* jjr,  Sa         SbS+ jjr-ScS, jr.SdS- jr/ScS. jr0SdS/ jr1ScS0 jr2SdS1 jr3ScS2 jr4SdS3 jr5SeS4 jr6SPS5 jr7SOS6 jr8\
SOS7 j5       r9\9Rt                  SfS8 j5       r9SOS9 jr;SPS: jr<SgS; jr=ShS< jr>SiS= jr?SjS> jr@SkS? jrAS]SlS@ jjrBSmSA jrCSnSB jrDSoSC jrESPSD jrF S]       SpSE jjrGSqSF jrHSrSG jrI\
SOSH j5       rJSPSI jrKSPSJ jrLSPSK jrMSPSL jrNSMrOg%)sPGconn   z!Callable[[PGresult], None] | Nonenotice_handlerz!Callable[[PGnotify], None] | Nonenotify_handlerc                    g N clsconninfos     A/var/www/html/venv/lib/python3.13/site-packages/psycopg/pq/abc.pyconnectPGconn.connect   s    /2    c                    g r   r   r   s     r   connect_startPGconn.connect_start   s    58r!   c                    g r   r   selfs    r   connect_pollPGconn.connect_poll       3r!   c                    g r   r   r&   s    r   finishPGconn.finish!       cr!   c                    g r   r   r&   s    r   infoPGconn.info#       ,/r!   c                    g r   r   r&   s    r   resetPGconn.reset&       Sr!   c                    g r   r   r&   s    r   reset_startPGconn.reset_start(   r*   r!   c                    g r   r   r&   s    r   
reset_pollPGconn.reset_poll*   s    r!   c                    g r   r   )r'   r   s     r   pingPGconn.ping,   r2   r!   c                    g r   r   r&   s    r   db	PGconn.db/   s    r!   c                    g r   r   r&   s    r   userPGconn.user2        r!   c                    g r   r   r&   s    r   passwordPGconn.password5       !$r!   c                    g r   r   r&   s    r   hostPGconn.host8   rF   r!   c                    g r   r   r&   s    r   hostaddrPGconn.hostaddr;   rJ   r!   c                    g r   r   r&   s    r   portPGconn.port>   rF   r!   c                    g r   r   r&   s    r   tty
PGconn.ttyA   s    r!   c                    g r   r   r&   s    r   optionsPGconn.optionsD        #r!   c                    g r   r   r&   s    r   statusPGconn.statusG   rF   r!   c                    g r   r   r&   s    r   transaction_statusPGconn.transaction_statusJ   s    ),r!   c                    g r   r   r'   names     r   parameter_statusPGconn.parameter_statusM       Sr!   c                    g r   r   r&   s    r   error_messagePGconn.error_messageO       &)r!   c                    g r   r   r'   encodings     r   get_error_messagePGconn.get_error_messageR   rf   r!   c                    g r   r   r&   s    r   	_encodingPGconn._encodingT   rZ   r!   c                    g r   r   r&   s    r   server_versionPGconn.server_versionW       %(r!   c                    g r   r   r&   s    r   socketPGconn.socketZ   rF   r!   c                    g r   r   r&   s    r   backend_pidPGconn.backend_pid]       "%r!   c                    g r   r   r&   s    r   needs_passwordPGconn.needs_password`   rj   r!   c                    g r   r   r&   s    r   used_passwordPGconn.used_passwordc   rv   r!   c                    g r   r   r&   s    r   
ssl_in_usePGconn.ssl_in_usef   r}   r!   c                    g r   r   r'   commands     r   exec_PGconn.exec_i       r!   c                    g r   r   r   s     r   
send_queryPGconn.send_queryk       #r!   Nc                    g r   r   r'   r   param_valuesparam_typesparam_formatsresult_formats         r   exec_paramsPGconn.exec_paramsm   s     r!   c                    g r   r   r   s         r   send_query_paramsPGconn.send_query_paramsv   s     r!   c                    g r   r   r'   rc   r   r   s       r   send_preparePGconn.send_prepare   s    
 r!   c                    g r   r   r'   rc   r   r   r   s        r   send_query_preparedPGconn.send_query_prepared   s     r!   c                    g r   r   r   s       r   preparePGconn.prepare   s    
 r!   c                    g r   r   r   s        r   exec_preparedPGconn.exec_prepared   s     r!   c                    g r   r   rb   s     r   describe_preparedPGconn.describe_prepared   s    #r!   c                    g r   r   rb   s     r   send_describe_preparedPGconn.send_describe_prepared       3r!   c                    g r   r   rb   s     r   describe_portalPGconn.describe_portal       r!   c                    g r   r   rb   s     r   send_describe_portalPGconn.send_describe_portal       r!   c                    g r   r   rb   s     r   close_preparedPGconn.close_prepared   s    sr!   c                    g r   r   rb   s     r   send_close_preparedPGconn.send_close_prepared   r   r!   c                    g r   r   rb   s     r   close_portalPGconn.close_portal       Sr!   c                    g r   r   rb   s     r   send_close_portalPGconn.send_close_portal   s    cr!   c                    g r   r   r&   s    r   
get_resultPGconn.get_result   s    Sr!   c                    g r   r   r&   s    r   consume_inputPGconn.consume_input       Sr!   c                    g r   r   r&   s    r   is_busyPGconn.is_busy   r.   r!   c                    g r   r   r&   s    r   nonblockingPGconn.nonblocking   r}   r!   c                    g r   r   )r'   args     r   r   r      s    -0r!   c                    g r   r   r&   s    r   flushPGconn.flush       Cr!   c                    g r   r   r&   s    r   set_single_row_modePGconn.set_single_row_mode       3r!   c                    g r   r   )r'   sizes     r   set_chunked_rows_modePGconn.set_chunked_rows_mode   r   r!   c                    g r   r   r&   s    r   cancel_connPGconn.cancel_conn   r   r!   c                    g r   r   r&   s    r   
get_cancelPGconn.get_cancel   s    cr!   c                    g r   r   r&   s    r   notifiesPGconn.notifies   r   r!   c                    g r   r   )r'   buffers     r   put_copy_dataPGconn.put_copy_data       Cr!   c                    g r   r   )r'   errors     r   put_copy_endPGconn.put_copy_end       sr!   c                    g r   r   )r'   async_s     r   get_copy_dataPGconn.get_copy_data   s    Cr!   c                    g r   r   )r'   filenos     r   tracePGconn.trace       #r!   c                    g r   r   )r'   flagss     r   set_trace_flagsPGconn.set_trace_flags   r   r!   c                    g r   r   r&   s    r   untracePGconn.untrace   s    sr!   c                    g r   r   )r'   passwdrD   	algorithms       r   encrypt_passwordPGconn.encrypt_password   s    r!   c                    g r   r   )r'   rD   r  s      r   change_passwordPGconn.change_password   s    3r!   c                    g r   r   )r'   exec_statuss     r   make_empty_resultPGconn.make_empty_result   r   r!   c                    g r   r   r&   s    r   pipeline_statusPGconn.pipeline_status   rj   r!   c                    g r   r   r&   s    r   enter_pipeline_modePGconn.enter_pipeline_mode   r   r!   c                    g r   r   r&   s    r   exit_pipeline_modePGconn.exit_pipeline_mode   r   r!   c                    g r   r   r&   s    r   pipeline_syncPGconn.pipeline_sync   r   r!   c                    g r   r   r&   s    r   send_flush_requestPGconn.send_flush_request   r   r!   r   )r   bytesreturnr   r   intr   Noner   list[ConninfoOption])r   r  r   r"  r   r  )rc   r  r   bytes | None.rm   strr   r+  )r   r+  )r   bool)r   r  r   PGresult)r   r  r   r$  )r   r  r   Sequence[Buffer | None] | Noner   Sequence[int] | Noner   r/  r   r"  r   r-  )r   r  r   r.  r   r/  r   r/  r   r"  r   r$  r   )rc   r  r   r  r   r/  r   r$  )
rc   r  r   r.  r   r/  r   r"  r   r$  )rc   r  r   r  r   r/  r   r-  )Nr   )
rc   r  r   zSequence[Buffer] | Noner   r/  r   r"  r   r-  )rc   r  r   r-  )rc   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  rD   r  r  r(  r   r  )rD   r  r  r  r   r$  )r  r"  r   r-  )P__name__
__module____qualname____firstlineno____annotations__classmethodr   r#   r(   r,   propertyr0   r4   r8   r;   r>   rA   rD   rH   rL   rO   rR   rU   rX   r\   r_   rd   rh   rn   rq   rt   rx   r{   r   r   r   r   r   r
   TEXTr   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  __static_attributes__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                  N   \ rS rSrSS jr\SS j5       r\SS j5       rSSS jjrSS jr	\SS j5       r
\SS j5       rS S	 jrS!S
 jrS!S jrS!S jrS!S jrS!S jrS!S jr\SS j5       rS"S jr\SS j5       rS#S jr\S$S j5       r\S%S j5       r\SS j5       rS&S jrSrg)'r-     c                    g r   r   r&   s    r   clearPGresult.clear   r6   r!   c                    g r   r   r&   s    r   r\   PGresult.status   rF   r!   c                    g r   r   r&   s    r   rh   PGresult.error_message   rj   r!   c                    g r   r   rl   s     r   rn   PGresult.get_error_message   rf   r!   c                    g r   r   )r'   	fieldcodes     r   error_fieldPGresult.error_field   r   r!   c                    g r   r   r&   s    r   ntuplesPGresult.ntuples       !r!   c                    g r   r   r&   s    r   nfieldsPGresult.nfields   rN  r!   c                    g r   r   r'   column_numbers     r   fnamePGresult.fname   r   r!   c                    g r   r   rS  s     r   ftablePGresult.ftable   r   r!   c                    g r   r   rS  s     r   	ftablecolPGresult.ftablecol   r   r!   c                    g r   r   rS  s     r   fformatPGresult.fformat   r   r!   c                    g r   r   rS  s     r   ftypePGresult.ftype       r!   c                    g r   r   rS  s     r   fmodPGresult.fmod  s    sr!   c                    g r   r   rS  s     r   fsizePGresult.fsize  rc  r!   c                    g r   r   r&   s    r   binary_tuplesPGresult.binary_tuples  s    $'r!   c                    g r   r   )r'   
row_numberrT  s      r   	get_valuePGresult.get_value	  s    cr!   c                    g r   r   r&   s    r   nparamsPGresult.nparams  rN  r!   c                    g r   r   )r'   param_numbers     r   
param_typePGresult.param_type  r   r!   c                    g r   r   r&   s    r   command_statusPGresult.command_status  s    .1r!   c                    g r   r   r&   s    r   command_tuplesPGresult.command_tuples  r2   r!   c                    g r   r   r&   s    r   	oid_valuePGresult.oid_value  rZ   r!   c                    g r   r   )r'   descriptionss     r   set_attributesPGresult.set_attributes  s    r!   r   Nr#  r!  r'  r)  r*  )rH  r"  r   r(  )rT  r"  r   r(  )rT  r"  r   r"  )rn  r"  rT  r"  r   r(  )ru  r"  r   r"  )r   r(  )r   z
int | None)r  zlist[PGresAttDesc]r   r$  )r2  r3  r4  r5  r?  r8  r\   rh   rn   rI  rL  rP  rU  rX  r[  r^  ra  re  rh  rk  ro  rr  rv  ry  r|  r  r  r;  r   r!   r   r-  r-     s        ) )@>! !! !<475323' 'Q! !71 1/ /# #Kr!   r-  c                      \ rS rSrSS jrSS jrSS jr\SS j5       r\SS j5       r	\SS j5       r
SSS jjrSS	 jrSS
 jrSrg)r0  i  c                    g r   r   r&   s    r   startPGcancelConn.start  r6   r!   c                    g r   r   r&   s    r   blockingPGcancelConn.blocking  s    r!   c                    g r   r   r&   s    r   pollPGcancelConn.poll!  s    3r!   c                    g r   r   r&   s    r   r\   PGcancelConn.status#  rF   r!   c                    g r   r   r&   s    r   rx   PGcancelConn.socket&  rF   r!   c                    g r   r   r&   s    r   rh   PGcancelConn.error_message)  rj   r!   c                    g r   r   rl   s     r   rn   PGcancelConn.get_error_message,  rf   r!   c                    g r   r   r&   s    r   r4   PGcancelConn.reset.  r6   r!   c                    g r   r   r&   s    r   r,   PGcancelConn.finish0  r.   r!   r   Nr#  r!  r'  r)  r*  )r2  r3  r4  r5  r  r  r  r8  r\   rx   rh   rn   r4   r,   r;  r   r!   r   r0  r0    s>     #      ) )@ !r!   r0  c                  (    \ rS rSrSS jrSS jrSrg)r1  i3  c                    g r   r   r&   s    r   freePGcancel.free4  r   r!   c                    g r   r   r&   s    r   cancelPGcancel.cancel6  r.   r!   r   Nr#  )r2  r3  r4  r5  r  r  r;  r   r!   r   r1  r1  3  s    !r!   r1  c                  P    \ rS rSr\SS j5       r\SS j5       r\S	S j5       rSrg)
Conninfoi9  c                    g r   r   )r   s    r   get_defaultsConninfo.get_defaults:  s    36r!   c                    g r   r   r   s     r   parseConninfo.parse=  s    =@r!   c                    g r   r   )r   optss     r   _options_from_arrayConninfo._options_from_array@  s    ORr!   r   Nr%  )r   r  r   r&  )r  zSequence[Any]r   r&  )	r2  r3  r4  r5  r7  r  r  r  r;  r   r!   r   r  r  9  s,    6 6@ @R Rr!   r  c                  T    \ rS rSrS
SS jjrSS jrSS jrSS jrSS jrSS jr	S	r
g)EscapingiD  Nc                    g r   r   )r'   conns     r   __init__Escaping.__init__E  r   r!   c                    g r   r   r'   datas     r   escape_literalEscaping.escape_literalG  r   r!   c                    g r   r   r  s     r   escape_identifierEscaping.escape_identifierI  r   r!   c                    g r   r   r  s     r   escape_stringEscaping.escape_stringK  r   r!   c                    g r   r   r  s     r   escape_byteaEscaping.escape_byteaM  s    3r!   c                    g r   r   r  s     r   unescape_byteaEscaping.unescape_byteaO  r   r!   r   r   )r  zPGconn | None)r  r   r   r  )r2  r3  r4  r5  r  r  r  r  r  r  r;  r   r!   r   r  r  D  s    78;768r!   r  N)__doc__
__future__r   typingr   r   r   r   r   _enumsr
   r   _compatr   r   miscr   r   r   r   r6  r   r-  r0  r1  r  r  r   r!   r   <module>r     s    # C C ! %<< 5	 4M.X M.`4Lx 4Ln"8 "."x "Sx S9x 9r!   