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

[to #45941432] sql in mysql routine can not access cursor variable

Browse Source
This commit is contained in:
obdev
2022-11-07 07:05:41 +00:00
committed by wangzelin.wzl
parent 7217bb9e00
commit 1a8e6bf6ae
2 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/pl/ob_pl_stmt.cpp
View File

@ -4522,7 +4522,8 @@ int lookup_pl_symbol(const void *pl_ns, const char *symbol, size_t len, int64_t
const oceanbase::pl::ObPLBlockNS *ns = static_cast<const oceanbase::pl::ObPLBlockNS *>(pl_ns);
if (OB_FAIL(ns->resolve_symbol(var_name, type, pl_data_type, parent_id, var_index))) {
LOG_WARN("failed to get var index", K(var_name), K(ret));
} else if (oceanbase::pl::ObPLExternalNS::LOCAL_VAR == type) {
} else if (oceanbase::pl::ObPLExternalNS::LOCAL_VAR == type
&& !pl_data_type.is_cursor_type()) { // mysql can not access explicit cursor in sql/expression
*idx = var_index;
} else { /*do nothing*/ }
}

13
src/sql/resolver/ob_resolver_utils.cpp
View File

@ -772,10 +772,17 @@ int ObResolverUtils::check_type_match(const pl::ObPLResolveCtx &resolve_ctx,
|| ObExtendTC == ob_obj_type_class(dst_type)) {
ret = OB_ERR_INVALID_TYPE_FOR_OP;
LOG_WARN("argument count not match", K(ret), K(src_type), K(dst_type));
} else {
// 检查普通类型之间是否可以互转
OZ (ObObjCaster::can_cast_in_oracle_mode(dst_type,
} else { // 检查普通类型之间是否可以互转
if (lib::is_oracle_mode()) {
OZ (ObObjCaster::can_cast_in_oracle_mode(dst_type,
dst_pl_type.get_meta_type()->get_collation_type(), src_type, src_coll_type));
} else if (!cast_supported(
src_type, src_coll_type, dst_type, dst_pl_type.get_meta_type()->get_collation_type())) {
ret = OB_ERR_INVALID_TYPE_FOR_OP;
LOG_WARN("inconsistent datatypes",
K(ret), K(src_type), K(src_coll_type),
K(dst_type), K(dst_pl_type.get_meta_type()->get_collation_type()));
}
}
bool is_numric_type = (IS_NUMRIC_TYPE(src_type) && IS_NUMRIC_TYPE(dst_type));
OX (match_info = ObRoutineMatchInfo::MatchInfo(