This is an automated email from the ASF dual-hosted git repository.
menghaoran pushed a change to branch opengauss_adapt
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
from 06fe196 Update OpenGaussDataSourceMetaData
add 5979e73 optimize mysql create & alter and drop table route logic
(#10414)
add 1c5c10a Add SchemaRegistryService (#10415)
add b23c8b7 Add TODO for DropShardingTableRuleBackendHandler (#10418)
add e2b611c Remove useless synchronized (#10422)
add 5bacfb1 Remove useless codes for RegistryCenter (#10423)
add 8080c24 Add DataSourceStatusRegistryService (#10425)
add a74aff2 Refactor EncryptRuleStatementConverter (#10424)
add 5f3a5fc Refactor exception for alter & drop readwrite splitting rule
(#10426)
add a5702a6 Move data source related event subscribe to
DataSourceRegistryService (#10427)
add b0a9f9e Move data source status related event subscribe to
DataSourceStatusRegistryService (#10428)
add c138848 Add etcd lock (#10391)
add 82fb0b8 Refactor exception for alter & drop db discovery rule (#10431)
add b74cf90 Add update from event test cases for
DataSourceStatusRegistryService (#10430)
add 5ba23e6 Move RuleConfigurationsAlteredEvent to
SchemaRuleRegistryService (#10432)
add 8749e70 Remove CalciteContextFactory and change API (#10433)
add 007b007 Refactor Oracle TCL test cases (#10435)
add 64d624f Move Metadata related event to SchemaRuleRegistryService
(#10445)
add 70a1145 Add ScalingRegistryService (#10447)
add 2cc4ac3 fixed #10421 (#10444)
add 8cc26a7 fix oracle meta data load error (#10448)
add 64e5dc9 Add assertion implementation for ExplainStatement (#10438)
add a28aba6 proofread the syntax definition of CREATE TABLE (#10383)
add c6383f1 Refactor exception for RDL (#10452)
add 427ec70 Add ProcessRegistrySubscriber (#10463)
add 081ad9e Add event bus register for SchemaRegistryService (#10459)
add 05f249e Add RQL for show sharding binding table rules (#10456)
add ce0a29c Move grant statement to GlobalRuleRegistryService (#10464)
add b838c6e Replace reflection with lambda in BackendConnection (#10466)
add 3e52fd7 Add RQL for show sharding broadcast table rules (#10467)
add 156fa6a Support Savepoint for Proxy (#10468)
add 0d99eab Add SPI register for rdl handler (#10473)
add e527a88 support postgresql alter table rename statement (#10462)
add 62d558f checked binding table rule (#10465)
add 510c5dc Show readwrite splitting & db discovery rules (#10479)
add dcc0eb3 Fix read binlog unsigned integer (#10478)
add 598ed47 Add all privileges permitted authority provider algorithm
(#10483)
add 77debda support mysql alter rename statement (#10487)
add d0ea924 minor refactor for RQL (#10488)
add 71a503d Fix the bug 'Exceeded the maximum number of open cursors'
(#10449) (#10471)
add 5d56d98 Refactor LocalTransactionManager (#10491)
add 83eb8e3 Show encrypt rules & show encrypt table rule (#10490)
add d8bb88e Refactor CreateReadwriteSplittingRuleBackendHandler (#10495)
add d6f897a fix exist projection subquery visit error (#10496)
add d470d44 Fix minor errors in sysbench documents (#10499)
add 384bd1d Proofread Oracle `SELECT` subquery clause (#10381)
add 630c1ef Fix #10497 minor refactor (#10498)
add f7dd88e add post validate for drop table statement (#10489)
add e18d3cf Show sharding table rules % show sharding table rule table
(#10503)
add 41f1335 Merge show encrypt rules and show encrypt table rule (#10506)
add c47772c Shutdown ExecutorService in SchemaBuilder (#10509)
add 024432e Split RegistryCenterNode to multiple nodes (#10511)
add bce69c7 Use daemon threads in SchemaBuilder (#10510)
add d298d51 Add line break to SchemaMetadataNodeTest.java (#10512)
add 128f726 Add more RQL parser tests in DistSQLStatementParserEngineTest
(#10508)
add 9aacab5 support pg alter index rename statement (#10502)
add fc7e2cd Minor refactor for RQL (#10516)
add d3c865c Update powered-by (#10517)
add 0071f20 Merge RegistryCenter.registerInstanceOnline and
initStateNodes (#10518)
add 8c9cd45 Refactor CreateEncryptRuleBackendHandler (#10520)
new cc158d5 Merge pull request #10523 from apache/master
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/community/content/powered-by/_index.cn.md | 3 +-
docs/community/content/powered-by/_index.en.md | 3 +-
.../test-engine/performance-test-sysbench.cn.md | 6 +-
.../test-engine/performance-test-sysbench.en.md | 6 +-
.../db/protocol/error/CommonErrorCode.java | 28 +-
.../db/protocol/error/CommonErrorCodeTest.java | 8 +-
.../integer/MySQLShortBinlogProtocolValue.java | 2 +-
.../integer/MySQLTinyBinlogProtocolValue.java | 2 +-
.../integer/MySQLShortBinlogProtocolValueTest.java | 9 +-
.../integer/MySQLTinyBinlogProtocolValueTest.java | 9 +-
.../src/main/antlr4/imports/RQLStatement.g4 | 32 +-
.../distsql/parser/autogen/DistSQLStatement.g4 | 7 +-
.../distsql/parser/core/DistSQLVisitor.java | 59 ++-
.../api/DistSQLStatementParserEngineTest.java | 91 +++++
.../show/ShowDatabaseDiscoveryRulesStatement.java | 17 +-
.../rql/show/ShowEncryptRulesStatement.java | 16 +-
.../show/ShowReadwriteSplittingRulesStatement.java | 17 +-
...wRuleStatement.java => ShowRulesStatement.java} | 10 +-
.../ShowShardingBindingTableRulesStatement.java | 17 +-
.../ShowShardingBroadcastTableRulesStatement.java | 17 +-
.../rql/show/ShowShardingTableRulesStatement.java | 18 +-
...ter.java => EncryptRuleStatementConverter.java} | 20 +-
...java => EncryptRuleStatementConverterTest.java} | 6 +-
.../shardingsphere/sharding/rule/ShardingRule.java | 10 +
.../sharding/rule/ShardingRuleTest.java | 10 +
.../src/test/resources/sharding/alter.xml | 136 +++----
.../src/test/resources/sharding/create.xml | 140 +++++++
.../src/test/resources/sharding/drop.xml | 140 +++++++
.../sharding/route/engine/ShardingSQLRouter.java | 2 +-
.../ShardingTableBroadcastRoutingEngine.java | 8 +-
.../type/single/SingleTablesRoutingEngine.java | 21 +-
.../validator/ShardingStatementValidator.java | 3 +-
.../ddl/ShardingDDLStatementValidator.java | 16 +
.../impl/ShardingAlterTableStatementValidator.java | 34 +-
.../impl/ShardingAlterViewStatementValidator.java | 2 +-
.../ShardingCreateFunctionStatementValidator.java | 2 +-
.../ShardingCreateProcedureStatementValidator.java | 2 +-
.../ShardingCreateTableStatementValidator.java | 7 +-
.../impl/ShardingCreateViewStatementValidator.java | 2 +-
.../impl/ShardingDropTableStatementValidator.java | 13 +-
.../impl/ShardingPrepareStatementValidator.java | 2 +-
.../dml/impl/ShardingDeleteStatementValidator.java | 2 +-
.../dml/impl/ShardingInsertStatementValidator.java | 2 +-
.../dml/impl/ShardingSelectStatementValidator.java | 2 +-
.../dml/impl/ShardingUpdateStatementValidator.java | 2 +-
.../ShardingTableBroadcastRoutingEngineTest.java | 7 +-
.../ShardingAlterTableStatementValidatorTest.java | 108 ++++--
.../ShardingCreateTableStatementValidatorTest.java | 86 ++++-
.../ShardingDropTableStatementValidatorTest.java | 84 ++++-
.../ddl/ShardingPrepareStatementValidatorTest.java | 6 +-
.../listener/PrivilegeNodeChangedListener.java | 4 +-
.../authority/listener/UserChangedListener.java | 4 +-
.../metadata/GovernanceMetaDataContexts.java | 18 +-
.../metadata/GovernanceMetaDataContextsTest.java | 2 +-
.../governance/core/facade/GovernanceFacade.java | 6 +-
.../governance/core/registry/RegistryCenter.java | 419 ++-------------------
.../core/registry/RegistryCenterNode.java | 389 -------------------
.../governance/core/registry/UserNode.java | 27 +-
.../governance/core/registry/cache/CacheNode.java} | 32 +-
.../registry/{ => cache}/RegistryCacheManager.java | 6 +-
.../registry/cache/ScalingRegistrySubscriber.java | 83 ++++
.../listener/impl/DataSourceChangedListener.java | 11 +-
.../impl/DataSourceStateChangedListener.java | 15 +-
.../listener/impl/GlobalRuleChangedListener.java | 4 +-
.../listener/impl/MetaDataChangedListener.java | 14 +-
.../listener/impl/PropertiesChangedListener.java | 6 +-
.../listener/impl/RuleChangedListener.java | 20 +-
.../listener/impl/SchemaChangedListener.java | 8 +-
.../impl/TerminalStateChangedListener.java | 6 +-
.../config/impl/DataSourceRegistryService.java | 45 ++-
.../config/impl/GlobalRuleRegistryService.java | 71 +++-
.../config/impl/PropertiesRegistryService.java | 10 +-
.../config/impl/SchemaRuleRegistryService.java | 29 +-
.../registry/service/config/node/GlobalNode.java | 36 +-
.../service/config/node/SchemaMetadataNode.java | 155 ++++++++
.../core/registry/service/process/ProcessNode.java | 33 +-
.../service/process/ProcessRegistrySubscriber.java | 109 ++++++
.../service/schema/SchemaRegistryService.java | 132 +++++++
.../state/DataSourceStatusRegistryService.java | 82 ++++
.../service/state/LockRegistryService.java | 6 +-
.../core/registry/service/state/StatesNode.java | 185 +++++++++
.../core/registry/util/SchemaNameUtil.java | 28 +-
.../core/facade/GovernanceFacadeTest.java | 4 +-
.../core/registry/RegistryCenterNodeTest.java | 134 -------
.../core/registry/RegistryCenterTest.java | 176 +--------
.../governance/core/registry/UserNodeTest.java | 17 +-
.../ScalingRegistrySubscriberTest.java} | 50 +--
.../config/impl/DataSourceRegistryServiceTest.java | 77 ++--
.../config/impl/SchemaRuleRegistryServiceTest.java | 10 +
.../service/config/node/GlobalNodeTest.java | 25 +-
.../config/node/SchemaMetadataNodeTest.java | 61 +++
.../service/schema/SchemaRegistryServiceTest.java | 152 ++++++++
.../state/DataSourceStatusRegistryServiceTest.java | 90 +++++
.../registry/service/state/StatesNodeTest.java | 84 +++++
.../test/resources/yaml/regcenter/data-source.yaml | 6 +
.../governance/repository/etcd/EtcdRepository.java | 34 +-
.../repository/etcd/props/EtcdPropertyKey.java | 7 +-
.../repository/etcd/EtcdRepositoryTest.java | 28 ++
...vilegesPermittedAuthorityProviderAlgorithm.java | 78 ++++
...gsphere.authority.spi.AuthorityProvideAlgorithm | 1 +
.../statement/ddl/AlterIndexStatementContext.java | 10 +-
.../statement/ddl/AlterTableStatementContext.java | 3 +
.../metadata/engine/MetadataRefresherFactory.java | 3 +
.../metadata/schema/builder/SchemaBuilder.java | 21 +-
.../builder/loader/ColumnMetaDataLoader.java | 3 +-
.../schema/builder/loader/IndexMetaDataLoader.java | 6 +
.../loader/dialect/H2TableMetaDataLoader.java | 3 +-
.../loader/dialect/MySQLTableMetaDataLoader.java | 3 +-
.../loader/dialect/OracleTableMetaDataLoader.java | 41 +-
.../dialect/PostgreSQLTableMetaDataLoader.java | 3 +-
.../dialect/SQLServerTableMetaDataLoader.java | 3 +-
.../loader/util/TableMetaDataLoaderUtil.java | 33 +-
.../type/AlterIndexStatementSchemaRefresher.java | 58 +++
.../type/AlterTableStatementSchemaRefresher.java | 27 +-
.../dialect/OracleTableMetaDataLoaderTest.java | 61 ++-
.../loader/util/TableMetaDataLoaderUtilTest.java | 37 +-
.../refresher/MetadataRefresherFactoryTest.java | 5 +-
.../AlterIndexStatementSchemaRefresherTest.java | 49 +++
.../AlterTableStatementSchemaRefresherTest.java | 72 +++-
.../infra/context/metadata/MetaDataContexts.java | 6 +-
.../metadata/impl/StandardMetaDataContexts.java | 6 +-
.../optimize/context/CalciteContextFactory.java | 50 ---
.../statement/ShardingSpherePreparedStatement.java | 4 +-
.../core/statement/ShardingSphereStatement.java | 4 +-
.../backend/communication/ProxySQLExecutor.java | 4 +-
.../jdbc/connection/BackendConnection.java | 10 +-
.../jdbc/connection/ConnectionPostProcessor.java} | 19 +-
.../transaction/BackendTransactionManager.java | 35 +-
.../transaction/ConnectionSavepointManager.java | 102 +++++
.../jdbc/transaction/LocalTransactionManager.java | 82 +++-
.../jdbc/transaction/TransactionManager.java | 24 ++
...DatabaseDiscoveryRulesNotExistedException.java} | 8 +-
...ption.java => DuplicateRuleNamesException.java} | 8 +-
.../exception/DuplicateTablesException.java | 3 +
.../exception/EncryptRulesNotExistedException.java | 2 +
...eadwriteSplittingRuleCreateExistsException.java | 33 --
...eadwriteSplittingRulesNotExistedException.java} | 10 +-
.../ShardingTableRuleNotExistedException.java | 4 +-
...java => ShardingTableRulesInUsedException.java} | 4 +-
.../AlterDatabaseDiscoveryRuleBackendHandler.java | 47 ++-
.../rdl/impl/AlterEncryptRuleBackendHandler.java | 22 +-
.../AlterReadwriteSplittingRuleBackendHandler.java | 34 +-
...terShardingBindingTableRulesBackendHandler.java | 34 +-
...rShardingBroadcastTableRulesBackendHandler.java | 4 +-
.../impl/AlterShardingTableRuleBackendHandler.java | 93 +++--
.../CreateDatabaseDiscoveryRuleBackendHandler.java | 5 +
.../rdl/impl/CreateEncryptRuleBackendHandler.java | 66 +++-
...CreateReadwriteSplittingRuleBackendHandler.java | 84 ++++-
...ateShardingBindingTableRulesBackendHandler.java | 34 +-
.../CreateShardingTableRuleBackendHandler.java | 13 +-
.../DropDatabaseDiscoveryRuleBackendHandler.java | 37 +-
.../rdl/impl/DropEncryptRuleBackendHandler.java | 8 +-
.../DropReadwriteSplittingRuleBackendHandler.java | 44 ++-
...ropShardingBindingTableRulesBackendHandler.java | 3 +-
...pShardingBroadcastTableRulesBackendHandler.java | 6 +-
.../impl/DropShardingTableRuleBackendHandler.java | 31 +-
.../text/distsql/rql/RQLBackendHandlerFactory.java | 49 ++-
.../DatabaseDiscoveryRulesQueryBackendHandler.java | 95 +++++
.../rql/impl/EncryptRulesQueryBackendHandler.java | 117 ++++++
...eadwriteSplittingRulesQueryBackendHandler.java} | 55 +--
.../distsql/rql/impl/RuleQueryBackendHandler.java | 94 -----
...ardingBindingTableRulesQueryBackendHandler.java | 83 ++++
...dingBroadcastTableRulesQueryBackendHandler.java | 80 ++++
.../rql/impl/ShardingRuleQueryBackendHandler.java | 157 --------
.../ShardingTableRulesQueryBackendHandler.java | 238 ++++++++++++
.../transaction/TransactionBackendHandler.java | 12 +
.../TransactionBackendHandlerFactory.java | 12 +
.../jdbc/connection/BackendConnectionTest.java | 28 +-
.../transaction/BackendTransactionManagerTest.java | 49 +++
.../text/distsql/RDLBackendHandlerFactoryTest.java | 6 +-
...terDatabaseDiscoveryRuleBackendHandlerTest.java | 9 +-
...erReadwriteSplittingRuleBackendHandlerTest.java | 9 +-
...rdingBroadcastTableRulesBackendHandlerTest.java | 4 +-
.../AlterShardingTableRuleBackendHandlerTest.java | 8 +-
.../impl/CreateEncryptRuleBackendHandlerTest.java | 13 +-
...teReadwriteSplittingRuleBackendHandlerTest.java | 45 ++-
.../CreateShardingTableRuleBackendHandlerTest.java | 21 +-
...ropDatabaseDiscoveryRuleBackendHandlerTest.java | 9 +-
...opReadwriteSplittingRuleBackendHandlerTest.java | 9 +-
...hardingBindingTableRulesBackendHandlerTest.java | 3 +-
...rdingBroadcastTableRulesBackendHandlerTest.java | 3 +-
.../DropShardingTableRuleBackendHandlerTest.java | 28 +-
...baseDiscoveryRulesQueryBackendHandlerTest.java} | 77 ++--
.../impl/EncryptRulesQueryBackendHandlerTest.java} | 90 ++---
...riteSplittingRulesQueryBackendHandlerTest.java} | 88 ++---
...gBindingTableRulesQueryBackendHandlerTest.java} | 79 ++--
...roadcastTableRulesQueryBackendHandlerTest.java} | 75 ++--
...ShardingTableRulesQueryBackendHandlerTest.java} | 94 ++---
.../src/test/resources/yaml/config-sharding.yaml | 51 +++
.../impl/GovernanceBootstrapInitializer.java | 2 +-
.../impl/GovernanceBootstrapInitializerTest.java | 15 +-
.../query/builder/ResponsePacketBuilder.java | 6 +-
.../frontend/mysql/err/MySQLErrPacketFactory.java | 55 +--
.../mysql/err/MySQLErrPacketFactoryTest.java | 10 +-
.../mysql/component/MySQLIncrementalDumper.java | 49 ++-
.../column/metadata/MySQLColumnMetaData.java | 18 +-
.../column/metadata/MySQLColumnMetaDataLoader.java | 59 ++-
.../column/value/UnsignedBigintHandler.java | 32 +-
.../component/column/value/UnsignedIntHandler.java | 27 +-
.../column/value/UnsignedMediumintHandler.java | 27 +-
.../column/value/UnsignedSmallintHandler.java | 27 +-
.../column/value/UnsignedTinyintHandler.java | 27 +-
.../mysql/component/column/value/ValueHandler.java | 28 +-
...aling.mysql.component.column.value.ValueHandler | 23 +-
.../column/value/UnsignedBigintHandlerTest.java | 20 +-
.../column/value/UnsignedIntHandlerTest.java | 27 +-
.../column/value/UnsignedMediumintHandlerTest.java | 35 +-
.../column/value/UnsignedSmallintHandlerTest.java | 19 +-
.../column/value/UnsignedTinyintHandlerTest.java | 35 +-
.../impl/MySQLDDLStatementSQLVisitor.java | 14 +
.../statement/impl/MySQLStatementSQLVisitor.java | 5 +
.../src/main/antlr4/imports/oracle/BaseRule.g4 | 16 +-
.../src/main/antlr4/imports/oracle/DMLStatement.g4 | 38 +-
.../main/antlr4/imports/oracle/OracleKeyword.g4 | 36 ++
.../impl/OracleDMLStatementSQLVisitor.java | 89 ++++-
.../sql/parser/autogen/PostgreSQLStatement.g4 | 2 +
.../impl/PostgreSQLDDLStatementSQLVisitor.java | 17 +
.../impl/PostgreSQLTCLStatementSQLVisitor.java | 25 +-
.../src/main/antlr4/imports/sqlserver/BaseRule.g4 | 3 +-
.../main/antlr4/imports/sqlserver/DDLStatement.g4 | 26 +-
.../antlr4/imports/sqlserver/SQLServerKeyword.g4 | 16 +
.../sql/parser/core/visitor/SQLVisitorRule.java | 6 +-
.../table/RenameTableDefinitionSegment.java} | 22 +-
.../common/segment/dml/predicate/LockSegment.java | 3 +
.../common/statement/ddl/AlterTableStatement.java | 12 +
.../statement/tcl/ReleaseSavepointStatement.java | 13 +-
.../tcl/RollbackToSavepointStatement.java | 17 +-
.../common/statement/tcl/SavepointStatement.java | 6 +
.../handler/ddl/AlterIndexStatementHandler.java | 16 +
.../ddl/PostgreSQLAlterIndexStatement.java | 16 +
.../PostgreSQLReleaseSavepointStatement.java} | 10 +-
.../PostgreSQLRollbackToSavepointStatement.java} | 10 +-
.../ddl/AlterIndexStatementHandlerTest.java | 17 +
.../asserts/segment/lock/LockClauseAssert.java | 15 +-
.../statement/dal/impl/ExplainStatementAssert.java | 19 +
.../ddl/impl/AlterTableStatementAssert.java | 15 +
.../segment/impl/lock/ExpectedLockClause.java | 4 +
.../statement/dal/ExplainStatementTestCase.java | 23 ++
.../statement/ddl/AlterTableStatementTestCase.java | 3 +
.../src/main/resources/case/dal/explain.xml | 91 +++++
.../src/main/resources/case/ddl/alter-table.xml | 6 +
.../src/main/resources/case/dml/select-lock.xml | 25 ++
.../main/resources/case/dml/select-order-by.xml | 39 ++
.../main/resources/case/dml/select-pagination.xml | 13 +
.../main/resources/case/dml/select-sub-query.xml | 17 +
.../{dml/select-sub-query.xml => dal/explain.xml} | 9 +-
.../src/main/resources/sql/supported/ddl/alter.xml | 3 +-
.../resources/sql/supported/dml/select-lock.xml | 2 +
.../sql/supported/dml/select-order-by.xml | 2 +
.../sql/supported/dml/select-pagination.xml | 1 +
.../sql/supported/dml/select-sub-query.xml | 7 +-
.../begin-transcation.xml} | 11 +-
.../main/resources/sql/supported/tcl/commit.xml | 30 ++
.../{dml/select-sub-query.xml => tcl/rollback.xml} | 12 +-
.../select-sub-query.xml => tcl/savepoint.xml} | 6 +-
.../set-auto-commit.xml} | 11 +-
.../sql/supported/tcl/set-transaction.xml | 33 ++
.../src/main/resources/sql/supported/tcl/tcl.xml | 63 ----
.../transaction/core/TransactionOperationType.java | 2 +-
259 files changed, 5811 insertions(+), 3122 deletions(-)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/EncryptRuleExistsException.java
=>
shardingsphere-distsql-parser/shardingsphere-distsql-parser-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rql/show/ShowDatabaseDiscoveryRulesStatement.java
(67%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/DatabaseDiscoveryRuleNotExistedException.java
=>
shardingsphere-distsql-parser/shardingsphere-distsql-parser-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rql/show/ShowEncryptRulesStatement.java
(65%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/EncryptRuleExistsException.java
=>
shardingsphere-distsql-parser/shardingsphere-distsql-parser-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rql/show/ShowReadwriteSplittingRulesStatement.java
(67%)
rename
shardingsphere-distsql-parser/shardingsphere-distsql-parser-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rql/show/{ShowRuleStatement.java
=> ShowRulesStatement.java} (87%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/DatabaseDiscoveryRuleNotExistedException.java
=>
shardingsphere-distsql-parser/shardingsphere-distsql-parser-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rql/show/ShowShardingBindingTableRulesStatement.java
(67%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/DatabaseDiscoveryRuleNotExistedException.java
=>
shardingsphere-distsql-parser/shardingsphere-distsql-parser-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rql/show/ShowShardingBroadcastTableRulesStatement.java
(66%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/EncryptRulesNotExistedException.java
=>
shardingsphere-distsql-parser/shardingsphere-distsql-parser-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/rql/show/ShowShardingTableRulesStatement.java
(64%)
rename
shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-common/src/main/java/org/apache/shardingsphere/encrypt/yaml/converter/{EncryptRuleConverter.java
=> EncryptRuleStatementConverter.java} (82%)
rename
shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-common/src/test/java/org/apache/shardingsphere/encrypt/yaml/converter/{EncryptRuleConverterTest.java
=> EncryptRuleStatementConverterTest.java} (96%)
create mode 100644
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-rewrite/src/test/resources/sharding/create.xml
create mode 100644
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-rewrite/src/test/resources/sharding/drop.xml
delete mode 100644
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/RegistryCenterNode.java
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/ShardingTableRuleExistedException.java
=>
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/UserNode.java
(63%)
copy
shardingsphere-governance/{shardingsphere-governance-repository/shardingsphere-governance-repository-provider/shardingsphere-governance-repository-etcd/src/main/java/org/apache/shardingsphere/governance/repository/etcd/props/EtcdPropertyKey.java
=>
shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/cache/CacheNode.java}
(61%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{
=> cache}/RegistryCacheManager.java (92%)
create mode 100644
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/cache/ScalingRegistrySubscriber.java
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/transaction/TransactionManager.java
=>
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/service/config/node/GlobalNode.java
(54%)
create mode 100644
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/service/config/node/SchemaMetadataNode.java
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/asserts/statement/dal/impl/ExplainStatementAssert.java
=>
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/service/process/ProcessNode.java
(53%)
create mode 100644
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/service/process/ProcessRegistrySubscriber.java
create mode 100644
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/service/schema/SchemaRegistryService.java
create mode 100644
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/service/state/DataSourceStatusRegistryService.java
create mode 100644
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/service/state/StatesNode.java
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/ReadwriteSplittingRuleDataSourcesNotExistedException.java
=>
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/util/SchemaNameUtil.java
(54%)
delete mode 100644
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/RegistryCenterNodeTest.java
copy
shardingsphere-transaction/shardingsphere-transaction-core/src/main/java/org/apache/shardingsphere/transaction/core/TransactionOperationType.java
=>
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/UserNodeTest.java
(71%)
copy
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/{service/config/impl/SchemaRuleRegistryServiceTest.java
=> cache/ScalingRegistrySubscriberTest.java} (55%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/ShardingTableRuleNotExistedException.java
=>
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/service/config/node/GlobalNodeTest.java
(63%)
create mode 100644
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/service/config/node/SchemaMetadataNodeTest.java
create mode 100644
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/service/schema/SchemaRegistryServiceTest.java
create mode 100644
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/service/state/DataSourceStatusRegistryServiceTest.java
create mode 100644
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/service/state/StatesNodeTest.java
create mode 100644
shardingsphere-infra/shardingsphere-infra-authority/shardingsphere-infra-authority-common/src/main/java/org/apache/shardingsphere/authority/provider/simple/AllPrivilegesPermittedAuthorityProviderAlgorithm.java
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/connection/MethodInvocation.java
=>
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/metadata/schema/builder/loader/util/TableMetaDataLoaderUtil.java
(54%)
create mode 100644
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/metadata/schema/refresher/type/AlterIndexStatementSchemaRefresher.java
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/connection/MethodInvocation.java
=>
shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/builder/loader/util/TableMetaDataLoaderUtilTest.java
(55%)
create mode 100644
shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/refresher/type/AlterIndexStatementSchemaRefresherTest.java
delete mode 100644
shardingsphere-infra/shardingsphere-infra-executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/optimize/context/CalciteContextFactory.java
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/{exception/ShardingRuleNotExistedException.java
=> communication/jdbc/connection/ConnectionPostProcessor.java} (70%)
create mode 100644
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/transaction/ConnectionSavepointManager.java
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/{DatabaseDiscoveryRuleNotExistedException.java
=> DatabaseDiscoveryRulesNotExistedException.java} (83%)
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/{DatabaseDiscoveryRuleDataSourcesNotExistedException.java
=> DuplicateRuleNamesException.java} (81%)
delete mode 100644
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/ReadwriteSplittingRuleCreateExistsException.java
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/{ReadwriteSplittingRuleDataSourcesNotExistedException.java
=> ReadwriteSplittingRulesNotExistedException.java} (80%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/{TablesInUsedException.java
=> ShardingTableRulesInUsedException.java} (90%)
create mode 100644
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rql/impl/DatabaseDiscoveryRulesQueryBackendHandler.java
create mode 100644
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rql/impl/EncryptRulesQueryBackendHandler.java
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rql/impl/{ReadwriteSplittingRuleQueryBackendHandler.java
=> ReadwriteSplittingRulesQueryBackendHandler.java} (53%)
delete mode 100644
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rql/impl/RuleQueryBackendHandler.java
create mode 100644
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rql/impl/ShardingBindingTableRulesQueryBackendHandler.java
create mode 100644
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rql/impl/ShardingBroadcastTableRulesQueryBackendHandler.java
delete mode 100644
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rql/impl/ShardingRuleQueryBackendHandler.java
create mode 100644
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rql/impl/ShardingTableRulesQueryBackendHandler.java
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/distsql/{rdl/impl/DropDatabaseDiscoveryRuleBackendHandlerTest.java
=> rql/impl/DatabaseDiscoveryRulesQueryBackendHandlerTest.java} (56%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/distsql/{rdl/impl/DropShardingBroadcastTableRulesBackendHandlerTest.java
=> rql/impl/EncryptRulesQueryBackendHandlerTest.java} (51%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/distsql/{rdl/impl/DropReadwriteSplittingRuleBackendHandlerTest.java
=> rql/impl/ReadwriteSplittingRulesQueryBackendHandlerTest.java} (53%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/distsql/{rdl/impl/CreateShardingTableRuleBackendHandlerTest.java
=> rql/impl/ShardingBindingTableRulesQueryBackendHandlerTest.java} (54%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/distsql/{rdl/impl/AlterShardingBroadcastTableRulesBackendHandlerTest.java
=> rql/impl/ShardingBroadcastTableRulesQueryBackendHandlerTest.java} (57%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/distsql/{rdl/impl/DropShardingBindingTableRulesBackendHandlerTest.java
=> rql/impl/ShardingTableRulesQueryBackendHandlerTest.java} (53%)
create mode 100644
shardingsphere-proxy/shardingsphere-proxy-backend/src/test/resources/yaml/config-sharding.yaml
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/ShardingTableRuleExistedException.java
=>
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/column/metadata/MySQLColumnMetaData.java
(72%)
copy
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/metadata/schema/builder/loader/ColumnMetaDataLoader.java
=>
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/column/metadata/MySQLColumnMetaDataLoader.java
(60%)
copy
shardingsphere-governance/shardingsphere-governance-repository/shardingsphere-governance-repository-provider/shardingsphere-governance-repository-etcd/src/main/java/org/apache/shardingsphere/governance/repository/etcd/props/EtcdPropertyKey.java
=>
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/column/value/UnsignedBigintHandler.java
(58%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/ShardingTableRuleExistedException.java
=>
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/column/value/UnsignedIntHandler.java
(62%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/ShardingTableRuleExistedException.java
=>
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/column/value/UnsignedMediumintHandler.java
(61%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/ShardingTableRuleExistedException.java
=>
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/column/value/UnsignedSmallintHandler.java
(61%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/ShardingTableRuleExistedException.java
=>
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/column/value/UnsignedTinyintHandler.java
(61%)
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/TablesInUsedException.java
=>
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/column/value/ValueHandler.java
(66%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/test/resources/yaml/regcenter/data-source-init-sql.yaml
=>
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/resources/META-INF/services/org.apache.shardingsphere.scaling.mysql.component.column.value.ValueHandler
(58%)
copy
shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/connection/MethodInvocationTest.java
=>
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/column/value/UnsignedBigintHandlerTest.java
(59%)
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/ShardingTableRuleExistedException.java
=>
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/column/value/UnsignedIntHandlerTest.java
(60%)
copy
shardingsphere-governance/shardingsphere-governance-repository/shardingsphere-governance-repository-provider/shardingsphere-governance-repository-etcd/src/main/java/org/apache/shardingsphere/governance/repository/etcd/props/EtcdPropertyKey.java
=>
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/column/value/UnsignedMediumintHandlerTest.java
(59%)
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/connection/MethodInvocationTest.java
=>
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/column/value/UnsignedSmallintHandlerTest.java
(59%)
copy
shardingsphere-governance/shardingsphere-governance-repository/shardingsphere-governance-repository-provider/shardingsphere-governance-repository-etcd/src/main/java/org/apache/shardingsphere/governance/repository/etcd/props/EtcdPropertyKey.java
=>
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/column/value/UnsignedTinyintHandlerTest.java
(59%)
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/segment/{dml/predicate/LockSegment.java
=> ddl/table/RenameTableDefinitionSegment.java} (78%)
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/ReadwriteSplittingRuleNotExistedException.java
=>
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/tcl/ReleaseSavepointStatement.java
(70%)
rename
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/exception/EncryptRuleExistsException.java
=>
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/tcl/RollbackToSavepointStatement.java
(69%)
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/statement/postgresql/{ddl/PostgreSQLAlterIndexStatement.java
=> tcl/PostgreSQLReleaseSavepointStatement.java} (82%)
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/statement/postgresql/{ddl/PostgreSQLAlterIndexStatement.java
=> tcl/PostgreSQLRollbackToSavepointStatement.java} (81%)
create mode 100644
shardingsphere-sql-parser/shardingsphere-sql-parser-test/src/main/resources/case/dal/explain.xml
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-test/src/main/resources/sql/supported/{dml/select-sub-query.xml
=> dal/explain.xml} (54%)
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-test/src/main/resources/sql/supported/{dml/select-sub-query.xml
=> tcl/begin-transcation.xml} (54%)
create mode 100644
shardingsphere-sql-parser/shardingsphere-sql-parser-test/src/main/resources/sql/supported/tcl/commit.xml
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-test/src/main/resources/sql/supported/{dml/select-sub-query.xml
=> tcl/rollback.xml} (54%)
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-test/src/main/resources/sql/supported/{dml/select-sub-query.xml
=> tcl/savepoint.xml} (54%)
copy
shardingsphere-sql-parser/shardingsphere-sql-parser-test/src/main/resources/sql/supported/{dml/select-sub-query.xml
=> tcl/set-auto-commit.xml} (54%)
create mode 100644
shardingsphere-sql-parser/shardingsphere-sql-parser-test/src/main/resources/sql/supported/tcl/set-transaction.xml
delete mode 100644
shardingsphere-sql-parser/shardingsphere-sql-parser-test/src/main/resources/sql/supported/tcl/tcl.xml
