You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by me...@apache.org on 2021/08/14 18:34:09 UTC
[shardingsphere] branch master updated (e00c228 -> d6e424b)
This is an automated email from the ASF dual-hosted git repository.
menghaoran pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
from e00c228 Issue10973 (#11803)
add d6e424b Add ContextManager (#11822)
No new revisions were added by this update.
Summary of changes:
.../collector/MetaDataInfoCollector.java | 2 +-
...ataContexts.java => ClusterContextManager.java} | 127 +++++++++++----------
.../shardingsphere-infra-context/pom.xml | 5 +
.../infra/context/manager/ContextManager.java | 73 ++++++++++++
.../context/manager/impl/MemoryContextManager.java | 58 ++++++++++
.../manager/impl/StandaloneContextManager.java | 58 ++++++++++
.../jdbc/adapter/AbstractResultSetAdapter.java | 2 +-
.../core/connection/ShardingSphereConnection.java | 13 +--
.../core/datasource/ShardingSphereDataSource.java | 25 ++--
.../metadata/ShardingSphereDatabaseMetaData.java | 6 +-
.../statement/ShardingSpherePreparedStatement.java | 2 +-
.../core/statement/ShardingSphereStatement.java | 2 +-
.../api/ShardingSphereDataSourceFactoryTest.java | 82 -------------
.../driver/executor/AbstractBaseExecutorTest.java | 63 +++++-----
.../batch/BatchPreparedStatementExecutorTest.java | 3 +-
.../driver/jdbc/adapter/ConnectionAdapterTest.java | 6 +-
.../jdbc/adapter/PreparedStatementAdapterTest.java | 2 +-
.../driver/jdbc/adapter/StatementAdapterTest.java | 2 +-
.../connection/ShardingSphereConnectionTest.java | 25 ++--
.../datasource/ShardingSphereDataSourceTest.java | 2 +-
.../ShardingSphereDatabaseMetaDataTest.java | 9 +-
.../resultset/ShardingSphereResultSetTest.java | 8 +-
.../statement/EncryptPreparedStatementTest.java | 2 +-
.../jdbc/core/statement/EncryptStatementTest.java | 2 +-
.../UnsupportedOperationConnectionTest.java | 7 +-
.../UnsupportedOperationPreparedStatementTest.java | 2 +-
.../GovernanceShardingSphereDataSource.java | 40 +++----
.../governance/internal/state/DriverState.java | 9 +-
.../internal/state/DriverStateContext.java | 12 +-
.../state/impl/CircuitBreakDriverState.java | 6 +-
.../internal/state/impl/LockDriverState.java | 6 +-
.../internal/state/impl/OKDriverState.java | 8 +-
.../GovernanceShardingSphereDataSourceTest.java | 105 +----------------
.../internal/state/DriverStateContextTest.java | 30 +++--
.../state/impl/CircuitBreakDriverStateTest.java | 7 +-
.../internal/state/impl/OKDriverStateTest.java | 7 +-
.../spring/boot/SpringBootStarterTest.java | 6 +-
.../shardingsphere/spring/SpringNamespaceTest.java | 2 +-
.../type/GovernanceSpringBootEncryptTest.java | 10 +-
...GovernanceSpringBootReadwriteSplittingTest.java | 10 +-
.../GovernanceSpringBootRegistryEncryptTest.java | 10 +-
...ceSpringBootRegistryReadwriteSplittingTest.java | 8 +-
.../GovernanceSpringBootRegistryShardingTest.java | 26 ++---
.../type/GovernanceSpringBootShardingTest.java | 28 ++---
.../governance/GovernanceEncryptNamespaceTest.java | 10 +-
.../GovernanceReadwriteSplittingNamespaceTest.java | 10 +-
.../GovernanceShardingNamespaceTest.java | 22 ++--
...nceShardingReadwriteSplittingNamespaceTest.java | 11 +-
.../communication/DatabaseCommunicationEngine.java | 11 +-
.../backend/communication/ProxySQLExecutor.java | 8 +-
.../jdbc/connection/BackendConnection.java | 2 +-
.../jdbc/datasource/JDBCBackendDataSource.java | 8 +-
.../jdbc/executor/ProxyJDBCExecutor.java | 2 +-
.../callback/ProxyJDBCExecutorCallback.java | 8 +-
...ySQLStatementMemoryStrictlyFetchSizeSetter.java | 2 +-
...eSQLStatementMemoryStrictlyFetchSizeSetter.java | 2 +-
.../transaction/BackendTransactionManager.java | 2 +-
.../backend/context/BackendExecutorContext.java | 2 +-
.../proxy/backend/context/ProxyContext.java | 47 +++-----
.../text/TextProtocolBackendHandlerFactory.java | 8 +-
.../mysql/executor/ShowDatabasesExecutor.java | 15 ++-
.../admin/mysql/executor/UseDatabaseExecutor.java | 4 +-
.../database/CreateDatabaseBackendHandler.java | 3 +-
.../DatabaseOperateBackendHandlerFactory.java | 12 +-
.../text/database/DropDatabaseBackendHandler.java | 3 +-
.../ral/advanced/PrviewDistSQLBackendHandler.java | 2 +-
.../ral/common/HintDistSQLBackendHandler.java | 3 +-
.../text/distsql/rdl/RDLBackendHandlerFactory.java | 12 +-
.../rdl/resource/AddResourceBackendHandler.java | 3 +-
.../rdl/resource/DropResourceBackendHandler.java | 3 +-
.../rdl/rule/RuleDefinitionBackendHandler.java | 2 +-
.../explain/ShardingCTLExplainBackendHandler.java | 2 +-
.../sctl/hint/ShardingCTLHintBackendHandler.java | 2 +-
.../TextProtocolBackendHandlerFactoryTest.java | 28 ++---
.../DatabaseCommunicationEngineFactoryTest.java | 12 +-
.../DatabaseCommunicationEngineTest.java | 12 +-
.../jdbc/connection/BackendConnectionTest.java | 52 ++++-----
.../jdbc/datasource/JDBCBackendDataSourceTest.java | 39 +++----
.../transaction/BackendTransactionManagerTest.java | 16 ++-
.../context/BackendExecutorContextTest.java | 13 ++-
.../proxy/backend/context/ProxyContextTest.java | 63 ++++++----
.../DatabaseOperateBackendHandlerFactoryTest.java | 25 ++--
.../mysql/executor/ShowDatabasesExecutorTest.java | 14 ++-
.../mysql/executor/ShowTablesExecutorTest.java | 14 ++-
.../mysql/executor/UseDatabaseExecutorTest.java | 17 ++-
.../impl/BroadcastDatabaseBackendHandlerTest.java | 14 ++-
.../SchemaAssignedDatabaseBackendHandlerTest.java | 14 ++-
.../impl/UnicastDatabaseBackendHandlerTest.java | 14 ++-
.../database/CreateDatabaseBackendHandlerTest.java | 24 ++--
.../database/DropDatabaseBackendHandlerTest.java | 15 +--
.../distsql/DistSQLBackendHandlerFactoryTest.java | 43 ++++---
.../resource/AddResourceBackendHandlerTest.java | 15 +--
.../resource/DropResourceBackendHandlerTest.java | 18 ++-
.../text/distsql/rql/RQLBackendHandlerTest.java | 11 +-
.../ShardingCTLExplainBackendHandlerTest.java | 14 ++-
.../hint/ShardingCTLHintBackendHandlerTest.java | 22 ++--
.../sctl/set/ShardingCTLSetBackendHandlerTest.java | 15 ++-
.../transaction/TransactionBackendHandlerTest.java | 3 -
.../impl/AbstractBootstrapInitializer.java | 17 ++-
.../impl/ClusterBootstrapInitializer.java | 7 ++
.../impl/MemoryBootstrapInitializer.java | 7 ++
.../impl/StandaloneBootstrapInitializer.java | 7 ++
.../resources/conf/config-readwrite-splitting.yaml | 2 +-
.../netty/FrontendChannelInboundHandler.java | 3 +-
.../protocol/FrontDatabaseProtocolTypeFactory.java | 8 +-
.../proxy/frontend/state/impl/OKProxyState.java | 2 +-
.../FrontDatabaseProtocolTypeFactoryTest.java | 19 +--
.../mysql/command/MySQLCommandExecuteEngine.java | 2 +-
.../admin/initdb/MySQLComInitDbExecutor.java | 4 +-
.../execute/MySQLComStmtExecuteExecutor.java | 10 +-
.../prepare/MySQLComStmtPrepareExecutor.java | 4 +-
.../fieldlist/MySQLComFieldListPacketExecutor.java | 2 +-
.../frontend/mysql/MySQLFrontendEngineTest.java | 18 +--
.../MySQLAuthenticationEngineTest.java | 15 ++-
.../MySQLAuthenticationHandlerTest.java | 16 ++-
.../command/MySQLCommandExecutorFactoryTest.java | 14 ++-
.../execute/MySQLComStmtExecuteExecutorTest.java | 13 ++-
.../PostgreSQLAuthenticationHandler.java | 9 +-
.../command/PostgreSQLCommandExecuteEngine.java | 2 +-
.../command/query/binary/PostgreSQLPortal.java | 2 +-
.../binary/parse/PostgreSQLComParseExecutor.java | 2 +-
.../PostgreSQLAuthenticationEngineTest.java | 10 +-
.../PostgreSQLAuthenticationHandlerTest.java | 16 ++-
.../parse/PostgreSQLComParseExecutorTest.java | 14 ++-
.../test/integration/engine/it/BaseITCase.java | 4 +-
125 files changed, 1008 insertions(+), 887 deletions(-)
copy shardingsphere-governance/shardingsphere-governance-context/src/main/java/org/apache/shardingsphere/governance/context/{metadata/GovernanceMetaDataContexts.java => ClusterContextManager.java} (87%)
create mode 100644 shardingsphere-infra/shardingsphere-infra-context/src/main/java/org/apache/shardingsphere/infra/context/manager/ContextManager.java
create mode 100644 shardingsphere-infra/shardingsphere-infra-context/src/main/java/org/apache/shardingsphere/infra/context/manager/impl/MemoryContextManager.java
create mode 100644 shardingsphere-infra/shardingsphere-infra-context/src/main/java/org/apache/shardingsphere/infra/context/manager/impl/StandaloneContextManager.java
delete mode 100644 shardingsphere-jdbc/shardingsphere-jdbc-core/src/test/java/org/apache/shardingsphere/driver/api/ShardingSphereDataSourceFactoryTest.java