pL ( d dl mZ d dlmZ d dlmZ d dlmZ d dlm Z d dl
mZmZ d dl
mZ d dlmZ d d lmZ d d
lmZ d dlmZ n# e$ r ed w xY werd d
lmZ d dlmZ d dlmZ d dlmZ G d de Zd Z d Z!d Z"d Z#d Z$dS ) )absolute_import text_type)
TYPE_CHECKING)SPANDATA)Hub)IntegrationDidNotEnable)record_sql_queries)
parse_version)Engine)listen)__version__zSQLAlchemy not installed.)Any)ContextManager)Optional)Spanc ( e Zd ZdZed ZdS )SqlalchemyIntegration
sqlalchemyc L t t } | 't d t | dk rt d t t
dt t t
dt t t
dt d S )Nz!Unparsable SQLAlchemy version: {}) z!SQLAlchemy 1.2 or newer required.before_cursor_executeafter_cursor_executehandle_error) r SQLALCHEMY_VERSIONr
formatr r
_before_cursor_execute_after_cursor_execute
_handle_error)versions t/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/sentry_sdk/integrations/sqlalchemy.py
setup_oncez SqlalchemyIntegration.setup_once s 233?3::;MNN
VBCCCv.0FGGGv-/DEEEv~}55555 N)__name__
__module____qualname__
identifierstaticmethodr$ r% r# r r s2 J6 6 \6 6 6r% r c t j }| t d S t |||||r|j r|j j pd | }||_ | } | t | | | |_
d S d S )N)
paramstyleexecutemany)r currentget_integrationr r dialectr- _sentry_sql_span_manager __enter___set_db_data_sentry_sql_span)
conncursor statement
parameterscontextr. argshubctx_mgrspans
r# r r 1 s +C
0119 MwM7?3MUQU
G (/G$DT4 #' r% c l t |dd }| d |_ | d d d d S d S )Nr2 )getattrr2 __exit__)r6 r7 r8 r9 r: r; r= s r# r r J sO +T G +/(tT***** r% c | j }|d S t |dd }|| d t |dd }| d |_ | d d d d S d S )Nr5 internal_errorr2 )execution_contextr@
set_statusr2 rA )r: r; rD r> r= s r# r! r! U s 1 $&8$??D()))
5t G 592tT***** r% c ` t | } d| v rdS d| v rdS d| v rdS d| v rdS d| v rdS d S )Nsqlitepostgres
postgresqlmariadbmysqloracler )names r# _get_db_systemrN m s` T??D4xT|Dy$w4x4r% c t |j j }| | t j | |j j j }| | t j | |j j j }| | t j
| |j j j }|"| t j | d S d S )N)
rN enginerM set_datar DB_SYSTEMurldatabaseDB_NAMEhostSERVER_ADDRESSportSERVER_PORT)r> r6 db_systemdb_nameserver_addressserver_ports r# r4 r4 s t{/00I
h()444ko&G
h&000[_)N!
h-~>>>+/&K
h*K88888 r% N)%
__future__r sentry_sdk._compatr sentry_sdk._typesr sentry_sdk.constsr sentry_sdk.hubr sentry_sdk.integrationsr r
sentry_sdk.tracing_utilsr sentry_sdk.utilsr sqlalchemy.enginer
sqlalchemy.eventr r r r ImportErrortypingr r r sentry_sdk.tracingr r r r r! rN r4 r+ r% r#