Skip to content

Commit 102f856

Browse files
terrymanuterrymanu
authored
Refactor PersistServiceFacade (#34996)
1 parent 211c29c commit 102f856

File tree

61 files changed

+105
-105
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

61 files changed

+105
-105
lines changed

‎features/broadcast/distsql/handler/src/test/java/org/apache/shardingsphere/broadcast/distsql/handler/update/CreateBroadcastTableRuleExecutorTest.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ void assertExecuteUpdateWithIfNotExists() throws SQLException {
7171
when(rule.getTables()).thenReturn(Collections.singleton("foo_tbl"));
7272
ContextManager contextManager = mockContextManager(database, rule);
7373
new DistSQLUpdateExecuteEngine(sqlStatement, "foo_db", contextManager).executeUpdate();
74-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
74+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
7575
verify(metaDataManagerPersistService).alterRuleConfiguration(any(),
7676
ArgumentMatchers.<BroadcastRuleConfiguration>argThat(x -> x.getTables().equals(new HashSet<>(Arrays.asList("foo_tbl", "bar_tbl")))));
7777
}
@@ -84,7 +84,7 @@ void assertExecuteUpdateWithoutIfNotExists() throws SQLException {
8484
when(rule.getTables()).thenReturn(Collections.singleton("foo_tbl"));
8585
ContextManager contextManager = mockContextManager(database, rule);
8686
new DistSQLUpdateExecuteEngine(sqlStatement, "foo_db", contextManager).executeUpdate();
87-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
87+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
8888
verify(metaDataManagerPersistService).alterRuleConfiguration(any(),
8989
ArgumentMatchers.<BroadcastRuleConfiguration>argThat(x -> x.getTables().equals(new HashSet<>(Arrays.asList("foo_tbl", "bar_tbl")))));
9090
}
@@ -95,7 +95,7 @@ void assertExecuteUpdateWithoutExistedRule() throws SQLException {
9595
ShardingSphereDatabase database = mock(ShardingSphereDatabase.class, RETURNS_DEEP_STUBS);
9696
ContextManager contextManager = mockContextManager(database, null);
9797
new DistSQLUpdateExecuteEngine(sqlStatement, "foo_db", contextManager).executeUpdate();
98-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
98+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
9999
verify(metaDataManagerPersistService).alterRuleConfiguration(any(),
100100
ArgumentMatchers.<BroadcastRuleConfiguration>argThat(x -> x.getTables().equals(new HashSet<>(Arrays.asList("foo_tbl", "bar_tbl")))));
101101
}

‎features/broadcast/distsql/handler/src/test/java/org/apache/shardingsphere/broadcast/distsql/handler/update/DropBroadcastTableRuleExecutorTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ void assertExecuteUpdate() throws SQLException {
5757
when(rule.getConfiguration().getTables()).thenReturn(Collections.singleton("foo_tbl"));
5858
ContextManager contextManager = mockContextManager(database, rule);
5959
new DistSQLUpdateExecuteEngine(sqlStatement, "foo_db", contextManager).executeUpdate();
60-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
60+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
6161
verify(metaDataManagerPersistService).removeRuleConfiguration(database, "broadcast");
6262
}
6363

‎features/encrypt/distsql/handler/src/test/java/org/apache/shardingsphere/encrypt/distsql/handler/update/AlterEncryptRuleExecutorTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ void assertExecuteUpdateWithAssistQueryAndLikeColumns() throws SQLException {
8888
when(rule.getAllTableNames()).thenReturn(Collections.singleton("t_encrypt"));
8989
when(rule.getConfiguration()).thenReturn(createCurrentRuleConfiguration());
9090
ContextManager contextManager = mockContextManager(rule);
91-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
91+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
9292
new DistSQLUpdateExecuteEngine(createSQLStatementWithAssistQueryAndLikeColumns(), "foo_db", contextManager).executeUpdate();
9393
metaDataManagerPersistService.removeRuleConfigurationItem(any(), ArgumentMatchers.argThat(this::assertToBeDroppedRuleConfiguration));
9494
metaDataManagerPersistService.alterRuleConfiguration(any(), ArgumentMatchers.argThat(this::assertToBeAlteredRuleConfiguration));
@@ -101,7 +101,7 @@ void assertExecuteUpdateWithoutAssistQueryAndLikeColumns() throws SQLException {
101101
when(rule.getConfiguration()).thenReturn(createCurrentRuleConfiguration());
102102
ContextManager contextManager = mockContextManager(rule);
103103
new DistSQLUpdateExecuteEngine(createSQLStatementWithoutAssistQueryAndLikeColumns(), "foo_db", contextManager).executeUpdate();
104-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
104+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
105105
metaDataManagerPersistService.removeRuleConfigurationItem(any(), ArgumentMatchers.argThat(this::assertToBeDroppedRuleConfiguration));
106106
metaDataManagerPersistService.alterRuleConfiguration(any(), ArgumentMatchers.argThat(this::assertToBeAlteredRuleConfiguration));
107107
}

‎features/encrypt/distsql/handler/src/test/java/org/apache/shardingsphere/encrypt/distsql/handler/update/CreateEncryptRuleExecutorTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ void assertExecuteUpdateWithIfNotExists() throws SQLException {
103103
CreateEncryptRuleStatement sqlStatement = createAESEncryptRuleSQLStatement(true);
104104
ContextManager contextManager = mockContextManager(rule);
105105
new DistSQLUpdateExecuteEngine(sqlStatement, "foo_db", contextManager).executeUpdate();
106-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
106+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
107107
metaDataManagerPersistService.alterRuleConfiguration(any(), ArgumentMatchers.argThat(this::assertIfNotExistsRuleConfiguration));
108108
}
109109

‎features/encrypt/distsql/handler/src/test/java/org/apache/shardingsphere/encrypt/distsql/handler/update/DropEncryptRuleExecutorTest.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ void assertExecuteUpdate() throws SQLException {
6868
when(rule.getConfiguration()).thenReturn(ruleConfig);
6969
ContextManager contextManager = mockContextManager(rule);
7070
new DistSQLUpdateExecuteEngine(createSQLStatement("T_ENCRYPT"), "foo_db", contextManager).executeUpdate();
71-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
71+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
7272
metaDataManagerPersistService.alterRuleConfiguration(any(), ArgumentMatchers.argThat(this::assertRuleConfiguration));
7373
}
7474

@@ -86,7 +86,7 @@ void assertExecuteUpdateWithInUsedEncryptor() throws SQLException {
8686
when(rule.getAllTableNames().contains(anyString())).thenReturn(true);
8787
ContextManager contextManager = mockContextManager(rule);
8888
new DistSQLUpdateExecuteEngine(createSQLStatement("T_ENCRYPT"), "foo_db", contextManager).executeUpdate();
89-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
89+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
9090
metaDataManagerPersistService.alterRuleConfiguration(any(), ArgumentMatchers.argThat(this::assertRuleConfigurationWithoutEncryptors));
9191
}
9292

@@ -104,7 +104,7 @@ void assertExecuteUpdateWithIfExists() throws SQLException {
104104
when(rule.getAllTableNames().contains(anyString())).thenReturn(true);
105105
ContextManager contextManager = mockContextManager(rule);
106106
new DistSQLUpdateExecuteEngine(statement, "foo_db", contextManager).executeUpdate();
107-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
107+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
108108
metaDataManagerPersistService.alterRuleConfiguration(any(), ArgumentMatchers.argThat(this::assertRuleConfigurationWithoutEncryptors));
109109
}
110110

‎features/mask/distsql/handler/src/test/java/org/apache/shardingsphere/mask/distsql/handler/update/AlterMaskRuleExecutorTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ void assertExecuteUpdate() throws SQLException {
6767
when(rule.getConfiguration()).thenReturn(currentRuleConfig);
6868
ContextManager contextManager = mockContextManager(rule);
6969
new DistSQLUpdateExecuteEngine(sqlStatement, "foo_db", contextManager).executeUpdate();
70-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
70+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
7171
metaDataManagerPersistService.removeRuleConfigurationItem(any(), ArgumentMatchers.argThat(this::assertToBeDroppedRuleConfiguration));
7272
metaDataManagerPersistService.alterRuleConfiguration(any(), ArgumentMatchers.argThat(this::assertToBeAlteredRuleConfiguration));
7373
}

‎features/mask/distsql/handler/src/test/java/org/apache/shardingsphere/mask/distsql/handler/update/CreateMaskRuleExecutorTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ void assertExecuteUpdateWithoutIfNotExists() throws SQLException {
6565
when(rule.getConfiguration()).thenReturn(currentRuleConfig);
6666
ContextManager contextManager = mockContextManager(rule);
6767
new DistSQLUpdateExecuteEngine(sqlStatement, "foo_db", contextManager).executeUpdate();
68-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
68+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
6969
metaDataManagerPersistService.alterRuleConfiguration(any(), ArgumentMatchers.argThat(this::assertRuleConfiguration));
7070
}
7171

@@ -77,7 +77,7 @@ void assertExecuteUpdateWithIfNotExists() throws SQLException {
7777
when(rule.getConfiguration()).thenReturn(currentRuleConfig);
7878
ContextManager contextManager = mockContextManager(rule);
7979
new DistSQLUpdateExecuteEngine(sqlStatement, "foo_db", contextManager).executeUpdate();
80-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
80+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
8181
metaDataManagerPersistService.alterRuleConfiguration(any(), ArgumentMatchers.argThat(this::assertRuleConfiguration));
8282
}
8383

‎features/mask/distsql/handler/src/test/java/org/apache/shardingsphere/mask/distsql/handler/update/DropMaskRuleExecutorTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ void assertExecuteUpdateWithoutIfExists() throws SQLException {
6060
when(rule.getConfiguration()).thenReturn(ruleConfig);
6161
ContextManager contextManager = mockContextManager(rule);
6262
new DistSQLUpdateExecuteEngine(createSQLStatement(false, "T_MASK"), "foo_db", contextManager).executeUpdate();
63-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
63+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
6464
metaDataManagerPersistService.alterRuleConfiguration(any(), ArgumentMatchers.argThat(this::assertRuleConfigurationWithoutIfExists));
6565
}
6666

@@ -78,7 +78,7 @@ void assertExecuteUpdateWithIfExists() throws SQLException {
7878
when(rule.getConfiguration()).thenReturn(ruleConfig);
7979
ContextManager contextManager = mockContextManager(rule);
8080
new DistSQLUpdateExecuteEngine(createSQLStatement(true, "T_USER"), "foo_db", contextManager).executeUpdate();
81-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
81+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
8282
metaDataManagerPersistService.alterRuleConfiguration(any(), ArgumentMatchers.argThat(this::assertRuleConfigurationWithoutIfExists));
8383
metaDataManagerPersistService.alterRuleConfiguration(any(), ArgumentMatchers.argThat(this::assertRuleConfigurationWithIfExists));
8484
}

‎features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/listener/ReadwriteSplittingContextManagerLifecycleListener.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ public void onDestroyed(final ContextManager contextManager) {
4343
}
4444

4545
private void updateQualifiedDataSourceState(final ContextManager contextManager) {
46-
Map<String, QualifiedDataSourceState> qualifiedDataSourceStateMap = contextManager.getPersistServiceFacade().getQualifiedDataSourceStatePersistService().load();
46+
Map<String, QualifiedDataSourceState> qualifiedDataSourceStateMap = contextManager.getPersistServiceFacade().getQualifiedDataSourceStateService().load();
4747
qualifiedDataSourceStateMap.forEach((key, value) -> updateQualifiedDataSourceState(contextManager.getMetaDataContexts().getMetaData(), new QualifiedDataSource(key), value));
4848
}
4949

‎features/readwrite-splitting/distsql/handler/src/main/java/org/apache/shardingsphere/readwritesplitting/distsql/handler/update/AlterReadwriteSplittingStorageUnitStatusExecutor.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ private void checkBeforeUpdate(final AlterReadwriteSplittingStorageUnitStatusSta
7474

7575
private void updateStatus(final ContextManager contextManager, final AlterReadwriteSplittingStorageUnitStatusStatement sqlStatement) {
7676
DataSourceState status = sqlStatement.isEnable() ? DataSourceState.ENABLED : DataSourceState.DISABLED;
77-
contextManager.getPersistServiceFacade().getQualifiedDataSourceStatePersistService().update(database.getName(), sqlStatement.getRuleName(), sqlStatement.getStorageUnitName(), status);
77+
contextManager.getPersistServiceFacade().getQualifiedDataSourceStateService().update(database.getName(), sqlStatement.getRuleName(), sqlStatement.getStorageUnitName(), status);
7878
}
7979

8080
@Override

‎infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/update/rdl/rule/engine/database/type/AlterDatabaseRuleOperator.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ public final class AlterDatabaseRuleOperator implements DatabaseRuleOperator {
4848
@SuppressWarnings("unchecked")
4949
public void operate(final DatabaseRuleDefinitionStatement sqlStatement, final ShardingSphereDatabase database, final RuleConfiguration currentRuleConfig) throws SQLException {
5050
RuleConfiguration toBeAlteredRuleConfig = executor.buildToBeAlteredRuleConfiguration(sqlStatement);
51-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
51+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
5252
metaDataManagerPersistService.alterRuleConfiguration(database, decorateRuleConfiguration(database, toBeAlteredRuleConfig));
5353
RuleConfiguration toBeDroppedRuleConfig = executor.buildToBeDroppedRuleConfiguration(toBeAlteredRuleConfig);
5454
metaDataManagerPersistService.removeRuleConfigurationItem(database, toBeDroppedRuleConfig);

‎infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/update/rdl/rule/engine/database/type/CreateDatabaseRuleOperator.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ public final class CreateDatabaseRuleOperator implements DatabaseRuleOperator {
4848
@SuppressWarnings("unchecked")
4949
public void operate(final DatabaseRuleDefinitionStatement sqlStatement, final ShardingSphereDatabase database, final RuleConfiguration currentRuleConfig) throws SQLException {
5050
RuleConfiguration toBeCreatedRuleConfig = executor.buildToBeCreatedRuleConfiguration(sqlStatement);
51-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
51+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
5252
metaDataManagerPersistService.alterRuleConfiguration(database, decorateRuleConfiguration(database, toBeCreatedRuleConfig));
5353
}
5454

‎infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/update/rdl/rule/engine/database/type/DropDatabaseRuleOperator.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ public void operate(final DatabaseRuleDefinitionStatement sqlStatement, final Sh
6060
}
6161
// TODO refactor to new metadata refresh way
6262
}
63-
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService();
63+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService();
6464
RuleConfiguration toBeDroppedRuleConfig = executor.buildToBeDroppedRuleConfiguration(sqlStatement);
6565
metaDataManagerPersistService.removeRuleConfigurationItem(database, toBeDroppedRuleConfig);
6666
RuleConfiguration toBeAlteredRuleConfig = executor.buildToBeAlteredRuleConfiguration(sqlStatement);

‎infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/update/rdl/rule/engine/global/GlobalRuleDefinitionExecuteEngine.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ public void executeUpdate() throws SQLException {
4848
ShardingSphereRule rule = contextManager.getMetaDataContexts().getMetaData().getGlobalRuleMetaData().getSingleRule(executor.getRuleClass());
4949
executor.setRule(rule);
5050
executor.checkBeforeUpdate(sqlStatement);
51-
contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService()
51+
contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService()
5252
.alterGlobalRuleConfiguration(executor.buildToBeAlteredRuleConfiguration(sqlStatement));
5353
}
5454
}

‎infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/executor/rdl/resource/AlterStorageUnitExecutor.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ public void executeUpdate(final AlterStorageUnitStatement sqlStatement, final Co
6666
Map<String, DataSourcePoolProperties> propsMap = DataSourceSegmentsConverter.convert(database.getProtocolType(), sqlStatement.getStorageUnits());
6767
validateHandler.validate(propsMap, getExpectedPrivileges(sqlStatement));
6868
try {
69-
contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService().alterStorageUnits(database, propsMap);
69+
contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService().alterStorageUnits(database, propsMap);
7070
} catch (final ShardingSphereExternalException ex) {
7171
throw new StorageUnitsOperateException("alter", propsMap.keySet(), ex);
7272
}

‎infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/executor/rdl/resource/RegisterStorageUnitExecutor.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ public void executeUpdate(final RegisterStorageUnitStatement sqlStatement, final
6767
}
6868
validateHandler.validate(propsMap, getExpectedPrivileges(sqlStatement));
6969
try {
70-
contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService().registerStorageUnits(database.getName(), propsMap);
70+
contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService().registerStorageUnits(database.getName(), propsMap);
7171
} catch (final ShardingSphereExternalException ex) {
7272
throw new StorageUnitsOperateException("register", propsMap.keySet(), ex);
7373
}

‎infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/executor/rdl/resource/UnregisterStorageUnitExecutor.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ public void executeUpdate(final UnregisterStorageUnitStatement sqlStatement, fin
5656
}
5757
checkInUsed(sqlStatement);
5858
try {
59-
contextManager.getPersistServiceFacade().getModePersistServiceFacade().getMetaDataManagerPersistService().unregisterStorageUnits(database, sqlStatement.getStorageUnitNames());
59+
contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService().unregisterStorageUnits(database, sqlStatement.getStorageUnitNames());
6060
} catch (final ShardingSphereServerException ex) {
6161
throw new StorageUnitsOperateException("unregister", sqlStatement.getStorageUnitNames(), ex);
6262
}

0 commit comments

Comments
 (0)