Support SQL non-parsing, transparent transmission mode

infra/parser/src/main/java/org/apache/shardingsphere/infra/parser/SimpleSQLParserEngine.java

@@ -17,16 +17,35 @@
 
 package org.apache.shardingsphere.infra.parser;
 
+import org.apache.shardingsphere.infra.parser.sql.SQLStatementParserEngine;
+import org.apache.shardingsphere.infra.parser.sql.SQLStatementParserEngineFactory;
+import org.apache.shardingsphere.sql.parser.api.CacheOption;
 import org.apache.shardingsphere.sql.parser.sql.common.statement.SQLStatement;
 import org.apache.shardingsphere.sql.parser.sql.common.statement.SimpleSQLStatement;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
 
 /**
  * Simple SQL parser engine.
  */
 public final class SimpleSQLParserEngine implements SQLParserEngine {
 
+    private final SQLStatementParserEngine sqlStatementParserEngine;
+
+    public SimpleSQLParserEngine(final String databaseType, final CacheOption sqlStatementCacheOption, final CacheOption parseTreeCacheOption, final boolean isParseComment) {
+        sqlStatementParserEngine = SQLStatementParserEngineFactory.getSQLStatementParserEngine(
+                databaseType, sqlStatementCacheOption, parseTreeCacheOption, isParseComment);
+    }
+
+    private boolean isContainShowDatabases(final String sql) {
+        String regex = "^(\\s*)show(\\s+)databases(\\s*)";
+        Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);
+        Matcher matcher = pattern.matcher(sql);
+        return matcher.matches();
+    }
+
     @Override
     public SQLStatement parse(final String sql, final boolean useCache) {
-        return new SimpleSQLStatement();
+        return isContainShowDatabases(sql) ? sqlStatementParserEngine.parse(sql, useCache) : new SimpleSQLStatement();
     }
 }

jdbc/core/src/test/java/org/apache/shardingsphere/driver/jdbc/core/datasource/ShardingSphereDataSourceTest.java

@@ -88,7 +88,7 @@ void assertRemoveGlobalRuleConfiguration() throws Exception {
         Connection connection = mock(Connection.class, RETURNS_DEEP_STUBS);
         when(connection.getMetaData().getURL()).thenReturn("jdbc:mock://127.0.0.1/foo_ds");
         CacheOption cacheOption = new CacheOption(1024, 1024);
-        SQLParserRuleConfiguration sqlParserRuleConfig = new SQLParserRuleConfiguration(true, cacheOption, cacheOption);
+        SQLParserRuleConfiguration sqlParserRuleConfig = new SQLParserRuleConfiguration(true, cacheOption, cacheOption, "Standard");
         try (
                 ShardingSphereDataSource actual = new ShardingSphereDataSource(DefaultDatabase.LOGIC_NAME,
                         null, Collections.singletonMap("ds", new MockedDataSource(connection)), Arrays.asList(mock(ShardingRuleConfiguration.class), sqlParserRuleConfig), new Properties())) {

kernel/parser/api/src/main/java/org/apache/shardingsphere/parser/config/SQLParserRuleConfiguration.java

@@ -34,4 +34,6 @@ public final class SQLParserRuleConfiguration implements GlobalRuleConfiguration
     private final CacheOption parseTreeCache;
 
     private final CacheOption sqlStatementCache;
+
+    private final String engineType;
 }

kernel/parser/core/src/main/java/org/apache/shardingsphere/parser/rule/SQLParserRule.java

@@ -46,7 +46,7 @@ public SQLParserRule(final SQLParserRuleConfiguration ruleConfig) {
         sqlCommentParseEnabled = ruleConfig.isSqlCommentParseEnabled();
         sqlStatementCache = ruleConfig.getSqlStatementCache();
         parseTreeCache = ruleConfig.getParseTreeCache();
-        engineType = "Standard";
+        engineType = ruleConfig.getEngineType();
     }
 
     /**
@@ -56,9 +56,9 @@ public SQLParserRule(final SQLParserRuleConfiguration ruleConfig) {
      * @return SQL parser engine
      */
     public SQLParserEngine getSQLParserEngine(final String databaseType) {
-        return "Standard".equals(engineType)
-                ? new ShardingSphereSQLParserEngine(databaseType, sqlStatementCache, parseTreeCache, sqlCommentParseEnabled)
-                : new SimpleSQLParserEngine();
+        return "Simple".equals(engineType)
+                ? new SimpleSQLParserEngine(databaseType, sqlStatementCache, parseTreeCache, sqlCommentParseEnabled)
+                : new ShardingSphereSQLParserEngine(databaseType, sqlStatementCache, parseTreeCache, sqlCommentParseEnabled);
     }
 
     @Override

kernel/parser/core/src/main/java/org/apache/shardingsphere/parser/rule/builder/DefaultSQLParserRuleConfigurationBuilder.java

@@ -33,7 +33,7 @@ public final class DefaultSQLParserRuleConfigurationBuilder implements DefaultGl
 
     @Override
     public SQLParserRuleConfiguration build() {
-        return new SQLParserRuleConfiguration(false, PARSE_TREE_CACHE_OPTION, SQL_STATEMENT_CACHE_OPTION);
+        return new SQLParserRuleConfiguration(false, PARSE_TREE_CACHE_OPTION, SQL_STATEMENT_CACHE_OPTION, "Standard");
     }
 
     @Override

kernel/parser/core/src/main/java/org/apache/shardingsphere/parser/yaml/config/YamlSQLParserRuleConfiguration.java

@@ -35,6 +35,8 @@ public final class YamlSQLParserRuleConfiguration implements YamlGlobalRuleConfi
 
     private YamlSQLParserCacheOptionRuleConfiguration parseTreeCache;
 
+    private String engineType;
+
     @Override
     public Class<SQLParserRuleConfiguration> getRuleConfigurationType() {
         return SQLParserRuleConfiguration.class;

kernel/parser/core/src/main/java/org/apache/shardingsphere/parser/yaml/swapper/YamlSQLParserRuleConfigurationSwapper.java

@@ -37,6 +37,7 @@ public YamlSQLParserRuleConfiguration swapToYamlConfiguration(final SQLParserRul
         result.setSqlCommentParseEnabled(data.isSqlCommentParseEnabled());
         result.setParseTreeCache(cacheOptionSwapper.swapToYamlConfiguration(data.getParseTreeCache()));
         result.setSqlStatementCache(cacheOptionSwapper.swapToYamlConfiguration(data.getSqlStatementCache()));
+        result.setEngineType(data.getEngineType());
         return result;
     }
 
@@ -48,7 +49,7 @@ public SQLParserRuleConfiguration swapToObject(final YamlSQLParserRuleConfigurat
         CacheOption sqlStatementCacheOption = null == yamlConfig.getSqlStatementCache()
                 ? DefaultSQLParserRuleConfigurationBuilder.SQL_STATEMENT_CACHE_OPTION
                 : cacheOptionSwapper.swapToObject(yamlConfig.getSqlStatementCache());
-        return new SQLParserRuleConfiguration(yamlConfig.isSqlCommentParseEnabled(), parseTreeCacheOption, sqlStatementCacheOption);
+        return new SQLParserRuleConfiguration(yamlConfig.isSqlCommentParseEnabled(), parseTreeCacheOption, sqlStatementCacheOption, yamlConfig.getEngineType());
     }
 
     @Override

kernel/parser/core/src/test/java/org/apache/shardingsphere/parser/rule/SQLParserRuleTest.java

@@ -33,7 +33,7 @@ class SQLParserRuleTest {
 
     @BeforeEach
     void setup() {
-        sqlParserRule = new SQLParserRule(new SQLParserRuleConfiguration(true, new CacheOption(2, 4), new CacheOption(3, 7)));
+        sqlParserRule = new SQLParserRule(new SQLParserRuleConfiguration(true, new CacheOption(2, 4), new CacheOption(3, 7), "Standard"));
     }
 
     @Test

kernel/parser/core/src/test/java/org/apache/shardingsphere/parser/rule/builder/SQLParserRuleBuilderTest.java

@@ -35,7 +35,8 @@ class SQLParserRuleBuilderTest {
 
     @Test
     void assertBuild() {
-        SQLParserRuleConfiguration ruleConfig = new SQLParserRuleConfiguration(true, new CacheOption(2, 5), new CacheOption(4, 7));
+        SQLParserRuleConfiguration ruleConfig = new SQLParserRuleConfiguration(true, new CacheOption(2, 5),
+                new CacheOption(4, 7), "Standard");
         SQLParserRule actualResult = new SQLParserRuleBuilder().build(ruleConfig, new HashMap<>(), new ConfigurationProperties(new Properties()));
         assertThat(actualResult.getConfiguration(), is(ruleConfig));
         assertTrue(actualResult.isSqlCommentParseEnabled());

kernel/parser/core/src/test/java/org/apache/shardingsphere/parser/yaml/swapper/YamlSQLParserRuleConfigurationSwapperTest.java

@@ -32,7 +32,7 @@ class YamlSQLParserRuleConfigurationSwapperTest {
     @Test
     void assertSwapToYamlConfiguration() {
         YamlSQLParserRuleConfiguration actual =
-                new YamlSQLParserRuleConfigurationSwapper().swapToYamlConfiguration(new SQLParserRuleConfiguration(true, new CacheOption(2, 5), new CacheOption(4, 7)));
+                new YamlSQLParserRuleConfigurationSwapper().swapToYamlConfiguration(new SQLParserRuleConfiguration(true, new CacheOption(2, 5), new CacheOption(4, 7), "Standard"));
         assertTrue(actual.isSqlCommentParseEnabled());
         assertThat(actual.getParseTreeCache().getInitialCapacity(), is(2));
         assertThat(actual.getParseTreeCache().getMaximumSize(), is(5L));

kernel/parser/distsql/handler/src/main/java/org/apache/shardingsphere/parser/distsql/handler/update/AlterSQLParserRuleStatementUpdater.java

@@ -40,7 +40,7 @@ public SQLParserRuleConfiguration buildAlteredRuleConfiguration(final SQLParserR
         CacheOption sqlStatementCache =
                 null == sqlStatement.getSqlStatementCache() ? currentRuleConfig.getSqlStatementCache()
                         : createCacheOption(currentRuleConfig.getSqlStatementCache(), sqlStatement.getSqlStatementCache());
-        return new SQLParserRuleConfiguration(sqlCommentParseEnabled, parseTreeCache, sqlStatementCache);
+        return new SQLParserRuleConfiguration(sqlCommentParseEnabled, parseTreeCache, sqlStatementCache, "Standard");
     }
 
     private CacheOption createCacheOption(final CacheOption cacheOption, final CacheOptionSegment segment) {

kernel/parser/distsql/handler/src/test/java/org/apache/shardingsphere/parser/distsql/handler/query/ShowSQLParserRuleExecutorTest.java

@@ -66,7 +66,7 @@ void assertGetColumnNames() {
 
     private ShardingSphereMetaData mockMetaData() {
         SQLParserRule sqlParserRule = mock(SQLParserRule.class);
-        when(sqlParserRule.getConfiguration()).thenReturn(new SQLParserRuleConfiguration(true, new CacheOption(128, 1024), new CacheOption(2000, 65535)));
+        when(sqlParserRule.getConfiguration()).thenReturn(new SQLParserRuleConfiguration(true, new CacheOption(128, 1024), new CacheOption(2000, 65535), "Standard"));
         return new ShardingSphereMetaData(new LinkedHashMap<>(), new ShardingSphereRuleMetaData(Collections.singleton(sqlParserRule)), new ConfigurationProperties(new Properties()));
     }
 }

kernel/sql-federation/executor/advanced/src/test/java/org/apache/shardingsphere/sqlfederation/advanced/AdvancedSQLFederationExecutorTest.java

@@ -64,7 +64,7 @@ void init() {
 
     private ShardingSphereRuleMetaData createGlobalRuleMetaData() {
         CacheOption cacheOption = new CacheOption(128, 1024L);
-        return new ShardingSphereRuleMetaData(Collections.singleton(new SQLParserRule(new SQLParserRuleConfiguration(false, cacheOption, cacheOption))));
+        return new ShardingSphereRuleMetaData(Collections.singleton(new SQLParserRule(new SQLParserRuleConfiguration(false, cacheOption, cacheOption, "Standard"))));
     }
 
     private ShardingSphereResourceMetaData mockResourceMetaData() {

kernel/sql-federation/optimizer/src/test/java/org/apache/shardingsphere/sqlfederation/optimizer/context/OptimizerContextTest.java

@@ -63,6 +63,6 @@ private ShardingSphereDatabase createShardingSphereDatabase() {
 
     private ShardingSphereRuleMetaData createShardingSphereRuleMetaData() {
         CacheOption cacheOption = new CacheOption(10, 1000);
-        return new ShardingSphereRuleMetaData(Collections.singleton(new SQLParserRule(new SQLParserRuleConfiguration(true, cacheOption, cacheOption))));
+        return new ShardingSphereRuleMetaData(Collections.singleton(new SQLParserRule(new SQLParserRuleConfiguration(true, cacheOption, cacheOption, "Standard"))));
     }
 }

proxy/backend/type/mysql/src/test/java/org/apache/shardingsphere/proxy/backend/mysql/handler/admin/executor/MySQLSetVariableAdminExecutorTest.java

@@ -91,7 +91,7 @@ private ContextManager mockContextManager() {
         ContextManager result = mock(ContextManager.class, RETURNS_DEEP_STUBS);
         when(result.getMetaDataContexts().getMetaData().getDatabase("foo_db")).thenReturn(mock(ShardingSphereDatabase.class));
         when(result.getMetaDataContexts().getMetaData().getGlobalRuleMetaData())
-                .thenReturn(new ShardingSphereRuleMetaData(Collections.singleton(new SQLParserRule(new SQLParserRuleConfiguration(false, new CacheOption(1, 1), new CacheOption(1, 1))))));
+                .thenReturn(new ShardingSphereRuleMetaData(Collections.singleton(new SQLParserRule(new SQLParserRuleConfiguration(false, new CacheOption(1, 1), new CacheOption(1, 1), "Standard")))));
         return result;
     }
 }

proxy/backend/type/postgresql/src/test/java/org/apache/shardingsphere/proxy/backend/postgresql/handler/admin/PostgreSQLAdminExecutorCreatorTest.java

@@ -131,7 +131,7 @@ void assertCreateWithSelectPgNamespaceAndPgClass() {
 
     private static SQLStatement parseSQL(final String sql) {
         CacheOption cacheOption = new CacheOption(0, 0);
-        SQLParserRule sqlParserRule = new SQLParserRule(new SQLParserRuleConfiguration(false, cacheOption, cacheOption));
+        SQLParserRule sqlParserRule = new SQLParserRule(new SQLParserRuleConfiguration(false, cacheOption, cacheOption, "Standard"));
         return sqlParserRule.getSQLParserEngine("PostgreSQL").parse(sql, false);
     }
 

proxy/frontend/type/mysql/src/test/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/binary/prepare/MySQLComStmtPrepareExecutorTest.java

@@ -227,7 +227,7 @@ private ContextManager mockContextManager() {
         when(result.getMetaDataContexts().getMetaData().getGlobalRuleMetaData()).thenReturn(mock(ShardingSphereRuleMetaData.class));
         CacheOption cacheOption = new CacheOption(1024, 1024);
         when(result.getMetaDataContexts().getMetaData().getGlobalRuleMetaData().getSingleRule(SQLParserRule.class))
-                .thenReturn(new SQLParserRule(new SQLParserRuleConfiguration(false, cacheOption, cacheOption)));
+                .thenReturn(new SQLParserRule(new SQLParserRuleConfiguration(false, cacheOption, cacheOption, "Standard")));
         when(result.getMetaDataContexts().getMetaData().getDatabase(connectionSession.getDatabaseName()).getProtocolType()).thenReturn(new MySQLDatabaseType());
         ShardingSphereTable table = new ShardingSphereTable();
         table.getColumns().put("id", new ShardingSphereColumn("id", Types.BIGINT, true, false, false, false, true));

sql-parser/statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/SimpleSQLStatement.java

@@ -17,10 +17,12 @@
 
 package org.apache.shardingsphere.sql.parser.sql.common.statement;
 
+import org.apache.shardingsphere.sql.parser.sql.dialect.statement.mysql.MySQLStatement;
+
 /**
  * Simple SQL statement.
  */
-public final class SimpleSQLStatement implements SQLStatement {
+public final class SimpleSQLStatement implements MySQLStatement {
 
     @Override
     public int getParameterCount() {

test/it/rewriter/src/test/java/org/apache/shardingsphere/test/it/rewrite/engine/SQLRewriterIT.java

@@ -88,7 +88,7 @@
 public abstract class SQLRewriterIT {
 
     private final SQLParserRule sqlParserRule = new SQLParserRule(new SQLParserRuleConfiguration(true,
-            DefaultSQLParserRuleConfigurationBuilder.PARSE_TREE_CACHE_OPTION, DefaultSQLParserRuleConfigurationBuilder.SQL_STATEMENT_CACHE_OPTION));
+            DefaultSQLParserRuleConfigurationBuilder.PARSE_TREE_CACHE_OPTION, DefaultSQLParserRuleConfigurationBuilder.SQL_STATEMENT_CACHE_OPTION, "Standard"));
 
     private final TimeServiceRule timeServiceRule = new TimeServiceRule(new TimeServiceRuleConfiguration("System", new Properties()));