diff --git a/src/sql/ob_sql.cpp b/src/sql/ob_sql.cpp index 6e6142b58d..19a912b85b 100644 --- a/src/sql/ob_sql.cpp +++ b/src/sql/ob_sql.cpp @@ -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(), result.get_is_from_plan_cache(), ¶ms))) { 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) { 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()));