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

[CP] pl not support batch_error

Browse Source
This commit is contained in:
LiuYoung00
2022-11-10 14:39:53 +00:00
committed by wangzelin.wzl
parent 067f2791d2
commit c7e99230b9
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -761,6 +761,10 @@ int ObMPStmtExecute::request_params(ObSQLSessionInfo *session,
const int64_t input_param_num = ps_session_info->get_param_count();
stmt_type_ = ps_session_info->get_stmt_type();
int8_t new_param_bound_flag = 0;
if (is_pl_stmt(stmt_type_)) {
// pl not support save exception
is_save_exception_ = 0;
}
// for returning into,
// all_param_num = input_param_num + returning_param_num
params_num_ = (all_param_num > input_param_num) ? all_param_num : input_param_num;

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

@ -297,7 +297,7 @@ int ObMPStmtPrexecute::before_process()
// other exec_mode set use ==
is_commit_on_success_ = exec_mode_ & OB_OCI_COMMIT_ON_SUCCESS;
exec_mode_ = exec_mode_ & (0xffffffff - OB_OCI_COMMIT_ON_SUCCESS);
if (OB_OCI_BATCH_ERRORS == exec_mode_) {
if (OB_OCI_BATCH_ERRORS == exec_mode_ && !is_pl_stmt(stmt_type_)) {
set_save_exception(true);
}
if (OB_SUCC(ret)) {