ó
    Ð]jŸ  ã                  ó  • % 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  SSK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)ÚTYPE_CHECKINGÚAnyÚProtocolÚ	TypeAliasÚUnion)ÚCallableÚSequenceé   )ÚFormatÚTraceé   )ÚSelf)ÚConninfoOptionÚPGnotifyÚPGresAttDescr   ÚBufferc                  ó$  • \ rS rSr% S\S'   S\S'   \SQS j5       r\SQS j5       rSRS jrSSS	 jr	\
STS
 j5       rSSS jrSSS jrSRS jr\SUS j5       r\
SVS j5       r\
SVS j5       r\
SVS j5       r\
SVS j5       r\
SVS j5       r\
SVS j5       r\
SVS j5       r\
SVS j5       r\
SRS j5       r\
SRS j5       rSWS jr\
SVS j5       rSXSYS jjr\
SZS j5       r\
SRS j5       r\
SRS j5       r\
SRS j5       r \
SRS  j5       r!\
SRS! j5       r"\
S[S" j5       r#\
S[S# j5       r$\
S[S$ j5       r%\
S[S% j5       r&S\S& jr'S]S' jr(S(S(\)RT                  4           S^S) jjr+S(S(\)RT                  4           S_S* jjr, S`       SaS+ jjr-S(\)RT                  4         SbS, jjr. S`       ScS- jjr/  Sd         SeS. jjr0SfS/ jr1SgS0 jr2SfS1 jr3SgS2 jr4SfS3 jr5SgS4 jr6SfS5 jr7SgS6 jr8ShS7 jr9SSS8 jr:SRS9 jr;\
SRS: j5       r<\<Rz                  SiS; j5       r<SRS< jr>SSS= jr?SjS> jr@SkS? jrASlS@ jrBSmSA jrCSnSB jrDS`SoSC jjrESpSD jrFSqSE jrGSrSF jrHSSSG jrI S`       SsSH jjrJStSI jrKSuSJ jrL\
SRSK j5       rMSSSL jrNSSSM jrOSSSN jrPSSSO jrQSPrRg()vÚPGconné   z!Callable[[PGresult], None] | NoneÚnotice_handlerz!Callable[[PGnotify], None] | NoneÚnotify_handlerc                ó   • g ©N© ©ÚclsÚconninfos     ÚK/home/mande/repo/quber/.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   Úfull_protocol_versionÚPGconn.full_protocol_version[   r3   r"   c                ó   • g r   r   r'   s    r   Úserver_versionÚPGconn.server_version^   ó   € Ø%(r"   c                ó   • g r   r   r'   s    r   ÚsocketÚPGconn.socketa   rG   r"   c                ó   • g r   r   r'   s    r   Úbackend_pidÚPGconn.backend_pidd   ó   € Ø"%r"   c                ó   • g r   r   r'   s    r   Úneeds_passwordÚPGconn.needs_passwordg   rk   r"   c                ó   • g r   r   r'   s    r   Úused_passwordÚPGconn.used_passwordj   r}   r"   c                ó   • g r   r   r'   s    r   Úused_gssapiÚPGconn.used_gssapim   s   € Ø#&r"   c                ó   • g r   r   r'   s    r   Ú
ssl_in_useÚPGconn.ssl_in_usep   r„   r"   c                ó   • g r   r   ©r(   Úcommands     r   Úexec_ÚPGconn.exec_s   ó   € °r"   c                ó   • g r   r   r’   s     r   Ú
send_queryÚPGconn.send_queryu   ó   € °#r"   Nc                ó   • g r   r   ©r(   r“   Úparam_valuesÚparam_typesÚparam_formatsÚresult_formats         r   Úexec_paramsÚPGconn.exec_paramsw   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*  r5  )r*  r5  )r*  Úbool)r“   r)  r*  ÚPGresult)r“   r)  r*  r.  )r“   r)  r�   úSequence[Buffer | None] | Nonerž   úSequence[int] | NonerŸ   r9  r    r,  r*  r7  )r“   r)  r�   r8  rž   r9  rŸ   r9  r    r,  r*  r.  r   )rd   r)  r“   r)  rž   r9  r*  r.  )
rd   r)  r�   r8  rŸ   r9  r    r,  r*  r.  )rd   r)  r“   r)  rž   r9  r*  r7  )Nr   )
rd   r)  r�   zSequence[Buffer] | NonerŸ   r9  r    r,  r*  r7  )rd   r)  r*  r7  )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ú   r2  r*  r,  )rÿ   r,  r*  ztuple[int, memoryview])r  r,  r*  r.  )r  r   r*  r.  )r  r)  rE   r)  r  r2  r*  r)  )rE   r)  r  r)  r*  r.  )r  r,  r*  r7  )SÚ__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˜   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)'r7  éï   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ÿ   rX  r"   c                ó   • g r   r   ©r(   Úcolumn_numbers     r   ÚfnameÚPGresult.fname  rÂ   r"   c                ó   • g r   r   r]  s     r   ÚftableÚPGresult.ftable  r–   r"   c                ó   • g r   r   r]  s     r   Ú	ftablecolÚPGresult.ftablecol  rø   r"   c                ó   • g r   r   r]  s     r   ÚfformatÚPGresult.fformat  rš   r"   c                ó   • g r   r   r]  s     r   ÚftypeÚPGresult.ftype
  ó   € °r"   c                ó   • g r   r   r]  s     r   ÚfmodÚPGresult.fmod  s   € ¨sr"   c                ó   • g r   r   r]  s     r   ÚfsizeÚPGresult.fsize  rm  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  rX  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+  r1  r3  r4  )rR  r,  r*  r2  )r^  r,  r*  r2  )r^  r,  r*  r,  )rx  r,  r^  r,  r*  r2  )r  r,  r*  r,  )r*  r2  )r*  z
int | None)rŒ  zlist[PGresAttDesc]r*  r.  )r<  r=  r>  r?  rI  rB  r]   ri   ro   rS  rV  rZ  r_  rb  re  rh  rk  ro  rr  ru  ry  r|  r€  rƒ  r†  r‰  r�  rE  r   r"   r   r7  r7  ï   s§   † Ü àÛ ó Ø àÛ)ó Ø)æ@ä>àÛ!ó Ø!àÛ!ó Ø!ä<ä4ä7ä5ä3ä2ä3àÛ'ó Ø'äQàÛ!ó Ø!ä7àÛ1ó Ø1àÛ/ó Ø/àÛ#ó Ø#çKr"   r7  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)r:  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.socket0  rG   r"   c                ó   • g r   r   r'   s    r   ri   ÚPGcancelConn.error_message3  rk   r"   c                ó   • g r   r   rm   s     r   ro   ÚPGcancelConn.get_error_message6  rg   r"   c                ó   • g r   r   r'   s    r   r5   ÚPGcancelConn.reset8  r7   r"   c                ó   • g r   r   r'   s    r   r-   ÚPGcancelConn.finish:  r/   r"   r   Nr-  r+  r1  r3  r4  )r<  r=  r>  r?  r‘  r”  r—  rB  r]   r   ri   ro   r5   r-   rE  r   r"   r   r:  r:  &  s>   † Ü ä#äàÛ ó Ø àÛ ó Ø àÛ)ó Ø)æ@ä ç!r"   r:  c                  ó(   • \ rS rSrSS jrSS jrSrg)r;  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-  )r<  r=  r>  r?  r§  rª  rE  r   r"   r   r;  r;  =  s   † Üç!r"   r;  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)
ÚConninfoiC  c                ó   • g r   r   )r   s    r   Úget_defaultsÚConninfo.get_defaultsD  s   € Ø36r"   c                ó   • g r   r   r   s     r   ÚparseÚConninfo.parseG  s   € Ø=@r"   c                ó   • g r   r   )r   Úoptss     r   Ú_options_from_arrayÚConninfo._options_from_arrayJ  s   € ØORr"   r   Nr/  )r   r)  r*  r0  )rµ  zSequence[Any]r*  r0  )	r<  r=  r>  r?  rA  r¯  r²  r¶  rE  r   r"   r   r­  r­  C  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)ÚEscapingiN  Nc                ó   • g r   r   )r(   Úconns     r   Ú__init__ÚEscaping.__init__O  rø   r"   c                ó   • g r   r   ©r(   Údatas     r   Úescape_literalÚEscaping.escape_literalQ  rÌ   r"   c                ó   • g r   r   r¿  s     r   Úescape_identifierÚEscaping.escape_identifierS  r¾   r"   c                ó   • g r   r   r¿  s     r   Úescape_stringÚEscaping.escape_stringU  rø   r"   c                ó   • g r   r   r¿  s     r   Úescape_byteaÚEscaping.escape_byteaW  s   € °3r"   c                ó   • g r   r   r¿  s     r   Úunescape_byteaÚEscaping.unescape_byteaY  rÌ   r"   r   r   )r»  zPGconn | None)rÀ  r   r*  r)  )r<  r=  r>  r?  r¼  rÁ  rÄ  rÇ  rÊ  rÍ  rE  r   r"   r   r¹  r¹  N  s   † Þ7ä8ä;ä7ä6ç8r"   r¹  N) Ú__doc__Ú
__future__r   Útypingr   r   r   r   r   Úcollections.abcr	   r
   Ú_enumsr   r   Ú_compatr   Úmiscr   r   r   r)  Ú	bytearrayÚ
memoryviewr   r@  r   r7  r:  r;  r­  r¹  r   r"   r   Ú<module>rØ     s�   ðòõ #ç AÕ Aß .ç !Ý æß<Ñ<ð ˜% ¨JÐ6Ñ7€ˆ	Ó 7ôV.ˆXô V.ôr4Lˆxô 4Lôn"�8ô "ô."ˆxô "ôSˆxô Sô9ˆxõ 9r"   