for apache#2082, Add SQLParserEntry.getDatabaseTypeAliases()

sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/parser/SQLParserFactory.java

@@ -52,13 +52,25 @@ public final class SQLParserFactory {
      */
     public static SQLParser newInstance(final DatabaseType databaseType, final String sql) {
         for (SQLParserEntry each : NewInstanceServiceLoader.newServiceInstances(SQLParserEntry.class)) {
-            if (DatabaseType.valueOf(each.getDatabaseType()) == databaseType) {
+            if (isCurrentDatabaseType(databaseType, each)) {
                 return createSQLParser(sql, each);
             }
         }
         throw new UnsupportedOperationException(String.format("Cannot support database type '%s'", databaseType));
     }
 
+    private static boolean isCurrentDatabaseType(final DatabaseType databaseType, final SQLParserEntry sqlParserEntry) {
+        if (DatabaseType.valueOf(sqlParserEntry.getDatabaseType()) == databaseType) {
+            return true;
+        }
+        for (String each : sqlParserEntry.getDatabaseTypeAliases()) {
+            if (DatabaseType.valueOf(each) == databaseType) {
+                return true;
+            }
+        }
+        return false;
+    }
+
     @SneakyThrows
     private static SQLParser createSQLParser(final String sql, final SQLParserEntry parserEntry) {
         Lexer lexer = parserEntry.getLexerClass().getConstructor(CharStream.class).newInstance(CharStreams.fromString(sql));

sharding-core/sharding-core-parse/sharding-core-parse-mysql/src/main/java/org/apache/shardingsphere/core/parse/MySQLParserEntry.java

@@ -22,6 +22,9 @@
 import org.apache.shardingsphere.core.parse.autogen.MySQLStatementLexer;
 import org.apache.shardingsphere.core.parse.spi.SQLParserEntry;
 
+import java.util.Collection;
+import java.util.Collections;
+
 /**
  * SQL parser entry for MySQL.
  *
@@ -34,6 +37,11 @@ public String getDatabaseType() {
         return "MySQL";
     }
 
+    @Override
+    public Collection<String> getDatabaseTypeAliases() {
+        return Collections.singletonList("H2");
+    }
+
     @Override
     public Class<? extends Lexer> getLexerClass() {
         return MySQLStatementLexer.class;

sharding-core/sharding-core-parse/sharding-core-parse-mysql/src/main/resources/META-INF/services/org.apache.shardingsphere.core.parse.spi.SQLParserEntry

@@ -16,4 +16,3 @@
 #
 
 org.apache.shardingsphere.core.parse.MySQLParserEntry
-org.apache.shardingsphere.core.parse.H2ParserEntry

sharding-core/sharding-core-parse/sharding-core-parse-oracle/src/main/java/org/apache/shardingsphere/core/parse/OracleParserEntry.java

@@ -22,6 +22,9 @@
 import org.apache.shardingsphere.core.parse.autogen.OracleStatementLexer;
 import org.apache.shardingsphere.core.parse.spi.SQLParserEntry;
 
+import java.util.Collection;
+import java.util.Collections;
+
 /**
  * SQL parser entry for Oracle.
  *
@@ -34,6 +37,11 @@ public String getDatabaseType() {
         return "Oracle";
     }
 
+    @Override
+    public Collection<String> getDatabaseTypeAliases() {
+        return Collections.emptyList();
+    }
+
     @Override
     public Class<? extends Lexer> getLexerClass() {
         return OracleStatementLexer.class;

sharding-core/sharding-core-parse/sharding-core-parse-postgresql/src/main/java/org/apache/shardingsphere/core/parse/PostgreSQLParserEntry.java

@@ -22,6 +22,9 @@
 import org.apache.shardingsphere.core.parse.autogen.PostgreSQLStatementLexer;
 import org.apache.shardingsphere.core.parse.spi.SQLParserEntry;
 
+import java.util.Collection;
+import java.util.Collections;
+
 /**
  * SQL parser entry for PostgreSQL.
  *
@@ -34,6 +37,11 @@ public String getDatabaseType() {
         return "PostgreSQL";
     }
 
+    @Override
+    public Collection<String> getDatabaseTypeAliases() {
+        return Collections.emptyList();
+    }
+
     @Override
     public Class<? extends Lexer> getLexerClass() {
         return PostgreSQLStatementLexer.class;

sharding-core/sharding-core-parse/sharding-core-parse-spi/src/main/java/org/apache/shardingsphere/core/parse/spi/SQLParserEntry.java

@@ -20,6 +20,8 @@
 import org.antlr.v4.runtime.Lexer;
 import org.apache.shardingsphere.core.parse.api.SQLParser;
 
+import java.util.Collection;
+
 /**
  * SQL parser entry.
  *
@@ -34,6 +36,13 @@ public interface SQLParserEntry {
      */
     String getDatabaseType();
 
+    /**
+     * Get database type alias.
+     *
+     * @return database type alias
+     */
+    Collection<String> getDatabaseTypeAliases();
+
     /**
      * Get SQL lexer class type.
      *

sharding-core/sharding-core-parse/sharding-core-parse-sqlserver/src/main/java/org/apache/shardingsphere/core/parse/SQLServerParserEntry.java

@@ -22,6 +22,9 @@
 import org.apache.shardingsphere.core.parse.autogen.SQLServerStatementLexer;
 import org.apache.shardingsphere.core.parse.spi.SQLParserEntry;
 
+import java.util.Collection;
+import java.util.Collections;
+
 /**
  * SQL parser entry for SQLServer.
  *
@@ -34,6 +37,11 @@ public String getDatabaseType() {
         return "SQLServer";
     }
 
+    @Override
+    public Collection<String> getDatabaseTypeAliases() {
+        return Collections.emptyList();
+    }
+
     @Override
     public Class<? extends Lexer> getLexerClass() {
         return SQLServerStatementLexer.class;