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

Change check flag is_prepare_protocol to is_text_ps_mode in text ps to skip after_get_plan

Browse Source
This commit is contained in:
obdev
2023-01-28 15:12:17 +08:00
committed by ob-robot
parent 7fb284784d
commit 5aea7f9305
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/sql/ob_sql.cpp
View File

@ -1343,7 +1343,7 @@ int ObSql::handle_sql_execute(const ObString &sql,
} }
} }
if (OB_SUCC(ret) && !(org_params.count() == 0 && context.is_prepare_protocol_)) { if (OB_SUCC(ret) && !context.is_text_ps_mode_) {
if (OB_FAIL(after_get_plan(pc_ctx, *session, result.get_physical_plan(), if (OB_FAIL(after_get_plan(pc_ctx, *session, result.get_physical_plan(),
result.get_is_from_plan_cache(), &params))) { result.get_is_from_plan_cache(), &params))) {
LOG_WARN("fail to handle after get plan", K(ret)); LOG_WARN("fail to handle after get plan", K(ret));
@ -1395,9 +1395,6 @@ int ObSql::handle_pl_execute(const ObString &sql,
if (OB_SUCC(ret) && is_prepare_protocol && !is_dynamic_sql) { if (OB_SUCC(ret) && is_prepare_protocol && !is_dynamic_sql) {
result.set_simple_ps_protocol(); result.set_simple_ps_protocol();
} }
if (OB_SUCC(ret) && params.count() == 0) {
context.is_prepare_protocol_ = false; // text protocol
}
LOG_TRACE("arrive handle pl execute", K(ret), K(sql), K(is_prepare_protocol), K(is_dynamic_sql), K(lbt())); LOG_TRACE("arrive handle pl execute", K(ret), K(sql), K(is_prepare_protocol), K(is_dynamic_sql), K(lbt()));