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

[CP] [to #50495693]prepare in prexecute reset session state

Browse Source
This commit is contained in:
LiuYoung00
2023-07-11 18:42:14 +00:00
committed by ob-robot
parent 871b092354
commit e354f149d2
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/observer/mysql/obmp_stmt_prexecute.cpp
View File

@ -77,6 +77,7 @@ ObMPStmtPrexecute::ObMPStmtPrexecute(const ObGlobalContext &gctx)
int ObMPStmtPrexecute::before_process()
{
int ret = OB_SUCCESS;
ObSQLSessionInfo *session = NULL;
if (OB_FAIL(ObMPBase::before_process())) {
LOG_WARN("fail to call before process", K(ret));
@ -357,9 +358,14 @@ int ObMPStmtPrexecute::before_process()
}
}
session->set_last_trace_id(ObCurTraceId::get_trace_id());
//对于tracelog的处理，不影响正常逻辑，错误码无须赋值给ret
if (session != NULL && OB_FAIL(ret)) {
int tmp_ret = OB_SUCCESS;
//清空WARNING BUFFER
ObSqlCtx sql_ctx; // sql_ctx do nothing in do_after_process
tmp_ret = do_after_process(*session, sql_ctx, false/*no asyn response*/);
UNUSED(tmp_ret);
}
if (session != NULL) {
revert_session(session);
}
}
@ -372,6 +378,10 @@ int ObMPStmtPrexecute::before_process()
OZ (flush_buffer(true));
}
if (session != NULL) {
revert_session(session);
}
return ret;
}