Skip to content

Package: SnapshotStorage

SnapshotStorage

nameinstructionbranchcomplexitylinemethod
SnapshotStorage(DriverConfiguration)
M: 0 C: 7
100%
M: 0 C: 0
100%
M: 0 C: 1
100%
M: 0 C: 3
100%
M: 0 C: 1
100%
addCentralData(Dataset)
M: 0 C: 6
100%
M: 0 C: 0
100%
M: 0 C: 1
100%
M: 0 C: 2
100%
M: 0 C: 1
100%
lambda$addCentralData$0(Dataset)
M: 0 C: 26
100%
M: 0 C: 2
100%
M: 0 C: 2
100%
M: 0 C: 7
100%
M: 0 C: 1
100%

Coverage

1: /**
2: * Copyright (C) 2020 Czech Technical University in Prague
3: * <p>
4: * This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public
5: * License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later
6: * version.
7: * <p>
8: * This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied
9: * warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
10: * details. You should have received a copy of the GNU General Public License along with this program. If not, see
11: * <http://www.gnu.org/licenses/>.
12: */
13: package cz.cvut.kbss.ontodriver.jena.connector;
14:
15: import cz.cvut.kbss.ontodriver.config.DriverConfiguration;
16: import org.apache.jena.query.Dataset;
17: import org.apache.jena.query.DatasetFactory;
18: import org.apache.jena.system.Txn;
19:
20: import java.util.Iterator;
21:
22: class SnapshotStorage extends LocalStorage {
23:
24: SnapshotStorage(DriverConfiguration configuration) {
25: super(configuration);
26: this.dataset = DatasetFactory.create();
27: }
28:
29: void addCentralData(Dataset central) {
30: Txn.executeRead(central, () -> {
31: final Iterator<String> it = central.listNames();
32:• while (it.hasNext()) {
33: final String name = it.next();
34: dataset.addNamedModel(name, central.getNamedModel(name));
35: }
36: dataset.setDefaultModel(central.getDefaultModel());
37: });
38: }
39: }