From 5ad8ac69abcf41942c99ebe217812829fd821dba Mon Sep 17 00:00:00 2001
From: jipeli <54889677+jipeli@users.noreply.github.com>
Date: Tue, 6 Aug 2024 18:33:26 +0800
Subject: [PATCH] (fix)(headless) fix sql grammar error (#1516) (#1519)

---
 .../server/utils/QueryReqConverter.java       | 20 +++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git a/headless/server/src/main/java/com/tencent/supersonic/headless/server/utils/QueryReqConverter.java b/headless/server/src/main/java/com/tencent/supersonic/headless/server/utils/QueryReqConverter.java
index c6fcadd0c..2e47adc34 100644
--- a/headless/server/src/main/java/com/tencent/supersonic/headless/server/utils/QueryReqConverter.java
+++ b/headless/server/src/main/java/com/tencent/supersonic/headless/server/utils/QueryReqConverter.java
@@ -22,12 +22,14 @@ import com.tencent.supersonic.headless.api.pojo.response.DatabaseResp;
 import com.tencent.supersonic.headless.api.pojo.response.DimSchemaResp;
 import com.tencent.supersonic.headless.api.pojo.response.MetricResp;
 import com.tencent.supersonic.headless.api.pojo.response.MetricSchemaResp;
+import com.tencent.supersonic.headless.api.pojo.response.ModelResp;
 import com.tencent.supersonic.headless.api.pojo.response.SemanticSchemaResp;
 import com.tencent.supersonic.headless.core.adaptor.db.DbAdaptor;
 import com.tencent.supersonic.headless.core.adaptor.db.DbAdaptorFactory;
 import com.tencent.supersonic.headless.core.pojo.DataSetQueryParam;
 import com.tencent.supersonic.headless.core.pojo.QueryStatement;
 import com.tencent.supersonic.headless.core.utils.SqlGenerateUtils;
+import java.util.Comparator;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.lang3.tuple.Pair;
@@ -269,6 +271,11 @@ public class QueryReqConverter {
                 // metricTable use measures replace metric
                 if (!CollectionUtils.isEmpty(measures)) {
                     metricTable.setMetrics(new ArrayList<>(measures));
+                } else {
+                    // empty measure , fill default
+                    metricTable.setMetrics(new ArrayList<>());
+                    metricTable.getMetrics().add(sqlGenerateUtils.generateInternalMetricName(
+                            getDefaultModel(semanticSchemaResp, metricTable.getDimensions())));
                 }
             }
         }
@@ -321,4 +328,17 @@ public class QueryReqConverter {
         deriveDimension.stream().filter(d -> !dimensions.contains(d)).forEach(d -> dimensions.add(d));
     }
 
+    private String getDefaultModel(SemanticSchemaResp semanticSchemaResp, List<String> dimensions) {
+        if (!CollectionUtils.isEmpty(dimensions)) {
+            Map<String, Long> modelMatchCnt = new HashMap<>();
+            for (ModelResp modelResp : semanticSchemaResp.getModelResps()) {
+                modelMatchCnt.put(modelResp.getBizName(), modelResp.getModelDetail().getDimensions().stream()
+                        .filter(d -> dimensions.contains(d.getBizName())).count());
+            }
+            return modelMatchCnt.entrySet().stream().sorted(Map.Entry.comparingByValue(Comparator.reverseOrder()))
+                    .map(m -> m.getKey()).findFirst().orElse("");
+        }
+        return semanticSchemaResp.getModelResps().get(0).getBizName();
+    }
+
 }