[shardingsphere] branch master updated (16a9c3f -> ee67c6e)

[pa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

panjuan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.


    from 16a9c3f  Shadow non-DML route (#12660)
     add ee67c6e  Add dataConsistencyCheckAlgorithm default implementation and DataConsistencyChecker refactor (#12653)

No new revisions were added by this update.

Summary of changes:
 .../proxy/initializer/BootstrapInitializer.java    |   4 +
 .../src/main/resources/conf/server.yaml            |   6 +-
 .../api/ScalingDataConsistencyCheckAlgorithm.java  |   8 ++
 ...gorithm.java => SingleTableDataCalculator.java} |  31 +++--
 .../impl/AbstractSingleTableDataCalculator.java    |  22 ++--
 .../scaling/core/api/impl/ScalingAPIImpl.java      |  41 +++---
 ...alingDefaultDataConsistencyCheckAlgorithm.java} |  25 ++--
 .../impl/SingleTableDataCalculatorRegistry.java    |  69 ++++++++++
 .../scaling/core/config/DumperConfiguration.java   |   3 +
 .../scaling/core/job/check/EnvironmentChecker.java |   8 --
 .../core/job/check/EnvironmentCheckerFactory.java  |   5 +-
 .../AbstractDataConsistencyChecker.java            |  89 -------------
 .../check/consistency/DataConsistencyChecker.java  |   9 +-
 .../consistency/DataConsistencyCheckerImpl.java    | 139 +++++++++++++++++++++
 .../core/job/preparer/ActualTableDefinition.java   |   3 +-
 ...g.core.api.ScalingDataConsistencyCheckAlgorithm |   2 +-
 .../impl/FixtureH2SingleTableDataCalculator.java   |  23 ++--
 .../scaling/core/api/impl/ScalingAPIImplTest.java  |  42 ++-----
 ...ngDefaultDataConsistencyCheckAlgorithmTest.java |  45 +++++++
 ...calingFixtureDataConsistencyCheckAlgorithm.java |  13 +-
 .../SingleTableDataCalculatorRegistryTest.java     |  40 ++++++
 .../fixture/FixtureDataConsistencyChecker.java     |  43 -------
 .../core/fixture/FixtureEnvironmentChecker.java    |   6 -
 ...st.java => DataConsistencyCheckerImplTest.java} |  21 +++-
 ...here.scaling.core.api.SingleTableDataCalculator |   2 +-
 .../DefaultMySQLSingleTableDataCalculator.java     |  77 ++++++++++++
 .../checker/MySQLDataConsistencyChecker.java       | 103 ---------------
 .../component/checker/MySQLEnvironmentChecker.java |   5 -
 ...here.scaling.core.api.SingleTableDataCalculator |   2 +-
 .../scaling/mysql/MySQLScalingEntryTest.java       |   2 -
 .../checker/OpenGaussEnvironmentChecker.java       |   6 -
 .../opengauss/OpenGaussScalingEntryTest.java       |   2 -
 ...DefaultPostgreSQLSingleTableDataCalculator.java |  49 ++++++++
 .../checker/PostgreSQLDataConsistencyChecker.java  |  47 -------
 .../checker/PostgreSQLEnvironmentChecker.java      |   5 -
 ...here.scaling.core.api.SingleTableDataCalculator |   2 +-
 .../postgresql/PostgreSQLScalingEntryTest.java     |   2 -
 37 files changed, 560 insertions(+), 441 deletions(-)
 copy shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api/{ScalingDataConsistencyCheckAlgorithm.java => SingleTableDataCalculator.java} (53%)
 copy shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-statement/src/main/java/org/apache/shardingsphere/sharding/distsql/parser/statement/AlterShardingTableRuleStatement.java => shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api/impl/AbstractSingleTableDataCalculator.java (54%)
 copy shardingsphere-scaling/shardingsphere-scaling-core/src/{test/java/org/apache/shardingsphere/scaling/core/api/impl/ScalingFixtureDataConsistencyCheckAlgorithm.java => main/java/org/apache/shardingsphere/scaling/core/api/impl/ScalingDefaultDataConsistencyCheckAlgorithm.java} (71%)
 create mode 100644 shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api/impl/SingleTableDataCalculatorRegistry.java
 delete mode 100644 shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/check/consistency/AbstractDataConsistencyChecker.java
 create mode 100644 shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/check/consistency/DataConsistencyCheckerImpl.java
 copy shardingsphere-scaling/shardingsphere-scaling-core/src/{test => main}/resources/META-INF/services/org.apache.shardingsphere.scaling.core.api.ScalingDataConsistencyCheckAlgorithm (92%)
 copy shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/recognizer/impl/H2Recognizer.java => shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/api/impl/FixtureH2SingleTableDataCalculator.java (61%)
 create mode 100644 shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/api/impl/ScalingDefaultDataConsistencyCheckAlgorithmTest.java
 create mode 100644 shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/api/impl/SingleTableDataCalculatorRegistryTest.java
 delete mode 100644 shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/fixture/FixtureDataConsistencyChecker.java
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/job/check/{AbstractDataConsistencyCheckerTest.java => DataConsistencyCheckerImplTest.java} (72%)
 copy examples/example-core/config-utility/src/main/resources/META-INF/services/org.apache.shardingsphere.encrypt.spi.EncryptAlgorithm => shardingsphere-scaling/shardingsphere-scaling-core/src/test/resources/META-INF/services/org.apache.shardingsphere.scaling.core.api.SingleTableDataCalculator (90%)
 create mode 100644 shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/checker/DefaultMySQLSingleTableDataCalculator.java
 delete mode 100644 shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/checker/MySQLDataConsistencyChecker.java
 copy examples/example-core/config-utility/src/main/resources/META-INF/services/org.apache.shardingsphere.encrypt.spi.EncryptAlgorithm => shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/resources/META-INF/services/org.apache.shardingsphere.scaling.core.api.SingleTableDataCalculator (89%)
 create mode 100644 shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/component/checker/DefaultPostgreSQLSingleTableDataCalculator.java
 delete mode 100644 shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/component/checker/PostgreSQLDataConsistencyChecker.java
 copy examples/example-core/config-utility/src/main/resources/META-INF/services/org.apache.shardingsphere.encrypt.spi.EncryptAlgorithm => shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-postgresql/src/main/resources/META-INF/services/org.apache.shardingsphere.scaling.core.api.SingleTableDataCalculator (88%)