PoolingStorageConnector extends AbstractConnector { @Override public void addStatements(Collection<Statement> statements) { verifyTransactionActive(); assert statements != null; localModel.addStatements(statements); } PoolingStorageConnector(StorageConnector centralConnector); @Override TupleQueryResult executeSelectQuery(String query); @Override boolean executeBooleanQuery(String query); @Override void executeUpdate(String query); @Override List<Resource> getContexts(); @Override ValueFactory getValueFactory(); @Override void begin(); @Override void commit(); @Override void rollback(); @Override void close(); @Override void addStatements(Collection<Statement> statements); @Override void removeStatements(Collection<Statement> statements); @Override Collection<Statement> findStatements(Resource subject, IRI property, Value value, boolean includeInferred); @Override Collection<Statement> findStatements(Resource subject, IRI property, Value value,
                                                boolean includeInferred, IRI context); @Override boolean containsStatement(Resource subject, IRI property, Value value, boolean includeInferred); @Override boolean containsStatement(Resource subject, IRI property, Value value, boolean includeInferred, IRI context); @Override T unwrap(Class<T> cls);  }
@Test(expected = IllegalStateException.class) public void testAddStatementsInactiveTransaction() { final List<Statement> statements = getStatements(); connector.addStatements(statements); }