This is an automated email from the ASF dual-hosted git repository. wuweijie pushed a commit to branch opengauss_adapt in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
commit 67fdf1792aa49b0d4ec732e1f2e5ab96f99acba2 Merge: cb5f7d6 69d122f Author: 吴伟杰 <[email protected]> AuthorDate: Fri Jul 2 22:01:33 2021 +0800 Merge branch 'merge' into opengauss_adapt README.md | 30 +- .../community/content/contribute/contributor.en.md | 2 +- .../content/features/dist-sql/syntax/_index.en.md | 2 +- .../features/dist-sql/syntax/rdl/_index.en.md | 2 +- .../syntax/rdl/rdl-db-discovery-rule.en.md | 43 +- .../dist-sql/syntax/rdl/rdl-encrypt-rule.en.md | 51 +- .../syntax/rdl/rdl-readwrite-splitting-rule.en.md | 59 +- .../dist-sql/syntax/rdl/rdl-resource.en.md | 36 +- .../dist-sql/syntax/rdl/rdl-sharding-rule.cn.md | 2 +- .../dist-sql/syntax/rdl/rdl-sharding-rule.en.md | 112 +- .../features/dist-sql/syntax/rql/_index.en.md | 2 +- .../syntax/rql/rql-db-discovery-rule.en.md | 27 +- .../dist-sql/syntax/rql/rql-encrypt-rule.cn.md | 4 +- .../dist-sql/syntax/rql/rql-encrypt-rule.en.md | 57 +- .../syntax/rql/rql-readwrite-splitting-rule.en.md | 52 +- .../dist-sql/syntax/rql/rql-resource.en.md | 30 +- .../dist-sql/syntax/rql/rql-sharding-rule.en.md | 111 +- .../features/dist-sql/syntax/sctl/_index.en.md | 2 +- .../content/features/dist-sql/usage/_index.en.md | 2 +- .../features/dist-sql/usage/sharding-rule.en.md | 105 +- docs/document/content/overview/_index.en.md | 34 +- .../sharding/docker-compose.yml | 0 .../governance/docker-compose.yml | 0 .../governance/run.sh | 0 .../governance/stop.sh | 0 .../sharding/conf/config-sharding.yaml | 0 .../sharding/conf/server.yaml | 0 .../sharding/docker-compose.yml | 0 examples/pom.xml | 5 - .../class-based-sharding-algorithm-example/pom.xml | 42 + .../YamlClassBasedShardingAlgorithmExample.java | 42 + .../classbased/factory/YamlDataSourceFactory.java | 42 + ...ClassBasedStandardShardingAlgorithmFixture.java | 51 + .../resources/META-INF/sharding-databases.yaml | 70 + .../src/main/resources/logback.xml | 34 + .../custom-sharding-algortihm-example/pom.xml | 35 + .../extension-example/pom.xml | 35 + .../GovernanceRawJavaConfigurationExample.java | 99 + .../GovernanceRawYamlConfigurationExample.java | 93 + .../raw/jdbc/JavaConfigurationExampleMain.java | 99 - .../raw/jdbc/YamlConfigurationExampleMain.java | 93 - .../META-INF/zookeeper/local/encrypt.yaml | 2 +- .../zookeeper/local/readwrite-splitting.yaml | 6 +- .../resources/META-INF/zookeeper/local/shadow.yaml | 4 +- .../zookeeper/local/sharding-databases-tables.yaml | 4 +- .../governance/spring/boot/ExampleMain.java | 41 - .../spring/boot/GovernanceSpringBootExample.java | 41 + .../application-local-zookeeper-encrypt.properties | 2 +- ...-local-zookeeper-readwrite-splitting.properties | 6 +- .../application-local-zookeeper-shadow.properties | 4 +- ...-zookeeper-sharding-databases-tables.properties | 4 +- .../governance/spring/namespace/ExampleMain.java | 61 - .../GovernanceSpringNamespaceExample.java | 61 + .../zookeeper/local/application-encrypt.xml | 2 +- .../local/application-readwrite-splitting.xml | 6 +- .../zookeeper/local/application-shadow.xml | 4 +- .../application-sharding-databases-tables.xml | 4 +- .../jdbc/EncryptRawJavaConfigurationExample.java | 43 + .../jdbc/EncryptRawYamlConfigurationExample.java | 45 + .../raw/jdbc/JavaConfigurationExampleMain.java | 43 - .../raw/jdbc/YamlConfigurationExampleMain.java | 45 - .../spring/boot/EncryptSpringBootExample.java | 41 + .../encrypt/table/spring/boot/ExampleMain.java | 41 - .../namespace/EncryptSpringNamespaceExample.java | 36 + .../table/spring/namespace/ExampleMain.java | 36 - .../META-INF/application-encrypt-databases.xml | 2 +- .../example/hint/raw/jdbc/ExampleMain.java | 96 - .../example/hint/raw/jdbc/HintRawExample.java | 96 + .../resources/META-INF/hint-databases-only.yaml | 4 +- .../resources/META-INF/hint-databases-tables.yaml | 4 +- .../main/resources/META-INF/hint-write-only.yaml | 6 +- .../raw/jdbc/JavaConfigurationExampleMain.java | 49 - .../jdbc/ShadowRawJavaConfigurationExample.java | 49 + .../jdbc/ShadowRawYamlConfigurationExample.java | 46 + .../raw/jdbc/YamlConfigurationExampleMain.java | 46 - .../shadow/table/spring/boot/ExampleMain.java | 41 - .../table/spring/boot/ShadowSpringBootExample.java | 41 + .../shadow/table/spring/namespace/ExampleMain.java | 39 - .../namespace/ShadowSpringNamespaceExample.java | 39 + .../application-encrypt-shadow-databases.xml | 4 +- ...cation-readwrite-splitting-shadow-databases.xml | 8 +- .../META-INF/application-shadow-databases.xml | 4 +- .../application-sharding-shadow-databases.xml | 8 +- examples/shardingsphere-jdbc-example/pom.xml | 1 + .../raw/jdbc/JavaConfigurationExampleMain.java | 48 - .../jdbc/JavaRangeConfigurationExampleMain.java | 51 - .../jdbc/ShardingRawJavaConfigurationExample.java | 48 + .../ShardingRawJavaRangeConfigurationExample.java | 51 + .../jdbc/ShardingRawYamlConfigurationExample.java | 49 + .../ShardingRawYamlRangeConfigurationExample.java | 49 + .../raw/jdbc/YamlConfigurationExampleMain.java | 49 - .../jdbc/YamlRangeConfigurationExampleMain.java | 49 - .../sharding/spring/boot/jpa/ExampleMain.java | 41 - .../boot/jpa/ShardingSpringBootJpaExample.java | 41 + ...pplication-sharding-databases-tables.properties | 4 +- ...ication-sharding-readwrite-splitting.properties | 12 +- .../application-sharding-tables.properties | 2 +- .../sharding/spring/boot/mybatis/ExampleMain.java | 41 - .../mybatis/ShardingSpringBootMybatisExample.java | 41 + .../sharding/spring/namespace/jpa/ExampleMain.java | 40 - .../jpa/ShardingSpringNamespaceJpaExample.java | 40 + .../META-INF/application-readwrite-splitting.xml | 6 +- .../application-sharding-databases-tables.xml | 4 +- .../META-INF/application-sharding-databases.xml | 4 +- .../application-sharding-readwrite-splitting.xml | 12 +- .../META-INF/application-sharding-tables.xml | 2 +- .../spring/namespace/mybatis/ExampleMain.java | 40 - .../ShardingSpringNamespaceMybatisExample.java | 40 + .../META-INF/application-readwrite-splitting.xml | 4 +- .../application-sharding-databases-tables.xml | 4 +- .../META-INF/application-sharding-databases.xml | 4 +- .../application-sharding-readwrite-splitting.xml | 12 +- .../META-INF/application-sharding-tables.xml | 2 +- .../xa/bitronix/raw/jdbc/ExampleMain.java | 44 - .../raw/jdbc/TransactionXaBitronixRawExample.java | 44 + .../xa/narayana/raw/jdbc/ExampleMain.java | 45 - .../raw/jdbc/TransactionXaNarayanaRawExample.java | 45 + .../transaction/xa/raw/jdbc/ExampleMain.java | 31 - .../xa/raw/jdbc/TransactionXaRawExample.java | 31 + .../xa/spring/boot/ExampleMainApplication.java | 44 - .../boot/TransactionXaSpringBootExample.java | 44 + .../xa/spring/namspace/ExampleMain.java | 34 - .../TransactionXaSpringNamespaceExample.java | 34 + .../application-sharding-databases-tables.xml | 4 +- .../META-INF/application-sharding-databases.xml | 4 +- .../META-INF/application-sharding-tables.xml | 2 +- .../base/seata/raw/jdbc/ExampleMain.java | 41 - .../raw/jdbc/TransactionBaseSeataRawExample.java | 41 + .../seata/spring/boot/ExampleMainApplication.java | 53 - .../TransactionBaseSeataSpringBootExample.java | 53 + .../example/parser/SQLFormatExampleMain.java | 38 - .../parser/SQLParameterizedExampleMain.java | 37 - .../example/parser/SQLParserFormatExample.java | 38 + .../parser/SQLParserParameterizedExample.java | 37 + .../mybatis/ProxySpringBootStarterExample.java | 65 + .../boot/mybatis/SpringBootStarterExample.java | 65 - .../example/proxy/hint/ExampleMain.java | 93 - .../example/proxy/hint/ProxyHintExample.java | 93 + .../main/resources/conf/config-databases-only.yaml | 4 +- .../resources/conf/config-databases-tables.yaml | 4 +- .../src/main/resources/conf/config-write-only.yaml | 6 +- .../db/protocol/error/CommonErrorCode.java | 40 - .../db/protocol/error/CustomizedErrorCode.java | 35 + .../db/protocol/error/CommonErrorCodeTest.java | 14 - .../binlog/row/column/MySQLBinlogColumnDef.java | 5 +- .../handshake/MySQLHandshakeResponse41Packet.java | 2 +- .../query/binary/bind/PostgreSQLComBindPacket.java | 4 +- .../binary/execute/PostgreSQLComExecutePacket.java | 10 +- .../execute/PostgreSQLPortalSuspendedPacket.java | 38 + shardingsphere-distsql-parser/pom.xml | 1 + .../src/main/antlr4/imports/Keyword.g4 | 4 + .../src/main/antlr4/imports/RDLStatement.g4 | 10 +- .../resource/ResourceDistSQLStatementVisitor.java | 14 +- .../api/DistSQLStatementParserEngineTest.java | 36 + .../distsql/parser/segment/DataSourceSegment.java | 4 + .../shardingsphere-distsql-parser-test/pom.xml | 39 + .../DatabaseDiscoveryRuleQueryResultSet.java | 74 - .../DatabaseDiscoveryRuleNotExistedException.java | 34 + .../InvalidDatabaseDiscoveryTypesException.java | 34 + .../query/DatabaseDiscoveryRuleQueryResultSet.java | 74 + ...AlterDatabaseDiscoveryRuleStatementUpdater.java | 141 + ...reateDatabaseDiscoveryRuleStatementUpdater.java | 126 + .../DropDatabaseDiscoveryRuleStatementUpdater.java | 83 + ....shardingsphere.infra.distsql.update.RDLUpdater | 20 + .../DatabaseDiscoveryRuleQueryResultSetTest.java | 65 - .../DatabaseDiscoveryRuleQueryResultSetTest.java | 65 + ...rDatabaseDiscoveryRuleStatementUpdaterTest.java | 82 + ...eDatabaseDiscoveryRuleStatementUpdaterTest.java | 65 + ...pDatabaseDiscoveryRuleStatementUpdaterTest.java | 66 + ...pache.shardingsphere.infra.distsql.RQLResultSet | 18 - ...shardingsphere.infra.distsql.query.RQLResultSet | 18 + ...baseDiscoveryRuleStatementParserEngineTest.java | 110 - .../encrypt/algorithm/AESEncryptAlgorithm.java | 9 +- .../encrypt/distsql/EncryptRuleQueryResultSet.java | 94 - .../exception/EncryptRuleNotExistedException.java | 34 + .../exception/InvalidEncryptorsException.java | 34 + .../distsql/query/EncryptRuleQueryResultSet.java | 94 + .../update/AlterEncryptRuleStatementUpdater.java | 121 + .../update/CreateEncryptRuleStatementUpdater.java | 106 + .../update/DropEncryptRuleStatementUpdater.java | 81 + .../metadata/EncryptTableMetaDataBuilder.java | 3 +- ...pache.shardingsphere.infra.distsql.RQLResultSet | 18 - ...shardingsphere.infra.distsql.query.RQLResultSet | 18 + ....shardingsphere.infra.distsql.update.RDLUpdater | 20 + .../distsql/EncryptRuleQueryResultSetTest.java | 68 - .../query/EncryptRuleQueryResultSetTest.java | 68 + .../AlterEncryptRuleStatementUpdaterTest.java | 73 + .../CreateEncryptRuleStatementUpdaterTest.java | 59 + .../DropEncryptRuleStatementUpdaterTest.java | 68 + .../metadata/EncryptTableMetaDataBuilderTest.java | 2 +- .../core/EncryptRuleStatementParserEngineTest.java | 124 - .../ReadwriteSplittingRuleQueryResultSet.java | 76 - .../exception/InvalidLoadBalancersException.java | 34 + .../ReadwriteSplittingRuleNotExistedException.java | 34 + .../ReadwriteSplittingRuleQueryResultSet.java | 76 + ...lterReadwriteSplittingRuleStatementUpdater.java | 135 + ...eateReadwriteSplittingRuleStatementUpdater.java | 123 + ...DropReadwriteSplittingRuleStatementUpdater.java | 83 + ...pache.shardingsphere.infra.distsql.RQLResultSet | 18 - ...shardingsphere.infra.distsql.query.RQLResultSet | 18 + ....shardingsphere.infra.distsql.update.RDLUpdater | 20 + .../ReadwriteSplittingRuleQueryResultSetTest.java | 70 - .../ReadwriteSplittingRuleQueryResultSetTest.java | 70 + ...ReadwriteSplittingRuleStatementUpdaterTest.java | 82 + ...ReadwriteSplittingRuleStatementUpdaterTest.java | 71 + ...ReadwriteSplittingRuleStatementUpdaterTest.java | 66 + ...riteSplittingRuleStatementParserEngineTest.java | 133 - .../token/pojo/ShadowInsertValuesToken.java | 12 +- .../shadow/condition/ShadowConditionTest.java | 34 + .../ShadowSQLRewriteContextDecoratorTest.java | 45 + .../ShadowParameterRewriterBuilderTest.java | 42 + .../ShadowInsertValueParameterRewriterTest.java | 71 + .../impl/ShadowPredicateParameterRewriterTest.java | 48 + .../token/ShadowTokenGenerateBuilderTest.java | 41 + .../impl/RemoveShadowColumnTokenGeneratorTest.java | 94 + .../impl/ShadowInsertValuesTokenGeneratorTest.java | 91 + .../ShadowPredicateColumnTokenGeneratorTest.java | 49 + .../token/pojo/ShadowInsertValuesTokenTest.java | 39 + .../converter/ShardingRuleStatementConverter.java | 4 +- .../ShardingBindingTableRuleQueryResultSet.java | 64 - .../ShardingBroadcastTableRuleQueryResultSet.java | 64 - .../distsql/ShardingTableRuleQueryResultSet.java | 206 -- .../exception/DuplicateBindingTablesException.java | 34 + .../exception/DuplicateTablesException.java | 34 + .../exception/InvalidKeyGeneratorsException.java | 34 + .../InvalidShardingAlgorithmsException.java | 34 + ...ShardingBindingTableRuleNotExistsException.java | 32 + ...ShardingBroadcastTableRuleExistedException.java | 32 + ...ardingBroadcastTableRuleNotExistsException.java | 32 + .../ShardingTableRuleNotExistedException.java | 34 + .../ShardingTableRulesInUsedException.java | 34 + .../ShardingBindingTableRuleQueryResultSet.java | 64 + .../ShardingBroadcastTableRuleQueryResultSet.java | 64 + .../query/ShardingTableRuleQueryResultSet.java | 206 ++ ...erShardingBindingTableRuleStatementUpdater.java | 100 + ...ShardingBroadcastTableRuleStatementUpdater.java | 66 + .../AlterShardingTableRuleStatementUpdater.java | 181 ++ ...teShardingBindingTableRuleStatementUpdater.java | 108 + ...ShardingBroadcastTableRuleStatementUpdater.java | 63 + .../CreateShardingTableRuleStatementUpdater.java | 145 + ...opShardingBindingTableRuleStatementUpdater.java | 58 + ...ShardingBroadcastTableRuleStatementUpdater.java | 58 + .../DropShardingTableRuleStatementUpdater.java | 109 + .../metadata/ShardingTableMetaDataBuilder.java | 2 +- .../token/generator/impl/TableTokenGenerator.java | 2 +- .../sharding/rewrite/token/pojo/TableToken.java | 10 +- ...pache.shardingsphere.infra.distsql.RQLResultSet | 20 - ...shardingsphere.infra.distsql.query.RQLResultSet | 20 + ....shardingsphere.infra.distsql.update.RDLUpdater | 26 + ...ShardingBindingTableRuleQueryResultSetTest.java | 59 - ...ardingBroadcastTableRuleQueryResultSetTest.java | 54 - .../ShardingTableRuleQueryResultSetTest.java | 78 - ...ShardingBindingTableRuleQueryResultSetTest.java | 59 + ...ardingBroadcastTableRuleQueryResultSetTest.java | 54 + .../query/ShardingTableRuleQueryResultSetTest.java | 78 + ...ardingBindingTableRuleStatementUpdaterTest.java | 71 + ...dingBroadcastTableRuleStatementUpdaterTest.java | 54 + ...AlterShardingTableRuleStatementUpdaterTest.java | 87 + ...ardingBindingTableRuleStatementUpdaterTest.java | 63 + ...reateShardingTableRuleStatementUpdaterTest.java | 53 + ...ardingBindingTableRuleStatementUpdaterTest.java | 63 + ...dingBroadcastTableRuleStatementUpdaterTest.java | 63 + .../DropShardingTableRuleStatementUpdaterTest.java | 93 + .../dal/show/ShowCreateTableMergedResultTest.java | 2 +- .../merge/dal/show/ShowTablesMergedResultTest.java | 2 +- .../merge/dql/ShardingDQLResultMergerTest.java | 2 +- .../dql/groupby/GroupByStreamMergedResultTest.java | 2 +- .../dql/orderby/OrderByStreamMergedResultTest.java | 2 +- .../engine/type/standard/AbstractSQLRouteTest.java | 8 +- .../ShardingRuleStatementParserEngineTest.java | 216 -- .../parser/segment/BindingTableRuleSegment.java | 15 +- .../AlterShardingBindingTableRulesStatement.java | 16 +- .../CreateShardingBindingTableRulesStatement.java | 16 +- .../authority/GovernanceAuthorityContext.java | 55 - .../metadata/GovernanceMetaDataContexts.java | 87 +- .../process/GovernanceExecuteProcessReporter.java | 6 +- ...a.context.metadata.MetaDataAwareEventSubscriber | 18 - .../metadata/GovernanceMetaDataContextsTest.java | 70 +- .../yaml/schema/swapper/SchemaYamlSwapper.java | 6 +- .../authority/checker/AuthorityChecker.java | 5 +- ...vilegesPermittedAuthorityProviderAlgorithm.java | 70 + .../schema/builder/SchemaPrivilegeBuilder.java | 92 + ...rivilegesPermittedShardingSpherePrivileges.java | 57 + .../authority/rule/AuthorityRule.java | 2 - ...gsphere.authority.spi.AuthorityProvideAlgorithm | 1 + .../NativeAuthorityProviderAlgorithmTest.java | 207 ++ .../builder/StoragePrivilegeBuilderTest.java | 174 ++ .../engine/ProjectionsContextEngine.java | 2 +- .../infra/binder/segment/table/TablesContext.java | 2 +- .../engine/GeneratedKeyContextEngineTest.java | 2 +- .../orderby/engine/OrderByContextEngineTest.java | 2 +- .../engine/ProjectionsContextEngineTest.java | 45 + .../binder/segment/table/TablesContextTest.java | 9 + .../config/datasource/DataSourceConverter.java | 4 +- .../shardingsphere/infra/distsql/RQLResultSet.java | 59 - .../infra/distsql/query/RQLResultSet.java | 59 + .../infra/distsql/update/RDLAlterUpdater.java | 39 + .../infra/distsql/update/RDLCreateUpdater.java | 49 + .../infra/distsql/update/RDLDropUpdater.java | 40 + .../infra/distsql/update/RDLUpdater.java | 49 + .../exception/rule/DuplicateResourceException.java | 32 + .../rule/DuplicateRuleNamesException.java | 32 + .../exception/rule/InvalidResourceException.java | 32 + .../exception/rule/ResourceInUsedException.java | 32 + .../rule/ResourceNotExistedException.java | 32 + .../rule/RuleDefinitionViolationException.java | 37 + .../metadata/resource/ShardingSphereResource.java | 10 + .../metadata/schema/ShardingSphereSchema.java | 2 + .../metadata/schema/builder/SchemaBuilder.java | 81 +- .../schema/builder/TableMetaDataBuilder.java | 14 +- .../builder/loader/ColumnMetaDataLoader.java | 12 +- .../schema/builder/loader/TableMetaDataLoader.java | 2 +- .../loader/dialect/H2TableMetaDataLoader.java | 2 +- .../loader/dialect/MySQLTableMetaDataLoader.java | 2 +- .../loader/dialect/OracleTableMetaDataLoader.java | 25 +- .../dialect/PostgreSQLTableMetaDataLoader.java | 2 +- .../dialect/SQLServerTableMetaDataLoader.java | 2 +- .../infra/metadata/schema/model/TableMetaData.java | 13 +- .../rule/builder/ShardingSphereRulesBuilder.java | 11 +- .../metadata/schema/ShardingSphereSchemaTest.java | 6 +- .../metadata/schema/builder/SchemaBuilderTest.java | 41 +- .../dialect/OracleTableMetaDataLoaderTest.java | 120 +- ...tainedFixtureRuleBasedTableMetaDataBuilder.java | 4 +- .../metadata/schema/model/TableMetaDataTest.java | 2 +- .../type/ShardingSphereSchemaBuildUtil.java | 2 +- .../infra/context/kernel/KernelProcessor.java | 2 +- .../metadata/MetaDataAwareEventSubscriber.java | 31 - .../context/metadata/MetaDataContextsBuilder.java | 38 +- .../metadata/impl/StandardMetaDataContexts.java | 11 +- .../impl/StandardMetaDataContextsTest.java | 17 +- .../infra/executor/check/SQLCheckEngine.java | 1 - .../executor/sql/context/ExecutionContext.java | 13 +- .../sql/execute/engine/raw/RawExecutor.java | 8 +- .../federate/schema/row/FederateRowExecutor.java | 2 +- .../FederateExecutionContextGenerator.java | 2 +- .../executor/sql/process/ExecuteProcessEngine.java | 8 +- .../sql/process/model/ExecuteProcessContext.java | 5 +- .../model/yaml/YamlExecuteProcessContext.java | 3 + .../sql/process/spi/ExecuteProcessReporter.java | 6 +- .../sql/context/ExecutionContextBuilderTest.java | 10 +- .../infra/executor/sql/log/SQLLoggerTest.java | 6 +- .../shardingsphere-infra-optimize/pom.xml | 30 + .../infra/optimize/ShardingSphereOptimizer.java | 16 +- .../infra/optimize/context/OptimizeContext.java | 8 + .../optimize/context/OptimizeContextFactory.java | 11 +- .../core/convert/SqlNodeConvertEngine.java | 13 +- .../core/convert/converter/SqlNodeConverter.java | 4 +- .../convert/converter/SqlNodeConverterUtil.java | 63 + .../impl/AbstractLimitSqlNodeConverter.java | 50 + .../BinaryOperationExpressionSqlNodeConverter.java | 44 + .../impl/ColumnOrderByItemSqlNodeConverter.java | 44 + .../impl/ColumnProjectionSqlNodeConverter.java | 37 + .../converter/impl/ColumnSqlNodeConverter.java | 44 + .../converter/impl/DistinctSqlNodeConverter.java | 5 +- .../ExpressionOrderByItemSqlNodeConverter.java | 33 + .../impl/ExpressionProjectionSqlNodeConverter.java | 36 + .../converter/impl/ExpressionSqlNodeConverter.java | 55 + .../converter/impl/GroupBySqlNodeConverter.java | 46 + .../converter/impl/HavingSqlNodeConverter.java | 38 + .../converter/impl/JoinTableSqlNodeConverter.java | 75 + .../impl/ListExpressionSqlNodeConverter.java | 53 + .../impl/LiteralExpressionSqlNodeConverter.java | 40 + .../converter/impl/OffsetSqlNodeConverter.java | 28 + .../converter/impl/OrderBySqlNodeConverter.java | 43 + .../impl/PaginationValueSqlConverter.java | 46 + .../impl/ProjectionsSqlNodeConverter.java | 57 + .../converter/impl/RowCountSqlNodeConverter.java | 28 + .../impl/SelectStatementSqlNodeConverter.java | 30 +- .../impl/SimpleTableSqlNodeConverter.java | 49 + .../impl/SubqueryTableSqlNodeConverter.java | 36 + .../converter/impl/TableSqlNodeConverter.java | 45 + .../converter/impl/WhereSqlNodeConverter.java | 40 + .../core/metadata/FederateSchemaMetadata.java | 56 - .../core/metadata/FederateSchemaMetadatas.java | 8 +- .../core/metadata/FederateTableMetadata.java | 39 +- .../optimize/core/operator/BinarySqlOperator.java | 72 + .../core/convert/BaseSqlNodeConverterTest.java | 72 + .../SelectStatementSqlNodeConverterTest.java | 169 ++ .../AlterTableStatementFederateRefresherTest.java | 2 +- .../DropTableStatementFederateRefresherTest.java | 2 +- .../driver/executor/DriverJDBCExecutor.java | 24 +- .../statement/ShardingSpherePreparedStatement.java | 12 +- .../core/statement/ShardingSphereStatement.java | 18 +- .../statement/EncryptPreparedStatementTest.java | 14 +- .../GovernanceShardingSphereDataSource.java | 16 - .../communication/DatabaseCommunicationEngine.java | 75 +- .../DatabaseCommunicationEngineFactory.java | 8 +- .../backend/communication/ProxySQLExecutor.java | 13 +- .../communication/SQLStatementSchemaHolder.java | 55 + .../jdbc/connection/BackendConnection.java | 79 +- .../jdbc/executor/ProxyJDBCExecutor.java | 15 +- .../callback/ProxyJDBCExecutorCallback.java | 12 +- .../callback/ProxyJDBCExecutorCallbackFactory.java | 15 +- .../ProxyPreparedStatementExecutorCallback.java | 6 +- .../impl/ProxyStatementExecutorCallback.java | 6 +- .../transaction/BackendTransactionManager.java | 1 + .../DatabaseDiscoveryRulesNotExistedException.java | 37 - .../exception/DuplicateBindingTablesException.java | 35 - .../exception/DuplicateResourceException.java | 32 - .../exception/DuplicateRuleNamesException.java | 37 - .../exception/DuplicateTablesException.java | 35 - .../exception/EncryptRulesNotExistedException.java | 37 - .../InvalidDatabaseDiscoveryTypesException.java | 35 - .../exception/InvalidEncryptorsException.java | 35 - .../exception/InvalidKeyGeneratorsException.java | 35 - .../exception/InvalidLoadBalancersException.java | 35 - .../exception/InvalidResourceException.java | 35 - .../InvalidShardingAlgorithmsException.java | 35 - ...ReadwriteSplittingRulesNotExistedException.java | 37 - .../backend/exception/ResourceInUsedException.java | 35 - .../exception/ResourceNotExistedException.java | 37 - .../backend/exception/RuleNotExistedException.java | 26 + .../backend/exception/RuleNotExistsException.java | 26 - ...hardingBindingTableRulesNotExistsException.java | 33 - ...ShardingBroadcastTableRulesExistsException.java | 30 - ...rdingBroadcastTableRulesNotExistsException.java | 33 - .../ShardingTableRuleNotExistedException.java | 37 - .../ShardingTableRulesInUsedException.java | 35 - .../backend/exception/TableLockedException.java | 4 +- .../TableModifyInTransactionException.java | 7 +- .../backend/text/TextProtocolBackendHandler.java | 8 + .../text/TextProtocolBackendHandlerFactory.java | 13 +- .../mysql/executor/ShowDatabasesExecutor.java | 32 +- .../mysql/executor/ShowProcessListExecutor.java | 4 +- .../data/impl/BroadcastDatabaseBackendHandler.java | 4 +- .../impl/SchemaAssignedDatabaseBackendHandler.java | 11 +- .../data/impl/UnicastDatabaseBackendHandler.java | 11 +- .../text/distsql/DistSQLBackendHandlerFactory.java | 6 +- .../text/distsql/rdl/RDLBackendHandlerFactory.java | 112 +- .../rdl/impl/AddResourceBackendHandler.java | 4 +- .../AlterDatabaseDiscoveryRuleBackendHandler.java | 125 - .../rdl/impl/AlterEncryptRuleBackendHandler.java | 116 - .../AlterReadwriteSplittingRuleBackendHandler.java | 126 - ...terShardingBindingTableRulesBackendHandler.java | 98 - ...rShardingBroadcastTableRulesBackendHandler.java | 49 - .../impl/AlterShardingTableRuleBackendHandler.java | 149 - .../CreateDatabaseDiscoveryRuleBackendHandler.java | 123 - .../rdl/impl/CreateEncryptRuleBackendHandler.java | 104 - ...CreateReadwriteSplittingRuleBackendHandler.java | 120 - ...ateShardingBindingTableRulesBackendHandler.java | 102 - ...eShardingBroadcastTableRulesBackendHandler.java | 55 - .../CreateShardingTableRuleBackendHandler.java | 131 - .../DropDatabaseDiscoveryRuleBackendHandler.java | 70 - .../rdl/impl/DropEncryptRuleBackendHandler.java | 70 - .../DropReadwriteSplittingRuleBackendHandler.java | 66 - .../rdl/impl/DropResourceBackendHandler.java | 4 +- ...ropShardingBindingTableRulesBackendHandler.java | 48 - ...pShardingBroadcastTableRulesBackendHandler.java | 48 - .../impl/DropShardingTableRuleBackendHandler.java | 94 - .../text/distsql/rdl/impl/RDLBackendHandler.java | 91 +- .../text/distsql/rql/DataSourceQueryResultSet.java | 2 +- .../text/distsql/rql/RQLBackendHandler.java | 2 +- .../text/distsql/rql/RQLBackendHandlerFactory.java | 2 +- .../explain/ShardingCTLExplainBackendHandler.java | 4 +- .../executor/HintShowTableStatusExecutor.java | 4 +- ...hardingsphere.infra.distsql.query.RQLResultSet} | 0 .../TextProtocolBackendHandlerFactoryTest.java | 1 + .../DatabaseCommunicationEngineFactoryTest.java | 11 +- .../DatabaseCommunicationEngineTest.java | 112 +- .../jdbc/connection/BackendConnectionTest.java | 142 +- .../jdbc/datasource/JDBCBackendDataSourceTest.java | 3 +- .../transaction/BackendTransactionManagerTest.java | 6 +- .../context/BackendExecutorContextTest.java | 3 +- .../proxy/backend/context/ProxyContextTest.java | 14 +- .../header/query/impl/QueryHeaderBuilderTest.java | 2 +- .../mysql/executor/ShowDatabasesExecutorTest.java | 7 +- .../executor/ShowProcessListExecutorTest.java | 3 +- .../mysql/executor/ShowTablesExecutorTest.java | 3 +- .../mysql/executor/UseDatabaseExecutorTest.java | 5 +- .../impl/BroadcastDatabaseBackendHandlerTest.java | 3 +- .../SchemaAssignedDatabaseBackendHandlerTest.java | 3 +- .../impl/UnicastDatabaseBackendHandlerTest.java | 3 +- .../distsql/DistSQLBackendHandlerFactoryTest.java | 57 +- .../rdl/impl/AddResourceBackendHandlerTest.java | 3 +- ...terDatabaseDiscoveryRuleBackendHandlerTest.java | 150 - .../impl/AlterEncryptRuleBackendHandlerTest.java | 127 - ...erReadwriteSplittingRuleBackendHandlerTest.java | 151 - ...hardingBindingTableRulesBackendHandlerTest.java | 119 - ...rdingBroadcastTableRulesBackendHandlerTest.java | 90 - .../AlterShardingTableRuleBackendHandlerTest.java | 146 - ...ateDatabaseDiscoveryRuleBackendHandlerTest.java | 134 - .../impl/CreateEncryptRuleBackendHandlerTest.java | 115 - ...teReadwriteSplittingRuleBackendHandlerTest.java | 156 -- ...hardingBindingTableRulesBackendHandlerTest.java | 136 - ...rdingBroadcastTableRulesBackendHandlerTest.java | 100 - .../CreateShardingTableRuleBackendHandlerTest.java | 113 - ...ropDatabaseDiscoveryRuleBackendHandlerTest.java | 113 - .../impl/DropEncryptRuleBackendHandlerTest.java | 117 - ...opReadwriteSplittingRuleBackendHandlerTest.java | 115 - ...hardingBindingTableRulesBackendHandlerTest.java | 108 - ...rdingBroadcastTableRulesBackendHandlerTest.java | 108 - .../DropShardingTableRuleBackendHandlerTest.java | 145 - .../text/distsql/rql/RQLBackendHandlerTest.java | 2 +- .../ShardingCTLExplainBackendHandlerTest.java | 3 +- .../hint/ShardingCTLHintBackendHandlerTest.java | 4 +- .../sctl/set/ShardingCTLSetBackendHandlerTest.java | 6 +- .../impl/AbstractBootstrapInitializer.java | 11 - .../AddResourcesStatementConverterTest.java | 3 +- .../frontend/command/CommandExecutorTask.java | 25 +- .../netty/FrontendChannelInboundHandler.java | 3 +- .../frontend/command/CommandExecutorTaskTest.java | 22 +- .../FrontDatabaseProtocolTypeFactoryTest.java | 7 +- .../execute/MySQLComStmtExecuteExecutor.java | 11 +- .../fieldlist/MySQLComFieldListPacketExecutor.java | 11 +- .../text/query/MySQLComQueryPacketExecutor.java | 5 + .../frontend/mysql/err/MySQLErrPacketFactory.java | 94 +- .../frontend/mysql/MySQLFrontendEngineTest.java | 4 +- .../MySQLAuthenticationEngineTest.java | 8 +- .../MySQLAuthenticationHandlerTest.java | 7 +- .../command/MySQLCommandExecutorFactoryTest.java | 11 +- .../execute/MySQLComStmtExecuteExecutorTest.java | 11 +- .../mysql/err/MySQLErrPacketFactoryTest.java | 4 +- .../postgresql/PostgreSQLFrontendEngine.java | 2 + .../command/PostgreSQLCommandExecutorFactory.java | 7 +- .../command/PostgreSQLConnectionContext.java | 90 +- .../command/query/binary/PostgreSQLPortal.java | 142 + .../binary/bind/PostgreSQLComBindExecutor.java | 105 +- .../binary/close/PostgreSQLComCloseExecutor.java | 22 +- .../execute/PostgreSQLComExecuteExecutor.java | 77 +- .../query/text/PostgreSQLComQueryExecutor.java | 23 +- .../postgresql/PostgreSQLFrontendEngineTest.java | 17 + .../PostgreSQLAuthenticationEngineTest.java | 3 +- .../PostgreSQLAuthenticationHandlerTest.java | 7 +- .../PostgreSQLCommandExecuteEngineTest.java | 10 - .../PostgreSQLCommandExecutorFactoryTest.java | 3 +- .../binary/bind/PostgreSQLComBindExecutorTest.java | 102 +- .../close/PostgreSQLComCloseExecutorTest.java | 15 +- .../execute/PostgreSQLComExecuteExecutorTest.java | 52 +- .../parse/PostgreSQLComParseExecutorTest.java | 3 +- .../query/text/PostgreSQLComQueryExecutorTest.java | 6 +- .../frontend/command/executor/CommandExecutor.java | 8 + .../scaling/web/entity/ResponseContent.java | 2 +- .../scaling/core/common/record/DataRecord.java | 2 +- .../scaling/core/config/DumperConfiguration.java | 2 +- .../scaling/core/config/HandleConfiguration.java | 2 +- .../scaling/core/config/ImporterConfiguration.java | 2 +- .../scaling/core/config/JobConfiguration.java | 2 +- .../scaling/core/config/ServerConfiguration.java | 2 +- .../core/config/yaml/YamlServerConfiguration.java | 2 +- .../core/executor/AbstractScalingExecutor.java | 2 +- .../scaling/mysql/binlog/BinlogContext.java | 6 +- .../scaling/mysql/binlog/BinlogPosition.java | 2 +- .../mysql/binlog/event/AbstractBinlogEvent.java | 2 +- .../mysql/binlog/event/DeleteRowsEvent.java | 2 +- .../mysql/binlog/event/UpdateRowsEvent.java | 2 +- .../scaling/mysql/binlog/event/WriteRowsEvent.java | 2 +- .../scaling/mysql/client/ServerInfo.java | 2 +- .../postgresql/wal/event/AbstractRowEvent.java | 2 +- .../postgresql/wal/event/AbstractWalEvent.java | 2 +- .../postgresql/wal/event/DeleteRowEvent.java | 2 +- .../postgresql/wal/event/UpdateRowEvent.java | 2 +- .../postgresql/wal/event/WriteRowEvent.java | 2 +- shardingsphere-sql-parser/pom.xml | 2 - .../shardingsphere-sql-parser-mysql/pom.xml | 2 +- .../src/main/antlr4/imports/mysql/BaseRule.g4 | 5 + .../src/main/antlr4/imports/mysql/Symbol.g4 | 1 + .../statement/impl/MySQLStatementSQLVisitor.java | 11 + .../shardingsphere-sql-parser-oracle/pom.xml | 2 +- .../src/main/antlr4/imports/oracle/BaseRule.g4 | 56 +- .../src/main/antlr4/imports/oracle/DDLStatement.g4 | 37 +- .../src/main/antlr4/imports/oracle/DMLStatement.g4 | 49 +- .../main/antlr4/imports/oracle/OracleKeyword.g4 | 32 + .../sql/parser/autogen/OracleStatement.g4 | 1 + .../impl/OracleDDLStatementSQLVisitor.java | 23 + .../impl/OracleDMLStatementSQLVisitor.java | 141 +- .../shardingsphere-sql-parser-postgresql/pom.xml | 2 +- .../shardingsphere-sql-parser-sql92/pom.xml | 2 +- .../shardingsphere-sql-parser-sqlserver/pom.xml | 2 +- .../core/database/visitor/SQLVisitorRule.java | 2 + .../sql/common/segment/dal/FromTableSegment.java | 2 +- .../sql/common/segment/ddl/index/IndexSegment.java | 18 +- .../common/segment/dml/expr/BetweenExpression.java | 4 +- .../common/segment/dml/expr/ListExpression.java | 4 +- .../generic/InsertMultiTableElementSegment.java | 40 + .../sql/common/segment/generic/OwnerSegment.java | 2 +- .../generic/table/DeleteMultiTableSegment.java | 6 +- .../sql/common/statement/dml/SelectStatement.java | 12 +- .../sql/parser/sql/common/util/SQLUtil.java | 14 + .../handler/dml/InsertStatementHandler.java | 30 + .../ddl/OracleAssociateStatisticsStatement.java | 46 + .../oracle/dml/OracleInsertStatement.java | 28 + .../shardingsphere-sql-parser-test/pom.xml | 51 - .../asserts/segment/index/IndexAssert.java | 48 - .../asserts/statement/SQLStatementAssert.java | 64 - .../asserts/statement/ddl/DDLStatementAssert.java | 97 - .../statement/ddl/impl/AnalyzeStatementAssert.java | 57 - .../statement/dml/impl/InsertStatementAssert.java | 137 - .../engine/SQLParserParameterizedTest.java | 90 - .../jaxb/cases/domain/SQLParserTestCases.java | 421 --- .../impl/assignment/ExpectedValueAssign.java | 36 - .../segment/impl/assignment/ExpectedVariable.java | 35 - .../impl/expr/ExpectedBetweenExpression.java | 40 - .../expr/ExpectedBinaryOperationExpression.java | 37 - .../segment/impl/expr/ExpectedExistsSubquery.java | 35 - .../segment/impl/expr/ExpectedExpression.java | 71 - .../impl/expr/ExpectedExpressionSegment.java | 21 - .../segment/impl/expr/ExpectedInExpression.java | 37 - .../segment/impl/expr/ExpectedListExpression.java | 34 - .../segment/impl/expr/ExpectedNotExpression.java | 32 - .../complex/ExpectedBaseComplexExpression.java | 32 - .../expr/complex/ExpectedCommonExpression.java | 31 - .../complex/ExpectedComplexExpressionSegment.java | 30 - .../expr/simple/ExpectedBaseSimpleExpression.java | 23 - .../expr/simple/ExpectedLiteralExpression.java | 31 - .../simple/ExpectedParameterMarkerExpression.java | 31 - .../simple/ExpectedSimpleExpressionSegment.java | 23 - .../segment/impl/expr/simple/ExpectedSubquery.java | 32 - .../segment/impl/having/ExpectedHavingClause.java | 39 - .../domain/segment/impl/index/ExpectedIndex.java | 30 - .../statement/dml/InsertStatementTestCase.java | 63 - .../sql/parser/parameterized/jaxb/sql/SQLCase.java | 43 - .../src/main/resources/case/dml/insert.xml | 1613 ----------- .../src/main/resources/case/dml/select.xml | 2909 ------------------- .../main/resources/sql/supported/dml/insert.xml | 79 - .../main/resources/sql/supported/dml/select.xml | 82 - shardingsphere-test/pom.xml | 1 + .../shardingsphere-parser-test/pom.xml | 83 + .../asserts/SQLCaseAssertContext.java | 0 .../asserts/segment/SQLSegmentAssert.java | 0 .../segment/assignment/AssignmentAssert.java | 0 .../segment/assignment/AssignmentValueAssert.java | 0 .../asserts/segment/column/ColumnAssert.java | 0 .../segment/definition/ColumnDefinitionAssert.java | 0 .../segment/definition/ColumnPositionAssert.java | 0 .../definition/ConstraintDefinitionAssert.java | 0 .../asserts/segment/distsql/AlgorithmAssert.java | 54 + .../asserts/segment/distsql/DataSourceAssert.java | 63 + .../asserts/segment/distsql/PropertiesAssert.java | 55 + .../asserts/segment/distsql/PropertyAssert.java | 53 + .../asserts/segment/distsql/SQLSegmentAssert.java | 46 + .../asserts/segment/distsql/SchemaAssert.java | 44 + .../asserts/segment/distsql/TableRuleAssert.java | 61 + .../distsql/rdl/DatabaseDiscoveryRuleAssert.java | 73 + .../segment/distsql/rdl/EncryptColumnAssert.java | 56 + .../segment/distsql/rdl/EncryptRuleAssert.java | 73 + .../distsql/rdl/ReadwriteSplittingRuleAssert.java | 63 + .../rdl/ShardingBindingTableRuleAssert.java | 53 + .../segment/expression/ExpressionAssert.java | 0 .../segment/groupby/GroupByClauseAssert.java | 0 .../asserts/segment/having/HavingClauseAssert.java | 0 .../asserts/segment/index/IndexAssert.java | 57 + .../segment/insert/InsertColumnsClauseAssert.java | 0 .../insert/InsertMultiTableElementAssert.java | 54 + .../segment/insert/InsertValuesClauseAssert.java | 0 .../insert/OnDuplicateKeyColumnsAssert.java | 0 .../asserts/segment/limit/LimitClauseAssert.java | 0 .../asserts/segment/lock/LockClauseAssert.java | 0 .../segment/orderby/OrderByClauseAssert.java | 0 .../asserts/segment/orderby/OrderByItemAssert.java | 0 .../asserts/segment/output/OutputClauseAssert.java | 0 .../asserts/segment/owner/OwnerAssert.java | 0 .../segment/parameter/ParameterMarkerAssert.java | 0 .../segment/projection/ProjectionAssert.java | 0 .../asserts/segment/schema/SchemaAssert.java | 0 .../asserts/segment/set/SetClauseAssert.java | 0 .../asserts/segment/table/TableAssert.java | 0 .../asserts/segment/where/WhereClauseAssert.java | 0 .../asserts/segment/with/WithClauseAssert.java | 0 .../asserts/statement/SQLStatementAssert.java | 72 + .../asserts/statement/dal/DALStatementAssert.java | 0 .../statement/dal/impl/ExplainStatementAssert.java | 0 .../dal/impl/MySQLUseStatementAssert.java | 0 .../dal/impl/SetVariableStatementAssert.java | 0 .../dal/impl/ShowColumnsStatementAssert.java | 0 .../dal/impl/ShowCreateTableStatementAssert.java | 0 .../dal/impl/ShowDatabasesStatementAssert.java | 0 .../dal/impl/ShowIndexStatementAssert.java | 0 .../statement/dal/impl/ShowStatementAssert.java | 0 .../dal/impl/ShowTableStatusStatementAssert.java | 0 .../dal/impl/ShowTablesStatementAssert.java | 0 .../asserts/statement/dcl/DCLStatementAssert.java | 0 .../dcl/impl/AlterLoginStatementAssert.java | 0 .../dcl/impl/AlterRoleStatementAssert.java | 0 .../dcl/impl/AlterUserStatementAssert.java | 0 .../dcl/impl/CreateLoginStatementAssert.java | 0 .../dcl/impl/CreateRoleStatementAssert.java | 0 .../dcl/impl/CreateUserStatementAssert.java | 0 .../dcl/impl/DenyUserStatementAssert.java | 0 .../dcl/impl/DropLoginStatementAssert.java | 0 .../dcl/impl/DropRoleStatementAssert.java | 0 .../dcl/impl/DropUserStatementAssert.java | 0 .../statement/dcl/impl/GrantStatementAssert.java | 0 .../dcl/impl/RenameUserStatementAssert.java | 0 .../statement/dcl/impl/RevokeStatementAssert.java | 0 .../dcl/impl/SetDefaultRoleStatementAssert.java | 0 .../dcl/impl/SetPasswordStatementAssert.java | 0 .../statement/dcl/impl/SetRoleStatementAssert.java | 0 .../asserts/statement/ddl/DDLStatementAssert.java | 102 + .../ddl/impl/AlterIndexStatementAssert.java | 0 .../ddl/impl/AlterSessionStatementAssert.java | 0 .../ddl/impl/AlterSynonymStatementAssert.java | 0 .../ddl/impl/AlterSystemStatementAssert.java | 0 .../ddl/impl/AlterTableStatementAssert.java | 0 .../statement/ddl/impl/AnalyzeStatementAssert.java | 57 + .../impl/AssociateStatisticsStatementAssert.java | 75 + .../ddl/impl/CreateIndexStatementAssert.java | 0 .../ddl/impl/CreateTableStatementAssert.java | 0 .../ddl/impl/DropIndexStatementAssert.java | 0 .../ddl/impl/DropTableStatementAssert.java | 0 .../ddl/impl/TruncateStatementAssert.java | 0 .../statement/distsql/rdl/RDLStatementAssert.java | 94 + .../rdl/alter/AlterRuleStatementAssert.java | 70 + .../AlterDatabaseDiscoveryRuleStatementAssert.java | 77 + .../impl/AlterEncryptRuleStatementAssert.java | 73 + ...AlterReadwriteSplittingRuleStatementAssert.java | 74 + ...erShardingBindingTableRulesStatementAssert.java | 75 + ...ShardingBroadcastTableRulesStatementAssert.java | 52 + .../AlterShardingTableRuleStatementAssert.java | 69 + .../rdl/create/AddResourceStatementAssert.java | 72 + .../rdl/create/CreateRuleStatementAssert.java | 73 + ...CreateDatabaseDiscoveryRuleStatementAssert.java | 73 + .../impl/CreateEncryptRuleStatementAssert.java | 75 + ...reateReadwriteSplittingRuleStatementAssert.java | 75 + ...teShardingBindingTableRulesStatementAssert.java | 75 + ...ShardingBroadcastTableRulesStatementAssert.java | 52 + .../CreateShardingTableRuleStatementAssert.java | 70 + .../rdl/drop/DropResourceStatementAssert.java | 50 + .../distsql/rdl/drop/DropRuleStatementAssert.java | 72 + .../DropDatabaseDiscoveryRuleStatementAssert.java | 52 + .../drop/impl/DropEncryptRuleStatementAssert.java | 52 + .../DropReadwriteSplittingRuleStatementAssert.java | 52 + ...opShardingBindingTableRulesStatementAssert.java | 41 + ...ShardingBroadcastTableRulesStatementAssert.java | 41 + .../impl/DropShardingTableRuleStatementAssert.java | 41 + .../statement/distsql/rql/RQLStatementAssert.java | 46 + .../distsql/rql/impl/ShowRulesStatementAssert.java | 72 + .../ShowDatabaseDiscoveryRulesStatementAssert.java | 51 + .../impl/rule/ShowEncryptRulesStatementAssert.java | 51 + ...ShowReadwriteSplittingRulesStatementAssert.java | 51 + ...owShardingBindingTableRulesStatementAssert.java | 51 + ...ShardingBroadcastTableRulesStatementAssert.java | 51 + .../ShowShardingTableRulesStatementAssert.java | 51 + .../asserts/statement/dml/DMLStatementAssert.java | 0 .../statement/dml/impl/CallStatementAssert.java | 0 .../statement/dml/impl/DeleteStatementAssert.java | 0 .../statement/dml/impl/InsertStatementAssert.java | 167 ++ .../statement/dml/impl/MergeStatementAssert.java | 0 .../statement/dml/impl/SelectStatementAssert.java | 0 .../statement/dml/impl/UpdateStatementAssert.java | 0 .../asserts/statement/tcl/TCLStatementAssert.java | 0 .../tcl/impl/BeginTransactionStatementAssert.java | 0 .../statement/tcl/impl/CommitStatementAssert.java | 0 .../tcl/impl/RollbackStatementAssert.java | 0 .../tcl/impl/SavepointStatementAssert.java | 0 .../tcl/impl/SetAutoCommitStatementAssert.java | 0 .../tcl/impl/SetConstraintsStatementAssert.java | 0 .../tcl/impl/SetTransactionStatementAssert.java | 0 .../asserts/value/IdentifierValueAssert.java | 0 .../engine/SQLParserParameterizedTest.java | 92 + .../UnsupportedSQLParserParameterizedTest.java | 0 .../jaxb/cases/SQLParserTestCasesRegistry.java | 0 .../cases/SQLParserTestCasesRegistryFactory.java | 0 .../jaxb/cases/domain/SQLParserTestCases.java | 560 ++++ .../AbstractExpectedDelimiterSQLSegment.java | 0 .../AbstractExpectedIdentifierSQLSegment.java | 0 .../domain/segment/AbstractExpectedSQLSegment.java | 0 .../segment/ExpectedDelimiterSQLSegment.java | 0 .../segment/ExpectedIdentifierSQLSegment.java | 0 .../cases/domain/segment/ExpectedSQLSegment.java | 0 .../impl/assignment/ExpectedAssignment.java | 0 .../impl/assignment/ExpectedAssignmentValue.java | 0 .../impl/assignment/ExpectedValueAssign.java | 39 + .../segment/impl/assignment/ExpectedVariable.java | 38 + .../segment/impl/call/ExpectedCallParameter.java | 0 .../segment/impl/call/ExpectedProcedureName.java | 0 .../impl/call/ExpectedProcedureParameters.java | 0 .../domain/segment/impl/column/ExpectedColumn.java | 0 .../definition/ExpectedAddColumnDefinition.java | 0 .../impl/definition/ExpectedColumnDefinition.java | 0 .../impl/definition/ExpectedColumnPosition.java | 0 .../definition/ExpectedConstraintDefinition.java | 0 .../definition/ExpectedModifyColumnDefinition.java | 0 .../segment/impl/distsql/ExpectedAlgorithm.java | 39 + .../segment/impl/distsql/ExpectedDataSource.java | 47 + .../segment/impl/distsql/ExpectedProperties.java | 36 + .../segment/impl/distsql/ExpectedProperty.java | 38 + .../segment/impl/distsql/ExpectedTableRule.java | 49 + .../rdl/ExceptedReadwriteSplittingRule.java | 50 + .../distsql/rdl/ExpectedDatabaseDiscoveryRule.java | 44 + .../impl/distsql/rdl/ExpectedEncryptColumn.java | 43 + .../impl/distsql/rdl/ExpectedEncryptRule.java | 36 + .../rdl/ExpectedShardingBindingTableRule.java | 35 + .../impl/expr/ExpectedBetweenExpression.java | 44 + .../expr/ExpectedBinaryOperationExpression.java | 41 + .../segment/impl/expr/ExpectedExistsSubquery.java | 39 + .../segment/impl/expr/ExpectedExpression.java | 74 + .../impl/expr/ExpectedExpressionSegment.java | 24 + .../segment/impl/expr/ExpectedInExpression.java | 41 + .../segment/impl/expr/ExpectedListExpression.java | 37 + .../segment/impl/expr/ExpectedNotExpression.java | 35 + .../complex/ExpectedBaseComplexExpression.java | 35 + .../expr/complex/ExpectedCommonExpression.java | 34 + .../complex/ExpectedComplexExpressionSegment.java | 33 + .../expr/simple/ExpectedBaseSimpleExpression.java | 26 + .../expr/simple/ExpectedLiteralExpression.java | 34 + .../simple/ExpectedParameterMarkerExpression.java | 34 + .../simple/ExpectedSimpleExpressionSegment.java | 26 + .../segment/impl/expr/simple/ExpectedSubquery.java | 35 + .../segment/impl/having/ExpectedHavingClause.java | 39 + .../domain/segment/impl/index/ExpectedIndex.java | 36 + .../impl/insert/ExpectedInsertColumnsClause.java | 0 .../insert/ExpectedInsertMultiTableElement.java | 36 + .../segment/impl/insert/ExpectedInsertValue.java | 0 .../impl/insert/ExpectedInsertValuesClause.java | 0 .../impl/insert/ExpectedOnDuplicateKeyColumns.java | 0 .../segment/impl/limit/ExpectedLimitClause.java | 0 .../impl/limit/ExpectedPaginationValue.java | 0 .../segment/impl/lock/ExpectedLockClause.java | 0 .../impl/orderby/ExpectedOrderByClause.java | 0 .../impl/orderby/item/ExpectedOrderByItem.java | 0 .../item/impl/ExpectedColumnOrderByItem.java | 0 .../item/impl/ExpectedExpressionOrderByItem.java | 0 .../item/impl/ExpectedIndexOrderByItem.java | 0 .../segment/impl/output/ExpectedOutputClause.java | 0 .../segment/impl/output/ExpectedOutputColumn.java | 0 .../impl/output/ExpectedOutputTableColumn.java | 0 .../impl/projection/ExpectedProjection.java | 0 .../impl/projection/ExpectedProjections.java | 0 .../ExpectedAggregationDistinctProjection.java | 0 .../aggregation/ExpectedAggregationProjection.java | 0 .../impl/column/ExpectedColumnProjection.java | 0 .../expression/ExpectedExpressionProjection.java | 0 .../shorthand/ExpectedShorthandProjection.java | 0 .../impl/subquery/ExpectedSubqueryProjection.java | 0 .../projection/impl/top/ExpectedTopProjection.java | 0 .../impl/projection/impl/top/ExpectedTopValue.java | 0 .../domain/segment/impl/schema/ExpectedSchema.java | 0 .../domain/segment/impl/set/ExpectedSetClause.java | 0 .../segment/impl/table/ExpectedJoinTable.java | 0 .../domain/segment/impl/table/ExpectedOwner.java | 0 .../segment/impl/table/ExpectedSimpleTable.java | 0 .../segment/impl/table/ExpectedSubqueryTable.java | 0 .../domain/segment/impl/table/ExpectedTable.java | 0 .../segment/impl/where/ExpectedWhereClause.java | 0 .../segment/impl/window/ExpectedWindowClause.java | 0 .../ExpectedCommonTableExpressColumnsClause.java | 0 .../with/ExpectedCommonTableExpressionClause.java | 0 .../segment/impl/with/ExpectedWithClause.java | 0 .../domain/statement/CommonStatementTestCase.java | 0 .../cases/domain/statement/SQLParserTestCase.java | 0 .../statement/dal/ExplainStatementTestCase.java | 0 .../dal/SetVariableStatementTestCase.java | 0 .../dal/ShowColumnsStatementTestCase.java | 0 .../dal/ShowCreateTableStatementTestCase.java | 0 .../dal/ShowDatabasesStatementTestCase.java | 0 .../statement/dal/ShowIndexStatementTestCase.java | 0 .../statement/dal/ShowStatementTestCase.java | 0 .../dal/ShowTableStatusStatementTestCase.java | 0 .../statement/dal/ShowTablesStatementTestCase.java | 0 .../domain/statement/dal/UseStatementTestCase.java | 0 .../statement/dcl/AlterLoginStatementTestCase.java | 0 .../statement/dcl/AlterRoleStatementTestCase.java | 0 .../statement/dcl/AlterUserStatementTestCase.java | 0 .../dcl/CreateLoginStatementTestCase.java | 0 .../statement/dcl/CreateRoleStatementTestCase.java | 0 .../statement/dcl/CreateUserStatementTestCase.java | 0 .../statement/dcl/DenyUserStatementTestCase.java | 0 .../statement/dcl/DropLoginStatementTestCase.java | 0 .../statement/dcl/DropRoleStatementTestCase.java | 0 .../statement/dcl/DropUserStatementTestCase.java | 0 .../statement/dcl/GrantStatementTestCase.java | 0 .../statement/dcl/RenameUserStatementTestCase.java | 0 .../statement/dcl/RevokeStatementTestCase.java | 0 .../dcl/SetDefaultRoleStatementTestCase.java | 0 .../dcl/SetPasswordStatementTestCase.java | 0 .../statement/dcl/SetRoleStatementTestCase.java | 0 .../ddl/AlterDatabaseStatementTestCase.java | 0 .../ddl/AlterFunctionStatementTestCase.java | 0 .../statement/ddl/AlterIndexStatementTestCase.java | 0 .../ddl/AlterProcedureStatementTestCase.java | 0 .../ddl/AlterSequenceStatementTestCase.java | 0 .../ddl/AlterServerStatementTestCase.java | 0 .../ddl/AlterSessionStatementTestCase.java | 0 .../ddl/AlterSynonymStatementTestCase.java | 0 .../ddl/AlterSystemStatementTestCase.java | 0 .../statement/ddl/AlterTableStatementTestCase.java | 0 .../statement/ddl/AnalyzeStatementTestCase.java | 0 .../ddl/AssociateStatisticsStatementTestCase.java | 47 + .../ddl/CreateDatabaseStatementTestCase.java | 0 .../ddl/CreateFunctionStatementTestCase.java | 0 .../ddl/CreateIndexStatementTestCase.java | 0 .../ddl/CreateProcedureStatementTestCase.java | 0 .../ddl/CreateSequenceStatementTestCase.java | 0 .../ddl/CreateServerStatementTestCase.java | 0 .../ddl/CreateTableStatementTestCase.java | 0 .../ddl/CreateTriggerStatementTestCase.java | 0 .../statement/ddl/CreateViewStatementTestCase.java | 0 .../ddl/DropDatabaseStatementTestCase.java | 0 .../ddl/DropFunctionStatementTestCase.java | 0 .../statement/ddl/DropIndexStatementTestCase.java | 0 .../ddl/DropProcedureStatementTestCase.java | 0 .../ddl/DropSequenceStatementTestCase.java | 0 .../statement/ddl/DropServerStatementTestCase.java | 0 .../statement/ddl/DropTableStatementTestCase.java | 0 .../ddl/DropTriggerStatementTestCase.java | 0 .../statement/ddl/DropViewStatementTestCase.java | 0 .../statement/ddl/TruncateStatementTestCase.java | 0 ...howDataBaseDiscoveryRulesStatementTestCase.java | 36 + .../impl/ShowEncryptRulesStatementTestCase.java | 40 + ...owReadWriteSplittingRulesStatementTestCase.java | 36 + ...ShardingBindingTableRulesStatementTestCase.java | 36 + ...ardingBroadcastTableRulesStatementTestCase.java | 36 + .../ShowShardingTableRulesStatementTestCase.java | 40 + ...lterDataBaseDiscoveryRuleStatementTestCase.java | 38 + .../alter/AlterEncryptRuleStatementTestCase.java | 38 + ...terReadWriteSplittingRuleStatementTestCase.java | 38 + ...ShardingBindingTableRulesStatementTestCase.java | 38 + ...ardingBroadcastTableRulesStatementTestCase.java | 37 + .../AlterShardingTableRuleStatementTestCase.java | 38 + .../rdl/create/AddResourceStatementTestCase.java | 38 + ...eateDataBaseDiscoveryRuleStatementTestCase.java | 38 + .../create/CreateEncryptRuleStatementTestCase.java | 38 + ...ateReadWriteSplittingRuleStatementTestCase.java | 38 + ...ShardingBindingTableRulesStatementTestCase.java | 38 + ...ardingBroadcastTableRulesStatementTestCase.java | 37 + .../CreateShardingTableRuleStatementTestCase.java | 38 + ...DropDataBaseDiscoveryRuleStatementTestCase.java | 37 + .../rdl/drop/DropEncryptRuleStatementTestCase.java | 37 + ...ropReadWriteSplittingRuleStatementTestCase.java | 37 + .../rdl/drop/DropResourceStatementTestCase.java | 37 + ...ShardingBindingTableRulesStatementTestCase.java | 26 + ...ardingBroadcastTableRulesStatementTestCase.java | 26 + .../DropShardingTableRuleStatementTestCase.java | 35 + .../statement/dml/CallStatementTestCase.java | 0 .../statement/dml/DeleteStatementTestCase.java | 0 .../statement/dml/InsertStatementTestCase.java | 70 + .../statement/dml/MergeStatementTestCase.java | 0 .../statement/dml/SelectStatementTestCase.java | 0 .../statement/dml/UpdateStatementTestCase.java | 0 .../tcl/BeginTransactionStatementTestCase.java | 0 .../statement/tcl/CommitStatementTestCase.java | 0 .../statement/tcl/RollbackStatementTestCase.java | 0 .../statement/tcl/SavepointStatementTestCase.java | 0 .../tcl/SetAutoCommitStatementTestCase.java | 0 .../tcl/SetConstraintsStatementTestCase.java | 0 .../tcl/SetTransactionStatementTestCase.java | 0 .../cases/domain/statement/tcl/XATestCase.java | 0 .../sql/parser/parameterized/jaxb/sql/SQLCase.java | 46 + .../parser/parameterized/jaxb/sql/SQLCaseType.java | 0 .../parser/parameterized/jaxb/sql/SQLCases.java | 0 .../jaxb/sql/loader/SQLCasesLoader.java | 0 .../jaxb/sql/loader/SQLCasesRegistry.java | 0 .../sql/loader/UnsupportedSQLCasesRegistry.java | 0 .../parameterized/loader/TestCaseFileLoader.java | 0 .../src/main/resources/case/dal/explain.xml | 0 .../src/main/resources/case/dal/reset.xml | 0 .../src/main/resources/case/dal/set.xml | 0 .../src/main/resources/case/dal/show.xml | 0 .../src/main/resources/case/dcl/alter-login.xml | 0 .../src/main/resources/case/dcl/alter-role.xml | 0 .../src/main/resources/case/dcl/alter-user.xml | 0 .../src/main/resources/case/dcl/create-login.xml | 0 .../src/main/resources/case/dcl/create-role.xml | 0 .../src/main/resources/case/dcl/create-user.xml | 0 .../src/main/resources/case/dcl/deny-user.xml | 0 .../src/main/resources/case/dcl/drop-login.xml | 0 .../src/main/resources/case/dcl/drop-role.xml | 0 .../src/main/resources/case/dcl/drop-user.xml | 0 .../src/main/resources/case/dcl/grant.xml | 0 .../src/main/resources/case/dcl/rename-user.xml | 0 .../src/main/resources/case/dcl/revoke.xml | 0 .../main/resources/case/dcl/set-default-role.xml | 0 .../src/main/resources/case/dcl/set-password.xml | 0 .../src/main/resources/case/dcl/set-role.xml | 0 .../src/main/resources/case/ddl/alter-database.xml | 0 .../src/main/resources/case/ddl/alter-function.xml | 0 .../src/main/resources/case/ddl/alter-index.xml | 0 .../main/resources/case/ddl/alter-procedure.xml | 0 .../src/main/resources/case/ddl/alter-sequence.xml | 0 .../src/main/resources/case/ddl/alter-server.xml | 0 .../src/main/resources/case/ddl/alter-session.xml | 0 .../src/main/resources/case/ddl/alter-synonym.xml | 0 .../src/main/resources/case/ddl/alter-system.xml | 0 .../src/main/resources/case/ddl/alter-table.xml | 0 .../src/main/resources/case/ddl/analyze.xml | 0 .../resources/case/ddl/associate-statistics.xml | 40 + .../main/resources/case/ddl/create-database.xml | 0 .../main/resources/case/ddl/create-function.xml | 0 .../src/main/resources/case/ddl/create-index.xml | 0 .../main/resources/case/ddl/create-procedure.xml | 0 .../main/resources/case/ddl/create-sequence.xml | 0 .../src/main/resources/case/ddl/create-server.xml | 0 .../src/main/resources/case/ddl/create-table.xml | 0 .../src/main/resources/case/ddl/create-trigger.xml | 0 .../src/main/resources/case/ddl/create-view.xml | 0 .../src/main/resources/case/ddl/drop-database.xml | 0 .../src/main/resources/case/ddl/drop-function.xml | 0 .../src/main/resources/case/ddl/drop-index.xml | 0 .../src/main/resources/case/ddl/drop-procedure.xml | 0 .../src/main/resources/case/ddl/drop-sequence.xml | 0 .../src/main/resources/case/ddl/drop-server.xml | 0 .../src/main/resources/case/ddl/drop-table.xml | 0 .../src/main/resources/case/ddl/drop-trigger.xml | 0 .../src/main/resources/case/ddl/drop-view.xml | 0 .../src/main/resources/case/ddl/truncate.xml | 0 .../src/main/resources/case/dml/call.xml | 0 .../src/main/resources/case/dml/delete.xml | 0 .../src/main/resources/case/dml/insert.xml | 1827 ++++++++++++ .../src/main/resources/case/dml/merge.xml | 0 .../src/main/resources/case/dml/replace.xml | 0 .../main/resources/case/dml/select-aggregate.xml | 0 .../main/resources/case/dml/select-expression.xml | 0 .../main/resources/case/dml/select-group-by.xml | 0 .../src/main/resources/case/dml/select-into.xml | 0 .../src/main/resources/case/dml/select-join.xml | 0 .../src/main/resources/case/dml/select-lock.xml | 0 .../src/main/resources/case/dml/select-or.xml | 0 .../main/resources/case/dml/select-order-by.xml | 0 .../dml/select-pagination-group-by-order-by.xml | 0 .../main/resources/case/dml/select-pagination.xml | 0 .../main/resources/case/dml/select-sub-query.xml | 0 .../src/main/resources/case/dml/select-with.xml | 0 .../src/main/resources/case/dml/select.xml | 2919 ++++++++++++++++++++ .../src/main/resources/case/dml/update.xml | 0 .../src/main/resources/case/rdl/alter.xml | 92 + .../src/main/resources/case/rdl/create.xml | 108 + .../src/main/resources/case/rdl/drop.xml | 45 + .../src/main/resources/case/rql/show.xml | 56 + .../main/resources/case/tcl/begin-transaction.xml | 0 .../src/main/resources/case/tcl/commit.xml | 0 .../src/main/resources/case/tcl/end.xml | 0 .../src/main/resources/case/tcl/rollback.xml | 0 .../src/main/resources/case/tcl/savepoint.xml | 0 .../main/resources/case/tcl/set-auto-commit.xml | 0 .../main/resources/case/tcl/set-constraints.xml | 0 .../main/resources/case/tcl/set-transaction.xml | 0 .../main/resources/case/tcl/start-transaction.xml | 0 .../main/resources/sql/supported/dal/explain.xml | 0 .../src/main/resources/sql/supported/dal/reset.xml | 0 .../src/main/resources/sql/supported/dal/set.xml | 0 .../src/main/resources/sql/supported/dal/show.xml | 0 .../resources/sql/supported/dcl/alter-login.xml | 0 .../resources/sql/supported/dcl/alter-role.xml | 0 .../resources/sql/supported/dcl/alter-user.xml | 0 .../resources/sql/supported/dcl/create-login.xml | 0 .../resources/sql/supported/dcl/create-role.xml | 0 .../resources/sql/supported/dcl/create-user.xml | 0 .../main/resources/sql/supported/dcl/deny-user.xml | 0 .../resources/sql/supported/dcl/drop-login.xml | 0 .../main/resources/sql/supported/dcl/drop-role.xml | 0 .../main/resources/sql/supported/dcl/drop-user.xml | 0 .../resources/sql/supported/dcl/grant-user.xml | 0 .../resources/sql/supported/dcl/rename-user.xml | 0 .../resources/sql/supported/dcl/revoke-user.xml | 0 .../sql/supported/dcl/set-default-role.xml | 0 .../resources/sql/supported/dcl/set-password.xml | 0 .../main/resources/sql/supported/dcl/set-role.xml | 0 .../resources/sql/supported/ddl/alter-database.xml | 0 .../resources/sql/supported/ddl/alter-function.xml | 0 .../resources/sql/supported/ddl/alter-index.xml | 0 .../sql/supported/ddl/alter-procedure.xml | 0 .../resources/sql/supported/ddl/alter-sequence.xml | 0 .../resources/sql/supported/ddl/alter-session.xml | 0 .../resources/sql/supported/ddl/alter-synonym.xml | 0 .../resources/sql/supported/ddl/alter-system.xml | 0 .../resources/sql/supported/ddl/alter-table.xml | 0 .../main/resources/sql/supported/ddl/analyze.xml | 0 .../sql/supported/ddl/associate-statistics.xml | 27 + .../sql/supported/ddl/create-database.xml | 0 .../sql/supported/ddl/create-function.xml | 0 .../resources/sql/supported/ddl/create-index.xml | 0 .../sql/supported/ddl/create-procedure.xml | 0 .../sql/supported/ddl/create-sequence.xml | 0 .../resources/sql/supported/ddl/create-table.xml | 0 .../resources/sql/supported/ddl/create-view.xml | 0 .../resources/sql/supported/ddl/drop-database.xml | 0 .../resources/sql/supported/ddl/drop-function.xml | 0 .../resources/sql/supported/ddl/drop-index.xml | 0 .../resources/sql/supported/ddl/drop-procedure.xml | 0 .../resources/sql/supported/ddl/drop-sequence.xml | 0 .../resources/sql/supported/ddl/drop-table.xml | 0 .../main/resources/sql/supported/ddl/drop-view.xml | 0 .../main/resources/sql/supported/ddl/truncate.xml | 0 .../src/main/resources/sql/supported/dml/call.xml | 0 .../main/resources/sql/supported/dml/delete.xml | 0 .../main/resources/sql/supported/dml/insert.xml | 85 + .../src/main/resources/sql/supported/dml/merge.xml | 0 .../main/resources/sql/supported/dml/replace.xml | 0 .../sql/supported/dml/select-aggregate.xml | 0 .../resources/sql/supported/dml/select-comment.xml | 0 .../sql/supported/dml/select-distinct.xml | 0 .../resources/sql/supported/dml/select-escape.xml | 0 .../sql/supported/dml/select-expression.xml | 0 .../sql/supported/dml/select-group-by.xml | 0 .../resources/sql/supported/dml/select-into.xml | 0 .../resources/sql/supported/dml/select-lock.xml | 0 .../main/resources/sql/supported/dml/select-or.xml | 0 .../sql/supported/dml/select-order-by.xml | 0 .../dml/select-pagination-group-by-order-by.xml | 0 .../sql/supported/dml/select-pagination.xml | 0 .../sql/supported/dml/select-relation.xml | 0 .../sql/supported/dml/select-sub-query.xml | 0 .../resources/sql/supported/dml/select-with.xml | 0 .../main/resources/sql/supported/dml/select.xml | 83 + .../main/resources/sql/supported/dml/update.xml | 0 .../src/main/resources/sql/supported/rdl/alter.xml | 26 + .../main/resources/sql/supported/rdl/create.xml | 30 + .../src/main/resources/sql/supported/rdl/drop.xml | 27 + .../src/main/resources/sql/supported/rql/show.xml | 29 + .../sql/supported/tcl/begin-transcation.xml | 0 .../main/resources/sql/supported/tcl/commit.xml | 0 .../src/main/resources/sql/supported/tcl/end.xml | 0 .../main/resources/sql/supported/tcl/rollback.xml | 0 .../main/resources/sql/supported/tcl/savepoint.xml | 0 .../sql/supported/tcl/set-auto-commit.xml | 0 .../sql/supported/tcl/set-constraints.xml | 0 .../sql/supported/tcl/set-transaction.xml | 0 .../sql/supported/tcl/start-transcation.xml | 0 .../main/resources/sql/unsupported/unsupported.xml | 0 .../DistSQLStatementParserParameterizedTest.java | 38 + .../resources/scenario/sharding/case/delete.xml | 12 +- .../resources/scenario/sharding/case/select.xml | 18 +- .../test/resources/scenario/sharding/case/show.xml | 8 +- .../transaction/core/ResourceDataSourceTest.java | 36 + 1114 files changed, 24735 insertions(+), 16111 deletions(-) diff --cc shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/PostgreSQLCommandExecutorFactory.java index 6da37e2,a0e9e75..f5bb0c1 --- a/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/PostgreSQLCommandExecutorFactory.java +++ b/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/PostgreSQLCommandExecutorFactory.java @@@ -22,9 -22,9 +22,10 @@@ import lombok.NoArgsConstructor import lombok.extern.slf4j.Slf4j; import org.apache.shardingsphere.db.protocol.postgresql.packet.command.PostgreSQLCommandPacket; import org.apache.shardingsphere.db.protocol.postgresql.packet.command.PostgreSQLCommandPacketType; +import org.apache.shardingsphere.db.protocol.postgresql.packet.command.query.binary.bind.OpenGaussComBatchBindPacket; import org.apache.shardingsphere.db.protocol.postgresql.packet.command.query.binary.bind.PostgreSQLComBindPacket; import org.apache.shardingsphere.db.protocol.postgresql.packet.command.query.binary.close.PostgreSQLComClosePacket; + import org.apache.shardingsphere.db.protocol.postgresql.packet.command.query.binary.execute.PostgreSQLComExecutePacket; import org.apache.shardingsphere.db.protocol.postgresql.packet.command.query.binary.parse.PostgreSQLComParsePacket; import org.apache.shardingsphere.db.protocol.postgresql.packet.command.query.text.PostgreSQLComQueryPacket; import org.apache.shardingsphere.proxy.backend.communication.jdbc.connection.BackendConnection;
