hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[dblink][4.2/4.1] print tx id in sql audit for dblink stmt

Browse Source
This commit is contained in:
jw-guo
2023-08-04 09:24:34 +00:00
committed by ob-robot
parent fe14ddd19f
commit 07b6bb607e
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/sql/dblink/ob_tm_service.cpp
View File

@ -136,6 +136,7 @@ int ObTMService::tm_rm_start(ObExecContext &exec_ctx,
} else { } else {
tx_id = tx_desc->tid(); tx_id = tx_desc->tid();
} }
my_session->get_raw_audit_record().trans_id_ = my_session->get_tx_id();
LOG_INFO("tm rm start", K(ret), K(tx_id), K(xid), K(need_start), K(need_promote)); LOG_INFO("tm rm start", K(ret), K(tx_id), K(xid), K(need_start), K(need_promote));
// TODO, if fail, the trans needs rollback // TODO, if fail, the trans needs rollback
@ -163,6 +164,7 @@ int ObTMService::tm_commit(ObExecContext &exec_ctx,
} else { } else {
ObSQLSessionInfo::LockGuard data_lock_guard(my_session->get_thread_data_lock()); ObSQLSessionInfo::LockGuard data_lock_guard(my_session->get_thread_data_lock());
tx_id = tx_desc->tid(); tx_id = tx_desc->tid();
my_session->get_raw_audit_record().trans_id_ = tx_id;
if (OB_FAIL(xa_service->commit_for_dblink_trans(tx_desc))) { if (OB_FAIL(xa_service->commit_for_dblink_trans(tx_desc))) {
LOG_WARN("fail to commit for dblink trans", K(ret)); LOG_WARN("fail to commit for dblink trans", K(ret));
} else { } else {
@ -197,6 +199,7 @@ int ObTMService::tm_rollback(ObExecContext &exec_ctx,
} else { } else {
ObSQLSessionInfo::LockGuard data_lock_guard(my_session->get_thread_data_lock()); ObSQLSessionInfo::LockGuard data_lock_guard(my_session->get_thread_data_lock());
tx_id = tx_desc->tid(); tx_id = tx_desc->tid();
my_session->get_raw_audit_record().trans_id_ = tx_id;
if (OB_FAIL(xa_service->rollback_for_dblink_trans(tx_desc))) { if (OB_FAIL(xa_service->rollback_for_dblink_trans(tx_desc))) {
LOG_WARN("fail to rollback for dblink trans", K(ret)); LOG_WARN("fail to rollback for dblink trans", K(ret));
} else { } else {