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

to issue<54372232>:fixr refcursor as argument of store routine issue

Browse Source
This commit is contained in:
obdev 2024-02-09 06:43:52 +00:00 committed by ob-robot
parent bcf67d825a
commit a929895ebb
2 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/pl/ob_pl.cpp
View File

@ -3154,7 +3154,7 @@ do { \
*/
if (func_.get_in_args().has_member(i)) {
const ObPLDataType &pl_type = func_.get_variables().at(i);
if (is_anonymous) {
if (is_anonymous && !func_.get_params_info().at(i).flag_.need_to_check_type_) {
OX (get_params().at(i) = params->at(i));
} else if (params->at(i).is_pl_mock_default_param()) { // 使用参数默认值
ObObjParam result;

9
src/sql/engine/expr/ob_expr_udf.cpp
View File

@ -295,6 +295,9 @@ int ObExprUDF::process_out_params(const ObObj *objs_stack,
result));
OX (result.copy_value_or_obj(*modify, true));
OX (modify->set_param_meta());
if (OB_SUCC(ret) && iparams.at(i).is_ref_cursor_type()) {
modify->set_is_ref_cursor_type(true);
}
OZ (dones.push_back(true));
} else {
OZ (dones.push_back(false));
@ -355,6 +358,9 @@ int ObExprUDF::process_singal_out_param(int64_t i,
} else {
OX (iparams.at(i).copy_value_or_obj(*modify, true));
OX (modify->set_param_meta());
if (OB_SUCC(ret) && iparams.at(i).is_ref_cursor_type()) {
modify->set_is_ref_cursor_type(true);
}
}
} else {
OZ (sql::ObSPIService::spi_convert(exec_ctx.get_my_session(),
@ -364,6 +370,9 @@ int ObExprUDF::process_singal_out_param(int64_t i,
result));
OX (result.copy_value_or_obj(*modify, true));
OX (modify->set_param_meta());
if (OB_SUCC(ret) && iparams.at(i).is_ref_cursor_type()) {
modify->set_is_ref_cursor_type(true);
}
}
OX (dones.at(i) = true);
}