[shardingsphere] branch master updated (c02b4b0 -> e13b2f4)

[zh...@apache.org]

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 c02b4b0  Refactor TextProtocolBackendHandler.getRowData (#8220)
     add e13b2f4  refactoring scaling modules (#8222)

No new revisions were added by this update.

Summary of changes:
 .../shardingsphere/scaling/ServerBootstrap.java    |   2 +-
 .../shardingsphere/scaling/WorkerBootstrap.java    |   2 +-
 .../{utils => util}/ResponseContentUtil.java       |   2 +-
 .../scaling/{utils => util}/ScalingConfigUtil.java |   5 +-
 .../scaling/web/HttpServerHandler.java             |   2 +-
 .../scaling/fixture/FixtureNopManager.java         |   2 +-
 .../{utils => util}/ResponseContentUtilTest.java   |   2 +-
 .../{utils => util}/ScalingConfigUtilTest.java     |   2 +-
 .../{utils => util}/ScalingConfigurationUtil.java  |   2 +-
 .../scaling/utils/ReflectionUtil.java              | 156 ---------------------
 .../scaling/web/HttpServerHandlerTest.java         |   4 +-
 .../scaling/web/HttpServerInitializerTest.java     |   2 +-
 .../UnexpectedDataRecordOrderException.java}       |   4 +-
 .../executor/importer/DataRecordMerger.java        |  12 +-
 .../execute/executor/record/GroupedDataRecord.java |   2 +-
 .../scaling/core/spi/ScalingEntryLoader.java       |   6 +-
 .../scaling/core/utils/ProxyConfigurationUtil.java |   2 +
 .../scaling/core/utils/ReflectionUtil.java         | 115 ++++++++++++++-
 .../scaling/core/config/RuleConfigurationTest.java |   2 +-
 .../core/datasource/DataSourceFactoryTest.java     |   2 +-
 .../core/datasource/DataSourceManagerTest.java     |   4 +-
 .../executor/importer/AbstractSqlBuilderTest.java  |   2 +-
 .../executor/importer/DataRecordMergerTest.java    |   9 +-
 .../execute/executor/record/DataRecordTest.java    |   2 +-
 .../FixtureShardingSphereJDBCConfiguration.java    |   2 +-
 .../AbstractResumeBreakPointManagerTest.java       |   4 +-
 .../RepositoryResumeBreakPointManagerTest.java     |   4 +-
 .../impl/DistributedScalingJobServiceTest.java     |   4 +-
 .../impl/StandaloneScalingJobServiceTest.java      |   6 +-
 .../scaling/core/spi/ScalingWorkerLoaderTest.java  |   2 +-
 .../scaling/core/util/ReflectionUtil.java          | 156 ---------------------
 .../scaling/elasticjob/util/ElasticJobUtils.java   |   3 +
 .../scaling/mysql/MySQLScalingEntry.java           |   8 +-
 .../mysql/{ => component}/MySQLBinlogDumper.java   |   2 +-
 .../MySQLDataConsistencyChecker.java               |   2 +-
 .../{ => component}/MySQLDataSourceChecker.java    |   2 +-
 .../mysql/{ => component}/MySQLImporter.java       |   2 +-
 .../mysql/{ => component}/MySQLJdbcDumper.java     |   2 +-
 .../{ => component}/MySQLPositionManager.java      |   2 +-
 .../mysql/{ => component}/MySQLSQLBuilder.java     |   2 +-
 ...yLoaderTest.java => MySQLScalingEntryTest.java} |  17 ++-
 .../mysql/{ => binlog}/BinlogPositionTest.java     |   3 +-
 .../scaling/mysql/client/MySQLClientTest.java      |  27 ++--
 .../netty/MySQLBinlogEventPacketDecoderTest.java   |   4 +-
 .../netty/MySQLCommandPacketDecoderTest.java       |  10 +-
 .../client/netty/MySQLNegotiateHandlerTest.java    |  10 +-
 .../{ => component}/MySQLBinlogDumperTest.java     |   4 +-
 .../MySQLDataSourceCheckerTest.java                |   2 +-
 .../mysql/{ => component}/MySQLImporterTest.java   |   2 +-
 .../mysql/{ => component}/MySQLJdbcDumperTest.java |   2 +-
 .../{ => component}/MySQLPositionManagerTest.java  |   2 +-
 .../mysql/{ => component}/MySQLSQLBuilderTest.java |  14 +-
 .../scaling/utils/ReflectionUtil.java              | 118 ----------------
 .../scaling/postgresql/PostgreSQLScalingEntry.java |   8 +-
 .../PostgreSQLDataConsistencyChecker.java          |   2 +-
 .../PostgreSQLDataSourceChecker.java               |   2 +-
 .../{ => component}/PostgreSQLImporter.java        |   2 +-
 .../{ => component}/PostgreSQLJdbcDumper.java      |   2 +-
 .../{ => component}/PostgreSQLPositionManager.java |   2 +-
 .../{ => component}/PostgreSQLSQLBuilder.java      |   2 +-
 .../{ => component}/PostgreSQLWalDumper.java       |   2 +-
 .../postgresql/wal/event/AbstractRowEvent.java     |   2 +-
 .../postgresql/wal/event/AbstractWalEvent.java     |   2 +-
 ...erTest.java => PostgreSQLScalingEntryTest.java} |  17 ++-
 .../PostgreSQLDataSourceCheckerTest.java           |   2 +-
 .../{ => component}/PostgreSQLImporterTest.java    |   2 +-
 .../{ => component}/PostgreSQLJdbcDumperTest.java  |   2 +-
 .../PostgreSQLPositionManagerTest.java             |   2 +-
 .../{ => component}/PostgreSQLSqlBuilderTest.java  |   2 +-
 .../{ => component}/PostgreSQLWalDumperTest.java   |   6 +-
 .../scaling/postgresql/utils/ReflectionUtil.java   |  85 -----------
 .../postgresql/wal/WalEventConverterTest.java      |   3 +-
 72 files changed, 262 insertions(+), 648 deletions(-)
 rename shardingsphere-scaling/shardingsphere-scaling-bootstrap/src/main/java/org/apache/shardingsphere/scaling/{utils => util}/ResponseContentUtil.java (98%)
 rename shardingsphere-scaling/shardingsphere-scaling-bootstrap/src/main/java/org/apache/shardingsphere/scaling/{utils => util}/ScalingConfigUtil.java (92%)
 rename shardingsphere-scaling/shardingsphere-scaling-bootstrap/src/test/java/org/apache/shardingsphere/scaling/{utils => util}/ResponseContentUtilTest.java (97%)
 rename shardingsphere-scaling/shardingsphere-scaling-bootstrap/src/test/java/org/apache/shardingsphere/scaling/{utils => util}/ScalingConfigUtilTest.java (96%)
 rename shardingsphere-scaling/shardingsphere-scaling-bootstrap/src/test/java/org/apache/shardingsphere/scaling/{utils => util}/ScalingConfigurationUtil.java (97%)
 delete mode 100644 shardingsphere-scaling/shardingsphere-scaling-bootstrap/src/test/java/org/apache/shardingsphere/scaling/utils/ReflectionUtil.java
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor/importer/UnexpectedDataRecordOrder.java => exception/UnexpectedDataRecordOrderException.java} (88%)
 delete mode 100644 shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/util/ReflectionUtil.java
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/{ => component}/MySQLBinlogDumper.java (99%)
 mode change 100755 => 100644
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/{ => component}/MySQLDataConsistencyChecker.java (98%)
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/{ => component}/MySQLDataSourceChecker.java (98%)
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/{ => component}/MySQLImporter.java (96%)
 mode change 100755 => 100644
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/{ => component}/MySQLJdbcDumper.java (98%)
 mode change 100755 => 100644
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/{ => component}/MySQLPositionManager.java (98%)
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/{ => component}/MySQLSQLBuilder.java (97%)
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/{spi/ScalingEntryLoaderTest.java => MySQLScalingEntryTest.java} (76%)
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/{ => binlog}/BinlogPositionTest.java (94%)
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/{ => component}/MySQLBinlogDumperTest.java (98%)
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/{ => component}/MySQLDataSourceCheckerTest.java (98%)
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/{ => component}/MySQLImporterTest.java (97%)
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/{ => component}/MySQLJdbcDumperTest.java (98%)
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/{ => component}/MySQLPositionManagerTest.java (98%)
 rename shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/{ => component}/MySQLSQLBuilderTest.java (84%)
 delete mode 100644 shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/utils/ReflectionUtil.java
 rename shardingsphere-scaling/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/{ => component}/PostgreSQLDataConsistencyChecker.java (96%)
 rename shardingsphere-scaling/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/{ => component}/PostgreSQLDataSourceChecker.java (97%)
 rename shardingsphere-scaling/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/{ => component}/PostgreSQLImporter.java (96%)
 mode change 100755 => 100644
 rename shardingsphere-scaling/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/{ => component}/PostgreSQLJdbcDumper.java (96%)
 mode change 100755 => 100644
 rename shardingsphere-scaling/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/{ => component}/PostgreSQLPositionManager.java (98%)
 rename shardingsphere-scaling/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/{ => component}/PostgreSQLSQLBuilder.java (97%)
 rename shardingsphere-scaling/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/{ => component}/PostgreSQLWalDumper.java (98%)
 mode change 100755 => 100644
 rename shardingsphere-scaling/shardingsphere-scaling-postgresql/src/test/java/org/apache/shardingsphere/scaling/postgresql/{spi/ScalingEntryLoaderTest.java => PostgreSQLScalingEntryTest.java} (75%)
 rename shardingsphere-scaling/shardingsphere-scaling-postgresql/src/test/java/org/apache/shardingsphere/scaling/postgresql/{ => component}/PostgreSQLDataSourceCheckerTest.java (98%)
 rename shardingsphere-scaling/shardingsphere-scaling-postgresql/src/test/java/org/apache/shardingsphere/scaling/postgresql/{ => component}/PostgreSQLImporterTest.java (97%)
 rename shardingsphere-scaling/shardingsphere-scaling-postgresql/src/test/java/org/apache/shardingsphere/scaling/postgresql/{ => component}/PostgreSQLJdbcDumperTest.java (98%)
 rename shardingsphere-scaling/shardingsphere-scaling-postgresql/src/test/java/org/apache/shardingsphere/scaling/postgresql/{ => component}/PostgreSQLPositionManagerTest.java (98%)
 rename shardingsphere-scaling/shardingsphere-scaling-postgresql/src/test/java/org/apache/shardingsphere/scaling/postgresql/{ => component}/PostgreSQLSqlBuilderTest.java (96%)
 rename shardingsphere-scaling/shardingsphere-scaling-postgresql/src/test/java/org/apache/shardingsphere/scaling/postgresql/{ => component}/PostgreSQLWalDumperTest.java (94%)
 delete mode 100644 shardingsphere-scaling/shardingsphere-scaling-postgresql/src/test/java/org/apache/shardingsphere/scaling/postgresql/utils/ReflectionUtil.java