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

to issue<49309819><47913681>:fix serveral bugs

Browse Source
This commit is contained in:
hanr881
2023-05-22 05:22:26 +00:00
committed by ob-robot
parent e4c999f49e
commit a1741c2ed9
3 changed files with 33 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
src/sql/engine/expr/ob_expr_collection_construct.cpp
View File

@ -119,16 +119,39 @@ int ObExprCollectionConstruct::cg_expr(ObExprCGCtx &op_cg_ctx,
return ret;
}
bool ObExprCollectionConstruct::is_match_type(const ObObj &element_obj, pl::ObPLType type)
int ObExprCollectionConstruct::check_match(const ObObj &element_obj, pl::ObElemDesc &desc, pl::ObPLINS &ns)
{
bool is_same = true;
int ret = OB_SUCCESS;
pl::ObPLType type = desc.get_pl_type();
bool is_comp = false;
if (pl::PL_NESTED_TABLE_TYPE == element_obj.get_meta().get_extend_type() ||
pl::PL_VARRAY_TYPE == element_obj.get_meta().get_extend_type()) {
is_same = pl::PL_NESTED_TABLE_TYPE == type || pl::PL_VARRAY_TYPE == type;
is_comp = pl::PL_NESTED_TABLE_TYPE == type || pl::PL_VARRAY_TYPE == type;
} else {
is_same = element_obj.get_meta().get_extend_type() == type;
is_comp = element_obj.get_meta().get_extend_type() == type;
}
return is_same;
if (is_comp) {
pl::ObPLComposite *composite = reinterpret_cast<pl::ObPLComposite*>(element_obj.get_ext());
CK (OB_NOT_NULL(composite));
if (OB_FAIL(ret)) {
} else if (composite->get_id() != desc.get_udt_id()) {
if (composite->is_record()) {
OZ (pl::ObPLResolver::check_composite_compatible(ns, composite->get_id(),
desc.get_udt_id(),
is_comp));
} else {
is_comp = false;
}
}
}
if (OB_SUCC(ret) && !is_comp) {
ret = OB_ERR_CALL_WRONG_ARG;
LOG_WARN("invalid argument. unexpected composite value", K(ret));
}
return ret;
}
int ObExprCollectionConstruct::eval_collection_construct(const ObExpr &expr,

3
src/sql/engine/expr/ob_expr_collection_construct.h
View File

@ -17,6 +17,7 @@
#include "sql/engine/expr/ob_expr_operator.h"
#include "pl/ob_pl_type.h"
#include "sql/engine/expr/ob_i_expr_extra_info.h"
#include "pl/ob_pl_user_type.h"
namespace oceanbase
{
@ -50,7 +51,7 @@ public:
const ObRawExpr &raw_expr, ObExpr &rt_expr) const override;
static int eval_collection_construct(const ObExpr &expr, ObEvalCtx &ctx, ObDatum &expr_datum);
static bool is_match_type(const ObObj &element_obj, pl::ObPLType type);
static int check_match(const ObObj &element_obj, pl::ObElemDesc &desc, pl::ObPLINS &ns);
struct ExtraInfo : public ObIExprExtraInfo
{