![[Jenkins]](/jenkins/static/bfc92e0d/images/svgs/logo.svg){kind=logo}
Package: PoolingStorageConnector
PoolingStorageConnector
| name | instruction | branch | complexity | line | method | ||||||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| PoolingStorageConnector(StorageConnector) |
|
|
|
|
|
||||||||||||||||||||
| addStatements(Collection) |
|
|
|
|
|
||||||||||||||||||||
| begin() |
|
|
|
|
|
||||||||||||||||||||
| close() |
|
|
|
|
|
||||||||||||||||||||
| commit() |
|
|
|
|
|
||||||||||||||||||||
| containsStatement(Resource, IRI, Value, boolean) |
|
|
|
|
|
||||||||||||||||||||
| containsStatement(Resource, IRI, Value, boolean, IRI) |
|
|
|
|
|
||||||||||||||||||||
| executeBooleanQuery(String) |
|
|
|
|
|
||||||||||||||||||||
| executeSelectQuery(String) |
|
|
|
|
|
||||||||||||||||||||
| executeUpdate(String) |
|
|
|
|
|
||||||||||||||||||||
| findStatements(Resource, IRI, Value, boolean) |
|
|
|
|
|
||||||||||||||||||||
| findStatements(Resource, IRI, Value, boolean, IRI) |
|
|
|
|
|
||||||||||||||||||||
| getContexts() |
|
|
|
|
|
||||||||||||||||||||
| getValueFactory() |
|
|
|
|
|
||||||||||||||||||||
| removeStatements(Collection) |
|
|
|
|
|
||||||||||||||||||||
| rollback() |
|
|
|
|
|
||||||||||||||||||||
| static {...} |
|
|
|
|
|
||||||||||||||||||||
| unwrap(Class) |
|
|
|
|
|
||||||||||||||||||||
| wrapConnection() |
|
|
|
|
|
||||||||||||||||||||
Coverage
1: /**
2: * Copyright (C) 2016 Czech Technical University in Prague
3: * <p>
4: * This program is free software: you can redistribute it and/or modify it under
5: * the terms of the GNU General Public License as published by the Free Software
6: * Foundation, either version 3 of the License, or (at your option) any
7: * later version.
8: * <p>
9: * This program is distributed in the hope that it will be useful, but WITHOUT
10: * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
11: * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
12: * details. You should have received a copy of the GNU General Public License
13: * along with this program. If not, see <http://www.gnu.org/licenses/>.
14: */
15: package cz.cvut.kbss.ontodriver.sesame.connector;
16:
17: import cz.cvut.kbss.ontodriver.exception.OntoDriverException;
18: import cz.cvut.kbss.ontodriver.sesame.exceptions.SesameDriverException;
19: import org.eclipse.rdf4j.common.iteration.Iterations;
20: import org.eclipse.rdf4j.model.*;
21: import org.eclipse.rdf4j.query.TupleQueryResult;
22: import org.eclipse.rdf4j.repository.RepositoryConnection;
23: import org.eclipse.rdf4j.repository.RepositoryException;
24:
25: import java.util.Collection;
26: import java.util.List;
27: import java.util.concurrent.locks.Lock;
28: import java.util.concurrent.locks.ReentrantReadWriteLock;
29:
30: class PoolingStorageConnector extends AbstractConnector {
31:
32: private static final ReentrantReadWriteLock LOCK = new ReentrantReadWriteLock();
33: private static Lock READ = LOCK.readLock();
34: private static Lock WRITE = LOCK.writeLock();
35:
36: private final StorageConnector centralConnector;
37:
38: private RepositoryConnection connection;
39: private LocalModel localModel;
40:
41: PoolingStorageConnector(StorageConnector centralConnector) {
42: this.centralConnector = centralConnector;
43: this.open = true;
44: }
45:
46: @Override
47: public TupleQueryResult executeSelectQuery(String query) throws SesameDriverException {
48:• if (transaction.isActive()) {
49: return new ConnectionStatementExecutor(wrapConnection()).executeSelectQuery(query);
50: }
51: READ.lock();
52: try {
53: return centralConnector.executeSelectQuery(query);
54: } finally {
55: READ.unlock();
56: }
57: }
58:
59: private RepositoryConnection wrapConnection() {
60: return new TransactionalRepositoryConnection(connection);
61: }
62:
63: @Override
64: public boolean executeBooleanQuery(String query) throws SesameDriverException {
65:• if (transaction.isActive()) {
66: return new ConnectionStatementExecutor(wrapConnection()).executeBooleanQuery(query);
67: }
68: READ.lock();
69: try {
70: return centralConnector.executeBooleanQuery(query);
71: } finally {
72: READ.unlock();
73: }
74: }
75:
76: @Override
77: public void executeUpdate(String query) throws SesameDriverException {
78: WRITE.lock();
79: try {
80: centralConnector.executeUpdate(query);
81: } finally {
82: WRITE.unlock();
83: }
84: }
85:
86: @Override
87: public List<Resource> getContexts() throws SesameDriverException {
88: READ.lock();
89: try {
90: return centralConnector.getContexts();
91: } finally {
92: READ.unlock();
93: }
94: }
95:
96: @Override
97: public ValueFactory getValueFactory() {
98: // We don't need to lock the central connector, as getting the value
99: // factory does not require communication with the repository
100: return centralConnector.getValueFactory();
101: }
102:
103: @Override
104: public void begin() throws SesameDriverException {
105: super.begin();
106: this.localModel = new LocalModel();
107: this.connection = centralConnector.acquireConnection();
108: }
109:
110: @Override
111: public void commit() throws SesameDriverException {
112: transaction.commit();
113: WRITE.lock();
114: try {
115: centralConnector.begin();
116: centralConnector.removeStatements(localModel.getRemovedStatements());
117: centralConnector.addStatements(localModel.getAddedStatements());
118: centralConnector.commit();
119: transaction.afterCommit();
120: } catch (SesameDriverException e) {
121: transaction.rollback();
122: centralConnector.rollback();
123: transaction.afterRollback();
124: throw e;
125: } finally {
126: WRITE.unlock();
127: centralConnector.releaseConnection(connection);
128: this.localModel = null;
129: }
130: }
131:
132: @Override
133: public void rollback() throws SesameDriverException {
134: transaction.rollback();
135: this.localModel = null;
136: centralConnector.releaseConnection(connection);
137: transaction.afterRollback();
138: }
139:
140: @Override
141: public void close() throws OntoDriverException {
142:• if (open && transaction.isActive()) {
143: this.localModel = null;
144: centralConnector.releaseConnection(connection);
145: }
146: super.close();
147: }
148:
149: @Override
150: public void addStatements(Collection<Statement> statements) {
151: verifyTransactionActive();
152:• assert statements != null;
153: localModel.addStatements(statements);
154: }
155:
156: @Override
157: public void removeStatements(Collection<Statement> statements) {
158: verifyTransactionActive();
159:• assert statements != null;
160: localModel.removeStatements(statements);
161: }
162:
163: @Override
164: public Collection<Statement> findStatements(Resource subject, IRI property, Value value, boolean includeInferred)
165: throws SesameDriverException {
166: return findStatements(subject, property, value, includeInferred, null);
167: }
168:
169: @Override
170: public Collection<Statement> findStatements(Resource subject, IRI property, Value value,
171: boolean includeInferred, IRI context) throws SesameDriverException {
172: verifyTransactionActive();
173: try {
174: final Collection<Statement> statements;
175:• if (context != null) {
176: statements = Iterations
177: .asList(connection.getStatements(subject, property, value, includeInferred, context));
178: } else {
179: statements = Iterations
180: .asList(connection.getStatements(subject, property, value, includeInferred));
181: }
182: localModel.enhanceStatements(statements, subject, property, value, context);
183: return statements;
184: } catch (RepositoryException e) {
185: rollback();
186: throw new SesameDriverException(e);
187: }
188: }
189:
190: @Override
191: public boolean containsStatement(Resource subject, IRI property, Value value, boolean includeInferred)
192: throws SesameDriverException {
193: return containsStatement(subject, property, value, includeInferred, null);
194: }
195:
196: @Override
197: public boolean containsStatement(Resource subject, IRI property, Value value, boolean includeInferred, IRI context)
198: throws SesameDriverException {
199: verifyTransactionActive();
200: try {
201: final LocalModel.Contains containsLocally = localModel.contains(subject, property, value, context);
202:• switch (containsLocally) {
203: case TRUE:
204: return true;
205: case FALSE:
206: return false;
207: default:
208:• if (context != null) {
209: return connection.hasStatement(subject, property, value, includeInferred, context);
210: } else {
211: return connection.hasStatement(subject, property, value, includeInferred);
212: }
213: }
214: } catch (RepositoryException e) {
215: rollback();
216: throw new SesameDriverException(e);
217: }
218: }
219:
220: @Override
221: public <T> T unwrap(Class<T> cls) throws OntoDriverException {
222:• if (cls.isAssignableFrom(this.getClass())) {
223: return cls.cast(this);
224: }
225: return centralConnector.unwrap(cls);
226: }
227: }