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

[CP] fix ntile selectivity bug in oracle mode

Browse Source
This commit is contained in:
akaError
2024-04-02 07:05:22 +00:00
committed by ob-robot
parent 12d8b47370
commit b6ea5e8416
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/sql/optimizer/ob_opt_selectivity.cpp
View File

@ -31,7 +31,7 @@
#include "share/stat/ob_dbms_stats_utils.h" #include "share/stat/ob_dbms_stats_utils.h"
#include "sql/optimizer/ob_access_path_estimation.h" #include "sql/optimizer/ob_access_path_estimation.h"
#include "sql/optimizer/ob_sel_estimator.h" #include "sql/optimizer/ob_sel_estimator.h"
#include "sql/optimizer/ob_opt_est_utils.h"
using namespace oceanbase::common; using namespace oceanbase::common;
using namespace oceanbase::share::schema; using namespace oceanbase::share::schema;
namespace oceanbase namespace oceanbase
@ -2378,7 +2378,7 @@ int ObOptSelectivity::calculate_special_ndv(const OptTableMetas &table_metas,
} else if (T_WIN_FUN_NTILE == win_expr->get_func_type()) { } else if (T_WIN_FUN_NTILE == win_expr->get_func_type()) {
ObSEArray<ObRawExpr *, 4> param_exprs; ObSEArray<ObRawExpr *, 4> param_exprs;
ObRawExpr* const_expr = NULL; ObRawExpr* const_expr = NULL;
ObObj result; ObObj result,out_ptr;
bool got_result = false; bool got_result = false;
const ParamStore *params = ctx.get_params(); const ParamStore *params = ctx.get_params();
if (OB_FAIL(param_exprs.assign(win_expr->get_func_params()))) { if (OB_FAIL(param_exprs.assign(win_expr->get_func_params()))) {
@ -2395,9 +2395,11 @@ int ObOptSelectivity::calculate_special_ndv(const OptTableMetas &table_metas,
LOG_WARN("fail to calc_const_or_calculable_expr", K(ret)); LOG_WARN("fail to calc_const_or_calculable_expr", K(ret));
} else if (!got_result || result.is_null() || !ob_is_numeric_type(result.get_type())) { } else if (!got_result || result.is_null() || !ob_is_numeric_type(result.get_type())) {
special_ndv = origin_rows/part_ndv; special_ndv = origin_rows/part_ndv;
} else if (OB_FAIL(ObOptEstObjToScalar::convert_obj_to_scalar_obj(&result, &out_ptr))) {
LOG_WARN("Failed to convert obj using old method", K(ret));
} else { } else {
double n = (double)ObOptEstObjToScalar::convert_obj_to_scalar(&result); double scalar = static_cast<double>(out_ptr.get_double());
special_ndv = std::min(origin_rows/part_ndv, n); special_ndv = std::min(origin_rows/part_ndv, scalar);
} }
} }
} else if (T_FUN_MIN == win_expr->get_func_type()|| } else if (T_FUN_MIN == win_expr->get_func_type()||