Move GenericSchemaBuilderMaterial.isSameProtocolAndStorageTypes() to GenericSchemaBuilder

infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/database/schema/builder/GenericSchemaBuilder.java

@@ -27,6 +27,7 @@
 import org.apache.shardingsphere.infra.database.core.metadata.data.model.IndexMetaData;
 import org.apache.shardingsphere.infra.database.core.metadata.data.model.SchemaMetaData;
 import org.apache.shardingsphere.infra.database.core.metadata.data.model.TableMetaData;
+import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
 import org.apache.shardingsphere.infra.database.core.type.DatabaseTypeRegistry;
 import org.apache.shardingsphere.infra.metadata.database.resource.unit.StorageUnit;
 import org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereColumn;
@@ -78,7 +79,7 @@ public static Map<String, ShardingSphereSchema> build(final GenericSchemaBuilder
      */
     public static Map<String, ShardingSphereSchema> build(final Collection<String> tableNames, final GenericSchemaBuilderMaterial material) throws SQLException {
         Map<String, SchemaMetaData> result = loadSchemas(tableNames, material);
-        if (!material.isSameProtocolAndStorageTypes()) {
+        if (!isSameProtocolAndStorageTypes(material.getProtocolType(), material.getStorageUnits())) {
             result = translate(result, material);
         }
         return revise(result, material);
@@ -98,6 +99,10 @@ private static Map<String, SchemaMetaData> loadSchemas(final Collection<String>
         return materials.isEmpty() ? Collections.emptyMap() : MetaDataLoader.load(materials);
     }
 
+    private static boolean isSameProtocolAndStorageTypes(final DatabaseType protocolType, final Map<String, StorageUnit> storageUnits) {
+        return storageUnits.values().stream().map(StorageUnit::getStorageType).allMatch(protocolType::equals);
+    }
+
     private static Map<String, SchemaMetaData> translate(final Map<String, SchemaMetaData> schemaMetaDataMap, final GenericSchemaBuilderMaterial material) {
         Collection<TableMetaData> tableMetaDataList = new LinkedList<>();
         for (StorageUnit each : material.getStorageUnits().values()) {

infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/database/schema/builder/GenericSchemaBuilderMaterial.java

@@ -43,13 +43,4 @@ public final class GenericSchemaBuilderMaterial {
     private final ConfigurationProperties props;
 
     private final String defaultSchemaName;
-
-    /**
-     * Judge whether same protocol and storage database types.
-     *
-     * @return is same or not
-     */
-    public boolean isSameProtocolAndStorageTypes() {
-        return storageUnits.values().stream().map(StorageUnit::getStorageType).allMatch(protocolType::equals);
-    }
 }