o DDiG@s&dZddlmZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl mZddlmZdd lmZmZmZed ZejZGd d d e ZGd dde ZGddde Zed-ddZ d.d/ddZedejejBZ d0ddZ!d1d!d"Z"d2d%d&Z#d3d)d*Z$ed4d+d,Z%dS)5z@ Various functionalities to make easier to work with the libpq. ) annotationsN) NamedTuple)Path)cache)abc) ConnStatusPipelineStatusTransactionStatusz psycopg.pqc@s&eZdZUded<ded<ded<dS)PGnotifybytesrelnameintbe_pidextraN__name__ __module__ __qualname____annotations__rrH/var/www/Datamplify/venv/lib/python3.10/site-packages/psycopg/pq/misc.pyr s  r c@sFeZdZUded<ded<ded<ded<ded<ded<d ed <d S) ConninfoOptionr keywordz bytes | NoneenvvarcompiledvallabeldispcharrdispsizeNrrrrrr   rc@sFeZdZUded<ded<ded<ded<ded<ded<ded <d S) PGresAttDescr namertableidcolumnidformattypidtyplen atttypmodNrrrrrr!*r r!return str | Nonec Cstjdkrtjd}durdStt|}|Stjdkrhtjd}|sfz$ddl}| ddg }t j t j |d}sJd}W|SW|Stye}z td|WYd}~|Sd}~ww|Stjd }|S) Nwin32z libpq.dlldarwinz libpq.dylibr pg_configz--libdirz(couldn't use pg_config to find libpq: %spq)sysplatformctypesutil find_librarystrrresolve subprocess check_outputstripdecodeospathexistsjoin Exceptionloggerdebug)libnamesplibdirexrrrfind_libpq_full_path4s0   rEobj,abc.PGconn | abc.PGresult | abc.PGcancelConnencodingr4cCs|r||S|S)a= Return an error message from a `PGconn`, `PGresult`, `PGcancelConn`. The return value is a `!str` (unlike pq data which is usually `!bytes`): use the connection encoding if available, otherwise the `!encoding` parameter as a fallback for decoding. Don't raise exceptions on decoding errors. )get_error_message)rGrIrrr error_messageOsrKu ^ (?: DEBUG | INFO | HINWEIS | WARNUNG | FEHLER | LOG | FATAL | PANIK # de | DEBUG | INFO | NOTICE | WARNING | ERROR | LOG | FATAL | PANIC # en | DEBUG | INFO | NOTICE | WARNING | ERROR | LOG | FATAL | PANIC # es | DEBUG | INFO | NOTICE | ATTENTION | ERREUR | LOG | FATAL | PANIC # fr | DEBUG | INFO | NOTICE | PERINGATAN | ERROR | LOG | FATAL | PANIK # id | DEBUG | INFO | NOTIFICA | ATTENZIONE | ERRORE | LOG | FATALE | PANICO # it | DEBUG | INFO | NOTICE | WARNING | ERROR | LOG | FATAL | PANIC # ja | 디버그 | 정보 | 알림 | 경고 | 오류 | 로그 | 치명적오류 | 손상 # ko | DEBUG | INFORMACJA | UWAGA | OSTRZEŻENIE | BŁĄD | DZIENNIK | KATASTROFALNY | PANIKA # pl | DEPURAÇÃO | INFO | NOTA | AVISO | ERRO | LOG | FATAL | PÂNICO # pt_BR | ОТЛАДКА | ИНФОРМАЦИЯ | ЗАМЕЧАНИЕ | ПРЕДУПРЕЖДЕНИЕ | ОШИБКА | СООБЩЕНИЕ | ВАЖНО | ПАНИКА # ru | DEBUG | INFO | NOTIS | VARNING | FEL | LOGG | FATALT | PANIK # sv | DEBUG | BİLGİ | NOT | UYARI | HATA | LOG | ÖLÜMCÜL\ \(FATAL\) | KRİTİK # tr | НАЛАГОДЖЕННЯ | ІНФОРМАЦІЯ | ПОВІДОМЛЕННЯ | ПОПЕРЕДЖЕННЯ | ПОМИЛКА | ЗАПИСУВАННЯ | ФАТАЛЬНО | ПАНІКА # uk | 调试 | 信息 | 注意 | 警告 | 错误 | 日志 | 致命错误 | 比致命错误还过分的错误 # zh_CN ) : \s+ msgcCs*t|}r||dd}|S)z2Strip severity and whitespaces from error message.rN)PREFIXESmatchspanr8)rLmrrrstrip_severitysrQr cCs||d}r t|SdS)Nreplacezno error details available)r9rQ)rLrIsmsgrrr_clean_error_messagesrTpgconn abc.PGconncCsg}|jtkrYt|jj}|jr|dt|jj7}|jds+| d|j f|j p2t }dkr>| d|f|j |jkrN| d|j f| d|j fnzt|jj}Wntyqd|jd }Ynwd d d |D}rd |d}d|d|S)zN Return summary information on a connection. Useful for __repr__ z , pipeline=/host5432portuserdatabasezstatus=z (unkndown) css|]}d|VqdS)z%s=%sNr).0partrrr sz%connection_summary..z ()[])statusOKr transaction_statusr"pipeline_statusr rX startswithappendr9rZget_compiled_portr[dbr ValueErrorr=)rUpartsrdrZspartsrrrconnection_summarys(      roversionrcCsNt|d\}}t|d\}}|dkr|dkr|d|S|d|d|S)zs Return a pretty representation of a PostgreSQL version For instance: 140002 -> 14.2, 90610 -> 9.6.10 d r.)divmod)rppatchmajorminorrrrversion_prettys rxcCs(ddlm}|d}|r|jr|jSdS)z0Return the default port compiled with the libpq.r) get_param_defrZrF)psycopg._conninfo_utilsryr)ryinforrrrjs rj)r)r*)rF)rGrHrIr4r)r4)rLr4r)r4)rLr rIr4r)r4)rUrVr)r4)rprr)r4)r)r4)&__doc__ __future__rr:rer/logging ctypes.utilr1typingrpathlibr functoolsrrFr_enumsrr r getLoggerr?rer rr!rErKcompileVERBOSE MULTILINErMrQrTrorxrjrrrrs>              #