Add DatabaseType#isSubtypeOfTrunkDatabase.

infra/database/core/src/main/java/org/apache/shardingsphere/infra/database/core/type/DatabaseType.java

@@ -45,6 +45,16 @@ default Optional<DatabaseType> getTrunkDatabaseType() {
         return Optional.empty();
     }
 
+    /**
+     * Judge whether current database type is instance of trunk database type.
+     *
+     * @param databaseTypeClass database type class
+     * @return true if current database type is instance of trunk database type, otherwise false
+     */
+    default boolean isSubtypeOfTrunkDatabase(Class<? extends DatabaseType> databaseTypeClass) {
+        return databaseTypeClass.isInstance(this) || getTrunkDatabaseType().map(databaseType -> databaseType.isSubtypeOfTrunkDatabase(databaseTypeClass)).orElse(false);
+    }
+
     @Override
     String getType();
 }

mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/util/TableRefreshUtils.java

@@ -53,7 +53,8 @@ public final class TableRefreshUtils {
      * @return table name
      */
     public static String getTableName(final DatabaseType databaseType, final IdentifierValue identifierValue) {
-        return databaseType instanceof OracleDatabaseType && QuoteCharacter.NONE == identifierValue.getQuoteCharacter() ? identifierValue.getValue().toUpperCase() : identifierValue.getValue();
+        return databaseType.isSubtypeOfTrunkDatabase(OracleDatabaseType.class) && QuoteCharacter.NONE == identifierValue.getQuoteCharacter() ? identifierValue.getValue().toUpperCase()
+                : identifierValue.getValue();
     }
 
     /**

test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/cases/PipelineContainerComposer.java

@@ -209,7 +209,7 @@ private void cleanUpDataSource() {
             return;
         }
         for (String each : Arrays.asList(DS_0, DS_1, DS_2, DS_3, DS_4)) {
-            String databaseName = databaseType instanceof OracleDatabaseType ? each.toUpperCase() : each;
+            String databaseName = databaseType.isSubtypeOfTrunkDatabase(OracleDatabaseType.class) ? each.toUpperCase() : each;
             containerComposer.cleanUpDatabase(databaseName);
         }
     }
@@ -238,7 +238,7 @@ public String appendExtraParameter(final String jdbcUrl) {
      * @throws SQLException SQL exception
      */
     public void registerStorageUnit(final String storageUnitName) throws SQLException {
-        String username = databaseType instanceof OracleDatabaseType ? storageUnitName : getUsername();
+        String username = databaseType.isSubtypeOfTrunkDatabase(OracleDatabaseType.class) ? storageUnitName : getUsername();
         String registerStorageUnitTemplate = "REGISTER STORAGE UNIT ${ds} ( URL='${url}', USER='${user}', PASSWORD='${password}')".replace("${ds}", storageUnitName)
                 .replace("${user}", username)
                 .replace("${password}", getPassword())
@@ -296,7 +296,7 @@ public String getActualJdbcUrlTemplate(final String databaseName, final boolean
      * @return actual JDBC URL template
      */
     public String getActualJdbcUrlTemplate(final String databaseName, final boolean isInContainer) {
-        if (databaseType instanceof OracleDatabaseType) {
+        if (databaseType.isSubtypeOfTrunkDatabase(OracleDatabaseType.class)) {
             return getActualJdbcUrlTemplate(databaseName, isInContainer, 0);
         }
         return appendExtraParameter(getActualJdbcUrlTemplate(databaseName, isInContainer, 0));

test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/framework/container/compose/DockerContainerComposer.java

@@ -73,7 +73,7 @@ public DockerContainerComposer(final DatabaseType databaseType, final String sto
             storageContainers.add(storageContainer);
         }
         AdaptorContainerConfiguration containerConfig = PipelineProxyClusterContainerConfigurationFactory.newInstance(databaseType);
-        DatabaseType proxyDatabaseType = databaseType instanceof OracleDatabaseType ? TypedSPILoader.getService(DatabaseType.class, "MySQL") : databaseType;
+        DatabaseType proxyDatabaseType = databaseType.isSubtypeOfTrunkDatabase(OracleDatabaseType.class) ? TypedSPILoader.getService(DatabaseType.class, "MySQL") : databaseType;
         ShardingSphereProxyClusterContainer proxyClusterContainer = (ShardingSphereProxyClusterContainer) AdapterContainerFactory.newInstance(
                 AdapterMode.CLUSTER, AdapterType.PROXY, proxyDatabaseType, "", containerConfig);
         for (DockerStorageContainer each : storageContainers) {
@@ -84,7 +84,7 @@ public DockerContainerComposer(final DatabaseType databaseType, final String sto
 
     @Override
     public String getProxyJdbcUrl(final String databaseName) {
-        if (databaseType instanceof OracleDatabaseType) {
+        if (databaseType.isSubtypeOfTrunkDatabase(OracleDatabaseType.class)) {
             return DataSourceEnvironment.getURL(TypedSPILoader.getService(DatabaseType.class, "MySQL"), proxyContainer.getHost(), proxyContainer.getFirstMappedPort(), databaseName);
         }
         return DataSourceEnvironment.getURL(databaseType, proxyContainer.getHost(), proxyContainer.getFirstMappedPort(), databaseName);

test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/framework/container/compose/NativeContainerComposer.java

@@ -120,7 +120,7 @@ private void dropTableWithOracle(final Connection connection, final String schem
 
     @Override
     public String getProxyJdbcUrl(final String databaseName) {
-        if (databaseType instanceof OracleDatabaseType) {
+        if (databaseType.isSubtypeOfTrunkDatabase(OracleDatabaseType.class)) {
             return String.format("jdbc:mysql://localhost:3307/%s?useSSL=false", databaseName);
         }
         return DataSourceEnvironment.getURL(databaseType, "localhost", 3307, databaseName);