This is an automated email from the ASF dual-hosted git repository.
kimmking pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
from d467b1a Fix code format for #7353 (#7505)
add 0576278 Add data consistency check function. (#7503)
No new revisions were added by this update.
Summary of changes:
.../scaling/web/HttpServerHandler.java | 29 ++++--
.../fixture/FixtureDataConsistencyChecker.java | 21 ++--
.../scaling/fixture/FixtureH2ScalingEntry.java | 16 +++-
.../shardingsphere-scaling-core/pom.xml | 5 +
.../scaling/core/ScalingJobController.java | 21 +++-
.../core/check/AbstractDataConsistencyChecker.java | 106 +++++++++++++++++++++
.../scaling/core/check/DataConsistencyChecker.java | 20 ++--
.../DataConsistencyCheckerFactory.java} | 19 ++--
.../scaling/core/config/ScalingContext.java | 4 +-
.../scaling/core/datasource/DataSourceManager.java | 6 +-
...dException.java => DataCheckFailException.java} | 12 +--
.../engine/ShardingScalingExecuteEngine.java | 27 +++++-
.../executor/importer/AbstractSqlBuilder.java | 32 +++++--
.../scaling/core/job/ShardingScalingJob.java | 19 +++-
.../resume/AbstractResumeBreakPointManager.java | 22 +++--
.../resume/FakeResumeBreakPointManager.java | 8 ++
.../job/preparer/ShardingScalingJobPreparer.java | 19 ++--
.../checker/DataSourceCheckerCheckerFactory.java | 2 +-
.../incremental/IncrementalDataScalingTask.java | 3 +-
.../core/schedule/ScalingTaskScheduler.java | 20 +---
.../scaling/core/spi/ScalingEntry.java | 23 +++--
.../scaling/core/utils/InventoryPositionUtil.java | 50 ----------
.../scaling/core/utils/ScalingTaskUtil.java | 47 +++++++++
.../scaling/core/ScalingJobControllerTest.java | 18 +++-
.../check/AbstractDataConsistencyCheckerTest.java | 89 +++++++++++++++++
.../engine/ShardingScalingExecuteEngineTest.java | 4 +-
.../fixture/FixtureDataConsistencyChecker.java} | 36 ++++---
.../core/fixture/FixtureH2ScalingEntry.java | 14 ++-
.../AbstractResumeBreakPointManagerTest.java | 8 ++
...IncrementalPositionResumeBreakPointManager.java | 8 ++
.../preparer/resumer/SyncPositionResumerTest.java | 10 +-
.../IncrementalDataScalingTaskTest.java | 2 +-
.../src/test/resources/config.json | 12 +--
.../scaling/mysql/MySQLDataConsistencyChecker.java | 101 ++++++++++++++++++++
.../scaling/mysql/MySQLImporter.java | 13 +--
.../scaling/mysql/MySQLScalingEntry.java | 12 ++-
.../scaling/mysql/MySQLSqlBuilder.java} | 30 +++---
.../scaling/mysql/spi/ScalingEntryLoaderTest.java | 4 +-
....java => PostgreSQLDataConsistencyChecker.java} | 22 +++--
.../postgresql/PostgreSQLDataSourceChecker.java | 2 +-
.../scaling/postgresql/PostgreSQLScalingEntry.java | 12 ++-
.../postgresql/spi/ScalingEntryLoaderTest.java | 4 +-
42 files changed, 692 insertions(+), 240 deletions(-)
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/segment/dml/pagination/limit/LimitValueSegment.java
=>
shardingsphere-scaling/shardingsphere-scaling-bootstrap/src/test/java/org/apache/shardingsphere/scaling/fixture/FixtureDataConsistencyChecker.java
(67%)
create mode 100644
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/check/AbstractDataConsistencyChecker.java
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/segment/SQLSegment.java
=>
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/check/DataConsistencyChecker.java
(71%)
copy
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{job/preparer/checker/DataSourceCheckerCheckerFactory.java
=> check/DataConsistencyCheckerFactory.java} (66%)
copy
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/exception/{PrepareFailedException.java
=> DataCheckFailException.java} (77%)
delete mode 100644
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/utils/InventoryPositionUtil.java
create mode 100644
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/utils/ScalingTaskUtil.java
create mode 100644
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/check/AbstractDataConsistencyCheckerTest.java
copy
shardingsphere-scaling/{shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/MySQLImporter.java
=>
shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/fixture/FixtureDataConsistencyChecker.java}
(55%)
mode change 100755 => 100644
create mode 100644
shardingsphere-scaling/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/MySQLDataConsistencyChecker.java
copy
shardingsphere-scaling/{shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/PostgreSQLImporter.java
=>
shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/MySQLSqlBuilder.java}
(58%)
mode change 100755 => 100644
copy
shardingsphere-scaling/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/{PostgreSQLImporter.java
=> PostgreSQLDataConsistencyChecker.java} (61%)
mode change 100755 => 100644
