Skip to content

Commit b6f561f

Browse files
committed
[fix](headless)Fix postgres schema issue.
1 parent 593d26a commit b6f561f

1 file changed

Lines changed: 1 addition & 8 deletions

File tree

  • headless/core/src/main/java/com/tencent/supersonic/headless/core/translator/parser/calcite

headless/core/src/main/java/com/tencent/supersonic/headless/core/translator/parser/calcite/DataModelNode.java

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -43,14 +43,7 @@ public static SqlNode build(ModelResp dataModel, SqlValidatorScope scope) throws
4343
}
4444
} else if (dataModel.getModelDetail().getTableQuery() != null
4545
&& !dataModel.getModelDetail().getTableQuery().isEmpty()) {
46-
if (dataModel.getModelDetail().getDbType()
47-
.equalsIgnoreCase(EngineType.POSTGRESQL.getName())) {
48-
String fullTableName = String.join(".public.",
49-
dataModel.getModelDetail().getTableQuery().split("\\."));
50-
sqlTable = "SELECT * FROM " + fullTableName;
51-
} else {
52-
sqlTable = "SELECT * FROM " + dataModel.getModelDetail().getTableQuery();
53-
}
46+
sqlTable = "SELECT * FROM " + dataModel.getModelDetail().getTableQuery();
5447
}
5548

5649
// String filterSql = dataModel.getFilterSql();

0 commit comments

Comments
 (0)