diff --git a/src/observer/ob_inner_sql_connection.cpp b/src/observer/ob_inner_sql_connection.cpp index c5883f3ad..4637dbde7 100644 --- a/src/observer/ob_inner_sql_connection.cpp +++ b/src/observer/ob_inner_sql_connection.cpp @@ -580,9 +580,8 @@ int ObInnerSQLConnection::process_record(ObInnerSQLResult &res, } record_stat(session, result_set.get_stmt_type(), is_from_pl); - ObSQLUtils::handle_audit_record(false, sql::PSCursor == exec_timestamp.exec_type_ - ? EXECUTE_PS_EXECUTE : EXECUTE_INNER, - session); + ObSQLUtils::handle_audit_record(false, sql::PSCursor == exec_timestamp.exec_type_ ? EXECUTE_PS_EXECUTE + : is_from_pl ? EXECUTE_PL_EXECUTE : EXECUTE_INNER, session); } return ret; } diff --git a/src/sql/ob_sql_define.h b/src/sql/ob_sql_define.h index 94d3cf9c8..8085bbb47 100644 --- a/src/sql/ob_sql_define.h +++ b/src/sql/ob_sql_define.h @@ -443,7 +443,8 @@ enum ObExecuteMode EXECUTE_PS_FETCH, EXECUTE_PS_SEND_PIECE, EXECUTE_PS_GET_PIECE, - EXECUTE_PS_SEND_LONG_DATA + EXECUTE_PS_SEND_LONG_DATA, + EXECUTE_PL_EXECUTE }; diff --git a/src/sql/session/ob_sql_session_info.cpp b/src/sql/session/ob_sql_session_info.cpp index 5e2833717..dff52e67c 100644 --- a/src/sql/session/ob_sql_session_info.cpp +++ b/src/sql/session/ob_sql_session_info.cpp @@ -1624,7 +1624,8 @@ const ObAuditRecordData &ObSQLSessionInfo::get_final_audit_record( || EXECUTE_PS_SEND_PIECE == mode || EXECUTE_PS_GET_PIECE == mode || EXECUTE_PS_SEND_LONG_DATA == mode - || EXECUTE_PS_FETCH == mode) { + || EXECUTE_PS_FETCH == mode + || EXECUTE_PL_EXECUTE == mode) { audit_record_.tenant_name_ = const_cast(get_tenant_name().ptr()); audit_record_.tenant_name_len_ = min(get_tenant_name().length(), OB_MAX_TENANT_NAME_LENGTH);