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

add placeholder for __all_virtual_tenant_parameter

Browse Source
This commit is contained in:
obdev
2023-04-27 08:41:13 +00:00
committed by ob-robot
parent 7e1a48d9dc
commit d8c632c87f
14 changed files with 72 additions and 116 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
src/sql/optimizer/ob_log_set.cpp
View File

@ -151,7 +151,6 @@ int ObLogSet::get_equal_set_conditions(ObIArray<ObRawExpr*> &equal_conds)
{
int ret = OB_SUCCESS;
ObSQLSessionInfo *session_info = NULL;
ObSEArray<ObRawExpr*, 8> select_exprs;
ObSEArray<ObRawExpr*, 8> set_exprs;
const ObSelectStmt *stmt = NULL;
ObRawExprFactory *expr_factory = NULL;
@ -161,9 +160,7 @@ int ObLogSet::get_equal_set_conditions(ObIArray<ObRawExpr*> &equal_conds)
ret = OB_ERR_UNEXPECTED;
LOG_WARN("get unexpected null", K(get_plan()), K(get_stmt()), K(session_info), K(ret));
} else if (OB_FALSE_IT(stmt = static_cast<const ObSelectStmt*>(get_stmt()))) {
} else if (OB_FAIL(get_set_exprs(select_exprs))) {
LOG_WARN("failed to get set exprs", K(ret));
} else if (OB_FAIL(ObTransformUtils::get_expr_in_cast(select_exprs, set_exprs))) {
} else if (OB_FAIL(stmt->get_pure_set_exprs(set_exprs))) {
LOG_WARN("failed to expr in cast", K(ret));
} else if (OB_FAIL(ObTransformUtils::get_equal_set_conditions(*expr_factory, session_info,
stmt, set_exprs, equal_conds))) {
@ -354,24 +351,6 @@ int ObLogSet::compute_sharding_info()
return ret;
}
int ObLogSet::is_my_set_expr(const ObRawExpr *expr, bool &bret)
{
int ret = OB_SUCCESS;
bret = false;
const ObSelectStmt *stmt = static_cast<const ObSelectStmt *>(get_stmt());
if (OB_ISNULL(stmt) || OB_ISNULL(expr)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpect NULL pointer", K(stmt), K(expr));
} else if (!expr->is_set_op_expr()) {
bret = false;
} else {
for (int64_t i = 0; OB_SUCC(ret) && !bret && i < stmt->get_select_item_size(); ++i) {
bret = expr == ObTransformUtils::get_expr_in_cast(stmt->get_select_item(i).expr_);
}
}
return ret;
}
int ObLogSet::set_search_ordering(const common::ObIArray<OrderItem> &search_ordering)
{
int ret = OB_SUCCESS;
@ -741,14 +720,17 @@ int ObLogSet::get_set_exprs(ObIArray<ObRawExpr *> &set_exprs)
return ret;
}
int ObLogSet::extra_set_exprs(ObIArray<ObRawExpr *> &set_exprs)
int ObLogSet::get_pure_set_exprs(ObIArray<ObRawExpr *> &set_exprs)
{
int ret = OB_SUCCESS;
ObSEArray<ObRawExpr *, 4> out_raw_exprs;
if (OB_FAIL(get_set_exprs(out_raw_exprs))) {
LOG_WARN("failed to get set exprs", K(ret));
} else if (OB_FAIL(ObTransformUtils::get_expr_in_cast(out_raw_exprs, set_exprs))) {
LOG_WARN("failed to get expr in cast", K(ret));
if (OB_ISNULL(get_stmt()) || OB_UNLIKELY(!get_stmt()->is_select_stmt())) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("get unexpected error", K(get_stmt()), K(ret));
} else {
const ObSelectStmt *sel_stmt = static_cast<const ObSelectStmt *>(get_stmt());
if (OB_FAIL(sel_stmt->get_pure_set_exprs(set_exprs))) {
LOG_WARN("failed to get set op exprs", K(ret));
} else { /*do nothing*/ }
}
return ret;
}