This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
from 5687ee8 Refactor JDBCExecutorCallback (#8293)
add 1c40c49 Refactoring DataSource Configuration (#8301)
No new revisions were added by this update.
Summary of changes:
.../shardingsphere/scaling/ServerBootstrap.java | 4 +-
.../shardingsphere/scaling/WorkerBootstrap.java | 4 +-
.../scaling/util/ScalingConfigUtil.java | 5 +-
.../scaling/util/ScalingConfigUtilTest.java | 4 -
.../core/check/AbstractDataConsistencyChecker.java | 10 +-
.../scaling/core/config/DumperConfiguration.java | 4 +-
.../scaling/core/config/ImporterConfiguration.java | 3 +-
.../core/config/InventoryDumperConfiguration.java | 8 +-
.../scaling/core/config/RuleConfiguration.java | 52 +++++---
.../scaling/core/config/SyncConfiguration.java | 4 +-
.../DataSourceConfiguration.java} | 22 +++-
...ShardingSphereJDBCDataSourceConfiguration.java} | 52 ++++----
.../StandardJDBCDataSourceConfiguration.java} | 32 ++++-
.../scaling/core/datasource/DataSourceFactory.java | 36 +-----
.../scaling/core/datasource/DataSourceManager.java | 16 +--
.../executor/channel/DistributionChannel.java | 6 +-
.../executor/dumper/AbstractJDBCDumper.java | 22 ++--
.../execute/executor/dumper/DumperFactory.java | 4 +-
.../executor/importer/AbstractJDBCImporter.java | 4 +-
.../execute/executor/importer/ImporterFactory.java | 2 +-
.../scaling/core/job/ShardingScalingJob.java | 8 +-
.../core/job/position/PrimaryKeyPosition.java | 4 +-
.../job/preparer/ShardingScalingJobPreparer.java | 26 ++--
.../job/preparer/resumer/SyncPositionResumer.java | 19 ++-
.../splitter/InventoryDataTaskSplitter.java | 18 +--
.../core/service/AbstractScalingJobService.java | 22 ++--
.../core/service/RegistryRepositoryHolder.java | 6 +-
.../scaling/core/service/ScalingJobService.java | 16 +--
.../service/impl/DistributedScalingJobService.java | 20 ++--
.../service/impl/StandaloneScalingJobService.java | 4 +-
.../scaling/core/spi/ScalingWorker.java | 4 +-
.../scaling/core/spi/ScalingWorkerLoader.java | 4 +-
.../core/utils/ConfigurationYamlConverter.java | 8 +-
.../scaling/core/utils/ProxyConfigurationUtil.java | 44 +++----
.../scaling/core/utils/ReflectionUtil.java | 10 +-
.../scaling/core/utils/SyncConfigurationUtil.java | 132 ++++++++++-----------
.../check/AbstractDataConsistencyCheckerTest.java | 8 +-
.../scaling/core/config/RuleConfigurationTest.java | 51 ++++----
.../JDBCDataSourceConfigurationTest.java | 14 +--
...dingSphereJDBCDataSourceConfigurationTest.java} | 6 +-
.../core/datasource/DataSourceFactoryTest.java | 8 +-
.../core/datasource/DataSourceManagerTest.java | 4 +-
.../importer/AbstractJDBCImporterTest.java | 10 +-
.../scaling/core/fixture/FixtureScalingWorker.java | 2 +-
.../splitter/InventoryDataTaskSplitterTest.java | 24 ++--
.../IncrementalDataScalingTaskTest.java | 10 +-
.../inventory/InventoryDataScalingTaskTest.java | 26 ++--
.../impl/DistributedScalingJobServiceTest.java | 4 +-
.../scaling/core/spi/ScalingWorkerLoaderTest.java | 6 +-
.../elasticjob/ElasticJobScalingWorker.java | 62 +++++-----
.../scaling/elasticjob/job/ScalingElasticJob.java | 14 +--
.../scaling/elasticjob/util/ElasticJobUtils.java | 12 +-
.../scaling/mysql/component/MySQLBinlogDumper.java | 13 +-
.../component/MySQLDataConsistencyChecker.java | 4 +-
.../scaling/mysql/component/MySQLJdbcDumper.java | 4 +-
.../mysql/component/MySQLBinlogDumperTest.java | 6 +-
.../mysql/component/MySQLJdbcDumperTest.java | 6 +-
.../postgresql/component/PostgreSQLWalDumper.java | 11 +-
.../scaling/postgresql/wal/LogicalReplication.java | 6 +-
.../scaling/postgresql/wal/WalEventConverter.java | 6 +-
.../component/PostgreSQLJdbcDumperTest.java | 8 +-
.../component/PostgreSQLWalDumperTest.java | 8 +-
.../postgresql/wal/LogicalReplicationTest.java | 4 +-
.../postgresql/wal/WalEventConverterTest.java | 6 +-
64 files changed, 498 insertions(+), 484 deletions(-)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config/{ScalingDataSourceConfiguration.java
=> datasource/DataSourceConfiguration.java} (69%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config/{ShardingSphereJDBCScalingDataSourceConfiguration.java
=> datasource/ShardingSphereJDBCDataSourceConfiguration.java} (53%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config/{JDBCScalingDataSourceConfiguration.java
=> datasource/StandardJDBCDataSourceConfiguration.java} (64%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/config/{
=> datasource}/JDBCDataSourceConfigurationTest.java (60%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/config/{ShardingSphereJDBCScalingDataSourceConfigurationTest.java
=> datasource/ShardingSphereJDBCDataSourceConfigurationTest.java} (84%)
