This is an automated email from the ASF dual-hosted git repository.
wuweijie pushed a change to branch 5.1.2-release
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
from c81f614a1ce Update example to 5.1.3-SNAPSHOT
add 50009e56804 Support parsing CREATE RESTORE POINT in Oracle (#18217)
add eb649c6d4e9 Remove unreachable branch in DatabaseBackendHandlerFactory
(#18218)
add 0781787897e Support cursor statement when call proxy through raw jdbc
(#18220)
add 6d1cebcde81 Avoid EventLoop blocked by closing JDBC resources (#18221)
add 3910510b51b Update release verification about Helm Chart (#18227)
add a73c3a6c1de Reduce overhead of stream operations in SPI (#18222)
add 3e51f2354d6 Move ContextManager.transactionContexts into
TransactionRule (#18077)
add 02d1eb6ffb9 Refactor ShardingSphereOptimizer (#18229)
add 28cc0bcd8b0 support parsing CREATE AGGREGATE in openGauss (#18225)
add 72b683cc3d4 Fix ci (#18232)
add 12d610ec9d5 Revert "Rename actualTablePrefix to replaceTablePrefix and
support logic table replace prefix (#18117)" (#18233)
add 1d2e0924eea Update JDBC Driver doc (#18236)
add 413b97c2b05 Refactor storage node and adjustment QualifiedSchema to
QualifiedDatabase (#18193)
add 5c9043ecd72 Handle the case where the value of the insert primary key
field is null (#18224)
add f02d43c2adb Change Chinese characters to English (#18239)
add 10b3f247b46 Update documents about command arguments of release
procedure (#18242)
add 237463c227e Update English document about command arguments of release
procedure (#18243)
add aac0d3026e0 Fix NoSuchElementException when execute preview cursor
statement (#18241)
add 8c2d591dc8d Refactor ShardingSphereOptimizer (#18246)
add ca981b219f0 Refactor CustomizedFilterableExecutor (#18247)
add 4352301b504 add AssistEncryptorName (#18166)
add c8afc55be50 Rename OriginalFilterableExecutor and
AdvancedFederationExecutor (#18249)
add 8758e3fd651 Add LockStateContext for distributed lock (#18245)
add ccd678fe988 make assistEncryptorName work and effect (#18173)
add 4f40688acac refactor convertToSQLStatement method, make it more easy
to understand (#18238)
add 85b42457b51 refactor to remove QueryAssistedEncryptAlgorithm (#18174)
add dec5581af37 Refine federation.executor package structure (#18251)
add 4e261889a88 Rename PreviewBackendHandler (#18252)
add b3e340b61ed Fix typo in MySQLServerInfo (#18253)
add c9f7da256d3 Add getter for RALBackendHandler.sqlStatement (#18255)
add 1c7733837d7 Add remainingRowCount for fetch statement to reduce result
set hold in memory (#18254)
add 2179bfbac2d parse assistedQueryEncryptor for encrypt distsql (#18256)
add 60b5ce0ddd3 Remove RALBackendHandler.initStatement() (#18258)
add 5dc4e54ed2f [Issue#17551] add SQLVisitorFacadeFactory test (#18248)
add d3e611a7d10 adjust time out value of
assertAsyncDestroyHikariDataSource method (#18257)
add 076269fd4be support assistEncryptor for EncryptDistSQLStatement
(#18179)
add bb03a529357 Remove HandlerParameter.databaseType (#18262)
add 85d69e80aaa Constraint token test (#17284)
add 39363f112a8 Refactor ConstraintTokenTest (#18263)
add a8d3ecb0e90 refactor instance id generator (#18265)
add 7b121cc3887 Fix CI ParseDistSQLBackendHandlerTest ERROR (#18264)
add 8307b4f0065 Revise ParseDistSQLBackendHandlerTest (#18266)
add c7c605db90f Refactor RALBackendHandlerFactory (#18268)
add adb90bdda37 Refactor dataSource disable logic and add license. (#18267)
add fcba4727d1a Rename variable name (#18270)
add a13924cf440 Optimize the configuration check on EncryptRule (#18184)
add 865da4240b4 Refactor RALBackendHandler.init() (#18273)
add a7c853405d2 Support parsing `DROP RESTORE POINT` in Oracle (#18231)
add ee8fad904b1 Rename SchemaVersionChangedEvent to
DatabaseVersionChangedEvent and adjust import format problem. (#18274)
add 2c4231b7bc4 Add rewrite logic for fetch statement to reduce memory
occupy (#18275)
add 764e1037e87 Refactor RALBackendHandler.init() (#18276)
add 6499e982673 Add PostgreSQL Copy Statement (#18272)
add 9c7c8f83541 Remove RALBackendHandler.HandlerParameter (#18278)
add 1a7104886f5 fix InstanceContext is built repeatedly for memory mode
(#18284)
add b11676fc415 Refactor UpdatableRALBackendHandler (#18289)
add 1c869c0e638 Update queryAssistedEncryptAlgorithm related doc (#18287)
add 5ae40c53c5a update encrypt related doc (#18290)
add c3fea749a24 add CosId keygen documentation (#18286)
add 089eaff5544 Refactor FormatHandler
add 83d4a7ca451 Rename FormatSQLHandler
add 90da0323a17 Merge pull request #18291 from terrymanu/dev
add 42a23c94044 Rename PreviewHandler
add 64827b00df5 Rename ParseDistSQLHandler
add 7ab38fd7542 Merge pull request #18293 from terrymanu/dev
add f0ffe3188f3 Refactor RALBackendHandlerFactory
add f7107f0aece Refactor RALBackendHandlerFactory
add 4843f62e02f Merge pull request #18294 from terrymanu/dev
add 750cfde85dc Refactor ParseDistSQLHandler (#18296)
add 202371b7cc0 [Issue#18169] add unit test for DatabaseTypeEngine (#18250)
add dfda0fd75f3 Remove useless assertion (#18298)
add eeb42f74fde refactor: modify sharding-sphere optimizer and unit tests.
(#18297)
add e70e8c993b0 Merge SingleLocalDataMergedResult and
MultipleLocalDataMergedResult to LocalDataMergedResult (#18299)
add bc232a908db Improve scaling it (#18288)
add ca544e238fe Add unit test for JdbcQueryPropertiesExtension (#18167)
add da701d9ce1c Revise 18167 JdbcQueryPropertiesExtension unit test
(#18300)
add be2c42b13a8 Move LocalDataMergedResult to infra module (#18302)
add f2a4a68e030 Add LocalDataQueryResultRow (#18303)
add b781cde538a Refactor CountInstanceRulesHandler (#18305)
add 58aafedf8aa Correct AuthorityProviderAlgorithm in document. (#18304)
add 358320d19f9 Remove useless log message (#18306)
add 1e90215376d update powered by (#18307)
add 7a5350f51f6 Use RuleExportEngine to decouple default impl for
ExportableRule (#18308)
add 855e717668f Refactor ExportableRule (#18309)
add 7e7f396f35a Refactor ExportableRule (#18310)
add fa3abbbb893 Move xxx-distsql-parser declaration from xxx-core to
xxx-distsql-handler (#18311)
add 248f718f552 Rename BindingTableCheckedConfiguration (#18312)
add 4cfa8a40986 Remove useless DatabaseDiscoveryRuleExportableFixture
(#18313)
add 3bc92ee9d0d Remove useless DatabaseDiscoveryRuleExportableFixture
(#18314)
add 98d93375c86 Remove useless ReadwriteSplittingRuleExportableFixture
(#18318)
add a4f2d12b8c7 Remove spring.shardingsphere.enable configuration (#18316)
add 16ff508eeef Use DatabaseDiscoveryRule in
DatabaseDiscoveryRuleQueryResultSet (#18321)
add 5f284510d45 Rename SchemaRule and related to DatabaseRule (#18325)
add bc458ef1973 Support parsing `ALTER OPERATOR` in PostgreSQL (#18322)
add 644409af23d Support parsing DROP OPERATOR in Oracle (#18324)
add d75eea1d9e9 Refactor DatabaseRulesCountResultSet (#18329)
add 40e6525d516 Refactor ReadwriteSplittingRuleQueryResultSet (#18332)
add 3f79e257db6 support traffic for execute batch (#18334)
add b2692b8389c Build special rules after global rule configuration
changed (#18333)
add f5ee13d7b20 Refactor SingleTableRule.assignNewDataSourceName() (#18342)
add 952c1feacb2 Update shasum arguments in Release documents (#18344)
add 2bccdef4f33 Support column segments parse in create index on table
statement (#18343)
add 97e574a702f Remove databaseType input param from SingleTableRule's
constructor (#18345)
add 9534fa51674 Refact the handler of autocommit (#18335)
add 3dc38c92d98 Rename SingleTableSchemaMetaDataDecoratorTest (#18347)
add fd7c4bd888f add unit test assertLoadReplicaStatus (#18346)
add 11f064c5281 Refactor
MySQLNormalReplicationDatabaseDiscoveryProviderAlgorithmTest (#18348)
add df1cad9c24f Added unit test case for projection engine (#18223)
add 6b9927c1af5 Revise #18223 (#18349)
add 618b57814dc WeightReplicaLoadBalanceAlgorithm can not be used by
multiple load balance rules (#17395)
add 7fec53c915a Revert typo for .codecov.yml (#18350)
add 3c072d5c2a4 fix #16831 (#16907)
add aefef189fc8 Update data structure in registry center (#18356)
add 7ef928755d9 Move unchanged SQLStatement into MySQLPreparedStatement
(#18357)
add 954bebf8dc0 update article for performance test (#18353)
add a4e99e5bf48 Update encrypt.cn.md
add a12ffc34546 Update encrypt.en.md
add b9ce6f0a9c6 Correct typos in encrypt
add a72e919961a Merge pull request #18339 from Jacob953/dev
add 39acbd90293 Support create index on table(column) statement rewrite
when config encrypt (#18366)
add 33bd777f70e Refactor CuratorCache build logic (#18363)
add 0dd125938e5 refresh special rules after database metadata version
changed (#18373)
add 5948a30eb3b Optimize stop writing error message for PostgreSQL (#18376)
add d4d05e7afc7 Add assert of stop writing in scaling integration test
(#18377)
add 69cf18ee351 Add getConfiguration method in ShardingSphereRule
interface (#18379)
add 0e2bc029e14 support parsing ALTER POLICY in PostgreSQL (#18371)
add 2a5acca0c13 Remove useless RenameTableLister (#18386)
add 687ab04cef0 Move logic of COM_STMT from packet to executor (#18384)
add f0b8224c8f2 Improve scaling increment task mysql binlog decoding
(#18375)
add 82a4ac0fbf8 Fix begin for postgresql & opengauss (#18359)
add bee3dd221d0 Refactor MetaDataRefreshEngineTest (#18390)
add a1a8373caec Refactor MetaDataRefreshEngine (#18391)
add a20d3ff64ce Delay is Long.MAX_VALUE if show slave status result is
null or second_behind_master is null (#18362)
add 05b6b042a4e Support create table with index statement rewrite when
config encrypt (#18388)
add cd3e0b20e9d Refactor ShowTrafficRulesStatement (#18392)
add a8998340ae9 Remove `SubjectSupplier` & `OperationSupplier` (#18383)
add add6295e079 Simplify MySQLComStmtPrepareExecutor (#18396)
add 1eb3d2deeb7 feat:fix optimize left menu usage (#18393)
add 09a50a0c7c6 Run scaling IT test for different DBs one by one (#18387)
add 010edeea525 Add logger filter to reduce scaling IT useless logs
(#18395)
add eda878dd63c Add PostgreSQL Create Access Method Statement (#18397)
add 93ec14e509d Refactor lock judge engine by SPI (#18394)
add 5fffa5558e3 Refactor MetaDataRefreshEngineTest (#18399)
add 94b783c03fe Refactor SetReadwriteSplittingStatusHandler (#18403)
add bca3ea126fb Remove the check method in ShardingRule. (#18398)
add 66a71db1e77 Merge branch 'master' into 5.1.2-release
No new revisions were added by this update.
Summary of changes:
.github/workflows/it-scaling.yml | 14 +-
docs/community/content/contribute/release.cn.md | 9 +-
docs/community/content/contribute/release.en.md | 9 +-
docs/community/content/powered-by/_index.cn.md | 4 +-
docs/community/content/powered-by/_index.en.md | 4 +-
docs/community/static/css/theme-white.css | 21 +
.../hugo-theme-learn/layouts/partials/menu.html | 3 +-
.../themes/hugo-theme-learn/static/js/learn.js | 8 +-
docs/document/content/dev-manual/encryption.cn.md | 10 -
docs/document/content/dev-manual/encryption.en.md | 10 -
docs/document/content/dev-manual/proxy.cn.md | 2 +-
docs/document/content/dev-manual/proxy.en.md | 2 +-
.../content/dev-manual/readwrite-splitting.en.md | 4 +-
.../content/reference/encrypt/_index.cn.md | 56 +-
.../content/reference/encrypt/_index.en.md | 87 +-
.../content/reference/management/_index.cn.md | 30 +-
.../content/reference/management/_index.en.md | 34 +-
...n.md => benchmarksql-proxy-sharding-test.cn.md} | 6 +-
.../test/performance-test/performance-test.cn.md | 431 ------
.../test/performance-test/performance-test.en.md | 434 ------
.../sysbench-proxy-norules-test.cn.md | 141 ++
.../test/performance-test/sysbench-test.en.md | 1483 --------------------
.../builtin-algorithm/keygen.cn.md | 23 +
.../builtin-algorithm/keygen.en.md | 23 +
.../java-api/rules/encrypt.cn.md | 18 +-
.../java-api/rules/encrypt.en.md | 4 +-
.../shardingsphere-jdbc/jdbc-driver/_index.cn.md | 2 +-
.../shardingsphere-jdbc/jdbc-driver/_index.en.md | 2 +-
.../distsql/syntax/ral/_index.cn.md | 74 +-
.../distsql/syntax/ral/_index.en.md | 62 +-
.../syntax/rql/rule-query/db-discovery.cn.md | 10 +-
.../syntax/rql/rule-query/db-discovery.en.md | 2 +-
.../distsql/syntax/rql/rule-query/encrypt.cn.md | 4 +-
.../distsql/syntax/rql/rule-query/encrypt.en.md | 28 +-
.../distsql/syntax/rql/rule-query/shadow.cn.md | 26 +-
.../distsql/syntax/rql/rule-query/shadow.en.md | 8 +-
docs/document/static/css/theme-white.css | 22 +-
.../hugo-theme-learn/layouts/partials/menu.html | 4 +-
.../themes/hugo-theme-learn/static/js/learn.js | 8 +-
.../TestQueryAssistedShardingEncryptAlgorithm.java | 11 +-
.../generator/core/ExampleGeneratorFactory.java | 2 +-
.../TestQueryAssistedShardingEncryptAlgorithm.ftl | 11 +-
.../collector/ProxyInfoCollectorTest.java | 3 +-
.../service/PrometheusPluginBootServiceTest.java | 3 +-
.../protocol/mysql/constant/MySQLServerInfo.java | 5 +-
.../binlog/AbstractMySQLBinlogEventPacket.java | 11 +
.../packet/binlog/MySQLBinlogEventHeader.java | 8 +-
.../management/MySQLBinlogRotateEventPacket.java | 2 +-
.../binlog/row/MySQLBinlogRowsEventPacket.java | 6 +-
.../binlog/row/MySQLBinlogTableMapEventPacket.java | 5 +-
.../query/binary/MySQLPreparedStatement.java | 6 +-
.../binary/MySQLPreparedStatementRegistry.java | 7 +-
.../binary/execute/MySQLComStmtExecutePacket.java | 66 +-
.../packet/binlog/MySQLBinlogEventHeaderTest.java | 4 +-
.../MySQLBinlogRotateEventPacketTest.java | 5 +-
.../binlog/row/MySQLBinlogRowsEventPacketTest.java | 105 +-
.../binary/MySQLPreparedStatementRegistryTest.java | 21 +-
.../execute/MySQLComStmtExecutePacketTest.java | 79 +-
.../postgresql/constant/PostgreSQLErrorCode.java | 1 +
.../core/common/CommonDistSQLStatementVisitor.java | 6 +-
.../parser/operation/DistSQLOperationTypeEnum.java | 42 -
.../operation/impl/AlterOperationSupplier.java | 32 -
.../operation/impl/RALOperationSupplier.java | 32 -
.../operation/impl/ShowOperationSupplier.java | 32 -
.../distsql/parser/statement/DistSQLStatement.java | 11 +-
.../parser/statement/DistSQLStatementType.java | 83 --
.../distsql/parser/statement/ral/RALStatement.java | 21 +-
.../queryable/CountInstanceRulesStatement.java | 4 +-
.../queryable/ShowTrafficRulesStatement.java | 8 +-
.../distsql/parser/statement/rdl/RDLStatement.java | 6 -
.../statement/rdl/ResourceDefinitionStatement.java | 10 +-
.../AlterDefaultSingleTableRuleStatement.java | 3 +-
.../rdl/alter/AlterResourceStatement.java | 4 +-
.../statement/rdl/alter/AlterRuleStatement.java | 6 -
.../statement/rdl/create/AddResourceStatement.java | 9 +-
.../CreateDefaultSingleTableRuleStatement.java | 3 +-
.../statement/rdl/create/CreateRuleStatement.java | 4 +-
.../drop/DropDefaultSingleTableRuleStatement.java | 3 +-
.../statement/rdl/drop/DropResourceStatement.java | 6 -
.../statement/rdl/drop/DropRuleStatement.java | 6 -
.../distsql/parser/statement/rql/RQLStatement.java | 12 -
.../rql/show/CountDatabaseRulesStatement.java | 6 -
.../statement/rql/show/ShowResourcesStatement.java | 3 +-
.../rql/show/ShowRulesUsedResourceStatement.java | 5 +-
.../rql/show/ShowSingleTableRulesStatement.java | 3 +-
.../rql/show/ShowSingleTableStatement.java | 3 +-
.../rql/show/ShowUnusedResourcesStatement.java | 3 +-
.../parser/subject/DistSQLSubjectTypeEnum.java | 45 -
.../impl/DatabaseDiscoverySubjectSupplier.java | 32 -
.../subject/impl/EncryptSubjectSupplier.java | 32 -
.../impl/ReadwriteSplittingSubjectSupplier.java | 32 -
.../subject/impl/ResourceSubjectSupplier.java | 32 -
.../subject/impl/ScalingSubjectSupplier.java | 32 -
.../parser/subject/impl/ShadowSubjectSupplier.java | 32 -
.../subject/impl/ShardingSubjectSupplier.java | 32 -
.../subject/impl/SingleTableSubjectSupplier.java | 32 -
.../config/DatabaseDiscoveryRuleConfiguration.java | 4 +-
.../shardingsphere-db-discovery-core/pom.xml | 10 -
...ProvidedDatabaseDiscoveryRuleConfiguration.java | 4 +-
.../dbdiscovery/rule/DatabaseDiscoveryRule.java | 59 +-
...orithmProvidedDatabaseDiscoveryRuleBuilder.java | 4 +-
.../rule/builder/DatabaseDiscoveryRuleBuilder.java | 4 +-
....infra.rule.builder.schema.DatabaseRuleBuilder} | 0
.../route/DatabaseDiscoverySQLRouterTest.java | 10 +-
.../rule/DatabaseDiscoveryRuleTest.java | 2 +-
...hmProvidedDatabaseDiscoveryRuleBuilderTest.java | 6 +-
.../builder/DatabaseDiscoveryRuleBuilderTest.java | 6 +-
.../pom.xml | 7 +-
.../DatabaseDiscoveryHeartbeatQueryResultSet.java | 11 +-
.../query/DatabaseDiscoveryRuleQueryResultSet.java | 31 +-
.../query/DatabaseDiscoveryTypeQueryResultSet.java | 10 +-
.../DropDatabaseDiscoveryRuleStatementUpdater.java | 13 +-
.../DatabaseDiscoveryRuleExportableFixture.java | 42 -
.../ReadwriteSplittingRuleExportableFixture.java | 59 -
...tabaseDiscoveryHeartbeatQueryResultSetTest.java | 7 +-
...scoveryProviderAlgorithmQueryResultSetTest.java | 7 +-
.../DatabaseDiscoveryRuleQueryResultSetTest.java | 43 +-
...pDatabaseDiscoveryRuleStatementUpdaterTest.java | 35 +-
.../AlterDatabaseDiscoveryHeartbeatStatement.java | 3 +-
.../AlterDatabaseDiscoveryRuleStatement.java | 3 +-
.../AlterDatabaseDiscoveryTypeStatement.java | 3 +-
.../CreateDatabaseDiscoveryHeartbeatStatement.java | 3 +-
.../CreateDatabaseDiscoveryRuleStatement.java | 3 +-
.../CreateDatabaseDiscoveryTypeStatement.java | 3 +-
.../DropDatabaseDiscoveryHeartbeatStatement.java | 3 +-
.../DropDatabaseDiscoveryRuleStatement.java | 3 +-
.../DropDatabaseDiscoveryTypeStatement.java | 3 +-
.../ShowDatabaseDiscoveryHeartbeatsStatement.java | 3 +-
.../ShowDatabaseDiscoveryRulesStatement.java | 3 +-
.../ShowDatabaseDiscoveryTypesStatement.java | 3 +-
.../shardingsphere-db-discovery-mysql/pom.xml | 7 +
...licationDatabaseDiscoveryProviderAlgorithm.java | 6 +-
...tionDatabaseDiscoveryProviderAlgorithmTest.java | 42 +-
.../api/config/EncryptRuleConfiguration.java | 4 +-
.../rule/EncryptColumnRuleConfiguration.java | 7 +
.../shardingsphere-encrypt-core/pom.xml | 10 -
.../AlgorithmProvidedEncryptRuleConfiguration.java | 4 +-
...OnDuplicateKeyUpdateValueParameterRewriter.java | 6 +-
.../EncryptInsertValueParameterRewriter.java | 14 +-
.../rewrite/token/EncryptTokenGenerateBuilder.java | 4 +-
.../EncryptIndexColumnTokenGenerator.java | 97 ++
.../EncryptInsertValuesTokenGenerator.java | 9 +-
.../shardingsphere/encrypt/rule/EncryptColumn.java | 6 +
.../shardingsphere/encrypt/rule/EncryptRule.java | 91 +-
.../shardingsphere/encrypt/rule/EncryptTable.java | 12 +-
.../AlgorithmProvidedEncryptRuleBuilder.java | 4 +-
.../encrypt/rule/builder/EncryptRuleBuilder.java | 4 +-
.../rule/YamlEncryptColumnRuleConfiguration.java | 2 +
.../EncryptColumnRuleConfigurationYamlSwapper.java | 2 +-
....infra.rule.builder.schema.DatabaseRuleBuilder} | 0
.../CoreQueryAssistedEncryptAlgorithmFixture.java | 11 +-
.../encrypt/rule/EncryptRuleTest.java | 10 +-
.../AlgorithmProvidedEncryptRuleBuilderTest.java | 6 +-
.../rule/builder/EncryptRuleBuilderTest.java | 6 +-
.../shardingsphere-encrypt-distsql-handler/pom.xml | 7 +-
.../converter/EncryptRuleStatementConverter.java | 19 +-
.../handler/query/EncryptRuleQueryResultSet.java | 7 +-
.../EncryptRuleStatementConverterTest.java | 3 +-
.../query/EncryptRuleQueryResultSetTest.java | 14 +-
.../AlterEncryptRuleStatementUpdaterTest.java | 6 +-
.../CreateEncryptRuleStatementUpdaterTest.java | 6 +-
.../main/antlr4/imports/encrypt/RDLStatement.g4 | 2 +-
.../core/EncryptDistSQLStatementVisitor.java | 8 +-
.../parser/segment/EncryptColumnSegment.java | 11 +
.../statement/AlterEncryptRuleStatement.java | 11 +-
.../statement/CreateEncryptRuleStatement.java | 11 +-
.../parser/statement/DropEncryptRuleStatement.java | 8 +-
.../statement/ShowEncryptRulesStatement.java | 11 +-
.../parser/EncryptRuleBeanDefinitionParser.java | 1 +
.../tag/EncryptRuleBeanDefinitionTag.java | 2 +
.../main/resources/META-INF/namespace/encrypt.xsd | 1 +
.../api/ReadwriteSplittingRuleConfiguration.java | 4 +-
.../pom.xml | 10 -
...rovidedReadwriteSplittingRuleConfiguration.java | 4 +-
.../WeightReplicaLoadBalanceAlgorithm.java | 6 +-
.../rule/ReadwriteSplittingRule.java | 32 +-
...rithmProvidedReadwriteSplittingRuleBuilder.java | 4 +-
.../builder/ReadwriteSplittingRuleBuilder.java | 4 +-
....infra.rule.builder.schema.DatabaseRuleBuilder} | 0
.../WeightReplicaLoadBalanceAlgorithmTest.java | 13 -
.../route/ReadwriteSplittingSQLRouterTest.java | 18 +-
.../rule/ReadwriteSplittingRuleTest.java | 17 +-
...mProvidedReadwriteSplittingRuleBuilderTest.java | 6 +-
.../builder/ReadwriteSplittingRuleBuilderTest.java | 6 +-
.../pom.xml | 7 +-
.../ReadwriteSplittingRuleQueryResultSet.java | 32 +-
...lterReadwriteSplittingRuleStatementUpdater.java | 7 +-
...eateReadwriteSplittingRuleStatementUpdater.java | 7 +-
.../DatabaseDiscoveryRuleExportableFixture.java | 42 -
.../ReadwriteSplittingRuleExportableFixture.java | 66 -
.../ReadwriteSplittingRuleQueryResultSetTest.java | 70 +-
...ReadwriteSplittingRuleStatementUpdaterTest.java | 9 +-
...ReadwriteSplittingRuleStatementUpdaterTest.java | 12 +-
.../AlterReadwriteSplittingRuleStatement.java | 3 +-
.../CreateReadwriteSplittingRuleStatement.java | 3 +-
.../DropReadwriteSplittingRuleStatement.java | 3 +-
...owReadwriteSplittingReadResourcesStatement.java | 3 +-
.../ShowReadwriteSplittingRulesStatement.java | 3 +-
.../hint/ClearReadwriteSplittingHintStatement.java | 3 +-
.../hint/SetReadwriteSplittingHintStatement.java | 3 +-
.../ShowReadwriteSplittingHintStatusStatement.java | 3 +-
.../SetReadwriteSplittingStatusStatement.java | 3 +-
.../shadow/api/config/ShadowRuleConfiguration.java | 4 +-
.../shardingsphere-shadow-core/pom.xml | 10 -
.../AlgorithmProvidedShadowRuleConfiguration.java | 4 +-
.../shardingsphere/shadow/rule/ShadowRule.java | 29 +-
.../AlgorithmProvidedShadowRuleBuilder.java | 4 +-
.../shadow/rule/builder/ShadowRuleBuilder.java | 4 +-
....infra.rule.builder.schema.DatabaseRuleBuilder} | 0
.../shadow/rule/builder/ShadowRuleBuilderTest.java | 6 +-
.../shardingsphere-shadow-distsql-handler/pom.xml | 5 +
.../checker/ShadowRuleStatementChecker.java | 4 +-
.../update/AlterShadowRuleStatementUpdater.java | 4 +-
...DropDefaultShadowAlgorithmStatementUpdater.java | 4 +-
.../DropShadowAlgorithmStatementUpdater.java | 4 +-
.../statement/AlterShadowAlgorithmStatement.java | 3 +-
.../parser/statement/AlterShadowRuleStatement.java | 3 +-
.../CreateDefaultShadowAlgorithmStatement.java | 3 +-
.../statement/CreateShadowAlgorithmStatement.java | 3 +-
.../statement/CreateShadowRuleStatement.java | 3 +-
.../DropDefaultShadowAlgorithmStatement.java | 3 +-
.../statement/DropShadowAlgorithmStatement.java | 3 +-
.../parser/statement/DropShadowRuleStatement.java | 3 +-
.../statement/ShowShadowAlgorithmsStatement.java | 3 +-
.../parser/statement/ShowShadowRulesStatement.java | 3 +-
.../statement/ShowShadowTableRulesStatement.java | 3 +-
.../api/config/ShardingRuleConfiguration.java | 4 +-
.../rule/ShardingAutoTableRuleConfiguration.java | 2 +-
.../rule/ShardingTableRuleConfiguration.java | 2 +-
.../shardingsphere-sharding-core/pom.xml | 10 -
...AlgorithmProvidedShardingRuleConfiguration.java | 4 +-
.../merge/dal/ShardingDALResultMerger.java | 5 +-
.../dal/common/SingleLocalDataMergedResult.java | 70 -
.../merge/ddl/fetch/FetchOrderByValueGroup.java | 17 +-
...der.java => FetchOrderByValueGroupsHolder.java} | 33 +-
.../merge/ddl/fetch/FetchStreamMergedResult.java | 101 +-
.../impl/FetchDirectionTokenGenerator.java | 54 +
.../rewrite/token/pojo/FetchDirectionToken.java | 65 +
.../token/pojo/ShardingTokenGenerateBuilder.java | 2 +
.../rule/BindingTableCheckedConfiguration.java} | 12 +-
.../shardingsphere/sharding/rule/ShardingRule.java | 147 +-
.../shardingsphere/sharding/rule/TableRule.java | 36 +-
.../AlgorithmProvidedShardingRuleBuilder.java | 4 +-
.../sharding/rule/builder/ShardingRuleBuilder.java | 4 +-
.../YamlShardingAutoTableRuleConfiguration.java | 2 +-
.../config/rule/YamlTableRuleConfiguration.java | 2 +-
...rdingAutoTableRuleConfigurationYamlSwapper.java | 4 +-
.../ShardingTableRuleConfigurationYamlSwapper.java | 4 +-
....infra.rule.builder.schema.DatabaseRuleBuilder} | 0
.../merge/dal/ShardingDALResultMergerTest.java | 4 +-
.../common/SingleLocalDataMergedResultTest.java | 68 -
.../fetch/FetchOrderByValueQueuesHolderTest.java | 20 +-
.../ddl/fetch/FetchStreamMergedResultTest.java | 1 +
.../rewrite/token/pojo/ConstraintTokenTest.java | 46 +
.../engine/fixture/AbstractRoutingEngineTest.java | 42 +-
.../engine/type/standard/AbstractSQLRouteTest.java | 6 +-
.../engine/type/standard/SubqueryRouteTest.java | 12 +-
.../sharding/rule/TableRuleTest.java | 4 +-
.../AlgorithmProvidedShardingRuleBuilderTest.java | 8 +-
.../rule/builder/ShardingRuleBuilderTest.java | 8 +-
...gAutoTableRuleConfigurationYamlSwapperTest.java | 4 +-
.../pom.xml | 7 +-
.../checker/ShardingTableRuleStatementChecker.java | 187 ++-
.../DefaultShardingStrategyQueryResultSet.java | 8 +-
.../query/ShardingKeyGeneratorsQueryResultSet.java | 4 +-
...rdingTableRulesUsedAlgorithmQueryResultSet.java | 21 +-
...ngTableRulesUsedKeyGeneratorQueryResultSet.java | 13 +-
.../AlterShardingTableRuleStatementUpdater.java | 1 -
...gDefaultShardingStrategyQueryResultSetTest.java | 12 +-
.../ShardingKeyGeneratorsQueryResultSetTest.java | 12 +-
...gTableRulesUsedAlgorithmQueryResultSetTest.java | 6 +-
...bleRulesUsedKeyGeneratorQueryResultSetTest.java | 6 +-
...erShardingKeyGeneratorStatementUpdaterTest.java | 4 +-
...teShardingKeyGeneratorStatementUpdaterTest.java | 17 +-
...reateShardingTableRuleStatementUpdaterTest.java | 7 +
.../distsql/statement/ApplyScalingStatement.java | 3 +-
.../distsql/statement/CheckScalingStatement.java | 3 +-
.../CreateShardingScalingRuleStatement.java | 3 +-
.../DisableShardingScalingRuleStatement.java | 3 +-
.../distsql/statement/DropScalingStatement.java | 3 +-
.../DropShardingScalingRuleStatement.java | 3 +-
.../EnableShardingScalingRuleStatement.java | 3 +-
.../distsql/statement/ResetScalingStatement.java | 3 +-
.../RestoreScalingSourceWritingStatement.java | 3 +-
.../ShowScalingCheckAlgorithmsStatement.java | 3 +-
.../statement/ShowScalingListStatement.java | 3 +-
.../statement/ShowScalingStatusStatement.java | 3 +-
.../ShowShardingScalingRulesStatement.java | 3 +-
.../distsql/statement/StartScalingStatement.java | 3 +-
.../StopScalingSourceWritingStatement.java | 3 +-
.../distsql/statement/StopScalingStatement.java | 3 +-
.../AlterDefaultShardingStrategyStatement.java | 3 +-
.../statement/AlterShardingAlgorithmStatement.java | 3 +-
.../AlterShardingBindingTableRulesStatement.java | 8 +-
.../AlterShardingBroadcastTableRulesStatement.java | 8 +-
.../AlterShardingKeyGeneratorStatement.java | 3 +-
.../statement/AlterShardingTableRuleStatement.java | 9 +-
.../CreateDefaultShardingStrategyStatement.java | 3 +-
.../CreateShardingAlgorithmStatement.java | 3 +-
.../CreateShardingBindingTableRulesStatement.java | 8 +-
...CreateShardingBroadcastTableRulesStatement.java | 3 +-
.../CreateShardingKeyGeneratorStatement.java | 3 +-
.../CreateShardingTableRuleStatement.java | 9 +-
.../DropDefaultShardingStrategyStatement.java | 3 +-
.../statement/DropShardingAlgorithmStatement.java | 3 +-
.../DropShardingBindingTableRulesStatement.java | 3 +-
.../DropShardingBroadcastTableRulesStatement.java | 8 +-
.../DropShardingKeyGeneratorStatement.java | 3 +-
.../statement/DropShardingTableRuleStatement.java | 3 +-
.../ShowDefaultShardingStrategyStatement.java | 3 +-
.../statement/ShowShardingAlgorithmsStatement.java | 3 +-
.../ShowShardingBindingTableRulesStatement.java | 3 +-
.../ShowShardingBroadcastTableRulesStatement.java | 3 +-
.../ShowShardingKeyGeneratorsStatement.java | 3 +-
.../statement/ShowShardingTableNodesStatement.java | 11 +-
.../statement/ShowShardingTableRulesStatement.java | 11 +-
...owShardingTableRulesUsedAlgorithmStatement.java | 3 +-
...hardingTableRulesUsedKeyGeneratorStatement.java | 3 +-
.../ShowUnusedShardingAlgorithmsStatement.java | 3 +-
.../ShowUnusedShardingKeyGeneratorsStatement.java | 3 +-
.../keygen/engine/GeneratedKeyContextEngine.java | 4 +-
.../statement/ddl/AlterIndexStatementContext.java | 6 +
.../statement/ddl/AlterTableStatementContext.java | 13 +-
.../statement/ddl/CreateIndexStatementContext.java | 6 +
.../statement/ddl/CreateTableStatementContext.java | 10 +
.../statement/ddl/DropIndexStatementContext.java | 6 +
.../infra/binder/type/IndexAvailable.java | 8 +
.../projection/engine/ProjectionEngineTest.java | 24 +
...uration.java => DatabaseRuleConfiguration.java} | 4 +-
.../instance/definition/InstanceDefinition.java | 29 +-
.../instanceid/DefaultInstanceIdGenerator.java} | 21 +-
.../instance/instanceid/InstanceIdGenerator.java | 29 +-
.../infra/metadata/ShardingSphereMetaData.java | 2 +-
.../metadata/database/ShardingSphereDatabase.java | 2 +-
.../database/rule/ShardingSphereRuleMetaData.java | 28 +-
.../infra/rule/ShardingSphereRule.java | 9 +
...maRuleBuilder.java => DatabaseRuleBuilder.java} | 12 +-
...actory.java => DatabaseRuleBuilderFactory.java} | 24 +-
.../rule/builder/schema/DatabaseRulesBuilder.java | 29 +-
...> DefaultDatabaseRuleConfigurationBuilder.java} | 10 +-
...ltDatabaseRuleConfigurationBuilderFactory.java} | 14 +-
.../scope/{SchemaRule.java => DatabaseRule.java} | 4 +-
.../{CheckableRule.java => ResourceHeldRule.java} | 37 +-
.../type/exportable/ExportableRule.java} | 18 +-
.../RuleExportEngine.java} | 35 +-
....infra.instance.instanceid.InstanceIdGenerator} | 2 +-
.../database/type/DatabaseTypeEngineTest.java | 30 +
.../destroyer/DataSourcePoolDestroyerTest.java | 2 +-
.../infra/fixture/TestShardingSphereRule.java | 16 +-
.../fixture/TestShardingSphereRuleBuilder.java | 12 +-
.../infra/instance/InstanceContextTest.java | 6 +-
.../database/ShardingSphereDatabaseTest.java | 7 +-
.../ShardingSphereRuleConfigurationFixture.java | 23 -
.../database/rule/ShardingSphereRuleFixture.java | 8 +
.../rule/ShardingSphereRuleMetaDataTest.java | 13 +-
.../schema/fixture/rule/CommonFixtureRule.java | 8 +
.../fixture/rule/DataNodeContainedFixtureRule.java | 8 +
...ureSchemaRule.java => FixtureDatabaseRule.java} | 14 +-
...uilder.java => FixtureDatabaseRuleBuilder.java} | 14 +-
....java => FixtureDatabaseRuleConfiguration.java} | 4 +-
...> FixtureDatabaseRuleConfigurationBuilder.java} | 12 +-
.../rule/builder/fixture/FixtureGlobalRule.java | 8 +
...st.java => DatabaseRuleBuilderFactoryTest.java} | 20 +-
.../builder/schema/DatabaseRulesBuilderTest.java | 4 +-
...tabaseRuleConfigurationBuilderFactoryTest.java} | 12 +-
....infra.rule.builder.schema.DatabaseRuleBuilder} | 2 +-
....schema.DefaultDatabaseRuleConfigurationBuilder | 2 +-
.../context/refresher/MetaDataRefreshEngine.java | 20 +-
.../infra/context/kernel/KernelProcessorTest.java | 4 +-
.../refresher/MetaDataRefreshEngineTest.java | 75 +-
.../refresher/MetaDataRefresherFactoryTest.java | 4 +-
.../fixture/MetaDataRefresherFixture.java | 9 +-
...a => MetaDataRefresherSQLStatementFixture.java} | 7 +-
.../type/DummyDropDatabaseMetaDataRefresher.java | 50 -
.../RenameTableStatementSchemaRefresherTest.java | 21 +-
...phere.infra.context.refresher.MetaDataRefresher | 1 -
.../jdbc/type/memory/JDBCMemoryQueryResult.java | 2 +-
.../query/impl/raw/type/RawMemoryQueryResult.java | 2 +-
.../type/memory/AbstractMemoryQueryResult.java | 14 +-
.../sql/context/ExecutionContextBuilderTest.java | 6 +-
.../type/memory/JDBCMemoryQueryResultTest.java | 10 +
.../infra/executor/sql/fixture/FixtureRule.java | 8 +
.../executor/FederationExecutorFactory.java | 6 +-
.../AdvancedExecuteDataContext.java} | 14 +-
.../AdvancedFederationExecutor.java} | 40 +-
.../AbstractUnsupportedOperationResultSet.java | 2 +-
...bstractUnsupportedUpdateOperationResultSet.java | 4 +-
.../resultset}/FederationResultSet.java | 77 +-
.../resultset}/WrapperAdapter.java | 2 +-
...ecutor.java => OriginalFederationExecutor.java} | 11 +-
.../executor/original/SQLDialectFactory.java | 59 +
.../{ => database}/FilterableDatabase.java | 3 +-
.../original/{ => schema}/FilterableSchema.java | 3 +-
.../{ => table}/FederationTableStatistic.java | 23 +-
.../executor/original/table/FilterableTable.java | 1 -
.../table/FilterableTableScanExecutor.java | 68 +-
.../AdvancedFederationExecutorTest.java} | 10 +-
.../optimizer/ShardingSphereOptimizer.java | 45 +-
.../converter/SQLNodeConverterEngine.java | 6 +-
.../statement/select/SelectStatementConverter.java | 3 +-
.../converter/type/CombineOperatorConverter.java | 18 +
.../planner/QueryOptimizePlannerFactory.java | 6 +-
.../optimizer/ShardingSphereOptimizerTest.java | 92 +-
.../engine/decorator/impl/TransparentRule.java | 7 +
.../result/impl/local/LocalDataMergedResult.java | 17 +-
.../result/impl/local/LocalDataQueryResultRow.java | 33 +-
.../merge/fixture/rule/DecoratorRuleFixture.java | 8 +
.../merge/fixture/rule/IndependentRuleFixture.java | 8 +
.../merge/fixture/rule/MergerRuleFixture.java | 8 +
.../impl/local/LocalDataMergedResultTest.java | 20 +-
.../infra/rewrite/fixture/FixtureRule.java | 8 +
.../infra/route/engine/SQLRouteEngineTest.java | 4 +-
.../fixture/rule/RouteFailureRuleFixture.java | 8 +
.../infra/route/fixture/rule/RouteRuleFixture.java | 8 +
.../driver/executor/DriverJDBCExecutor.java | 5 +-
.../jdbc/core/connection/ConnectionManager.java | 8 +-
.../core/connection/ShardingSphereConnection.java | 6 +-
.../core/datasource/ShardingSphereDataSource.java | 14 +-
.../statement/ShardingSpherePreparedStatement.java | 9 +-
.../driver/executor/AbstractBaseExecutorTest.java | 12 +-
.../JDBCQueryAssistedEncryptAlgorithmFixture.java | 11 +-
.../driver/jdbc/adapter/ConnectionAdapterTest.java | 3 +-
.../core/connection/ConnectionManagerTest.java | 2 +-
.../connection/ShardingSphereConnectionTest.java | 5 +-
.../datasource/ShardingSphereDataSourceTest.java | 26 +-
.../ReadwriteSplittingPreparedStatementTest.java | 20 +
.../UnsupportedOperationConnectionTest.java | 3 +-
.../driver/state/DriverStateContextTest.java | 7 +-
.../driver/state/ok/OKDriverStateTest.java | 3 +-
.../config/config-encrypt-query-with-cipher.yaml | 3 +-
.../config/config-encrypt-query-with-plain.yaml | 3 +-
.../boot/ShardingSphereAutoConfiguration.java | 2 -
.../additional-spring-configuration-metadata.json | 6 -
.../src/test/resources/application.properties | 1 +
.../namespace/AbstractSpringNamespaceTest.java | 4 +-
...hardingSphereAlgorithmBeanDefinitionParser.java | 4 +-
.../authority/spi/AuthorityProviderAlgorithm.java | 6 +-
.../authority/rule/AuthorityRule.java | 17 +-
.../netty/MySQLBinlogEventPacketDecoder.java | 56 +-
.../MySQLJdbcQueryPropertiesExtensionTest.java | 56 +
.../netty/MySQLBinlogEventPacketDecoderTest.java | 115 +-
.../OpenGaussJdbcQueryPropertiesExtensionTest.java | 24 +-
...PostgreSQLJdbcQueryPropertiesExtensionTest.java | 24 +-
.../shardingsphere/parser/rule/SQLParserRule.java | 3 +
.../config/SingleTableRuleConfiguration.java | 4 +-
.../shardingsphere-single-table-core/pom.xml | 7 +
.../engine/SingleTableStandardRouteEngine.java | 56 +-
.../singletable/rule/SingleTableRule.java | 62 +-
...ngleTableDatabaseRuleConfigurationBuilder.java} | 4 +-
.../rule/builder/SingleTableRuleBuilder.java | 7 +-
....infra.rule.builder.schema.DatabaseRuleBuilder} | 0
...schema.DefaultDatabaseRuleConfigurationBuilder} | 2 +-
.../metadata/SingleTableSchemaBuilderTest.java | 128 --
...=> SingleTableSchemaMetaDataDecoratorTest.java} | 2 +-
.../route/SingleTableSQLRouterTest.java | 132 +-
...ingleTableDatabaseBroadcastRouteEngineTest.java | 21 +-
.../engine/SingleTableStandardRouteEngineTest.java | 53 +-
.../singletable/rule/SingleTableRuleTest.java | 78 +-
...TableDatabaseRuleConfigurationBuilderTest.java} | 9 +-
.../rule/builder/SingleTableRuleBuilderTest.java | 34 +-
.../sqltranslator/rule/SQLTranslatorRule.java | 5 +
.../shardingsphere/traffic/rule/TrafficRule.java | 11 +-
.../algorithm/engine/TrafficEngineTest.java | 2 +-
.../RandomTrafficLoadBalanceAlgorithmTest.java | 4 +-
.../RoundRobinTrafficLoadBalanceAlgorithmTest.java | 4 +-
.../transaction/ConnectionTransaction.java | 13 +-
.../ShardingSphereTransactionManagerEngine.java | 7 +-
.../context/TransactionContextsBuilder.java | 64 -
.../transaction/core/TransactionOperationType.java | 2 +-
.../transaction/rule/TransactionRule.java | 80 +-
.../rule/builder/TransactionRuleBuilder.java | 2 +-
.../spi/ShardingSphereTransactionManager.java | 5 +-
.../transaction/ConnectionTransactionTest.java | 43 +-
...ShardingSphereTransactionManagerEngineTest.java | 6 +-
.../context/TransactionContextsBuilderTest.java | 69 -
.../context/TransactionContextsTest.java | 61 -
...herShardingSphereTransactionManagerFixture.java | 3 +-
.../ShardingSphereTransactionManagerFixture.java | 3 +-
.../SeataATShardingSphereTransactionManager.java | 28 +-
...eataATShardingSphereTransactionManagerTest.java | 7 +-
.../xa/XAShardingSphereTransactionManager.java | 5 +-
.../xa/XAShardingSphereTransactionManagerTest.java | 6 +-
.../NarayanaConfigurationFileGeneratorTest.java | 10 +-
.../mode/manager/ContextManager.java | 115 +-
.../instance/InstanceIdGeneratorFactory.java | 53 +
.../mode/manager/lock/LockJudgeEngine.java | 32 +-
.../mode/manager/lock/LockJudgeEngineBuilder.java | 27 +-
.../lock/ShardingSphereLockJudgeEngine.java | 48 +-
.../mode/metadata/MetaDataContexts.java | 5 +-
.../mode/metadata/MetaDataContextsBuilder.java | 2 +-
.../mode/metadata/persist/node/ComputeNode.java | 18 -
.../service/impl/DatabaseRulePersistService.java | 2 +-
.../mode/metadata/storage/StorageNodeStatus.java | 12 +-
...java => StorageNodeDataSourceChangedEvent.java} | 7 +-
...hardingsphere.mode.manager.lock.LockJudgeEngine | 2 +-
.../mode/manager/ContextManagerTest.java | 25 +-
.../lock/ShardingSphereLockJudgeEngineTest.java | 47 +-
.../mode/metadata/fixture/FixtureRule.java | 12 +-
.../mode/metadata/fixture/FixtureRuleBuilder.java | 4 +-
.../persist/MetaDataPersistServiceTest.java | 2 +-
.../metadata/persist/node/ComputeNodeTest.java | 48 +-
...st.java => DatabaseRulePersistServiceTest.java} | 10 +-
....infra.rule.builder.schema.DatabaseRuleBuilder} | 0
...ta-schema-rule.yaml => data-database-rule.yaml} | 0
.../cluster/ClusterContextManagerBuilder.java | 17 +-
.../ClusterContextManagerCoordinator.java | 46 +-
.../cluster/coordinator/RegistryCenter.java | 2 +-
.../lock/AbstractDistributedLockNodeService.java | 59 -
.../coordinator/lock/DistributedLockContext.java | 5 +
.../cluster/coordinator/lock/LockNodeService.java | 50 +-
.../ShardingSphereDistributedDatabaseLock.java | 29 +-
.../database/node/DatabaseLockNodeService.java | 11 +-
.../watcher/DatabaseLockChangedWatcher.java | 2 +-
.../distributed/ShardingSphereDistributedLock.java | 24 +-
.../node/DistributedLockNodeService.java | 11 +-
.../watcher/DistributedLockChangedWatcher.java | 5 +-
...a => ShardingSphereDistributedLockManager.java} | 19 +-
.../lock/manager/state/LockStateContext.java | 91 ++
.../manager/state/LockStateContextFactory.java | 23 +-
.../state/ShardingSphereLockStateContext.java | 76 +
.../coordinator/lock/mutex/InterMutexLock.java | 2 +-
.../mutex/ShardingSphereInterMutexLockHolder.java | 68 +-
.../lock/{ => service}/LockNodeServiceFactory.java | 3 +-
.../lock/{ => service}/LockRegistryService.java | 2 +-
.../lock/service/MutexLockRegistryService.java | 1 -
.../coordinator/lock/util/LockNodeUtil.java | 10 +
...Event.java => DatabaseVersionChangedEvent.java} | 4 +-
.../metadata/watcher/MetaDataChangedWatcher.java | 14 +-
.../compute/service/ComputeNodeStatusService.java | 3 +-
.../watcher/ComputeNodeStateChangedWatcher.java | 28 +-
...ngedEvent.java => StorageNodeChangedEvent.java} | 9 +-
.../{StorageStatusNode.java => StorageNode.java} | 25 +-
.../storage/service/StorageNodeStatusService.java | 6 +-
.../subscriber/StorageNodeStatusSubscriber.java | 6 +-
.../watcher/StorageNodeStateChangedWatcher.java | 18 +-
...rdinator.lock.manager.ShardingSphereLockManager | 2 +-
...oordinator.lock.manager.state.LockStateContext} | 2 +-
.../ClusterContextManagerCoordinatorTest.java | 38 +-
.../database/node/DatabaseLockNodeServiceTest.java | 5 -
.../node/DistributedLockNodeServiceTest.java | 5 -
... ShardingSphereDistributedLockManagerTest.java} | 22 +-
.../{ => service}/LockNodeServiceFactoryTest.java | 6 +-
.../LockNodeServiceTest.java} | 13 +-
.../lock/service/MutexLockRegistryServiceTest.java | 1 -
.../coordinator/lock/util/LockNodeUtilTest.java | 10 +-
.../service/ComputeNodeStatusServiceTest.java | 27 +-
.../ComputeNodeStateChangedWatcherTest.java | 5 +-
...ageStatusNodeTest.java => StorageNodeTest.java} | 13 +-
.../StorageNodeStatusSubscriberTest.java | 8 +-
.../StorageNodeStateChangedWatcherTest.java | 36 +-
.../zookeeper/CuratorZookeeperRepository.java | 11 +-
.../memory/MemoryContextManagerBuilder.java | 11 +-
.../StandaloneContextManagerBuilder.java | 11 +-
.../StandaloneContextManagerBuilderTextTest.java | 12 +-
.../shardingsphere-proxy-backend/pom.xml | 32 +-
.../communication/DatabaseCommunicationEngine.java | 13 +-
.../jdbc/JDBCDatabaseCommunicationEngine.java | 1 +
.../jdbc/datasource/JDBCBackendDataSource.java | 17 +-
.../transaction/JDBCBackendTransactionManager.java | 13 +-
.../backend/exception/DatabaseLockedException.java | 6 +
.../backend/exception/InTransactionException.java | 18 +-
.../text/TextProtocolBackendHandlerFactory.java | 2 +-
.../mysql/executor/ShowConnectionIdExecutor.java | 5 +-
.../executor/ShowCurrentDatabaseExecutor.java | 5 +-
.../mysql/executor/ShowCurrentUserExecutor.java | 5 +-
.../mysql/executor/ShowDatabasesExecutor.java | 17 +-
.../mysql/executor/ShowTransactionExecutor.java | 5 +-
.../admin/mysql/executor/ShowVersionExecutor.java | 5 +-
.../text/data/DatabaseBackendHandlerFactory.java | 3 +-
.../impl/SchemaAssignedDatabaseBackendHandler.java | 10 +-
.../text/distsql/DistSQLBackendHandlerFactory.java | 8 +-
.../distsql/ral/QueryableRALBackendHandler.java | 53 +-
.../text/distsql/ral/RALBackendHandler.java | 59 +-
.../text/distsql/ral/RALBackendHandlerFactory.java | 99 +-
.../distsql/ral/UpdatableRALBackendHandler.java | 17 +-
.../{FormatHandler.java => FormatSQLHandler.java} | 33 +-
...ackendHandler.java => ParseDistSQLHandler.java} | 37 +-
...tSQLBackendHandler.java => PreviewHandler.java} | 46 +-
.../ShowReadwriteSplittingHintStatusExecutor.java | 13 +-
.../executor/ShowShardingHintStatusExecutor.java | 21 +-
.../queryable/CountInstanceRulesHandler.java | 149 +-
.../ExportDatabaseConfigurationHandler.java | 25 +-
.../common/queryable/ShowAuthorityRuleHandler.java | 24 +-
.../ral/common/queryable/ShowInstanceHandler.java | 31 +-
.../common/queryable/ShowInstanceModeHandler.java | 8 +-
...ShowReadwriteSplittingReadResourcesHandler.java | 43 +-
.../common/queryable/ShowSQLParserRuleHandler.java | 25 +-
.../common/queryable/ShowTableMetadataHandler.java | 35 +-
.../common/queryable/ShowTrafficRulesHandler.java | 42 +-
.../queryable/ShowTransactionRuleHandler.java | 26 +-
.../ral/common/queryable/ShowVariableHandler.java | 46 +-
.../ral/common/updatable/AlterInstanceHandler.java | 21 +-
.../updatable/AlterSQLParserRuleHandler.java | 35 +-
.../common/updatable/AlterTrafficRuleHandler.java | 23 +-
.../updatable/AlterTransactionRuleHandler.java | 22 +-
.../ral/common/updatable/ApplyDistSQLHandler.java | 4 +-
.../common/updatable/CreateTrafficRuleHandler.java | 28 +-
.../common/updatable/DiscardDistSQLHandler.java | 4 +-
.../common/updatable/DropTrafficRuleHandler.java | 30 +-
.../ImportDatabaseConfigurationHandler.java | 57 +-
.../ral/common/updatable/LabelInstanceHandler.java | 10 +-
.../common/updatable/PrepareDistSQLHandler.java | 4 +-
.../updatable/RefreshTableMetadataHandler.java | 43 +-
.../common/updatable/SetInstanceStatusHandler.java | 8 +-
.../SetReadwriteSplittingStatusHandler.java | 37 +-
.../ral/common/updatable/SetVariableHandler.java | 34 +-
.../common/updatable/UnlabelInstanceHandler.java | 12 +-
...ltSet.java => DatabaseRulesCountResultSet.java} | 9 +-
.../transaction/TransactionAutoCommitHandler.java | 44 -
.../transaction/TransactionBackendHandler.java | 46 +-
.../TransactionBackendHandlerFactory.java | 2 +-
.../text/transaction/TransactionXAHandler.java | 4 +-
...dingsphere.infra.distsql.query.DistSQLResultSet | 2 +-
.../communication/ProxySQLExecutorTest.java | 3 +-
.../jdbc/JDBCDatabaseCommunicationEngineTest.java | 1 +
.../jdbc/connection/JDBCBackendConnectionTest.java | 34 +-
.../jdbc/datasource/JDBCBackendDataSourceTest.java | 16 +-
.../JDBCBackendTransactionManagerTest.java | 17 +-
.../swapper/YamlProxyConfigurationSwapperTest.java | 8 +-
.../proxy/backend/context/ProxyContextTest.java | 4 +-
.../backend/session/ConnectionSessionTest.java | 3 +
.../TextProtocolBackendHandlerFactoryTest.java | 23 +-
.../DatabaseAdminQueryBackendHandlerTest.java | 34 +-
.../executor/ShowCurrentUserExecutorTest.java | 3 +-
.../executor/SelectDatabaseExecutorTest.java | 2 +-
.../data/DatabaseBackendHandlerFactoryTest.java | 10 -
.../distsql/DistSQLBackendHandlerFactoryTest.java | 6 +-
.../fixture/CreateFixtureRuleStatement.java | 6 -
...ndlerTest.java => ParseDistSQLHandlerTest.java} | 26 +-
.../common/queryable/CountInstanceRulesTest.java | 63 +-
.../ExportDatabaseConfigurationHandlerTest.java | 9 +-
.../queryable/ShowAuthorityRuleHandlerTest.java | 14 +-
.../queryable/ShowInstanceModeHandlerTest.java | 3 +-
.../queryable/ShowSQLParserRuleHandlerTest.java | 11 +-
.../queryable/ShowTableMetadataHandlerTest.java | 9 +-
.../queryable/ShowTrafficRulesHandlerTest.java | 20 +-
.../queryable/ShowTransactionRuleHandlerTest.java | 18 +-
.../queryable/ShowVariableBackendHandlerTest.java | 25 +-
.../common/updatable/AlterInstanceHandlerTest.java | 12 +-
.../updatable/AlterSQLParserRuleHandlerTest.java | 33 +-
.../updatable/AlterTrafficRuleHandlerTest.java | 58 +-
.../updatable/CreateTrafficRuleHandlerTest.java | 45 +-
.../updatable/DropTrafficRuleHandlerTest.java | 105 +-
.../ImportDatabaseConfigurationHandlerTest.java | 12 +-
.../updatable/SetVariableBackendHandlerTest.java | 39 +-
.../common/updatable/SetVariableExecutorTest.java | 20 +-
...t.java => DatabaseRulesCountResultSetTest.java} | 11 +-
.../rql/UnusedDataSourceQueryResultSetTest.java | 2 +-
.../TransactionBackendHandlerFactoryTest.java | 6 +-
.../transaction/TransactionBackendHandlerTest.java | 6 +-
.../proxy/initializer/BootstrapInitializer.java | 3 +-
.../frontend/command/CommandExecutorTask.java | 5 +-
.../netty/FrontendChannelInboundHandler.java | 11 +-
.../frontend/command/CommandExecutorTaskTest.java | 3 +-
.../DatabaseProtocolFrontendEngineFixture.java | 2 +-
.../netty/FrontendChannelInboundHandlerTest.java | 6 +-
.../FrontDatabaseProtocolTypeFactoryTest.java | 7 +-
.../proxy/frontend/mysql/MySQLFrontendEngine.java | 4 +-
.../mysql/command/MySQLCommandExecuteEngine.java | 1 -
.../mysql}/command/MySQLCommandPacketFactory.java | 10 +-
.../execute/MySQLComStmtExecuteExecutor.java | 60 +-
.../prepare/MySQLComStmtPrepareExecutor.java | 24 +-
.../frontend/mysql/MySQLFrontendEngineTest.java | 2 +-
.../MySQLAuthenticationHandlerTest.java | 4 +-
.../command/MySQLCommandExecutorFactoryTest.java | 5 +-
.../command/MySQLCommandPacketFactoryTest.java | 13 +-
.../execute/MySQLComStmtExecuteExecutorTest.java | 120 +-
.../opengauss/OpenGaussFrontendEngine.java | 5 +-
.../opengauss/err/OpenGaussErrorPacketFactory.java | 4 +
.../OpenGaussAuthenticationEngineTest.java | 2 +-
.../OpenGaussAuthenticationHandlerTest.java | 4 +-
.../postgresql/PostgreSQLFrontendEngine.java | 5 +-
.../command/query/extended/JDBCPortal.java | 3 +-
.../postgresql/err/PostgreSQLErrPacketFactory.java | 9 +
.../PostgreSQLAuthenticationEngineTest.java | 2 +-
.../PostgreSQLAuthenticationHandlerTest.java | 4 +-
.../PostgreSQLCommandExecuteEngineTest.java | 3 +-
...ummyReactiveDatabaseProtocolFrontendEngine.java | 2 +-
.../mysql/command/ReactiveMySQLFrontendEngine.java | 2 +-
.../ReactiveMySQLComStmtExecuteExecutor.java | 74 +-
.../spi/DatabaseProtocolFrontendEngine.java | 3 +-
.../spi/type/optional/OptionalSPIRegistry.java | 4 +-
.../spi/type/required/RequiredSPIRegistry.java | 7 +-
.../impl/MySQLDDLStatementSQLVisitor.java | 14 +-
.../main/antlr4/imports/opengauss/DDLStatement.g4 | 4 +-
.../sql/parser/autogen/OpenGaussStatement.g4 | 1 +
.../impl/OpenGaussDDLStatementSQLVisitor.java | 7 +
.../src/main/antlr4/imports/oracle/BaseRule.g4 | 4 +
.../src/main/antlr4/imports/oracle/DDLStatement.g4 | 14 +
.../main/antlr4/imports/oracle/OracleKeyword.g4 | 8 +
.../sql/parser/autogen/OracleStatement.g4 | 3 +
.../impl/OracleDDLStatementSQLVisitor.java | 167 ++-
.../src/main/antlr4/imports/postgresql/BaseRule.g4 | 13 +-
.../main/antlr4/imports/postgresql/DDLStatement.g4 | 10 +-
.../main/antlr4/imports/postgresql/DMLStatement.g4 | 64 +-
.../src/main/antlr4/imports/postgresql/Literals.g4 | 2 +-
.../antlr4/imports/postgresql/PostgreSQLKeyword.g4 | 16 +
.../parser/autogen/PostgreSQLStatementParser.g4 | 3 +
.../impl/PostgreSQLDDLStatementSQLVisitor.java | 21 +
.../impl/PostgreSQLDMLStatementSQLVisitor.java | 66 +
.../impl/SQLServerDDLStatementSQLVisitor.java | 17 +
.../core/database/visitor/SQLVisitorRule.java | 14 +-
.../visitor/SQLVisitorFacadeFactoryTest.java | 19 +-
.../parser/fixture/SQLVisitorFacadeFixture.java | 70 +
....shardingsphere.sql.parser.spi.SQLVisitorFacade | 3 +-
.../parser/sql/common/constant/DirectionType.java | 61 +-
.../dml/prepare/PrepareStatementQuerySegment.java | 86 ++
.../statement/ddl/AlterOperatorStatement.java | 14 +-
.../common/statement/ddl/AlterPolicyStatement.java | 12 +-
.../statement/ddl/CreateAccessMethodStatement.java | 14 +-
.../statement/ddl/CreateAggregateStatement.java | 14 +-
.../sql/parser/sql/common/util/SQLUtil.java | 8 +-
.../dialect/handler/dml/CopyStatementHandler.java | 64 +
.../ddl/OpenGaussCreateAggregateStatement.java | 17 +-
.../ddl/OracleCreateRestorePointStatement.java} | 10 +-
.../ddl/OracleDropOperatorStatement.java} | 10 +-
.../ddl/OracleDropRestorePointStatement.java} | 10 +-
.../PostgreSQLAlterOperatorStatement.java} | 8 +-
.../PostgreSQLAlterPolicyStatement.java} | 8 +-
.../ddl/PostgreSQLCreateAccessMethodStatement.java | 17 +-
.../postgresql/dml/PostgreSQLCopyStatement.java | 23 +
.../pipeline/cases/base/BaseExtraSQLITCase.java | 35 +
.../data/pipeline/cases/base/BaseITCase.java | 66 +-
.../pipeline/cases/command/ExtraSQLCommand.java | 13 +
.../cases/general/MySQLGeneralScalingIT.java | 10 +-
.../cases/general/PostgreSQLGeneralScalingIT.java | 13 +-
.../cases/primarykey/TextPrimaryKeyScalingIT.java | 9 +-
.../framework/helper/ScalingCaseHelper.java | 3 +-
.../data/pipeline/logger/ScalingLoggerFilter.java | 53 +
.../src/test/resources/env/logback.xml | 3 -
.../test/resources/env/scenario/general/mysql.xml | 8 +
.../resources/env/scenario/general/postgresql.xml | 20 +-
.../scenario/primarykey/text_primary_key/mysql.xml | 8 +
.../primarykey/text_primary_key/postgresql.xml | 8 +
.../src/test/resources/logback-test.xml | 3 +
.../SQLNodeConvertEngineParameterizedTest.java | 1 +
.../segment/distsql/rdl/EncryptColumnAssert.java | 1 +
.../prepare/PrepareStatementQueryAssert.java | 90 ++
.../ddl/impl/CreateIndexStatementAssert.java | 11 +
.../statement/dml/impl/CopyStatementAssert.java | 44 +
.../jaxb/cases/domain/SQLParserTestCases.java | 68 +-
.../impl/column/ExpectedColumns.java} | 19 +-
.../impl/distsql/rdl/ExpectedEncryptColumn.java | 5 +-
.../impl/query/ExpectedPrepareStatementQuery.java} | 28 +-
.../AlterOperatorStatementTestCase.java} | 6 +-
.../AlterPolicyStatementTestCase.java} | 6 +-
.../CreateAccessMethodStatementTestCase.java} | 6 +-
.../CreateAggregateStatementTestCase.java} | 6 +-
.../ddl/CreateIndexStatementTestCase.java | 4 +
.../CreateRestorePointStatementTestCase.java} | 6 +-
.../DropRestorePointStatementTestCase.java} | 6 +-
.../statement/dml/CopyStatementTestCase.java | 16 +
.../ddl/{drop-operator.xml => alter-operator.xml} | 6 +-
.../case/{dml/copy.xml => ddl/alter-policy.xml} | 6 +-
.../{dml/copy.xml => ddl/create-access-method.xml} | 4 +-
.../{dml/copy.xml => ddl/create-aggregate.xml} | 3 +-
.../src/main/resources/case/ddl/create-index.xml | 74 +
.../{dml/copy.xml => ddl/create-restore-point.xml} | 3 +-
.../src/main/resources/case/ddl/drop-operator.xml | 1 +
.../{dml/copy.xml => ddl/drop-restore-point.xml} | 3 +-
.../src/main/resources/case/dml/copy.xml | 62 +-
.../src/main/resources/case/dml/select-union.xml | 19 +
.../src/main/resources/case/rdl/alter.xml | 1 +
.../src/main/resources/case/rdl/create.xml | 1 +
.../ddl/{drop-operator.xml => alter-operator.xml} | 6 +-
.../ddl/{drop-operator.xml => alter-policy.xml} | 6 +-
...{drop-operator.xml => create-access-method.xml} | 4 +-
.../{dml/copy.xml => ddl/create-aggregate.xml} | 2 +-
.../{dml/copy.xml => ddl/create-restore-point.xml} | 2 +-
.../resources/sql/supported/ddl/drop-operator.xml | 1 +
.../supported/ddl/drop-restore-point.xml} | 7 +-
.../src/main/resources/sql/supported/dml/copy.xml | 11 +-
.../resources/sql/supported/dml/select-union.xml | 1 +
.../src/main/resources/sql/supported/rdl/alter.xml | 2 +-
.../main/resources/sql/supported/rdl/create.xml | 2 +-
.../main/resources/sql/unsupported/unsupported.xml | 55 -
.../pipeline/core/util/PipelineContextUtil.java | 2 +-
.../src/test/resources/logback-test.xml | 4 +-
...ewriteQueryAssistedEncryptAlgorithmFixture.java | 11 +-
.../AbstractSQLRewriterParameterizedTest.java | 2 +-
.../ddl/alter/{alter.xml => alter-table.xml} | 27 +-
.../ddl/create/{create.xml => create-index.xml} | 11 +-
.../query-with-cipher/ddl/create/create-table.xml | 29 +
.../{insert_column.xml => insert-column.xml} | 0
...rt_on_duplicate.xml => insert-on-duplicate.xml} | 0
.../dml/insert/{insert_set.xml => insert-set.xml} | 0
.../{select_group_by.xml => select-group-by.xml} | 0
.../select/{select_join.xml => select-join.xml} | 0
.../{select_order_by.xml => select-order-by.xml} | 0
...select_projection.xml => select-projection.xml} | 0
.../{select_subquery.xml => select-subquery.xml} | 0
.../select/{select_where.xml => select-where.xml} | 0
.../ddl/alter/{alter.xml => alter-table.xml} | 39 +-
.../ddl/create/{create.xml => create-index.xml} | 11 +-
.../query-with-plain/ddl/create/create-table.xml | 29 +
.../{insert_column.xml => insert-column.xml} | 0
...rt_on_duplicate.xml => insert-on-duplicate.xml} | 0
.../dml/insert/{insert_set.xml => insert-set.xml} | 0
.../{select_group_by.xml => select-group-by.xml} | 0
.../select/{select_join.xml => select-join.xml} | 0
.../{select_order_by.xml => select-order-by.xml} | 0
...select_projection.xml => select-projection.xml} | 0
.../{select_subquery.xml => select-subquery.xml} | 0
.../select/{select_where.xml => select-where.xml} | 0
.../scenario/encrypt/config/query-with-cipher.yaml | 21 +-
.../scenario/encrypt/config/query-with-plain.yaml | 21 +-
.../ddl/create/{create.xml => create-table.xml} | 0
.../{insert_column.xml => insert-column.xml} | 0
.../dml/insert/{insert_set.xml => insert-set.xml} | 0
.../select/{select_join.xml => select-join.xml} | 0
...select_projection.xml => select-projection.xml} | 0
.../{select_subquery.xml => select-subquery.xml} | 0
.../select/{select_where.xml => select-where.xml} | 0
...select_projection.xml => select-projection.xml} | 0
.../select/{select_where.xml => select-where.xml} | 0
.../scenario/mix/config/query-with-cipher.yaml | 9 +-
.../scenario/mix/config/query-with-plain.yaml | 6 +-
.../scenario/sharding/case/{ => dal}/analyze.xml | 0
.../case/{alter.xml => ddl/alter-table.xml} | 0
.../scenario/sharding/case/{ => ddl}/close.xml | 0
.../case/{create.xml => ddl/create-table.xml} | 0
.../scenario/sharding/case/{ => ddl}/cursor.xml | 0
.../sharding/case/{drop.xml => ddl/drop-table.xml} | 0
.../resources/scenario/sharding/case/ddl/fetch.xml | 169 +++
.../scenario/sharding/case/{ => ddl}/index.xml | 0
.../scenario/sharding/case/{ => ddl}/move.xml | 0
.../scenario/sharding/case/{ => ddl}/show.xml | 0
.../scenario/sharding/case/{ => dml}/copy.xml | 0
.../scenario/sharding/case/{ => dml}/delete.xml | 0
.../scenario/sharding/case/{ => dml}/insert.xml | 0
.../scenario/sharding/case/{ => dml}/select.xml | 0
.../scenario/sharding/case/{ => dml}/update.xml | 0
.../resources/scenario/sharding/case/fetch.xml | 29 -
833 files changed, 7351 insertions(+), 8654 deletions(-)
rename
docs/document/content/reference/test/performance-test/{benchmarksql-test.cn.md
=> benchmarksql-proxy-sharding-test.cn.md} (99%)
delete mode 100644
docs/document/content/reference/test/performance-test/performance-test.cn.md
delete mode 100644
docs/document/content/reference/test/performance-test/performance-test.en.md
create mode 100644
docs/document/content/reference/test/performance-test/sysbench-proxy-norules-test.cn.md
delete mode 100644
docs/document/content/reference/test/performance-test/sysbench-test.en.md
delete mode 100644
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/operation/DistSQLOperationTypeEnum.java
delete mode 100644
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/operation/impl/AlterOperationSupplier.java
delete mode 100644
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/operation/impl/RALOperationSupplier.java
delete mode 100644
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/operation/impl/ShowOperationSupplier.java
delete mode 100644
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/DistSQLStatementType.java
delete mode 100644
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/subject/DistSQLSubjectTypeEnum.java
delete mode 100644
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/subject/impl/DatabaseDiscoverySubjectSupplier.java
delete mode 100644
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/subject/impl/EncryptSubjectSupplier.java
delete mode 100644
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/subject/impl/ReadwriteSplittingSubjectSupplier.java
delete mode 100644
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/subject/impl/ResourceSubjectSupplier.java
delete mode 100644
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/subject/impl/ScalingSubjectSupplier.java
delete mode 100644
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/subject/impl/ShadowSubjectSupplier.java
delete mode 100644
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/subject/impl/ShardingSubjectSupplier.java
delete mode 100644
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/subject/impl/SingleTableSubjectSupplier.java
rename
shardingsphere-features/shardingsphere-db-discovery/shardingsphere-db-discovery-core/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.rule.builder.schema.SchemaRuleBuilder
=> org.apache.shardingsphere.infra.rule.builder.schema.DatabaseRuleBuilder}
(100%)
delete mode 100644
shardingsphere-features/shardingsphere-db-discovery/shardingsphere-db-discovery-distsql/shardingsphere-db-discovery-distsql-handler/src/test/java/org/apache/shardingsphere/dbdiscovery/distsql/handler/fixture/DatabaseDiscoveryRuleExportableFixture.java
delete mode 100644
shardingsphere-features/shardingsphere-db-discovery/shardingsphere-db-discovery-distsql/shardingsphere-db-discovery-distsql-handler/src/test/java/org/apache/shardingsphere/dbdiscovery/distsql/handler/fixture/ReadwriteSplittingRuleExportableFixture.java
create mode 100644
shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-core/src/main/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/EncryptIndexColumnTokenGenerator.java
rename
shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-core/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.rule.builder.schema.SchemaRuleBuilder
=> org.apache.shardingsphere.infra.rule.builder.schema.DatabaseRuleBuilder}
(100%)
rename
shardingsphere-features/shardingsphere-readwrite-splitting/shardingsphere-readwrite-splitting-core/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.rule.builder.schema.SchemaRuleBuilder
=> org.apache.shardingsphere.infra.rule.builder.schema.DatabaseRuleBuilder}
(100%)
delete mode 100644
shardingsphere-features/shardingsphere-readwrite-splitting/shardingsphere-readwrite-splitting-distsql/shardingsphere-readwrite-splitting-distsql-handler/src/test/java/org/apache/shardingsphere/readwritesplitting/distsql/handler/fixture/DatabaseDiscoveryRuleExportableFixture.java
delete mode 100644
shardingsphere-features/shardingsphere-readwrite-splitting/shardingsphere-readwrite-splitting-distsql/shardingsphere-readwrite-splitting-distsql-handler/src/test/java/org/apache/shardingsphere/readwritesplitting/distsql/handler/fixture/ReadwriteSplittingRuleExportableFixture.java
rename
shardingsphere-features/shardingsphere-shadow/shardingsphere-shadow-core/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.rule.builder.schema.SchemaRuleBuilder
=> org.apache.shardingsphere.infra.rule.builder.schema.DatabaseRuleBuilder}
(100%)
delete mode 100644
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/main/java/org/apache/shardingsphere/sharding/merge/dal/common/SingleLocalDataMergedResult.java
copy
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/common/queryable/ShowTrafficRulesStatement.java
=>
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/main/java/org/apache/shardingsphere/sharding/merge/ddl/fetch/FetchOrderByValueGroup.java
(70%)
rename
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/main/java/org/apache/shardingsphere/sharding/merge/ddl/fetch/{FetchOrderByValueQueuesHolder.java
=> FetchOrderByValueGroupsHolder.java} (55%)
create mode 100644
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/FetchDirectionTokenGenerator.java
create mode 100644
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/pojo/FetchDirectionToken.java
rename
shardingsphere-features/shardingsphere-sharding/{shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/main/java/org/apache/shardingsphere/sharding/distsql/handler/checker/BindingTableCheckedConfig.java
=>
shardingsphere-sharding-core/src/main/java/org/apache/shardingsphere/sharding/rule/BindingTableCheckedConfiguration.java}
(84%)
rename
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.rule.builder.schema.SchemaRuleBuilder
=> org.apache.shardingsphere.infra.rule.builder.schema.DatabaseRuleBuilder}
(100%)
delete mode 100644
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/test/java/org/apache/shardingsphere/sharding/merge/dal/common/SingleLocalDataMergedResultTest.java
create mode 100644
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/test/java/org/apache/shardingsphere/sharding/rewrite/token/pojo/ConstraintTokenTest.java
rename
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/config/scope/{SchemaRuleConfiguration.java
=> DatabaseRuleConfiguration.java} (90%)
copy
shardingsphere-infra/shardingsphere-infra-common/src/{test/java/org/apache/shardingsphere/infra/metadata/database/schema/fixture/rule/CommonFixtureRule.java
=>
main/java/org/apache/shardingsphere/infra/instance/instanceid/DefaultInstanceIdGenerator.java}
(60%)
rename
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/subject/DistSQLSubjectSupplier.java
=>
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/instance/instanceid/InstanceIdGenerator.java
(62%)
rename
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/rule/builder/schema/{SchemaRuleBuilder.java
=> DatabaseRuleBuilder.java} (78%)
rename
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/rule/builder/schema/{SchemaRuleBuilderFactory.java
=> DatabaseRuleBuilderFactory.java} (63%)
rename
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/rule/builder/schema/{DefaultSchemaRuleConfigurationBuilder.java
=> DefaultDatabaseRuleConfigurationBuilder.java} (72%)
rename
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/rule/builder/schema/{DefaultSchemaRuleConfigurationBuilderFactory.java
=> DefaultDatabaseRuleConfigurationBuilderFactory.java} (69%)
rename
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/rule/identifier/scope/{SchemaRule.java
=> DatabaseRule.java} (92%)
rename
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/rule/identifier/type/{CheckableRule.java
=> ResourceHeldRule.java} (58%)
copy
shardingsphere-infra/{shardingsphere-infra-merge/src/main/java/org/apache/shardingsphere/infra/merge/engine/decorator/impl/TransparentRule.java
=>
shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/rule/identifier/type/exportable/ExportableRule.java}
(75%)
rename
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/rule/identifier/type/{ExportableRule.java
=> exportable/RuleExportEngine.java} (59%)
rename
shardingsphere-infra/shardingsphere-infra-common/src/{test/resources/META-INF/services/org.apache.shardingsphere.infra.rule.builder.schema.DefaultSchemaRuleConfigurationBuilder
=>
main/resources/META-INF/services/org.apache.shardingsphere.infra.instance.instanceid.InstanceIdGenerator}
(89%)
delete mode 100644
shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/database/rule/ShardingSphereRuleConfigurationFixture.java
rename
shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/rule/builder/fixture/{FixtureSchemaRule.java
=> FixtureDatabaseRule.java} (68%)
rename
shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/rule/builder/fixture/{FixtureSchemaRuleBuilder.java
=> FixtureDatabaseRuleBuilder.java} (65%)
rename
shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/rule/builder/fixture/{FixtureSchemaRuleConfiguration.java
=> FixtureDatabaseRuleConfiguration.java} (83%)
rename
shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/rule/builder/fixture/{FixtureSchemaRuleConfigurationBuilder.java
=> FixtureDatabaseRuleConfigurationBuilder.java} (71%)
rename
shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/rule/builder/schema/{SchemaRuleBuilderFactoryTest.java
=> DatabaseRuleBuilderFactoryTest.java} (69%)
rename
shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/rule/builder/schema/{DefaultSchemaRuleConfigurationBuilderFactoryTest.java
=> DefaultDatabaseRuleConfigurationBuilderFactoryTest.java} (72%)
rename
shardingsphere-infra/shardingsphere-infra-common/src/test/resources/META-INF/services/{org.apache.shardingsphere.infra.rule.builder.schema.SchemaRuleBuilder
=> org.apache.shardingsphere.infra.rule.builder.schema.DatabaseRuleBuilder}
(91%)
copy
shardingsphere-kernel/shardingsphere-single-table/shardingsphere-single-table-core/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.rule.builder.schema.SchemaRuleBuilder
=>
shardingsphere-infra/shardingsphere-infra-common/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.rule.builder.schema.DefaultDatabaseRuleConfigurationBuilder
(89%)
copy
shardingsphere-infra/shardingsphere-infra-context/src/test/java/org/apache/shardingsphere/infra/context/refresher/fixture/{FixtureSQLStatement.java
=> MetaDataRefresherSQLStatementFixture.java} (86%)
delete mode 100644
shardingsphere-infra/shardingsphere-infra-context/src/test/java/org/apache/shardingsphere/infra/context/refresher/type/DummyDropDatabaseMetaDataRefresher.java
rename
shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-executor/src/main/java/org/apache/shardingsphere/infra/federation/executor/{customized/CustomizedFilterableExecuteDataContext.java
=> advanced/AdvancedExecuteDataContext.java} (72%)
rename
shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-executor/src/main/java/org/apache/shardingsphere/infra/federation/executor/{customized/CustomizedFilterableExecutor.java
=> advanced/AdvancedFederationExecutor.java} (74%)
rename
shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-executor/src/main/java/org/apache/shardingsphere/infra/federation/executor/{customized
=> advanced/resultset}/AbstractUnsupportedOperationResultSet.java (98%)
rename
shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-executor/src/main/java/org/apache/shardingsphere/infra/federation/executor/{customized
=> advanced/resultset}/AbstractUnsupportedUpdateOperationResultSet.java (99%)
rename
shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-executor/src/main/java/org/apache/shardingsphere/infra/federation/executor/{customized
=> advanced/resultset}/FederationResultSet.java (78%)
rename
shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-executor/src/main/java/org/apache/shardingsphere/infra/federation/executor/{customized
=> advanced/resultset}/WrapperAdapter.java (94%)
rename
shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-executor/src/main/java/org/apache/shardingsphere/infra/federation/executor/original/{OriginalFilterableExecutor.java
=> OriginalFederationExecutor.java} (94%)
create mode 100644
shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-executor/src/main/java/org/apache/shardingsphere/infra/federation/executor/original/SQLDialectFactory.java
rename
shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-executor/src/main/java/org/apache/shardingsphere/infra/federation/executor/original/{
=> database}/FilterableDatabase.java (95%)
rename
shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-executor/src/main/java/org/apache/shardingsphere/infra/federation/executor/original/{
=> schema}/FilterableSchema.java (95%)
rename
shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-executor/src/main/java/org/apache/shardingsphere/infra/federation/executor/original/{
=> table}/FederationTableStatistic.java (80%)
rename
shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-executor/src/test/java/org/apache/shardingsphere/infra/federation/executor/{customized/CustomizedFilterableExecutorTest.java
=> advanced/AdvancedFederationExecutorTest.java} (90%)
rename
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/main/java/org/apache/shardingsphere/sharding/merge/dal/common/MultipleLocalDataMergedResult.java
=>
shardingsphere-infra/shardingsphere-infra-merge/src/main/java/org/apache/shardingsphere/infra/merge/result/impl/local/LocalDataMergedResult.java
(79%)
rename
shardingsphere-kernel/shardingsphere-transaction/shardingsphere-transaction-core/src/main/java/org/apache/shardingsphere/transaction/context/TransactionContexts.java
=>
shardingsphere-infra/shardingsphere-infra-merge/src/main/java/org/apache/shardingsphere/infra/merge/result/impl/local/LocalDataQueryResultRow.java
(56%)
rename
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/test/java/org/apache/shardingsphere/sharding/merge/dal/common/MultipleLocalDataMergedResultTest.java
=>
shardingsphere-infra/shardingsphere-infra-merge/src/test/java/org/apache/shardingsphere/infra/merge/result/impl/local/LocalDataMergedResultTest.java
(70%)
create mode 100644
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-dialect/shardingsphere-data-pipeline-mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/datasource/MySQLJdbcQueryPropertiesExtensionTest.java
copy
shardingsphere-infra/shardingsphere-infra-context/src/test/java/org/apache/shardingsphere/infra/context/refresher/MetaDataRefresherFactoryTest.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-dialect/shardingsphere-data-pipeline-opengauss/src/test/java/org/apache/shardingsphere/data/pipeline/opengauss/datasource/OpenGaussJdbcQueryPropertiesExtensionTest.java
(52%)
copy
shardingsphere-infra/shardingsphere-infra-context/src/test/java/org/apache/shardingsphere/infra/context/refresher/MetaDataRefresherFactoryTest.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-dialect/shardingsphere-data-pipeline-postgresql/src/test/java/org/apache/shardingsphere/data/pipeline/postgresql/datasource/PostgreSQLJdbcQueryPropertiesExtensionTest.java
(52%)
rename
shardingsphere-kernel/shardingsphere-single-table/shardingsphere-single-table-core/src/main/java/org/apache/shardingsphere/singletable/rule/builder/{DefaultSingleTableSchemaRuleConfigurationBuilder.java
=> DefaultSingleTableDatabaseRuleConfigurationBuilder.java} (87%)
copy
shardingsphere-kernel/shardingsphere-single-table/shardingsphere-single-table-core/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.rule.builder.schema.SchemaRuleBuilder
=> org.apache.shardingsphere.infra.rule.builder.schema.DatabaseRuleBuilder}
(100%)
rename
shardingsphere-kernel/shardingsphere-single-table/shardingsphere-single-table-core/src/main/resources/META-INF/services/{org.apache.shardingsphere.infra.rule.builder.schema.DefaultSchemaRuleConfigurationBuilder
=>
org.apache.shardingsphere.infra.rule.builder.schema.DefaultDatabaseRuleConfigurationBuilder}
(95%)
delete mode 100644
shardingsphere-kernel/shardingsphere-single-table/shardingsphere-single-table-core/src/test/java/org/apache/shardingsphere/singletable/metadata/SingleTableSchemaBuilderTest.java
rename
shardingsphere-kernel/shardingsphere-single-table/shardingsphere-single-table-core/src/test/java/org/apache/shardingsphere/singletable/metadata/{SingleTableSchemaMetaDataBuilderTest.java
=> SingleTableSchemaMetaDataDecoratorTest.java} (98%)
rename
shardingsphere-kernel/shardingsphere-single-table/shardingsphere-single-table-core/src/test/java/org/apache/shardingsphere/singletable/rule/builder/{DefaultSingleTableSchemaRuleConfigurationBuilderTest.java
=> DefaultSingleTableDatabaseRuleConfigurationBuilderTest.java} (78%)
delete mode 100644
shardingsphere-kernel/shardingsphere-transaction/shardingsphere-transaction-core/src/main/java/org/apache/shardingsphere/transaction/context/TransactionContextsBuilder.java
delete mode 100644
shardingsphere-kernel/shardingsphere-transaction/shardingsphere-transaction-core/src/test/java/org/apache/shardingsphere/transaction/context/TransactionContextsBuilderTest.java
delete mode 100644
shardingsphere-kernel/shardingsphere-transaction/shardingsphere-transaction-core/src/test/java/org/apache/shardingsphere/transaction/context/TransactionContextsTest.java
create mode 100644
shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/instance/InstanceIdGeneratorFactory.java
rename
shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-api/src/main/java/org/apache/shardingsphere/encrypt/spi/QueryAssistedEncryptAlgorithm.java
=>
shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/lock/LockJudgeEngine.java
(52%)
copy
shardingsphere-spi/src/main/java/org/apache/shardingsphere/spi/type/optional/OptionalSPIRegistry.java
=>
shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/lock/LockJudgeEngineBuilder.java
(60%)
rename
shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/metadata/storage/event/{DataSourceNameDisabledEvent.java
=> StorageNodeDataSourceChangedEvent.java} (81%)
rename
shardingsphere-kernel/shardingsphere-single-table/shardingsphere-single-table-core/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.rule.builder.schema.SchemaRuleBuilder
=>
shardingsphere-mode/shardingsphere-mode-core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.manager.lock.LockJudgeEngine
(91%)
rename
shardingsphere-mode/shardingsphere-mode-core/src/test/java/org/apache/shardingsphere/mode/metadata/persist/service/impl/{SchemaRulePersistServiceTest.java
=> DatabaseRulePersistServiceTest.java} (88%)
rename
shardingsphere-mode/shardingsphere-mode-core/src/test/resources/META-INF/services/{org.apache.shardingsphere.infra.rule.builder.schema.SchemaRuleBuilder
=> org.apache.shardingsphere.infra.rule.builder.schema.DatabaseRuleBuilder}
(100%)
copy
shardingsphere-mode/shardingsphere-mode-core/src/test/resources/yaml/persist/{data-schema-rule.yaml
=> data-database-rule.yaml} (100%)
delete mode 100644
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/lock/AbstractDistributedLockNodeService.java
rename
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/lock/manager/{DistributedLockManager.java
=> ShardingSphereDistributedLockManager.java} (82%)
create mode 100644
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/lock/manager/state/LockStateContext.java
copy
shardingsphere-spi/src/main/java/org/apache/shardingsphere/spi/type/optional/OptionalSPIRegistry.java
=>
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/lock/manager/state/LockStateContextFactory.java
(65%)
create mode 100644
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/lock/manager/state/ShardingSphereLockStateContext.java
rename
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/lock/{
=> service}/LockNodeServiceFactory.java (95%)
rename
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/lock/{
=> service}/LockRegistryService.java (99%)
rename
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/config/event/version/{SchemaVersionChangedEvent.java
=> DatabaseVersionChangedEvent.java} (91%)
rename
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/storage/event/{DisabledStateChangedEvent.java
=> StorageNodeChangedEvent.java} (80%)
rename
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/storage/node/{StorageStatusNode.java
=> StorageNode.java} (72%)
copy
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/resources/META-INF/services/{org.apache.shardingsphere.mode.manager.cluster.coordinator.lock.manager.ShardingSphereLockManager
=>
org.apache.shardingsphere.mode.manager.cluster.coordinator.lock.manager.state.LockStateContext}
(94%)
rename
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/lock/manager/{DistributedLockManagerTest.java
=> ShardingSphereDistributedLockManagerTest.java} (69%)
rename
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/lock/{
=> service}/LockNodeServiceFactoryTest.java (89%)
rename
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/lock/{AbstractDistributedLockNodeServiceTest.java
=> service/LockNodeServiceTest.java} (84%)
rename
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/storage/node/{StorageStatusNodeTest.java
=> StorageNodeTest.java} (72%)
rename
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/operation/DistSQLOperationSupplier.java
=>
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/InTransactionException.java
(74%)
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/{FormatHandler.java
=> FormatSQLHandler.java} (65%)
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/{ParseDistSQLBackendHandler.java
=> ParseDistSQLHandler.java} (66%)
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/{PreviewDistSQLBackendHandler.java
=> PreviewHandler.java} (82%)
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rql/rule/{SchemaRulesCountResultSet.java
=> DatabaseRulesCountResultSet.java} (94%)
delete mode 100644
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/transaction/TransactionAutoCommitHandler.java
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advance/{ParseDistSQLBackendHandlerTest.java
=> ParseDistSQLHandlerTest.java} (75%)
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/distsql/rql/{SchemaRulesCountResultSetTest.java
=> DatabaseRulesCountResultSetTest.java} (95%)
rename
{shardingsphere-db-protocol/shardingsphere-db-protocol-mysql/src/main/java/org/apache/shardingsphere/db/protocol/mysql/packet
=>
shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql}/command/MySQLCommandPacketFactory.java
(81%)
rename
shardingsphere-db-protocol/shardingsphere-db-protocol-mysql/src/test/java/org/apache/shardingsphere/db/protocol/mysql/packet/command/MySQLMySQLCommandPacketFactoryTest.java
=>
shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-mysql/src/test/java/org/apache/shardingsphere/proxy/frontend/mysql/command/MySQLCommandPacketFactoryTest.java
(95%)
rename
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/operation/impl/AddOperationSupplier.java
=>
shardingsphere-sql-parser/shardingsphere-sql-parser-engine/src/test/java/org/apache/shardingsphere/sql/parser/core/database/visitor/SQLVisitorFacadeFactoryTest.java
(63%)
create mode 100644
shardingsphere-sql-parser/shardingsphere-sql-parser-engine/src/test/java/org/apache/shardingsphere/sql/parser/fixture/SQLVisitorFacadeFixture.java
rename
shardingsphere-mode/shardingsphere-mode-core/src/test/resources/yaml/persist/data-schema-rule.yaml
=>
shardingsphere-sql-parser/shardingsphere-sql-parser-engine/src/test/resources/META-INF/services/org.apache.shardingsphere.sql.parser.spi.SQLVisitorFacade
(91%)
create mode 100644
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/segment/dml/prepare/PrepareStatementQuerySegment.java
copy
shardingsphere-infra/shardingsphere-infra-context/src/test/java/org/apache/shardingsphere/infra/context/refresher/fixture/FixtureSQLStatement.java
=>
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/ddl/AlterOperatorStatement.java
(78%)
copy
shardingsphere-infra/shardingsphere-infra-context/src/test/java/org/apache/shardingsphere/infra/context/refresher/fixture/FixtureSQLStatement.java
=>
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/ddl/AlterPolicyStatement.java
(80%)
copy
shardingsphere-infra/shardingsphere-infra-context/src/test/java/org/apache/shardingsphere/infra/context/refresher/fixture/FixtureSQLStatement.java
=>
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/ddl/CreateAccessMethodStatement.java
(77%)
rename
shardingsphere-infra/shardingsphere-infra-context/src/test/java/org/apache/shardingsphere/infra/context/refresher/fixture/FixtureSQLStatement.java
=>
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/ddl/CreateAggregateStatement.java
(78%)
create mode 100644
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/handler/dml/CopyStatementHandler.java
rename
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/operation/impl/DropOperationSupplier.java
=>
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/statement/opengauss/ddl/OpenGaussCreateAggregateStatement.java
(63%)
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/statement/{postgresql/dml/PostgreSQLCopyStatement.java
=> oracle/ddl/OracleCreateRestorePointStatement.java} (82%)
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/statement/{postgresql/dml/PostgreSQLCopyStatement.java
=> oracle/ddl/OracleDropOperatorStatement.java} (83%)
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/statement/{postgresql/dml/PostgreSQLCopyStatement.java
=> oracle/ddl/OracleDropRestorePointStatement.java} (83%)
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/statement/postgresql/{dml/PostgreSQLCopyStatement.java
=> ddl/PostgreSQLAlterOperatorStatement.java} (84%)
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/statement/postgresql/{dml/PostgreSQLCopyStatement.java
=> ddl/PostgreSQLAlterPolicyStatement.java} (84%)
rename
shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/operation/impl/CreateOperationSupplier.java
=>
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/statement/postgresql/ddl/PostgreSQLCreateAccessMethodStatement.java
(62%)
create mode 100644
shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/logger/ScalingLoggerFilter.java
create mode 100644
shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/asserts/segment/prepare/PrepareStatementQueryAssert.java
copy
shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/{statement/dml/CopyStatementTestCase.java
=> segment/impl/column/ExpectedColumns.java} (67%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/{statement/ddl/CreateIndexStatementTestCase.java
=> segment/impl/query/ExpectedPrepareStatementQuery.java} (56%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/statement/{dml/CopyStatementTestCase.java
=> ddl/AlterOperatorStatementTestCase.java} (86%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/statement/{dml/CopyStatementTestCase.java
=> ddl/AlterPolicyStatementTestCase.java} (87%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/statement/{dml/CopyStatementTestCase.java
=> ddl/CreateAccessMethodStatementTestCase.java} (86%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/statement/{dml/CopyStatementTestCase.java
=> ddl/CreateAggregateStatementTestCase.java} (86%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/statement/{dml/CopyStatementTestCase.java
=> ddl/CreateRestorePointStatementTestCase.java} (86%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/statement/{dml/CopyStatementTestCase.java
=> ddl/DropRestorePointStatementTestCase.java} (86%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/ddl/{drop-operator.xml
=> alter-operator.xml} (78%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/{dml/copy.xml
=> ddl/alter-policy.xml} (80%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/{dml/copy.xml
=> ddl/create-access-method.xml} (86%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/{dml/copy.xml
=> ddl/create-aggregate.xml} (94%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/{dml/copy.xml
=> ddl/create-restore-point.xml} (93%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/{dml/copy.xml
=> ddl/drop-restore-point.xml} (93%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/ddl/{drop-operator.xml
=> alter-operator.xml} (59%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/ddl/{drop-operator.xml
=> alter-policy.xml} (64%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/ddl/{drop-operator.xml
=> create-access-method.xml} (75%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/{dml/copy.xml
=> ddl/create-aggregate.xml} (84%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/{dml/copy.xml
=> ddl/create-restore-point.xml} (87%)
copy
shardingsphere-test/shardingsphere-parser-test/src/main/resources/{case/dml/copy.xml
=> sql/supported/ddl/drop-restore-point.xml} (87%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-cipher/ddl/alter/{alter.xml
=> alter-table.xml} (76%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-cipher/ddl/create/{create.xml
=> create-index.xml} (62%)
create mode 100644
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-cipher/ddl/create/create-table.xml
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-cipher/dml/insert/{insert_column.xml
=> insert-column.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-cipher/dml/insert/{insert_on_duplicate.xml
=> insert-on-duplicate.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-cipher/dml/insert/{insert_set.xml
=> insert-set.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-cipher/dml/select/{select_group_by.xml
=> select-group-by.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-cipher/dml/select/{select_join.xml
=> select-join.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-cipher/dml/select/{select_order_by.xml
=> select-order-by.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-cipher/dml/select/{select_projection.xml
=> select-projection.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-cipher/dml/select/{select_subquery.xml
=> select-subquery.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-cipher/dml/select/{select_where.xml
=> select-where.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-plain/ddl/alter/{alter.xml
=> alter-table.xml} (59%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-plain/ddl/create/{create.xml
=> create-index.xml} (61%)
create mode 100644
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-plain/ddl/create/create-table.xml
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-plain/dml/insert/{insert_column.xml
=> insert-column.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-plain/dml/insert/{insert_on_duplicate.xml
=> insert-on-duplicate.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-plain/dml/insert/{insert_set.xml
=> insert-set.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-plain/dml/select/{select_group_by.xml
=> select-group-by.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-plain/dml/select/{select_join.xml
=> select-join.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-plain/dml/select/{select_order_by.xml
=> select-order-by.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-plain/dml/select/{select_projection.xml
=> select-projection.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-plain/dml/select/{select_subquery.xml
=> select-subquery.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/encrypt/case/query-with-plain/dml/select/{select_where.xml
=> select-where.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/mix/case/query-with-cipher/ddl/create/{create.xml
=> create-table.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/mix/case/query-with-cipher/dml/insert/{insert_column.xml
=> insert-column.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/mix/case/query-with-cipher/dml/insert/{insert_set.xml
=> insert-set.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/mix/case/query-with-cipher/dml/select/{select_join.xml
=> select-join.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/mix/case/query-with-cipher/dml/select/{select_projection.xml
=> select-projection.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/mix/case/query-with-cipher/dml/select/{select_subquery.xml
=> select-subquery.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/mix/case/query-with-cipher/dml/select/{select_where.xml
=> select-where.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/mix/case/query-with-plain/dml/select/{select_projection.xml
=> select-projection.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/mix/case/query-with-plain/dml/select/{select_where.xml
=> select-where.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/{
=> dal}/analyze.xml (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/{alter.xml
=> ddl/alter-table.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/{
=> ddl}/close.xml (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/{create.xml
=> ddl/create-table.xml} (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/{
=> ddl}/cursor.xml (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/{drop.xml
=> ddl/drop-table.xml} (100%)
create mode 100644
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/ddl/fetch.xml
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/{
=> ddl}/index.xml (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/{
=> ddl}/move.xml (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/{
=> ddl}/show.xml (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/{
=> dml}/copy.xml (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/{
=> dml}/delete.xml (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/{
=> dml}/insert.xml (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/{
=> dml}/select.xml (100%)
rename
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/{
=> dml}/update.xml (100%)
delete mode 100644
shardingsphere-test/shardingsphere-rewrite-test/src/test/resources/scenario/sharding/case/fetch.xml
