*Jf~dZddlZddlZddlZddlZddlZddlmZm Z m Z m Z ddl m Z mZddlmZmZmZddlmZdd lmZejd ZejZGd d e ZGd de ZGdde Zede efdZdde e efdedefdZej dej!ej"zZ#dedefdZ$de defdZ%dS)z@ Various functionalities to make easier to work with the libpq. N)cast NamedTupleOptionalUnion)PGconnPGresult) ConnStatusTransactionStatusPipelineStatus)cache)pgconn_encodingz psycopg.pqc.eZdZUeed<eed<eed<dS)PGnotifyrelnamebe_pidextraN__name__ __module__ __qualname__bytes__annotations__intR/home/alex/cs2snipeproduction/venv/lib/python3.11/site-packages/psycopg/pq/misc.pyrrs+ NNN KKK LLLLLrrczeZdZUeed<eeed<eeed<eeed<eed<eed<eed<dS) ConninfoOptionkeywordenvvarcompiledvallabeldispchardispsizeN)rrrrrrrrrrr r sd NNN UOuo % LLLOOOMMMMMrr cVeZdZUeed<eed<eed<eed<eed<eed<eed<dS) PGresAttDescnametableidcolumnidformattypidtyplen atttypmodNrrrrr)r)(sO KKK LLLMMM KKK JJJ KKKNNNNNrr)returncrtjdkr!tjd}ntjdkrtjd}|s ddl}|ddg}tj |d}tj |sd}nR#t$r%}td|Yd}~n(d}~wwxYwntjd }|S) Nwin32z libpq.dlldarwinz libpq.dylibr pg_configz--libdirz(couldn't use pg_config to find libpq: %spq)sysplatformctypesutil find_library subprocess check_outputstripdecodeospathjoinexists Exceptionloggerdebug)libnamesplibdirexs rfind_libpq_full_pathrK2s- |w+**;77  ! !+**=99 M M''''+z)BCCIIKKRRTT',,v}==w~~g..#"G M M M GLLLLLLLL M M+**400 Ns$BC%% D/DDutf8objencodingcft|drtt|}|j}n[t|dr'|jt krt |}|j}n$tdt|j |r$t| |d}nd}|S)a0 Return an error message from a `PGconn` or `PGresult`. 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. error_field error_messagez!PGconn or PGresult expected, got replacezno details available) hasattrrr rQstatusOKr TypeErrortyperstrip_severityr?)rMrNbmsgmsgs rrQrQMssM"" R8S!!  o & &R :  &s++H PDII>$ Jru ^ (?: 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+ rZct|}|r"||dd}|S)z2Strip severity and whitespaces from error message.rN)PREFIXESmatchspanr>)rZms rrXrXsCsA!!&&((1+--  99;;rpgconncg}|jtkr-t|jj}|jr|dt |jjz }|jds.| d|j f|j dkr.| d|j f|j |j kr.| d|j f| d|j fnt|jj}dd |D}|rd |d }d |d |S)zN Return summary information on a connection. Useful for __repr__ z , pipeline=/hosts5432portuserdatabase c3 K|] }d|zV dS)z%s=%sNr).0parts r z%connection_summary..s&77gn777777rz ()[])rTrUr transaction_statusr*pipeline_statusr rc startswithappendr?rdredbr rB)r`partsrTspartss rconnection_summaryrvs E }"6#<==B  ! R QN63I$J$J$OQQ QF{%%d++ 9 LL&&+"4"4"6"67 8 8 8 ;' ! ! LL&&+"4"4"6"67 8 8 8 ;&) # # LL&&+"4"4"6"67 8 8 8 j&)"2"2"4"456666FM**/ XX77777 7 7F  f v   r)rL)&__doc__rer@r7logging ctypes.utilr9typingrrrrabcrr _enumsr r r _compatr _encodingsr getLoggerrErUrr r)strrKrQcompileVERBOSE MULTILINEr\rXrvrrrrs0  444444444444!!!!!!!!AAAAAAAAAA((((((  < ( (]z Z:hsm4uVX-.#3J 2:(J-  4!v!#!!!!!!r