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

fix core at ObMPConnect::init_process_single_stmt

Browse Source
This commit is contained in:
2149
2023-11-22 05:15:14 +00:00
committed by ob-robot
parent 0aeb373b45
commit 0cf38dd0d0
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/observer/mysql/obmp_connect.cpp
View File

@ -212,6 +212,9 @@ int ObMPConnect::init_process_single_stmt(const ObMultiStmtItem &multi_stmt_item
ObSchemaGetterGuard schema_guard;
// init_connect可以执行query和dml语句，必须加上req_timeinfo_guard
observer::ObReqTimeGuard req_timeinfo_guard;
//Do not change the order of SqlCtx and Allocator. ObSqlCtx uses the resultset's allocator to
//allocate memory for ObSqlCtx::base_constraints_. The allocator must be deconstructed after sqlctx.
ObArenaAllocator allocator(ObModIds::OB_SQL_SESSION);
ObSqlCtx ctx;
ctx.exec_type_ = MpQuery;
if (OB_FAIL(init_process_var(ctx, multi_stmt_item, session))) {
@ -229,7 +232,6 @@ int ObMPConnect::init_process_single_stmt(const ObMultiStmtItem &multi_stmt_item
}
ctx.retry_times_ = 0; // 这里是建立连接的时候的初始化sql的执行，不重试
ctx.schema_guard_ = &schema_guard;
ObArenaAllocator allocator(ObModIds::OB_SQL_SESSION);
HEAP_VAR(ObMySQLResultSet, result, session, allocator) {
result.set_has_more_result(has_more_result);
result.get_exec_context().get_task_exec_ctx().set_min_cluster_version(GET_MIN_CLUSTER_VERSION());