Skip to content

Commit 9ae4b22

Browse files
terrymanuterrymanu
authored
Refactor ModePersistServiceFacade (#34998)
1 parent 102f856 commit 9ae4b22

File tree

43 files changed

+72
-72
lines changed

Some content is hidden

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

43 files changed

+72
-72
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().getModeFacade().getMetaDataManagerPersistService();
74+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
87+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
98+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
60+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
91+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
104+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
106+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
71+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
89+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
107+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
70+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
68+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
80+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
63+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
81+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
8282
metaDataManagerPersistService.alterRuleConfiguration(any(), ArgumentMatchers.argThat(this::assertRuleConfigurationWithoutIfExists));
8383
metaDataManagerPersistService.alterRuleConfiguration(any(), ArgumentMatchers.argThat(this::assertRuleConfigurationWithIfExists));
8484
}

‎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().getModeFacade().getMetaDataManagerPersistService();
51+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
51+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService();
63+
MetaDataManagerPersistService metaDataManagerPersistService = contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService();
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().getModeFacade().getMetaDataManagerPersistService()
51+
contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService()
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().getModeFacade().getMetaDataManagerPersistService().alterStorageUnits(database, propsMap);
69+
contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService().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().getModeFacade().getMetaDataManagerPersistService().registerStorageUnits(database.getName(), propsMap);
70+
contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService().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().getModeFacade().getMetaDataManagerPersistService().unregisterStorageUnits(database, sqlStatement.getStorageUnitNames());
59+
contextManager.getPersistServiceFacade().getModeFacade().getMetaDataManagerService().unregisterStorageUnits(database, sqlStatement.getStorageUnitNames());
6060
} catch (final ShardingSphereServerException ex) {
6161
throw new StorageUnitsOperateException("unregister", sqlStatement.getStorageUnitNames(), ex);
6262
}

‎infra/distsql-handler/src/test/java/org/apache/shardingsphere/distsql/handler/executor/rdl/resource/UnregisterStorageUnitExecutorTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ private ContextManager mockContextManager() {
8585
MetaDataContexts metaDataContexts = mock(MetaDataContexts.class, RETURNS_DEEP_STUBS);
8686
ContextManager result = mock(ContextManager.class, RETURNS_DEEP_STUBS);
8787
when(result.getMetaDataContexts()).thenReturn(metaDataContexts);
88-
when(result.getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService()).thenReturn(metaDataManagerPersistService);
88+
when(result.getPersistServiceFacade().getModeFacade().getMetaDataManagerService()).thenReturn(metaDataManagerPersistService);
8989
when(result.getDatabase("foo_db")).thenReturn(database);
9090
return result;
9191
}

‎jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverExecuteExecutor.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ public boolean execute(final ShardingSphereDatabase database, final QueryContext
102102
return null != resultSet;
103103
}
104104
FederationMetaDataRefreshEngine federationMetaDataRefreshEngine = new FederationMetaDataRefreshEngine(
105-
connection.getContextManager().getPersistServiceFacade().getModeFacade().getMetaDataManagerPersistService(), database);
105+
connection.getContextManager().getPersistServiceFacade().getModeFacade().getMetaDataManagerService(), database);
106106
if (sqlFederationEngine.enabled() && federationMetaDataRefreshEngine.isNeedRefresh(queryContext.getSqlStatementContext())) {
107107
federationMetaDataRefreshEngine.refresh(queryContext.getSqlStatementContext());
108108
return true;

0 commit comments

Comments
 (0)