
    ,ho                       % S r SSKJ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  \\\\4   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)Union)TYPE_CHECKINGAnyCallableProtocolSequence   )FormatTrace   )Self	TypeAlias)ConninfoOptionPGnotifyPGresAttDescr   Bufferc                     \ rS rSr% S\S'   S\S'   \SPS j5       r\SPS j5       rSQS jrSRS	 jr	\
SSS
 j5       rSRS jrSRS jrSQS jr\STS j5       r\
SUS j5       r\
SUS j5       r\
SUS j5       r\
SUS j5       r\
SUS j5       r\
SUS j5       r\
SUS j5       r\
SUS j5       r\
SQS j5       r\
SQS j5       rSVS jr\
SUS j5       rSWSXS jjr\
SYS j5       r\
SQS j5       r\
SQS j5       r\
SQS j5       r \
SQS  j5       r!\
SZS! j5       r"\
SZS" j5       r#\
SZS# j5       r$\
SZS$ j5       r%S[S% jr&S\S& jr'S'S'\(RR                  4           S]S( jjr*S'S'\(RR                  4           S^S) jjr+ S_       S`S* jjr,S'\(RR                  4         SaS+ jjr- S_       SbS, jjr.  Sc         SdS- jjr/SeS. jr0SfS/ jr1SeS0 jr2SfS1 jr3SeS2 jr4SfS3 jr5SeS4 jr6SfS5 jr7SgS6 jr8SRS7 jr9SQS8 jr:\
SQS9 j5       r;\;Rx                  ShS: j5       r;SQS; jr=SRS< jr>SiS= jr?SjS> jr@SkS? jrASlS@ jrBSmSA jrCS_SnSB jjrDSoSC jrESpSD jrFSqSE jrGSRSF jrH S_       SrSG jjrISsSH jrJStSI jrK\
SQSJ j5       rLSRSK jrMSRSL jrNSRSM jrOSRSN jrPSOrQg')uPGconn   z!Callable[[PGresult], None] | Nonenotice_handlerz!Callable[[PGnotify], None] | Nonenotify_handlerc                    g N clsconninfos     I/var/www/html/Ai_home/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-   r3   r"   c                    g r   r   r'   s    r   db	PGconn.db0   s    r"   c                    g r   r   r'   s    r   userPGconn.user3        r"   c                    g r   r   r'   s    r   passwordPGconn.password6       !$r"   c                    g r   r   r'   s    r   hostPGconn.host9   rG   r"   c                    g r   r   r'   s    r   hostaddrPGconn.hostaddr<   rK   r"   c                    g r   r   r'   s    r   portPGconn.port?   rG   r"   c                    g r   r   r'   s    r   tty
PGconn.ttyB   s    r"   c                    g r   r   r'   s    r   optionsPGconn.optionsE        #r"   c                    g r   r   r'   s    r   statusPGconn.statusH   rG   r"   c                    g r   r   r'   s    r   transaction_statusPGconn.transaction_statusK   s    ),r"   c                    g r   r   r(   names     r   parameter_statusPGconn.parameter_statusN       Sr"   c                    g r   r   r'   s    r   error_messagePGconn.error_messageP       &)r"   c                    g r   r   r(   encodings     r   get_error_messagePGconn.get_error_messageS   rg   r"   c                    g r   r   r'   s    r   	_encodingPGconn._encodingU   r[   r"   c                    g r   r   r'   s    r   protocol_versionPGconn.protocol_versionX   s    '*r"   c                    g r   r   r'   s    r   server_versionPGconn.server_version[       %(r"   c                    g r   r   r'   s    r   socketPGconn.socket^   rG   r"   c                    g r   r   r'   s    r   backend_pidPGconn.backend_pida       "%r"   c                    g r   r   r'   s    r   needs_passwordPGconn.needs_passwordd   rk   r"   c                    g r   r   r'   s    r   used_passwordPGconn.used_passwordg   rz   r"   c                    g r   r   r'   s    r   used_gssapiPGconn.used_gssapij   s    #&r"   c                    g r   r   r'   s    r   
ssl_in_usePGconn.ssl_in_usem   r   r"   c                    g r   r   r(   commands     r   exec_PGconn.exec_p       r"   c                    g r   r   r   s     r   
send_queryPGconn.send_queryr       #r"   Nc                    g r   r   r(   r   param_valuesparam_typesparam_formatsresult_formats         r   exec_paramsPGconn.exec_paramst   s     r"   c                    g r   r   r   s         r   send_query_paramsPGconn.send_query_params}   s     r"   c                    g r   r   r(   rd   r   r   s       r   send_preparePGconn.send_prepare   s    
 r"   c                    g r   r   r(   rd   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   rc   s     r   describe_preparedPGconn.describe_prepared   s    #r"   c                    g r   r   rc   s     r   send_describe_preparedPGconn.send_describe_prepared       3r"   c                    g r   r   rc   s     r   describe_portalPGconn.describe_portal       r"   c                    g r   r   rc   s     r   send_describe_portalPGconn.send_describe_portal       r"   c                    g r   r   rc   s     r   close_preparedPGconn.close_prepared   s    sr"   c                    g r   r   rc   s     r   send_close_preparedPGconn.send_close_prepared   r   r"   c                    g r   r   rc   s     r   close_portalPGconn.close_portal       Sr"   c                    g r   r   rc   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(   passwdrE   	algorithms       r   encrypt_passwordPGconn.encrypt_password   s    r"   c                    g r   r   )r(   rE   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   rk   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&  )rd   r&  r'  bytes | None.rn   strr'  r2  )r'  r2  )r'  bool)r   r&  r'  PGresult)r   r&  r'  r+  )r   r&  r   Sequence[Buffer | None] | Noner   Sequence[int] | Noner   r6  r   r)  r'  r4  )r   r&  r   r5  r   r6  r   r6  r   r)  r'  r+  r   )rd   r&  r   r&  r   r6  r'  r+  )
rd   r&  r   r5  r   r6  r   r)  r'  r+  )rd   r&  r   r&  r   r6  r'  r4  )Nr   )
rd   r&  r   zSequence[Buffer] | Noner   r6  r   r)  r'  r4  )rd   r&  r'  r4  )rd   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&  rE   r&  r  r/  r'  r&  )rE   r&  r  r&  r'  r+  )r  r)  r'  r4  )R__name__
__module____qualname____firstlineno____annotations__classmethodr    r$   r)   r-   propertyr1   r5   r9   r<   r?   rB   rE   rI   rM   rP   rS   rV   rY   r]   r`   re   ri   ro   rr   ru   rx   r|   r   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)'r4     c                    g r   r   r'   s    r   clearPGresult.clear   r7   r"   c                    g r   r   r'   s    r   r]   PGresult.status   rG   r"   c                    g r   r   r'   s    r   ri   PGresult.error_message   rk   r"   c                    g r   r   rm   s     r   ro   PGresult.get_error_message   rg   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   rU  r"   c                    g r   r   r(   column_numbers     r   fnamePGresult.fname   r   r"   c                    g r   r   rZ  s     r   ftablePGresult.ftable  r   r"   c                    g r   r   rZ  s     r   	ftablecolPGresult.ftablecol  r   r"   c                    g r   r   rZ  s     r   fformatPGresult.fformat  r   r"   c                    g r   r   rZ  s     r   ftypePGresult.ftype      r"   c                    g r   r   rZ  s     r   fmodPGresult.fmod	  s    sr"   c                    g r   r   rZ  s     r   fsizePGresult.fsize  rj  r"   c                    g r   r   r'   s    r   binary_tuplesPGresult.binary_tuples  s    $'r"   c                    g r   r   )r(   
row_numberr[  s      r   	get_valuePGresult.get_value  s    cr"   c                    g r   r   r'   s    r   nparamsPGresult.nparams  rU  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  r3   r"   c                    g r   r   r'   s    r   	oid_valuePGresult.oid_value  r[   r"   c                    g r   r   )r(   descriptionss     r   set_attributesPGresult.set_attributes   s    r"   r   Nr*  r(  r.  r0  r1  )rO  r)  r'  r/  )r[  r)  r'  r/  )r[  r)  r'  r)  )ru  r)  r[  r)  r'  r/  )r|  r)  r'  r)  )r'  r/  )r'  z
int | None)r  zlist[PGresAttDesc]r'  r+  )r9  r:  r;  r<  rF  r?  r]   ri   ro   rP  rS  rW  r\  r_  rb  re  rh  rl  ro  rr  rv  ry  r}  r  r  r  r  rB  r   r"   r   r4  r4     s        ) )@>! !! !<475323' 'Q! !71 1/ /# #Kr"   r4  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)r7  i#  c                    g r   r   r'   s    r   startPGcancelConn.start$  r7   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*  rG   r"   c                    g r   r   r'   s    r   r|   PGcancelConn.socket-  rG   r"   c                    g r   r   r'   s    r   ri   PGcancelConn.error_message0  rk   r"   c                    g r   r   rm   s     r   ro   PGcancelConn.get_error_message3  rg   r"   c                    g r   r   r'   s    r   r5   PGcancelConn.reset5  r7   r"   c                    g r   r   r'   s    r   r-   PGcancelConn.finish7  r/   r"   r   Nr*  r(  r.  r0  r1  )r9  r:  r;  r<  r  r  r  r?  r]   r|   ri   ro   r5   r-   rB  r   r"   r   r7  r7  #  s>     #      ) )@ !r"   r7  c                  (    \ rS rSrSS jrSS jrSrg)r8  i:  c                    g r   r   r'   s    r   freePGcancel.free;  r   r"   c                    g r   r   r'   s    r   cancelPGcancel.cancel=  r/   r"   r   Nr*  )r9  r:  r;  r<  r  r  rB  r   r"   r   r8  r8  :  s    !r"   r8  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)
Conninfoi@  c                    g r   r   )r   s    r   get_defaultsConninfo.get_defaultsA  s    36r"   c                    g r   r   r   s     r   parseConninfo.parseD  s    =@r"   c                    g r   r   )r   optss     r   _options_from_arrayConninfo._options_from_arrayG  s    ORr"   r   Nr,  )r   r&  r'  r-  )r  zSequence[Any]r'  r-  )	r9  r:  r;  r<  r>  r  r  r  rB  r   r"   r   r  r  @  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)EscapingiK  Nc                    g r   r   )r(   conns     r   __init__Escaping.__init__L  r   r"   c                    g r   r   r(   datas     r   escape_literalEscaping.escape_literalN  r   r"   c                    g r   r   r  s     r   escape_identifierEscaping.escape_identifierP  r   r"   c                    g r   r   r  s     r   escape_stringEscaping.escape_stringR  r   r"   c                    g r   r   r  s     r   escape_byteaEscaping.escape_byteaT  s    3r"   c                    g r   r   r  s     r   unescape_byteaEscaping.unescape_byteaV  r   r"   r   r   )r  zPGconn | None)r  r   r'  r&  )r9  r:  r;  r<  r  r  r  r  r  r  rB  r   r"   r   r  r  K  s    78;768r"   r  N)__doc__
__future__r   typingr   r   r   r   r   r	   _enumsr   r   _compatr   r   miscr   r   r   r&  	bytearray
memoryviewr   r=  r   r4  r7  r8  r  r  r   r"   r   <module>r     s    #  C C ! %<< %J67	 7S.X S.l4Lx 4Ln"8 "."x "Sx S9x 9r"   