Refactor DataNode format (#32964)

apache · Sep 23, 2024 · 5cc2f09 · 5cc2f09
1 parent 70e13e0
commit 5cc2f09
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/infra/common/src/main/java/org/apache/shardingsphere/infra/datanode/DataNode.java b/infra/common/src/main/java/org/apache/shardingsphere/infra/datanode/DataNode.java
@@ -110,7 +110,7 @@ private boolean isActualDataNodesIncludedDataSourceInstance(final String actualD
      */
     public String format(final DatabaseType databaseType) {
         DialectDatabaseMetaData dialectDatabaseMetaData = new DatabaseTypeRegistry(databaseType).getDialectDatabaseMetaData();
-        return dialectDatabaseMetaData.getDefaultSchema().isPresent() ? dataSourceName + DELIMITER + schemaName + DELIMITER + tableName : dataSourceName + DELIMITER + tableName;
+        return dialectDatabaseMetaData.getDefaultSchema().isPresent() && schemaName != null ? dataSourceName + DELIMITER + schemaName + DELIMITER + tableName : dataSourceName + DELIMITER + tableName;
     }
 
     @Override