You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by wu...@apache.org on 2022/12/09 11:14:48 UTC
[shardingsphere] branch 5.3.0-release updated (46038f5e6c2 -> 3a28730acb3)
This is an automated email from the ASF dual-hosted git repository.
wuweijie pushed a change to branch 5.3.0-release
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
from 46038f5e6c2 Merge remote-tracking branch 'apache/master' into 5.3.0-release
add 89c5a6f2a0e update the example module docs (#22738)
add b2a01c519e0 19937 federation optimization test 20221205 (#22693)
add e93726c8b75 Make sure ShardingSphereDriver can load configuration file from classpath with mutiple ClassLoaders (#22677)
add 6473d1fb614 Add ensembleTracker parameter support deploy ZooKeeper on cloud (#22745)
add 610a4ebc82c Add CDC create subscription event and listener (#22739)
add 8bfa611ac9b Improve MySQL incremental client reconnect and close (#22740)
add f372dc5d0b0 Refactor AgentTypedSPIRegistry (#22748)
add 318aa2bf915 Remove ensembleTracker configuration (#22747)
add a6d9e3a4876 Refactor ReflectiveUtil (#22749)
add 224b7d1ac80 Remove spring dependencies (#22751)
add 055cdbffd0a Move package of ShardingSphereAlgorithm (#22753)
add 631fdf40f87 Fix wrong decide result when execute same sharding condition subquery with sql federation (#22754)
add eb230d4ac97 Refactor : disable the example upload action temporarily (#22757) (#22758)
add b7b4ec3fa39 Move ExportableConstants to rule package (#22760)
add 8ea92c7a51c Update `脱敏` in encrypt chinese documents to `加密` and `decryption` in encrypt english documents to `encryption` (#22761)
add 7e7e3eb3ad0 Add shardingsphere-distsql-handler module (#22765)
add 04525dc4129 Fix the transaction IT test assert usage specification (#22764)
add 8dc3fdc76a0 Fix occasional test exceptions for ShardingSphereDataCollectorTest. (#22767)
add 509a27b4a99 initialize the mask module and add the underlying spi interface, mask rule class (#22766)
add deb1c83ff6c Add like literal for show single table statement (#22763)
add 3a28730acb3 Merge branch 'master' into 5.3.0-release
No new revisions were added by this update.
Summary of changes:
.github/workflows/nightly-build-example.yml | 14 +-
.../core/plugin/PluginBootServiceManager.java | 16 +-
.../agent/core/spi/AgentTypedSPIRegistry.java | 34 +---
.../cdc/core => distsql/handler}/pom.xml | 16 +-
.../handler}/exception/DistSQLException.java | 2 +-
.../resource/DuplicateResourceException.java | 2 +-
.../exception/resource/EmptyResourceException.java | 2 +-
.../resource/InvalidResourcesException.java | 2 +-
.../MissingRequiredResourcesException.java | 2 +-
.../ResourceDefinitionViolationException.java | 4 +-
.../resource/ResourceInUsedException.java | 2 +-
.../exception/rule/AlgorithmInUsedException.java | 2 +-
.../rule/DuplicateAlgorithmException.java | 2 +-
.../exception/rule/DuplicateRuleException.java | 2 +-
.../InvalidAlgorithmConfigurationException.java | 2 +-
.../rule/InvalidRuleConfigurationException.java | 2 +-
.../rule/MissingRequiredAlgorithmException.java | 2 +-
.../rule/MissingRequiredRuleException.java | 2 +-
.../rule/RuleDefinitionViolationException.java | 4 +-
.../exception/rule/RuleInUsedException.java | 2 +-
.../handler}/query/DatabaseDistSQLResultSet.java | 2 +-
.../distsql/handler}/query/DistSQLResultSet.java | 2 +-
.../handler}/query/GlobalRuleDistSQLResultSet.java | 2 +-
.../handler}/update/GlobalRuleRALUpdater.java | 2 +-
.../distsql/handler}/update/RALUpdater.java | 2 +-
.../distsql/handler}/update/RALUpdaterFactory.java | 2 +-
.../update/RuleDefinitionAlterUpdater.java | 2 +-
.../update/RuleDefinitionCreateUpdater.java | 2 +-
.../handler}/update/RuleDefinitionDropUpdater.java | 2 +-
.../handler}/update/RuleDefinitionUpdater.java | 2 +-
.../update/RuleDefinitionUpdaterFactory.java | 2 +-
.../DataSourcePropertiesValidateHandler.java | 28 +--
.../fixture/config/FixtureRuleConfiguration.java | 15 +-
.../fixture/statement}/FixtureRALStatement.java | 2 +-
.../fixture/statement}/FixtureRuleStatement.java | 2 +-
.../fixture/updater}/FixtureRALUpdater.java | 5 +-
.../updater}/FixtureRuleDefinitionUpdater.java | 6 +-
.../handler}/update/RALUpdaterFactoryTest.java | 6 +-
.../update/RuleDefinitionUpdaterFactoryTest.java | 6 +-
...hardingsphere.distsql.handler.update.RALUpdater | 2 +-
...re.distsql.handler.update.RuleDefinitionUpdater | 2 +-
distsql/parser/pom.xml | 1 +
distsql/parser/src/main/antlr4/imports/Keyword.g4 | 4 +
.../parser/src/main/antlr4/imports/RQLStatement.g4 | 6 +-
.../core/kernel/KernelDistSQLStatementVisitor.java | 3 +-
distsql/pom.xml | 1 +
.../rql/show/ShowSingleTableStatement.java | 5 +-
.../single-table/show-single-table.cn.md | 36 +++-
.../single-table/show-single-table.en.md | 36 +++-
.../shardingsphere-jdbc/java-api/rules/mix.cn.md | 4 +-
.../shardingsphere-jdbc/java-api/rules/mix.en.md | 4 +-
.../yaml-config/rules/mix.cn.md | 2 +-
.../yaml-config/rules/mix.en.md | 2 +-
.../syntax/rql/rule-query/single-table.cn.md | 14 +-
.../syntax/rql/rule-query/single-table.en.md | 14 +-
examples/README.md | 73 +------
examples/README_ZH.md | 76 ++-----
.../DatabaseDiscoveryProviderAlgorithmFactory.java | 2 +-
.../spi/DatabaseDiscoveryProviderAlgorithm.java | 2 +-
.../dbdiscovery/rule/DatabaseDiscoveryRule.java | 2 +-
.../rule/DatabaseDiscoveryRuleTest.java | 2 +-
features/db-discovery/distsql/handler/pom.xml | 5 +
.../CountDatabaseDiscoveryRuleQueryResultSet.java | 2 +-
.../DatabaseDiscoveryHeartbeatQueryResultSet.java | 2 +-
.../query/DatabaseDiscoveryRuleQueryResultSet.java | 2 +-
.../query/DatabaseDiscoveryTypeQueryResultSet.java | 2 +-
...DatabaseDiscoveryHeartbeatStatementUpdater.java | 6 +-
...AlterDatabaseDiscoveryRuleStatementUpdater.java | 10 +-
...AlterDatabaseDiscoveryTypeStatementUpdater.java | 8 +-
...DatabaseDiscoveryHeartbeatStatementUpdater.java | 4 +-
...reateDatabaseDiscoveryRuleStatementUpdater.java | 10 +-
...reateDatabaseDiscoveryTypeStatementUpdater.java | 6 +-
...DatabaseDiscoveryHeartbeatStatementUpdater.java | 6 +-
.../DropDatabaseDiscoveryRuleStatementUpdater.java | 10 +-
.../DropDatabaseDiscoveryTypeStatementUpdater.java | 6 +-
...gsphere.distsql.handler.query.DistSQLResultSet} | 0
...e.distsql.handler.update.RuleDefinitionUpdater} | 0
...tabaseDiscoveryHeartbeatQueryResultSetTest.java | 2 +-
.../DatabaseDiscoveryRuleQueryResultSetTest.java | 2 +-
.../DatabaseDiscoveryTypeQueryResultSetTest.java | 2 +-
...baseDiscoveryHeartbeatStatementUpdaterTest.java | 4 +-
...overyProviderAlgorithmStatementUpdaterTest.java | 6 +-
...rDatabaseDiscoveryRuleStatementUpdaterTest.java | 6 +-
...baseDiscoveryHeartbeatStatementUpdaterTest.java | 2 +-
...overyProviderAlgorithmStatementUpdaterTest.java | 4 +-
...eDatabaseDiscoveryRuleStatementUpdaterTest.java | 6 +-
...baseDiscoveryHeartbeatStatementUpdaterTest.java | 4 +-
...overyProviderAlgorithmStatementUpdaterTest.java | 4 +-
...pDatabaseDiscoveryRuleStatementUpdaterTest.java | 8 +-
.../encrypt/factory/EncryptAlgorithmFactory.java | 2 +-
.../encrypt/spi/EncryptAlgorithm.java | 2 +-
features/encrypt/distsql/handler/pom.xml | 5 +
.../query/CountEncryptRuleQueryResultSet.java | 2 +-
.../handler/query/EncryptRuleQueryResultSet.java | 2 +-
.../update/AlterEncryptRuleStatementUpdater.java | 8 +-
.../update/CreateEncryptRuleStatementUpdater.java | 10 +-
.../update/DropEncryptRuleStatementUpdater.java | 4 +-
...gsphere.distsql.handler.query.DistSQLResultSet} | 0
...e.distsql.handler.update.RuleDefinitionUpdater} | 0
.../query/EncryptRuleQueryResultSetTest.java | 2 +-
.../AlterEncryptRuleStatementUpdaterTest.java | 6 +-
.../CreateEncryptRuleStatementUpdaterTest.java | 6 +-
.../DropEncryptRuleStatementUpdaterTest.java | 2 +-
.../cdc/core => features/mask/api}/pom.xml | 16 +-
.../mask/api/config/MaskRuleConfiguration.java | 29 ++-
.../config/rule/MaskColumnRuleConfiguration.java | 15 +-
.../config/rule/MaskTableRuleConfiguration.java | 17 +-
.../mask/factory/MaskAlgorithmFactory.java | 24 +--
.../shardingsphere/mask/spi/MaskAlgorithm.java} | 21 +-
.../cdc => features/mask}/core/pom.xml | 18 +-
.../mask/algorithm/hash/MD5MaskAlgorithm.java | 20 +-
.../shardingsphere/mask/constant/MaskOrder.java | 15 +-
.../shardingsphere/mask/rule/MaskColumn.java | 15 +-
.../apache/shardingsphere/mask/rule/MaskRule.java | 60 ++++++
.../apache/shardingsphere/mask/rule/MaskTable.java | 21 +-
...rg.apache.shardingsphere.mask.spi.MaskAlgorithm | 2 +-
{distsql => features/mask}/pom.xml | 13 +-
features/pom.xml | 1 +
.../ReadQueryLoadBalanceAlgorithmFactory.java | 2 +-
.../spi/ReadQueryLoadBalanceAlgorithm.java | 2 +-
.../rule/ReadwriteSplittingRule.java | 4 +-
.../readwrite-splitting/distsql/handler/pom.xml | 5 +
.../ReadwriteSplittingRuleStatementChecker.java | 12 +-
.../CountReadwriteSplittingRuleQueryResultSet.java | 2 +-
.../ReadwriteSplittingRuleQueryResultSet.java | 6 +-
...lterReadwriteSplittingRuleStatementUpdater.java | 2 +-
...eateReadwriteSplittingRuleStatementUpdater.java | 2 +-
...DropReadwriteSplittingRuleStatementUpdater.java | 8 +-
...gsphere.distsql.handler.query.DistSQLResultSet} | 0
...e.distsql.handler.update.RuleDefinitionUpdater} | 0
.../ReadwriteSplittingRuleQueryResultSetTest.java | 4 +-
...ReadwriteSplittingRuleStatementUpdaterTest.java | 10 +-
...ReadwriteSplittingRuleStatementUpdaterTest.java | 10 +-
...ReadwriteSplittingRuleStatementUpdaterTest.java | 6 +-
.../shadow/factory/ShadowAlgorithmFactory.java | 2 +-
.../shardingsphere/shadow/spi/ShadowAlgorithm.java | 2 +-
features/shadow/distsql/handler/pom.xml | 5 +
.../checker/ShadowRuleStatementChecker.java | 8 +-
.../query/CountShadowRuleQueryResultSet.java | 2 +-
.../DefaultShadowAlgorithmQueryResultSet.java | 2 +-
.../query/ShadowAlgorithmQueryResultSet.java | 2 +-
.../handler/query/ShadowRuleQueryResultSet.java | 2 +-
.../query/ShadowTableRuleQueryResultSet.java | 2 +-
...lterDefaultShadowAlgorithmStatementUpdater.java | 6 +-
.../update/AlterShadowRuleStatementUpdater.java | 8 +-
...eateDefaultShadowAlgorithmStatementUpdater.java | 6 +-
.../update/CreateShadowRuleStatementUpdater.java | 6 +-
...DropDefaultShadowAlgorithmStatementUpdater.java | 4 +-
.../DropShadowAlgorithmStatementUpdater.java | 8 +-
.../update/DropShadowRuleStatementUpdater.java | 4 +-
...gsphere.distsql.handler.query.DistSQLResultSet} | 0
...e.distsql.handler.update.RuleDefinitionUpdater} | 0
.../query/ShadowAlgorithmQueryResultSetTest.java | 2 +-
.../query/ShadowRuleQueryResultSetTest.java | 2 +-
.../query/ShadowTableRuleQueryResultSetTest.java | 2 +-
...DefaultShadowAlgorithmStatementUpdaterTest.java | 6 +-
.../AlterShadowRuleStatementUpdaterTest.java | 10 +-
...DefaultShadowAlgorithmStatementUpdaterTest.java | 2 +-
.../CreateShadowRuleStatementUpdaterTest.java | 6 +-
...DefaultShadowAlgorithmStatementUpdaterTest.java | 2 +-
.../DropShadowAlgorithmStatementUpdaterTest.java | 2 +-
.../update/DropShadowRuleStatementUpdaterTest.java | 2 +-
.../factory/KeyGenerateAlgorithmFactory.java | 2 +-
.../sharding/factory/ShardingAlgorithmFactory.java | 2 +-
.../factory/ShardingAuditAlgorithmFactory.java | 2 +-
.../sharding/spi/KeyGenerateAlgorithm.java | 2 +-
.../sharding/spi/ShardingAlgorithm.java | 2 +-
.../sharding/spi/ShardingAuditAlgorithm.java | 2 +-
.../decider/ShardingSQLFederationDecider.java | 10 +-
.../decider/ShardingSQLFederationDeciderTest.java | 37 +++-
features/sharding/distsql/handler/pom.xml | 5 +
.../checker/ShardingTableRuleStatementChecker.java | 12 +-
.../query/BroadcastTableRuleQueryResultSet.java | 2 +-
.../query/CountShardingRuleQueryResultSet.java | 2 +-
.../DefaultShardingStrategyQueryResultSet.java | 2 +-
.../query/ShardingAlgorithmsQueryResultSet.java | 2 +-
.../query/ShardingAuditorsQueryResultSet.java | 2 +-
.../query/ShardingKeyGeneratorsQueryResultSet.java | 2 +-
.../query/ShardingTableNodesQueryResultSet.java | 2 +-
.../ShardingTableReferenceRuleQueryResultSet.java | 2 +-
.../query/ShardingTableRuleQueryResultSet.java | 2 +-
...rdingTableRulesUsedAlgorithmQueryResultSet.java | 2 +-
...hardingTableRulesUsedAuditorQueryResultSet.java | 2 +-
...ngTableRulesUsedKeyGeneratorQueryResultSet.java | 2 +-
.../UnusedShardingAlgorithmsQueryResultSet.java | 2 +-
.../UnusedShardingAuditorsQueryResultSet.java | 2 +-
.../UnusedShardingKeyGeneratorsQueryResultSet.java | 2 +-
...terDefaultShardingStrategyStatementUpdater.java | 8 +-
...ShardingTableReferenceRuleStatementUpdater.java | 8 +-
.../AlterShardingTableRuleStatementUpdater.java | 4 +-
.../CreateBroadcastTableRuleStatementUpdater.java | 8 +-
...ateDefaultShardingStrategyStatementUpdater.java | 10 +-
...ShardingTableReferenceRuleStatementUpdater.java | 8 +-
.../CreateShardingTableRuleStatementUpdater.java | 2 +-
.../DropBroadcastTableRuleStatementUpdater.java | 4 +-
.../DropDefaultStrategyStatementUpdater.java | 4 +-
.../DropShardingAlgorithmStatementUpdater.java | 8 +-
.../DropShardingAuditorStatementUpdater.java | 6 +-
.../DropShardingKeyGeneratorStatementUpdater.java | 6 +-
...ShardingTableReferenceRuleStatementUpdater.java | 4 +-
.../DropShardingTableRuleStatementUpdater.java | 8 +-
...gsphere.distsql.handler.query.DistSQLResultSet} | 0
...e.distsql.handler.update.RuleDefinitionUpdater} | 0
.../checker/ShardingRuleStatementCheckerTest.java | 8 +-
.../ShardingTableNodesQueryResultSetTest.java | 2 +-
.../query/ShardingTableRuleQueryResultSetTest.java | 2 +-
...gTableRulesUsedAlgorithmQueryResultSetTest.java | 2 +-
...ingTableRulesUsedAuditorQueryResultSetTest.java | 2 +-
...bleRulesUsedKeyGeneratorQueryResultSetTest.java | 2 +-
...efaultShardingStrategyStatementUpdaterTest.java | 6 +-
...dingTableReferenceRuleStatementUpdaterTest.java | 2 +-
...efaultShardingStrategyStatementUpdaterTest.java | 6 +-
...dingTableReferenceRuleStatementUpdaterTest.java | 4 +-
...reateShardingTableRuleStatementUpdaterTest.java | 2 +-
...DropBroadcastTableRuleStatementUpdaterTest.java | 2 +-
...efaultShardingStrategyStatementUpdaterTest.java | 2 +-
.../DropShardingAlgorithmStatementUpdaterTest.java | 6 +-
.../DropShardingAuditorStatementUpdaterTest.java | 4 +-
...opShardingKeyGeneratorStatementUpdaterTest.java | 4 +-
...dingTableReferenceRuleStatementUpdaterTest.java | 2 +-
.../DropShardingTableRuleStatementUpdaterTest.java | 6 +-
.../algorithm/AlgorithmDescription.java | 2 +-
.../algorithm/ShardingSphereAlgorithm.java | 2 +-
.../algorithm/ShardingSphereAlgorithmFactory.java | 3 +-
.../props/DataSourcePropertiesValidator.java | 13 +-
.../exception/rule/RuleDisabledException.java | 32 ---
.../exception/rule/RuleEnabledException.java | 32 ---
.../exportable}/constant/ExportableConstants.java | 4 +-
.../constant/ExportableItemConstants.java | 2 +-
.../ShardingSphereAlgorithmFactoryTest.java | 5 +-
.../fixture/ShardingSphereAlgorithmFixture.java | 4 +-
.../props/DataSourcePropertiesValidatorTest.java | 18 +-
...gsphere.infra.algorithm.ShardingSphereAlgorithm | 2 +-
.../infra/util/reflect/ReflectiveUtil.java | 26 ++-
.../infra/util/reflect/ReflectiveUtilTest.java | 23 +--
.../util/reflect/fixture/ReflectiveFixture.java} | 21 +-
.../jdbc/core/driver/ShardingSphereDriverURL.java | 22 ++-
.../factory/AuthorityProviderAlgorithmFactory.java | 2 +-
.../authority/spi/AuthorityProviderAlgorithm.java | 2 +-
kernel/authority/distsql/handler/pom.xml | 5 +
.../handler/AuthorityRuleQueryResultSet.java | 2 +-
...gsphere.distsql.handler.query.DistSQLResultSet} | 0
.../handler/AuthorityRuleQueryResultSetTest.java | 2 +-
.../DataConsistencyCalculateAlgorithm.java | 2 +-
.../DataConsistencyCalculateAlgorithmFactory.java | 2 +-
.../spi/ingest/channel/PipelineChannelCreator.java | 2 +-
.../channel/PipelineChannelCreatorFactory.java | 2 +-
.../spi/ratelimit/JobRateLimitAlgorithm.java | 2 +-
.../ratelimit/JobRateLimitAlgorithmFactory.java | 2 +-
kernel/data-pipeline/cdc/client/pom.xml | 4 +
.../data/pipeline/cdc/client/CDCClient.java | 39 +++-
.../client/handler/SubscriptionRequestHandler.java | 35 ++--
.../client/parameter/StartCDCClientParameter.java | 37 ++--
kernel/data-pipeline/cdc/core/pom.xml | 4 +
.../data/pipeline/cdc/api/CDCJobAPI.java | 19 +-
.../data/pipeline/cdc/api/CDCJobAPIFactory.java | 24 ++-
.../data/pipeline/cdc/api/impl/CDCJobAPIImpl.java | 195 ++++++++++++++++++
.../data/pipeline/cdc/api/job/type/CDCJobType.java | 16 +-
.../api/pojo/CreateSubscriptionJobParameter.java | 31 +--
.../cdc/config/job/CDCJobConfiguration.java | 53 +++++
.../data/pipeline/cdc/core/job/CDCJob.java | 53 +++++
.../data/pipeline/cdc/core/job/CDCJobId.java | 31 +--
.../CDCJobConfigurationChangedProcessor.java | 72 +++++++
.../cdc/yaml/job/YamlCDCJobConfiguration.java | 55 ++++++
.../yaml/job/YamlCDCJobConfigurationSwapper.java | 60 ++++++
....shardingsphere.data.pipeline.cdc.api.CDCJobAPI | 2 +-
...andler.PipelineChangedJobConfigurationProcessor | 2 +-
...he.shardingsphere.data.pipeline.spi.job.JobType | 2 +-
.../data/pipeline/cdc/core/job/CDCJobIdTest.java | 16 +-
.../AbstractInventoryIncrementalJobAPIImpl.java | 2 +-
...RC32MatchDataConsistencyCalculateAlgorithm.java | 2 +-
...DataMatchDataConsistencyCalculateAlgorithm.java | 2 +-
.../ShardingSphereDataScheduleCollector.java | 2 +-
.../PipelineChangedJobConfigurationProcessor.java | 1 +
.../execute/ShardingSphereDataCollectorTest.java | 10 +-
.../pipeline/mysql/ingest/client/MySQLClient.java | 29 ++-
.../mysql/ingest/client/PasswordEncryption.java | 4 +-
.../ingest/client/PasswordEncryptionTest.java | 2 +-
kernel/data-pipeline/distsql/handler/pom.xml | 5 +
...ShowMigrationCheckAlgorithmsQueryResultSet.java | 2 +-
.../ShowMigrationCheckStatusQueryResultSet.java | 2 +-
.../ShowMigrationJobStatusQueryResultSet.java | 2 +-
.../query/ShowMigrationListQueryResultSet.java | 2 +-
...wMigrationSourceStorageUnitsQueryResultSet.java | 2 +-
.../handler/update/CheckMigrationJobUpdater.java | 2 +-
.../handler/update/CommitMigrationUpdater.java | 2 +-
.../handler/update/DropMigrationCheckUpdater.java | 2 +-
.../handler/update/MigrateTableUpdater.java | 2 +-
.../RegisterMigrationSourceStorageUnitUpdater.java | 9 +-
.../handler/update/RollbackMigrationUpdater.java | 2 +-
.../handler/update/StartMigrationCheckUpdater.java | 2 +-
.../handler/update/StartMigrationUpdater.java | 2 +-
.../handler/update/StopMigrationCheckUpdater.java | 2 +-
.../handler/update/StopMigrationUpdater.java | 2 +-
...nregisterMigrationSourceStorageUnitUpdater.java | 2 +-
...gsphere.distsql.handler.query.DistSQLResultSet} | 0
...ardingsphere.distsql.handler.update.RALUpdater} | 0
kernel/parser/distsql/handler/pom.xml | 5 +
.../handler/query/SQLParserRuleQueryResultSet.java | 2 +-
.../update/AlterSQLParserRuleStatementUpdater.java | 2 +-
...gsphere.distsql.handler.query.DistSQLResultSet} | 0
...re.distsql.handler.update.GlobalRuleRALUpdater} | 0
.../singletable/rule/SingleTableRule.java | 3 +-
.../optimizer/it/SQLOptimizeEngineIT.java | 34 ++++
.../resources/cases/federation-query-sql-cases.xml | 220 +++++++++++++++++++++
kernel/sql-translator/distsql/handler/pom.xml | 5 +
.../handler/SQLTranslatorRuleQueryResultSet.java | 2 +-
...gsphere.distsql.handler.query.DistSQLResultSet} | 0
.../traffic/factory/TrafficAlgorithmFactory.java | 2 +-
.../TrafficLoadBalanceAlgorithmFactory.java | 2 +-
.../traffic/spi/TrafficAlgorithm.java | 2 +-
.../traffic/spi/TrafficLoadBalanceAlgorithm.java | 2 +-
kernel/traffic/distsql/handler/pom.xml | 5 +
.../handler/query/TrafficRulesQueryResultSet.java | 2 +-
.../update/AlterTrafficRuleStatementUpdater.java | 6 +-
.../update/CreateTrafficRuleStatementUpdater.java | 6 +-
.../update/DropTrafficRuleStatementUpdater.java | 4 +-
...gsphere.distsql.handler.query.DistSQLResultSet} | 0
...re.distsql.handler.update.GlobalRuleRALUpdater} | 0
.../query/TrafficRulesQueryResultSetTest.java | 2 +-
.../AlterTrafficRuleStatementUpdaterTest.java | 4 +-
.../CreateTrafficRuleStatementUpdaterTest.java | 4 +-
.../DropTrafficRuleStatementUpdaterTest.java | 2 +-
kernel/transaction/distsql/handler/pom.xml | 5 +
.../query/TransactionRuleQueryResultSet.java | 2 +-
.../AlterTransactionRuleStatementUpdater.java | 4 +-
...gsphere.distsql.handler.query.DistSQLResultSet} | 0
...re.distsql.handler.update.GlobalRuleRALUpdater} | 0
.../cluster/zookeeper/ZookeeperRepository.java | 1 +
.../cluster/zookeeper/ZookeeperRepositoryTest.java | 2 +
pom.xml | 23 +--
.../backend/handler/cdc/CDCBackendHandler.java | 83 ++++++++
.../ral/QueryableGlobalRuleRALBackendHandler.java | 2 +-
...ueryableGlobalRuleRALBackendHandlerFactory.java | 4 +-
.../distsql/ral/RALBackendHandlerFactory.java | 4 +-
.../ral/UpdatableGlobalRuleRALBackendHandler.java | 2 +-
...pdatableGlobalRuleRALBackendHandlerFactory.java | 2 +-
...aseDiscoveryRuleConfigurationImportChecker.java | 6 +-
...iteSplittingRuleConfigurationImportChecker.java | 4 +-
.../ShardingRuleConfigurationImportChecker.java | 8 +-
.../query/QueryableScalingRALBackendHandler.java | 2 +-
.../QueryableScalingRALBackendHandlerFactory.java | 2 +-
.../update/UpdatableScalingRALBackendHandler.java | 2 +-
.../queryable/ShowMigrationRuleQueryResultSet.java | 2 +-
...owStatusFromReadwriteSplittingRulesHandler.java | 4 +-
.../AlterInventoryIncrementalRuleUpdater.java | 2 +-
...SplittingStorageUnitStatusStatementHandler.java | 6 +-
.../ImportDatabaseConfigurationHandler.java | 14 +-
.../ral/updatable/RefreshTableMetaDataHandler.java | 4 +-
.../resource/AlterStorageUnitBackendHandler.java | 14 +-
.../RegisterStorageUnitBackendHandler.java | 12 +-
.../UnregisterStorageUnitBackendHandler.java | 6 +-
.../rdl/rule/RuleDefinitionBackendHandler.java | 10 +-
...aultSingleTableStorageUnitStatementUpdater.java | 4 +-
.../handler/distsql/rql/RQLBackendHandler.java | 2 +-
.../distsql/rql/RQLBackendHandlerFactory.java | 4 +-
.../rql/resource/StorageUnitQueryResultSet.java | 2 +-
.../rule/CountSingleTableRuleQueryResultSet.java | 2 +-
.../rule/RulesUsedStorageUnitQueryResultSet.java | 2 +-
.../rql/rule/SingleTableQueryResultSet.java | 8 +-
.../rql/rule/SingleTableRulesQueryResultSet.java | 2 +-
...gsphere.distsql.handler.query.DistSQLResultSet} | 0
...ardingsphere.distsql.handler.update.RALUpdater} | 0
...e.distsql.handler.update.RuleDefinitionUpdater} | 0
.../backend/handler/cdc/CDCBackendHandlerTest.java | 100 ++++++++++
.../handler/cdc/fixture/FixtureCDCJobAPI.java | 11 +-
.../distsql/DistSQLBackendHandlerFactoryTest.java | 2 +-
.../FixtureRuleDefinitionCreateUpdater.java | 2 +-
.../QueryableScalingFixtureQueryResultSet.java | 2 +-
.../ImportDatabaseConfigurationHandlerTest.java | 16 +-
.../updatable/RefreshTableMetaDataHandlerTest.java | 4 +-
.../AlterStorageUnitBackendHandlerTest.java | 14 +-
.../RegisterStorageUnitBackendHandlerTest.java | 14 +-
.../UnregisterStorageUnitBackendHandlerTest.java | 6 +-
...etDefaultSingleTableStorageUnitUpdaterTest.java | 2 +-
.../handler/distsql/rql/RQLBackendHandlerTest.java | 2 +-
.../RulesUsedStorageUnitQueryResultSetTest.java | 4 +-
.../distsql/rql/SingleTableQueryResultSetTest.java | 14 +-
.../rql/SingleTableRulesQueryResultSetTest.java | 2 +-
....shardingsphere.data.pipeline.cdc.api.CDCJobAPI | 2 +-
...gsphere.distsql.handler.query.DistSQLResultSet} | 0
...e.distsql.handler.update.RuleDefinitionUpdater} | 0
.../frontend/netty/CDCChannelInboundHandler.java | 18 +-
test/e2e/pipeline/pom.xml | 4 +
.../cases/autocommit/MySQLAutoCommitTestCase.java | 14 +-
.../autocommit/PostgresSQLAutoCommitTestCase.java | 14 +-
.../ExceptionInTransactionTestCase.java | 2 -
.../cases/cursor/OpenGaussCursorTestCase.java | 19 +-
.../cases/nested/NestedTransactionTestCase.java | 16 +-
.../cases/readonly/SetReadOnlyTestCase.java | 6 +-
.../cases/truncate/MySQLXATruncateTestCase.java | 21 +-
.../DataConsistencyCalculateAlgorithmFixture.java | 2 +-
392 files changed, 2244 insertions(+), 1133 deletions(-)
copy {kernel/data-pipeline/cdc/core => distsql/handler}/pom.xml (67%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/DistSQLException.java (95%)
copy {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/resource/DuplicateResourceException.java (95%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/resource/EmptyResourceException.java (94%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/resource/InvalidResourcesException.java (95%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/resource/MissingRequiredResourcesException.java (95%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/resource/ResourceDefinitionViolationException.java (89%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/resource/ResourceInUsedException.java (95%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/rule/AlgorithmInUsedException.java (95%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/rule/DuplicateAlgorithmException.java (95%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/rule/DuplicateRuleException.java (96%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/rule/InvalidAlgorithmConfigurationException.java (96%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/rule/InvalidRuleConfigurationException.java (96%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/rule/MissingRequiredAlgorithmException.java (96%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/rule/MissingRequiredRuleException.java (97%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/rule/RuleDefinitionViolationException.java (90%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/exception/rule/RuleInUsedException.java (95%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/query/DatabaseDistSQLResultSet.java (95%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/query/DistSQLResultSet.java (95%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/query/GlobalRuleDistSQLResultSet.java (95%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/update/GlobalRuleRALUpdater.java (96%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/update/RALUpdater.java (96%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/update/RALUpdaterFactory.java (96%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/update/RuleDefinitionAlterUpdater.java (96%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/update/RuleDefinitionCreateUpdater.java (96%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/update/RuleDefinitionDropUpdater.java (97%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/update/RuleDefinitionUpdater.java (96%)
rename {infra/common/src/main/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler}/update/RuleDefinitionUpdaterFactory.java (96%)
copy kernel/authority/api/src/main/java/org/apache/shardingsphere/authority/spi/AuthorityProviderAlgorithm.java => distsql/handler/src/main/java/org/apache/shardingsphere/distsql/handler/validate/DataSourcePropertiesValidateHandler.java (50%)
copy infra/common/src/test/java/org/apache/shardingsphere/infra/fixture/FixtureRuleStatement.java => distsql/handler/src/test/java/org/apache/shardingsphere/distsql/handler/fixture/config/FixtureRuleConfiguration.java (70%)
rename {infra/common/src/test/java/org/apache/shardingsphere/infra/fixture => distsql/handler/src/test/java/org/apache/shardingsphere/distsql/handler/fixture/statement}/FixtureRALStatement.java (93%)
copy {infra/common/src/test/java/org/apache/shardingsphere/infra/fixture => distsql/handler/src/test/java/org/apache/shardingsphere/distsql/handler/fixture/statement}/FixtureRuleStatement.java (93%)
rename {infra/common/src/test/java/org/apache/shardingsphere/infra/fixture => distsql/handler/src/test/java/org/apache/shardingsphere/distsql/handler/fixture/updater}/FixtureRALUpdater.java (83%)
rename {infra/common/src/test/java/org/apache/shardingsphere/infra/fixture => distsql/handler/src/test/java/org/apache/shardingsphere/distsql/handler/fixture/updater}/FixtureRuleDefinitionUpdater.java (81%)
copy {infra/common/src/test/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/test/java/org/apache/shardingsphere/distsql/handler}/update/RALUpdaterFactoryTest.java (83%)
rename {infra/common/src/test/java/org/apache/shardingsphere/infra/distsql => distsql/handler/src/test/java/org/apache/shardingsphere/distsql/handler}/update/RuleDefinitionUpdaterFactoryTest.java (83%)
copy infra/common/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.update.RuleDefinitionUpdater => distsql/handler/src/test/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.update.RALUpdater (91%)
copy infra/common/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.update.RALUpdater => distsql/handler/src/test/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.update.RuleDefinitionUpdater (90%)
rename features/db-discovery/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet => org.apache.shardingsphere.distsql.handler.query.DistSQLResultSet} (100%)
rename features/db-discovery/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.update.RuleDefinitionUpdater => org.apache.shardingsphere.distsql.handler.update.RuleDefinitionUpdater} (100%)
rename features/encrypt/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet => org.apache.shardingsphere.distsql.handler.query.DistSQLResultSet} (100%)
rename features/encrypt/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.update.RuleDefinitionUpdater => org.apache.shardingsphere.distsql.handler.update.RuleDefinitionUpdater} (100%)
copy {kernel/data-pipeline/cdc/core => features/mask/api}/pom.xml (67%)
copy kernel/authority/api/src/main/java/org/apache/shardingsphere/authority/spi/AuthorityProviderAlgorithm.java => features/mask/api/src/main/java/org/apache/shardingsphere/mask/api/config/MaskRuleConfiguration.java (53%)
copy kernel/traffic/api/src/main/java/org/apache/shardingsphere/traffic/spi/TrafficAlgorithm.java => features/mask/api/src/main/java/org/apache/shardingsphere/mask/api/config/rule/MaskColumnRuleConfiguration.java (71%)
copy kernel/traffic/api/src/main/java/org/apache/shardingsphere/traffic/spi/TrafficAlgorithm.java => features/mask/api/src/main/java/org/apache/shardingsphere/mask/api/config/rule/MaskTableRuleConfiguration.java (68%)
copy kernel/authority/api/src/main/java/org/apache/shardingsphere/authority/factory/AuthorityProviderAlgorithmFactory.java => features/mask/api/src/main/java/org/apache/shardingsphere/mask/factory/MaskAlgorithmFactory.java (60%)
copy features/{sharding/api/src/main/java/org/apache/shardingsphere/sharding/spi/KeyGenerateAlgorithm.java => mask/api/src/main/java/org/apache/shardingsphere/mask/spi/MaskAlgorithm.java} (67%)
copy {kernel/data-pipeline/cdc => features/mask}/core/pom.xml (71%)
copy infra/common/src/test/java/org/apache/shardingsphere/infra/config/algorithm/fixture/ShardingSphereAlgorithmFixture.java => features/mask/core/src/main/java/org/apache/shardingsphere/mask/algorithm/hash/MD5MaskAlgorithm.java (69%)
copy kernel/traffic/api/src/main/java/org/apache/shardingsphere/traffic/spi/TrafficAlgorithm.java => features/mask/core/src/main/java/org/apache/shardingsphere/mask/constant/MaskOrder.java (74%)
copy kernel/traffic/api/src/main/java/org/apache/shardingsphere/traffic/spi/TrafficAlgorithm.java => features/mask/core/src/main/java/org/apache/shardingsphere/mask/rule/MaskColumn.java (74%)
create mode 100644 features/mask/core/src/main/java/org/apache/shardingsphere/mask/rule/MaskRule.java
rename infra/common/src/main/java/org/apache/shardingsphere/infra/distsql/exception/resource/DuplicateResourceException.java => features/mask/core/src/main/java/org/apache/shardingsphere/mask/rule/MaskTable.java (55%)
copy infra/common/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.update.RALUpdater => features/mask/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mask.spi.MaskAlgorithm (92%)
copy {distsql => features/mask}/pom.xml (76%)
rename features/readwrite-splitting/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet => org.apache.shardingsphere.distsql.handler.query.DistSQLResultSet} (100%)
rename features/readwrite-splitting/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.update.RuleDefinitionUpdater => org.apache.shardingsphere.distsql.handler.update.RuleDefinitionUpdater} (100%)
rename features/shadow/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet => org.apache.shardingsphere.distsql.handler.query.DistSQLResultSet} (100%)
rename features/shadow/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.update.RuleDefinitionUpdater => org.apache.shardingsphere.distsql.handler.update.RuleDefinitionUpdater} (100%)
rename features/sharding/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet => org.apache.shardingsphere.distsql.handler.query.DistSQLResultSet} (100%)
rename features/sharding/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.update.RuleDefinitionUpdater => org.apache.shardingsphere.distsql.handler.update.RuleDefinitionUpdater} (100%)
rename infra/common/src/main/java/org/apache/shardingsphere/infra/{config => }/algorithm/AlgorithmDescription.java (95%)
rename infra/common/src/main/java/org/apache/shardingsphere/infra/{config => }/algorithm/ShardingSphereAlgorithm.java (95%)
rename infra/common/src/main/java/org/apache/shardingsphere/infra/{config => }/algorithm/ShardingSphereAlgorithmFactory.java (92%)
delete mode 100644 infra/common/src/main/java/org/apache/shardingsphere/infra/distsql/exception/rule/RuleDisabledException.java
delete mode 100644 infra/common/src/main/java/org/apache/shardingsphere/infra/distsql/exception/rule/RuleEnabledException.java
rename infra/common/src/main/java/org/apache/shardingsphere/infra/{distsql => rule/identifier/type/exportable}/constant/ExportableConstants.java (89%)
rename infra/common/src/main/java/org/apache/shardingsphere/infra/{distsql => rule/identifier/type/exportable}/constant/ExportableItemConstants.java (93%)
rename infra/common/src/test/java/org/apache/shardingsphere/infra/{config => }/algorithm/ShardingSphereAlgorithmFactoryTest.java (89%)
copy infra/common/src/test/java/org/apache/shardingsphere/infra/{config => }/algorithm/fixture/ShardingSphereAlgorithmFixture.java (89%)
copy kernel/authority/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet => infra/common/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.algorithm.ShardingSphereAlgorithm (90%)
copy infra/{common/src/test/java/org/apache/shardingsphere/infra/fixture/FixtureRuleStatement.java => util/src/test/java/org/apache/shardingsphere/infra/util/reflect/fixture/ReflectiveFixture.java} (67%)
rename kernel/authority/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet => org.apache.shardingsphere.distsql.handler.query.DistSQLResultSet} (100%)
copy infra/common/src/test/java/org/apache/shardingsphere/infra/config/algorithm/fixture/ShardingSphereAlgorithmFixture.java => kernel/data-pipeline/cdc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/parameter/StartCDCClientParameter.java (53%)
copy features/sharding/api/src/main/java/org/apache/shardingsphere/sharding/spi/KeyGenerateAlgorithm.java => kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/api/CDCJobAPI.java (65%)
copy features/sharding/api/src/main/java/org/apache/shardingsphere/sharding/spi/KeyGenerateAlgorithm.java => kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/api/CDCJobAPIFactory.java (64%)
create mode 100644 kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/api/impl/CDCJobAPIImpl.java
copy infra/common/src/test/java/org/apache/shardingsphere/infra/fixture/FixtureRuleStatement.java => kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/api/job/type/CDCJobType.java (70%)
copy infra/common/src/test/java/org/apache/shardingsphere/infra/config/algorithm/fixture/ShardingSphereAlgorithmFixture.java => kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/api/pojo/CreateSubscriptionJobParameter.java (60%)
create mode 100644 kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/config/job/CDCJobConfiguration.java
create mode 100644 kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/job/CDCJob.java
rename infra/common/src/test/java/org/apache/shardingsphere/infra/config/algorithm/fixture/ShardingSphereAlgorithmFixture.java => kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/job/CDCJobId.java (54%)
create mode 100644 kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/metadata/processor/CDCJobConfigurationChangedProcessor.java
create mode 100644 kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/yaml/job/YamlCDCJobConfiguration.java
create mode 100644 kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/yaml/job/YamlCDCJobConfigurationSwapper.java
copy infra/common/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.update.RuleDefinitionUpdater => kernel/data-pipeline/cdc/core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.cdc.api.CDCJobAPI (91%)
rename infra/common/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.config.algorithm.ShardingSphereAlgorithm => kernel/data-pipeline/cdc/core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.metadata.node.event.handler.PipelineChangedJobConfigurationProcessor (88%)
rename infra/common/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.update.RALUpdater => kernel/data-pipeline/cdc/core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.job.JobType (92%)
rename infra/common/src/test/java/org/apache/shardingsphere/infra/distsql/update/RALUpdaterFactoryTest.java => kernel/data-pipeline/cdc/core/src/test/java/org/apache/shardingsphere/data/pipeline/cdc/core/job/CDCJobIdTest.java (59%)
rename kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet => org.apache.shardingsphere.distsql.handler.query.DistSQLResultSet} (100%)
rename kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.update.RALUpdater => org.apache.shardingsphere.distsql.handler.update.RALUpdater} (100%)
rename kernel/parser/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet => org.apache.shardingsphere.distsql.handler.query.DistSQLResultSet} (100%)
rename kernel/parser/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.update.GlobalRuleRALUpdater => org.apache.shardingsphere.distsql.handler.update.GlobalRuleRALUpdater} (100%)
rename kernel/sql-translator/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet => org.apache.shardingsphere.distsql.handler.query.DistSQLResultSet} (100%)
rename kernel/traffic/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet => org.apache.shardingsphere.distsql.handler.query.DistSQLResultSet} (100%)
rename kernel/traffic/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.update.GlobalRuleRALUpdater => org.apache.shardingsphere.distsql.handler.update.GlobalRuleRALUpdater} (100%)
rename kernel/transaction/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet => org.apache.shardingsphere.distsql.handler.query.DistSQLResultSet} (100%)
rename kernel/transaction/distsql/handler/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.update.GlobalRuleRALUpdater => org.apache.shardingsphere.distsql.handler.update.GlobalRuleRALUpdater} (100%)
create mode 100644 proxy/backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/cdc/CDCBackendHandler.java
rename proxy/backend/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet => org.apache.shardingsphere.distsql.handler.query.DistSQLResultSet} (100%)
rename proxy/backend/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.update.RALUpdater => org.apache.shardingsphere.distsql.handler.update.RALUpdater} (100%)
rename proxy/backend/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.update.RuleDefinitionUpdater => org.apache.shardingsphere.distsql.handler.update.RuleDefinitionUpdater} (100%)
create mode 100644 proxy/backend/src/test/java/org/apache/shardingsphere/proxy/backend/handler/cdc/CDCBackendHandlerTest.java
rename infra/common/src/test/java/org/apache/shardingsphere/infra/fixture/FixtureRuleStatement.java => proxy/backend/src/test/java/org/apache/shardingsphere/proxy/backend/handler/cdc/fixture/FixtureCDCJobAPI.java (68%)
rename infra/common/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.update.RuleDefinitionUpdater => proxy/backend/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.cdc.api.CDCJobAPI (91%)
rename proxy/backend/src/test/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet => org.apache.shardingsphere.distsql.handler.query.DistSQLResultSet} (100%)
rename proxy/backend/src/test/resources/META-INF/services/{org.apache.shardingsphere.infra.distsql.update.RuleDefinitionUpdater => org.apache.shardingsphere.distsql.handler.update.RuleDefinitionUpdater} (100%)