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

Sql audit miss ddl sql

Browse Source
This commit is contained in:
obdev
2023-08-28 07:10:19 +00:00
committed by ob-robot
parent ab7ee2bbd8
commit 9c8ae20255
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/sql/engine/cmd/ob_table_executor.cpp
View File

@ -319,12 +319,14 @@ int ObCreateTableExecutor::execute_ctas(ObExecContext &ctx,
obrpc::ObCommonRpcProxy *common_rpc_proxy) obrpc::ObCommonRpcProxy *common_rpc_proxy)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
ObString cur_query;
int64_t affected_rows = 0; int64_t affected_rows = 0;
ObMySQLProxy *sql_proxy = ctx.get_sql_proxy(); ObMySQLProxy *sql_proxy = ctx.get_sql_proxy();
common::ObCommonSqlProxy *user_sql_proxy; common::ObCommonSqlProxy *user_sql_proxy;
common::ObOracleSqlProxy oracle_sql_proxy; common::ObOracleSqlProxy oracle_sql_proxy;
ObSQLSessionInfo *my_session = ctx.get_my_session(); ObSQLSessionInfo *my_session = ctx.get_my_session();
ObPhysicalPlanCtx *plan_ctx = ctx.get_physical_plan_ctx(); ObPhysicalPlanCtx *plan_ctx = ctx.get_physical_plan_ctx();
ObArenaAllocator allocator("CreateTableExec");
HEAP_VAR(obrpc::ObAlterTableArg, alter_table_arg) { HEAP_VAR(obrpc::ObAlterTableArg, alter_table_arg) {
obrpc::ObDropTableArg drop_table_arg; obrpc::ObDropTableArg drop_table_arg;
obrpc::ObTableItem table_item; obrpc::ObTableItem table_item;
@ -341,6 +343,11 @@ int ObCreateTableExecutor::execute_ctas(ObExecContext &ctx,
OB_NOT_NULL(plan_ctx), OB_NOT_NULL(plan_ctx),
OB_NOT_NULL(common_rpc_proxy), OB_NOT_NULL(common_rpc_proxy),
OB_NOT_NULL(ctx.get_sql_ctx())); OB_NOT_NULL(ctx.get_sql_ctx()));
if (OB_SUCC(ret)) {
if (OB_FAIL(ob_write_string(allocator, my_session->get_current_query_string(), cur_query))) {
LOG_WARN("failed to write string to session", K(ret));
}
}
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
ObInnerSQLConnectionPool *pool = static_cast<observer::ObInnerSQLConnectionPool*>(sql_proxy->get_pool()); ObInnerSQLConnectionPool *pool = static_cast<observer::ObInnerSQLConnectionPool*>(sql_proxy->get_pool());
if (OB_ISNULL(pool)) { if (OB_ISNULL(pool)) {
@ -476,6 +483,7 @@ int ObCreateTableExecutor::execute_ctas(ObExecContext &ctx,
LOG_DEBUG("table exists, no need to CTAS", K(create_table_res.table_id_)); LOG_DEBUG("table exists, no need to CTAS", K(create_table_res.table_id_));
} }
} }
OZ(my_session->store_query_string(cur_query));
} }
return ret; return ret;
} }