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

fix mysqltest

Browse Source
This commit is contained in:
hanr881
2023-06-05 06:42:55 +00:00
committed by ob-robot
parent 4cf19e5877
commit 3a5d8cf7a8
2 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/pl/ob_pl_package_manager.cpp
View File

@ -742,6 +742,12 @@ int ObPLPackageManager::set_package_var_val(const ObPLResolveCtx &resolve_ctx,
OX (cursor->set_sync_cursor()); OX (cursor->set_sync_cursor());
} }
} }
} else if (var->get_type().is_opaque_type()) {
if (var_val.is_null()) {
ret = OB_NOT_SUPPORTED;
LOG_WARN("can not sync package opaque type", K(ret));
LOG_USER_ERROR(OB_NOT_SUPPORTED, "sync package opaque type");
}
} else { } else {
OZ (var->get_type().deserialize(resolve_ctx, OZ (var->get_type().deserialize(resolve_ctx,
var->get_type().is_cursor_type() ? var->get_type().is_cursor_type() ?

2
src/pl/ob_pl_package_state.cpp
View File

@ -294,6 +294,8 @@ int ObPLPackageState::make_pkg_var_kv_value(ObPLExecCtx &ctx, ObObj &var_val, in
} else { } else {
OX (value.set_bool(true)); OX (value.set_bool(true));
} }
} else if (var->get_type().is_opaque_type()) {
value.set_null();
} else { } else {
OZ (var->get_type().serialize(resolve_ctx, var_val, value)); OZ (var->get_type().serialize(resolve_ctx, var_val, value));
} }