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

[CP] [to #55847301] fix: use plan sql id instead of session sql id in remote executeion sql audit

Browse Source
This commit is contained in:
0xacc
2024-04-08 12:32:52 +00:00
committed by ob-robot
parent 0a8539f2ae
commit 4718c98e28
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/sql/executor/ob_remote_executor_processor.cpp
View File

@ -565,7 +565,14 @@ void ObRemoteBaseExecuteP<T>::record_sql_audit_and_plan_stat(
audit_record.seq_ = 0; //don't use now
audit_record.status_ =
(OB_SUCCESS == ret || common::OB_ITER_END == ret) ? obmysql::REQUEST_SUCC : ret;
session->get_cur_sql_id(audit_record.sql_id_, OB_MAX_SQL_ID_LENGTH + 1);
if (OB_NOT_NULL(plan)) {
const ObString &sql_id = plan->get_sql_id_string();
int64_t length = sql_id.length();
MEMCPY(audit_record.sql_id_, sql_id.ptr(), std::min(length, OB_MAX_SQL_ID_LENGTH));
audit_record.sql_id_[OB_MAX_SQL_ID_LENGTH] = '\0';
} else {
session->get_cur_sql_id(audit_record.sql_id_, OB_MAX_SQL_ID_LENGTH + 1);
}
audit_record.db_id_ = session->get_database_id();
audit_record.execution_id_ = session->get_current_execution_id();
audit_record.client_addr_ = session->get_client_addr();