topdog/supersonic
1
0
Fork 0
mirror of https://github.com/tencentmusic/supersonic.git synced 2025-12-11 03:58:14 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

(fix)(headless)Fix aggregator parsing of struct query.
Some checks failed
supersonic CentOS CI / build (21) (push) Has been cancelled
Details
supersonic mac CI / build (21) (push) Has been cancelled
Details
supersonic ubuntu CI / build (21) (push) Has been cancelled
Details
supersonic windows CI / build (21) (push) Has been cancelled
Details

Browse Source
This commit is contained in:
jerryjzhang
2025-02-21 20:04:12 +08:00
parent 94e853f57e
commit 75f623404d
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
headless/core/src/main/java/com/tencent/supersonic/headless/core/utils/SqlGenerateUtils.java
View File

@@ -86,17 +86,17 @@ public class SqlGenerateUtils {
public String getSelectField(final Aggregator agg) { public String getSelectField(final Aggregator agg) {
if (AggOperatorEnum.COUNT_DISTINCT.equals(agg.getFunc())) { if (AggOperatorEnum.COUNT_DISTINCT.equals(agg.getFunc())) {
return "count(distinct " + agg.getColumn() + " ) AS " + agg.getColumn() + " "; return "count(distinct " + agg.getColumn() + " ) ";
} }
if (CollectionUtils.isEmpty(agg.getArgs())) { if (CollectionUtils.isEmpty(agg.getArgs())) {
return agg.getFunc() + "( " + agg.getColumn() + " ) AS " + agg.getColumn() + " "; return agg.getFunc() + "( " + agg.getColumn() + " ) ";
} }
return agg.getFunc() + "( " return agg.getFunc() + "( "
+ agg.getArgs().stream() + agg.getArgs().stream()
.map(arg -> arg.equals(agg.getColumn()) ? arg .map(arg -> arg.equals(agg.getColumn()) ? arg
: (StringUtils.isNumeric(arg) ? arg : ("'" + arg + "'"))) : (StringUtils.isNumeric(arg) ? arg : ("'" + arg + "'")))
.collect(Collectors.joining(",")) .collect(Collectors.joining(","))
+ " ) AS " + agg.getColumn() + " "; + " ) ";
} }
public String getSelectField(final Aggregator agg, Map<String, String> deriveMetrics) { public String getSelectField(final Aggregator agg, Map<String, String> deriveMetrics) {