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

fix listagg param check bug

Browse Source
This commit is contained in:
wangt1xiuyi
2024-05-29 10:22:48 +00:00
committed by ob-robot
parent fc9d6e0f7b
commit c9481cfc40
1 changed files with 14 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/sql/resolver/expr/ob_raw_expr_deduce_type.cpp
View File

@ -3147,13 +3147,20 @@ int ObRawExprDeduceType::set_agg_group_concat_result_type(ObAggFunRawExpr &expr,
}
result_type.set_varchar();
if (lib::is_oracle_mode()) {
ObSEArray<ObExprResType*, 2, ObNullAllocator> params;
for (int64_t i = 0; OB_SUCC(ret) && i < types.count(); ++i) {
OZ (params.push_back(&types[i]));
}
if (OB_FAIL(dummy_op.aggregate_length_semantics_oracle(
*my_session_, params, result_type))) {
LOG_WARN("fail to aggregate length semantics for string result", K(ret), K(types));
if (expr.get_real_param_count() > 2) {
ret = OB_ERR_PARAM_SIZE;
LOG_WARN("listagg has 2 params at most", K(ret), K(expr.get_real_param_count()));
} else {
ObSEArray<ObExprResType*, 2, ObNullAllocator> params;
for (int64_t i = 0; OB_SUCC(ret) && i < types.count(); ++i) {
OZ (params.push_back(&types[i]));
}
if (OB_SUCC(ret)) {
if (OB_FAIL(dummy_op.aggregate_length_semantics_oracle(
*my_session_, params, result_type))) {
LOG_WARN("fail to aggregate length semantics for string result", K(ret), K(types));
}
}
}
}
if (OB_FAIL(ret)) {