|
@@ -133,20 +133,16 @@ public class SimpleDatabaseManagerService implements DatabaseManagerService, Met
|
|
|
|
|
|
@Override
|
|
|
public Map<ObjectMetadata.ObjectType, List<? extends ObjectMetadata>> getMetas() {
|
|
|
- String dsId = DataSourceHolder.switcher().currentDataSourceId();
|
|
|
return parserRepo
|
|
|
.computeIfAbsent(DataSourceHolder.currentDatabaseType(), t -> new HashMap<>())
|
|
|
.entrySet()
|
|
|
- .parallelStream()
|
|
|
+ .stream()
|
|
|
.collect(Collectors.toMap(Map.Entry::getKey, entry -> {
|
|
|
try {
|
|
|
- DataSourceHolder.switcher().use(dsId);
|
|
|
return entry.getValue().parseAll();
|
|
|
} catch (SQLException e) {
|
|
|
log.error("parse meta {} error", entry.getKey(), e);
|
|
|
return new ArrayList<>();
|
|
|
- } finally {
|
|
|
- DataSourceHolder.switcher().reset();
|
|
|
}
|
|
|
}));
|
|
|
}
|