@Test (expected = AddStatementException.class) public void testAddStatement_AddNull() throws Exception { final AccumuloRyaStatementStore accumuloRyaStatementStore = createAccumuloRyaStatementStore(); accumuloRyaStatementStore.addStatement(null); }
@Override public void addStatement(final RyaStatement statement) throws AddStatementException { try { accumuloRyaDao.add(statement); accumuloRyaDao.flush(); if(!containsStatement(statement)) { statement.setTimestamp(statement.getTimestamp() + 1L); accumuloRyaDao.add(statement); } } catch (final RyaDAOException | ContainsStatementException e) { throw new AddStatementException("Unable to add the Rya Statement", e); } }
AccumuloRyaStatementStore implements RyaStatementStore { @Override public void addStatement(final RyaStatement statement) throws AddStatementException { try { accumuloRyaDao.add(statement); accumuloRyaDao.flush(); if(!containsStatement(statement)) { statement.setTimestamp(statement.getTimestamp() + 1L); accumuloRyaDao.add(statement); } } catch (final RyaDAOException | ContainsStatementException e) { throw new AddStatementException("Unable to add the Rya Statement", e); } } }
AccumuloRyaStatementStore implements RyaStatementStore { @Override public void addStatement(final RyaStatement statement) throws AddStatementException { try { accumuloRyaDao.add(statement); accumuloRyaDao.flush(); if(!containsStatement(statement)) { statement.setTimestamp(statement.getTimestamp() + 1L); accumuloRyaDao.add(statement); } } catch (final RyaDAOException | ContainsStatementException e) { throw new AddStatementException("Unable to add the Rya Statement", e); } } AccumuloRyaStatementStore(final AccumuloRyaDAO dao, final String tablePrefix, final String ryaInstance); }
AccumuloRyaStatementStore implements RyaStatementStore { @Override public void addStatement(final RyaStatement statement) throws AddStatementException { try { accumuloRyaDao.add(statement); accumuloRyaDao.flush(); if(!containsStatement(statement)) { statement.setTimestamp(statement.getTimestamp() + 1L); accumuloRyaDao.add(statement); } } catch (final RyaDAOException | ContainsStatementException e) { throw new AddStatementException("Unable to add the Rya Statement", e); } } AccumuloRyaStatementStore(final AccumuloRyaDAO dao, final String tablePrefix, final String ryaInstance); @Override Iterator<RyaStatement> fetchStatements(); @Override void addStatement(final RyaStatement statement); @Override void removeStatement(final RyaStatement statement); @Override void updateStatement(final RyaStatement original, final RyaStatement update); @Override boolean containsStatement(final RyaStatement ryaStatement); @Override Optional<MergeParentMetadata> getParentMetadata(); @Override void setParentMetadata(final MergeParentMetadata metadata); RyaStatement findStatement(final RyaStatement ryaStatement); void addIterator(final IteratorSetting iteratorSetting); }
AccumuloRyaStatementStore implements RyaStatementStore { @Override public void addStatement(final RyaStatement statement) throws AddStatementException { try { accumuloRyaDao.add(statement); accumuloRyaDao.flush(); if(!containsStatement(statement)) { statement.setTimestamp(statement.getTimestamp() + 1L); accumuloRyaDao.add(statement); } } catch (final RyaDAOException | ContainsStatementException e) { throw new AddStatementException("Unable to add the Rya Statement", e); } } AccumuloRyaStatementStore(final AccumuloRyaDAO dao, final String tablePrefix, final String ryaInstance); @Override Iterator<RyaStatement> fetchStatements(); @Override void addStatement(final RyaStatement statement); @Override void removeStatement(final RyaStatement statement); @Override void updateStatement(final RyaStatement original, final RyaStatement update); @Override boolean containsStatement(final RyaStatement ryaStatement); @Override Optional<MergeParentMetadata> getParentMetadata(); @Override void setParentMetadata(final MergeParentMetadata metadata); RyaStatement findStatement(final RyaStatement ryaStatement); void addIterator(final IteratorSetting iteratorSetting);  }