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

[CP] to issue<2024112800105361719>:fix pakcage var default value sync issue

Browse Source
This commit is contained in:
hanr881 2024-12-16 20:16:32 +00:00 committed by ob-robot
parent ae289fd4d0
commit cd154a7287
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/pl/ob_pl_package.cpp
View File

@ -226,7 +226,8 @@ int ObPLPackage::instantiate_package_state(const ObPLResolveCtx &resolve_ctx,
} else if (OB_NOT_NULL(ser_value = resolve_ctx.session_info_.get_user_variable_value(key))) {
need_deserialize = true;
}
if (OB_SUCC(ret) && need_deserialize) {
if (OB_FAIL(ret)) {
} else if (need_deserialize) {
if (OB_FAIL(package_state.get_package_var_val(var_idx, value))) {
LOG_WARN("failt to get package var", K(ret), K(var_idx));
} else {
@ -300,6 +301,13 @@ int ObPLPackage::instantiate_package_state(const ObPLResolveCtx &resolve_ctx,
OZ (resolve_ctx.session_info_.get_pl_sync_pkg_vars()->set_refactored(key));
}
}
} else {
const sql::ObSqlExpression *default_expr = var->is_formal_param() ? NULL : get_default_expr(var->get_default());
if (OB_NOT_NULL(default_expr) &&
!IS_CONST_TYPE(default_expr->get_expr_items().at(0).get_item_type())) { // has default value, make user var to sync it
OZ (package_state.update_changed_vars(var_idx));
OX (resolve_ctx.session_info_.set_pl_can_retry(false));
}
}
}
}