SharedStorageConnector extends AbstractStorageConnector { @Override public synchronized void close() { if (!isOpen()) { return; } if (storage != null) { storage.close(); } super.close(); } SharedStorageConnector(DriverConfiguration configuration); @Override synchronized void begin(); @Override synchronized void commit(); @Override void rollback(); @Override Collection<Statement> find(Resource subject, Property property, RDFNode value, String context); @Override boolean contains(Resource subject, Property property, RDFNode value, String context); @Override List<String> getContexts(); @Override void add(List<Statement> statements, String context); @Override void remove(List<Statement> statements, String context); @Override void remove(Resource subject, Property property, RDFNode object, String context); @Override AbstractResultSet executeSelectQuery(Query query, StatementOntology target); @Override AbstractResultSet executeAskQuery(Query query, StatementOntology target); @Override void executeUpdate(String query, StatementOntology target); @Override synchronized void close(); synchronized void reloadStorage(); synchronized void setDataset(Dataset dataset);  }
@Test public void closeClosesUnderlyingStorageAccessor() { final SharedStorageConnector connector = initConnector(); assertTrue(connector.isOpen()); connector.close(); assertFalse(connector.isOpen()); verify(connector.storage).close(); }