1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.shardingsphere.mode.manager.switcher;
19
20 import lombok.Getter;
21 import lombok.RequiredArgsConstructor;
22 import org.apache.shardingsphere.infra.datasource.pool.destroyer.DataSourcePoolDestroyer;
23 import org.apache.shardingsphere.infra.datasource.pool.props.domain.DataSourcePoolProperties;
24 import org.apache.shardingsphere.infra.metadata.database.resource.node.StorageNode;
25
26 import javax.sql.DataSource;
27 import java.util.Collection;
28 import java.util.Map;
29 import java.util.Objects;
30
31
32
33
34 @RequiredArgsConstructor
35 @Getter
36 public final class SwitchingResource {
37
38 private final Map<StorageNode, DataSource> newDataSources;
39
40 private final Map<StorageNode, DataSource> staleDataSources;
41
42 private final Collection<String> staleStorageUnitNames;
43
44 private final Map<String, DataSourcePoolProperties> mergedDataSourcePoolPropertiesMap;
45
46
47
48
49 public void closeStaleDataSources() {
50 staleDataSources.values().stream().filter(Objects::nonNull).forEach(each -> new DataSourcePoolDestroyer(each).asyncDestroy());
51 }
52 }