topdog/supersonic
1
0
Fork 0
mirror of https://github.com/tencentmusic/supersonic.git synced 2026-04-19 21:14:25 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

[improvement][headless] Current mainstream large models are not as intelligent, and setting this restriction leads to excessive query failures.

Browse Source
This commit is contained in:
beat4ocean
2025-03-05 17:09:20 +08:00
parent 0e6050e8ce
commit 9c10089707
1 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
headless/core/src/main/java/com/tencent/supersonic/headless/core/translator/parser/SqlQueryParser.java
View File

@@ -50,19 +50,19 @@ public class SqlQueryParser implements QueryParser {
queryFields.removeAll(queryAliases);
Ontology ontology = queryStatement.getOntology();
OntologyQuery ontologyQuery = buildOntologyQuery(ontology, queryFields);
// check if there are fields not matched with any metric or dimension
if (queryFields.size() > ontologyQuery.getMetrics().size()
+ ontologyQuery.getDimensions().size()) {
List<String> semanticFields = Lists.newArrayList();
ontologyQuery.getMetrics().forEach(m -> semanticFields.add(m.getName()));
ontologyQuery.getDimensions().forEach(d -> semanticFields.add(d.getName()));
String errMsg =
String.format("Querying columns[%s] not matched with semantic fields[%s].",
queryFields, semanticFields);
queryStatement.setErrMsg(errMsg);
queryStatement.setStatus(QueryState.INVALID);
return;
}
// // check if there are fields not matched with any metric or dimension
// if (queryFields.size() > ontologyQuery.getMetrics().size()
// + ontologyQuery.getDimensions().size()) {
// List<String> semanticFields = Lists.newArrayList();
// ontologyQuery.getMetrics().forEach(m -> semanticFields.add(m.getName()));
// ontologyQuery.getDimensions().forEach(d -> semanticFields.add(d.getName()));
// String errMsg =
// String.format("Querying columns[%s] not matched with semantic fields[%s].",
// queryFields, semanticFields);
// queryStatement.setErrMsg(errMsg);
// queryStatement.setStatus(QueryState.INVALID);
// return;
// }
queryStatement.setOntologyQuery(ontologyQuery);
AggOption sqlQueryAggOption = getAggOption(sqlQuery.getSql(), ontologyQuery.getMetrics());