![[Jenkins]](/jenkins/static/06277ae5/images/svgs/logo.svg){kind=logo}
Package: SesameConnection
SesameConnection
| name | instruction | branch | complexity | line | method | ||||||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| SesameConnection(SesameAdapter) |
|
|
|
|
|
||||||||||||||||||||
| close() |
|
|
|
|
|
||||||||||||||||||||
| commit() |
|
|
|
|
|
||||||||||||||||||||
| commitIfAuto() |
|
|
|
|
|
||||||||||||||||||||
| contains(Axiom, Set) |
|
|
|
|
|
||||||||||||||||||||
| createStatement() |
|
|
|
|
|
||||||||||||||||||||
| ensureOpen() |
|
|
|
|
|
||||||||||||||||||||
| find(AxiomDescriptor) |
|
|
|
|
|
||||||||||||||||||||
| generateIdentifier(URI) |
|
|
|
|
|
||||||||||||||||||||
| getContexts() |
|
|
|
|
|
||||||||||||||||||||
| isAutoCommit() |
|
|
|
|
|
||||||||||||||||||||
| isConsistent(URI) |
|
|
|
|
|
||||||||||||||||||||
| isInferred(Axiom, Set) |
|
|
|
|
|
||||||||||||||||||||
| isOpen() |
|
|
|
|
|
||||||||||||||||||||
| lists() |
|
|
|
|
|
||||||||||||||||||||
| persist(AxiomValueDescriptor) |
|
|
|
|
|
||||||||||||||||||||
| prepareStatement(String) |
|
|
|
|
|
||||||||||||||||||||
| properties() |
|
|
|
|
|
||||||||||||||||||||
| remove(AxiomDescriptor) |
|
|
|
|
|
||||||||||||||||||||
| removeListener() |
|
|
|
|
|
||||||||||||||||||||
| rollback() |
|
|
|
|
|
||||||||||||||||||||
| setAutoCommit(boolean) |
|
|
|
|
|
||||||||||||||||||||
| setListener(ConnectionListener) |
|
|
|
|
|
||||||||||||||||||||
| setLists(SesameLists) |
|
|
|
|
|
||||||||||||||||||||
| setProperties(Properties) |
|
|
|
|
|
||||||||||||||||||||
| setTypes(SesameTypes) |
|
|
|
|
|
||||||||||||||||||||
| static {...} |
|
|
|
|
|
||||||||||||||||||||
| types() |
|
|
|
|
|
||||||||||||||||||||
| unwrap(Class) |
|
|
|
|
|
||||||||||||||||||||
| update(AxiomValueDescriptor) |
|
|
|
|
|
||||||||||||||||||||
Coverage
1: /**
2: * Copyright (C) 2022 Czech Technical University in Prague
3: *
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: *
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;
16:
17: import cz.cvut.kbss.ontodriver.*;
18: import cz.cvut.kbss.ontodriver.Properties;
19: import cz.cvut.kbss.ontodriver.descriptor.AxiomDescriptor;
20: import cz.cvut.kbss.ontodriver.descriptor.AxiomValueDescriptor;
21: import cz.cvut.kbss.ontodriver.exception.IdentifierGenerationException;
22: import cz.cvut.kbss.ontodriver.exception.OntoDriverException;
23: import cz.cvut.kbss.ontodriver.model.Axiom;
24: import cz.cvut.kbss.ontodriver.sesame.exceptions.SesameDriverException;
25: import cz.cvut.kbss.ontodriver.sesame.query.SesamePreparedStatement;
26: import cz.cvut.kbss.ontodriver.sesame.query.SesameStatement;
27:
28: import java.net.URI;
29: import java.util.*;
30:
31: import static cz.cvut.kbss.ontodriver.util.ErrorUtils.getNPXMessageSupplier;
32:
33: /**
34: * @deprecated Switch to {@code Rdf4jConnection} from the new ontodriver-rdf4j module.
35: */
36: @Deprecated
37: class SesameConnection implements Connection {
38:
39: private final SesameAdapter adapter;
40: private boolean open;
41: private boolean autoCommit;
42:
43: private Lists lists;
44: private Types types;
45: private Properties properties;
46:
47: private ConnectionListener listener;
48:
49: SesameConnection(SesameAdapter adapter) {
50:• assert adapter != null;
51: this.adapter = adapter;
52: this.open = true;
53: }
54:
55: void setLists(SesameLists lists) {
56: this.lists = lists;
57: }
58:
59: void setTypes(SesameTypes types) {
60: this.types = types;
61: }
62:
63: public void setProperties(Properties properties) {
64: this.properties = properties;
65: }
66:
67: void setListener(ConnectionListener listener) {
68: ensureOpen();
69:• assert listener != null;
70: this.listener = listener;
71: }
72:
73: void removeListener() {
74: this.listener = null;
75: }
76:
77: @Override
78: public void close() throws Exception {
79:• if (!open) {
80: return;
81: }
82: try {
83: adapter.close();
84:• if (listener != null) {
85: listener.connectionClosed(this);
86: }
87: } finally {
88: this.open = false;
89: }
90: }
91:
92: @Override
93: public boolean isOpen() {
94: return open;
95: }
96:
97: @Override
98: public void commit() throws OntoDriverException {
99: ensureOpen();
100:• if (autoCommit) {
101: return;
102: }
103: adapter.commit();
104: }
105:
106: @Override
107: public void rollback() throws OntoDriverException {
108: ensureOpen();
109:• if (autoCommit) {
110: return;
111: }
112: adapter.rollback();
113: }
114:
115: @Override
116: public void setAutoCommit(boolean autoCommit) {
117: ensureOpen();
118: this.autoCommit = autoCommit;
119: }
120:
121: @Override
122: public boolean isAutoCommit() {
123: ensureOpen();
124: return autoCommit;
125: }
126:
127: @Override
128: public Statement createStatement() {
129: ensureOpen();
130: return new SesameStatement(adapter.getQueryExecutor());
131: }
132:
133: @Override
134: public PreparedStatement prepareStatement(String sparql) {
135: ensureOpen();
136: Objects.requireNonNull(sparql);
137:• if (sparql.isEmpty()) {
138: throw new IllegalArgumentException("The value for prepared statement cannot be empty.");
139: }
140: return new SesamePreparedStatement(adapter.getQueryExecutor(), sparql);
141: }
142:
143: @Override
144: public boolean isConsistent(URI context) {
145: ensureOpen();
146: return adapter.isConsistent(context);
147: }
148:
149: @Override
150: public List<URI> getContexts() throws OntoDriverException {
151: ensureOpen();
152: return adapter.getContexts();
153: }
154:
155: @Override
156: public URI generateIdentifier(URI classUri) throws OntoDriverException {
157: ensureOpen();
158: Objects.requireNonNull(classUri);
159: try {
160: return adapter.generateIdentifier(classUri);
161: } catch (IdentifierGenerationException e) {
162: throw new SesameDriverException(e);
163: }
164: }
165:
166: @Override
167: public boolean contains(Axiom<?> axiom, Set<URI> contexts) throws OntoDriverException {
168: ensureOpen();
169: Objects.requireNonNull(axiom, getNPXMessageSupplier("axiom"));
170: Objects.requireNonNull(contexts);
171: return adapter.contains(axiom, contexts);
172: }
173:
174: @Override
175: public boolean isInferred(Axiom<?> axiom, Set<URI> contexts) throws OntoDriverException {
176: ensureOpen();
177: // Not implemented. Switch to RDF4J OntoDriver for implementation of new features
178: return true;
179: }
180:
181: @Override
182: public Collection<Axiom<?>> find(AxiomDescriptor descriptor) throws OntoDriverException {
183: ensureOpen();
184: Objects.requireNonNull(descriptor);
185: try {
186: return adapter.find(descriptor);
187: } catch (RuntimeException e) {
188: throw new SesameDriverException(e);
189: }
190: }
191:
192: @Override
193: public void persist(AxiomValueDescriptor descriptor) throws OntoDriverException {
194: ensureOpen();
195: Objects.requireNonNull(descriptor);
196: try {
197: adapter.persist(descriptor);
198: commitIfAuto();
199: } catch (RuntimeException e) {
200: throw new SesameDriverException(e);
201: }
202: }
203:
204: @Override
205: public void update(AxiomValueDescriptor descriptor) throws OntoDriverException {
206: ensureOpen();
207: Objects.requireNonNull(descriptor);
208: try {
209: adapter.update(descriptor);
210: commitIfAuto();
211: } catch (RuntimeException e) {
212: throw new SesameDriverException(e);
213: }
214: }
215:
216: @Override
217: public void remove(AxiomDescriptor descriptor) throws OntoDriverException {
218: ensureOpen();
219: Objects.requireNonNull(descriptor);
220: try {
221: adapter.remove(descriptor);
222: commitIfAuto();
223: } catch (RuntimeException e) {
224: throw new SesameDriverException(e);
225: }
226: }
227:
228: @Override
229: public Lists lists() {
230: ensureOpen();
231:• assert lists != null;
232: return lists;
233: }
234:
235: @Override
236: public Types types() {
237: ensureOpen();
238:• assert types != null;
239: return types;
240: }
241:
242: @Override
243: public Properties properties() {
244: ensureOpen();
245:• assert properties != null;
246: return properties;
247: }
248:
249: void ensureOpen() {
250:• if (!open) {
251: throw new IllegalStateException("This connection is closed.");
252: }
253: }
254:
255: void commitIfAuto() throws SesameDriverException {
256:• if (autoCommit) {
257: adapter.commit();
258: }
259: }
260:
261: @Override
262: public <T> T unwrap(Class<T> cls) throws OntoDriverException {
263:• if (cls.isAssignableFrom(this.getClass())) {
264: return cls.cast(this);
265: }
266: return adapter.unwrap(cls);
267: }
268: }