diff --git a/core/core-backend/src/main/java/io/dataease/dataset/manage/DatasetSQLManage.java b/core/core-backend/src/main/java/io/dataease/dataset/manage/DatasetSQLManage.java index 9a8f5358b9..520be1882a 100644 --- a/core/core-backend/src/main/java/io/dataease/dataset/manage/DatasetSQLManage.java +++ b/core/core-backend/src/main/java/io/dataease/dataset/manage/DatasetSQLManage.java @@ -209,8 +209,6 @@ public class DatasetSQLManage { String tablePrefix = ""; String tableSuffix = ""; if (ObjectUtils.isNotEmpty(currentSQLObj.getTableSchema())) { - ts = currentSQLObj.getTableSchema() + "."; - if (isCross) { tablePrefix = "`"; tableSuffix = "`"; @@ -219,6 +217,8 @@ public class DatasetSQLManage { tablePrefix = datasourceType.getPrefix(); tableSuffix = datasourceType.getSuffix(); } + + ts = tablePrefix + currentSQLObj.getTableSchema() + tableSuffix + "."; } // build join join.append(" ").append(joinType).append(" ") diff --git a/core/core-backend/src/main/java/io/dataease/dataset/utils/TableUtils.java b/core/core-backend/src/main/java/io/dataease/dataset/utils/TableUtils.java index e1d6bd4001..7fec9dcb5e 100644 --- a/core/core-backend/src/main/java/io/dataease/dataset/utils/TableUtils.java +++ b/core/core-backend/src/main/java/io/dataease/dataset/utils/TableUtils.java @@ -44,7 +44,6 @@ public class TableUtils { String prefix = ""; String suffix = ""; if (StringUtils.isNotEmpty(sqlObj.getTableSchema())) { - schema = sqlObj.getTableSchema() + "."; if (isCross) { prefix = "`"; suffix = "`"; @@ -52,6 +51,7 @@ public class TableUtils { prefix = datasourceType.getPrefix(); suffix = datasourceType.getSuffix(); } + schema = prefix + sqlObj.getTableSchema() + suffix + "."; } return schema + prefix + sqlObj.getTableName() + suffix + " " + sqlObj.getTableAlias(); }