@Test public void testDropAndDestroy() throws RyaDAOException { assertTrue(dao.isInitialized()); dao.dropAndDestroy(); for (String tableName : dao.getTables()) { assertFalse(tableExists(tableName)); } assertFalse(dao.isInitialized()); }
@Override public void dropAndDestroy() throws RyaDAOException { for (final String tableName : getTables()) { try { if (tableName != null) { drop(tableName); } } catch (final AccumuloSecurityException e) { logger.error(e.getMessage()); throw new RyaDAOException(e); } catch (final AccumuloException e) { logger.error(e.getMessage()); throw new RyaDAOException(e); } catch (final TableNotFoundException e) { logger.warn(e.getMessage()); } } destroy(); for(final AccumuloIndexer indexer : this.secondaryIndexers) { try { indexer.dropAndDestroy(); } catch(final Exception e) { logger.error("Failed to drop and destroy indexer", e); } } }
AccumuloRyaDAO implements RyaDAO<AccumuloRdfConfiguration>, RyaNamespaceManager<AccumuloRdfConfiguration> { @Override public void dropAndDestroy() throws RyaDAOException { for (final String tableName : getTables()) { try { if (tableName != null) { drop(tableName); } } catch (final AccumuloSecurityException e) { logger.error(e.getMessage()); throw new RyaDAOException(e); } catch (final AccumuloException e) { logger.error(e.getMessage()); throw new RyaDAOException(e); } catch (final TableNotFoundException e) { logger.warn(e.getMessage()); } } destroy(); for(final AccumuloIndexer indexer : this.secondaryIndexers) { try { indexer.dropAndDestroy(); } catch(final Exception e) { logger.error("Failed to drop and destroy indexer", e); } } } }
AccumuloRyaDAO implements RyaDAO<AccumuloRdfConfiguration>, RyaNamespaceManager<AccumuloRdfConfiguration> { @Override public void dropAndDestroy() throws RyaDAOException { for (final String tableName : getTables()) { try { if (tableName != null) { drop(tableName); } } catch (final AccumuloSecurityException e) { logger.error(e.getMessage()); throw new RyaDAOException(e); } catch (final AccumuloException e) { logger.error(e.getMessage()); throw new RyaDAOException(e); } catch (final TableNotFoundException e) { logger.warn(e.getMessage()); } } destroy(); for(final AccumuloIndexer indexer : this.secondaryIndexers) { try { indexer.dropAndDestroy(); } catch(final Exception e) { logger.error("Failed to drop and destroy indexer", e); } } }  }
AccumuloRyaDAO implements RyaDAO<AccumuloRdfConfiguration>, RyaNamespaceManager<AccumuloRdfConfiguration> { @Override public void dropAndDestroy() throws RyaDAOException { for (final String tableName : getTables()) { try { if (tableName != null) { drop(tableName); } } catch (final AccumuloSecurityException e) { logger.error(e.getMessage()); throw new RyaDAOException(e); } catch (final AccumuloException e) { logger.error(e.getMessage()); throw new RyaDAOException(e); } catch (final TableNotFoundException e) { logger.warn(e.getMessage()); } } destroy(); for(final AccumuloIndexer indexer : this.secondaryIndexers) { try { indexer.dropAndDestroy(); } catch(final Exception e) { logger.error("Failed to drop and destroy indexer", e); } } }  @Override boolean isInitialized(); @Override void init(); @Override String getVersion(); @Override void add(final RyaStatement statement); @Override void add(final Iterator<RyaStatement> iter); @Override void delete(final RyaStatement stmt, final AccumuloRdfConfiguration aconf); @Override void delete(final Iterator<RyaStatement> statements, final AccumuloRdfConfiguration conf); @Override void dropGraph(final AccumuloRdfConfiguration conf, final RyaIRI... graphs); @Override void destroy(); @Override void addNamespace(final String pfx, final String namespace); @Override String getNamespace(final String pfx); @Override void removeNamespace(final String pfx); @SuppressWarnings({ "unchecked", "rawtypes" }) @Override CloseableIteration<Namespace, RyaDAOException> iterateNamespace(); @Override RyaNamespaceManager<AccumuloRdfConfiguration> getNamespaceManager(); @Override void purge(final RdfCloudTripleStoreConfiguration configuration); @Override void dropAndDestroy(); synchronized Connector getConnector(); synchronized void setConnector(final Connector connector); BatchWriterConfig getBatchWriterConfig(); void setBatchWriterConfig(final BatchWriterConfig batchWriterConfig); @Override synchronized AccumuloRdfConfiguration getConf(); @Override synchronized void setConf(final AccumuloRdfConfiguration conf); RyaTableMutationsFactory getRyaTableMutationsFactory(); void setRyaTableMutationsFactory(final RyaTableMutationsFactory ryaTableMutationsFactory); @Override AccumuloRyaQueryEngine getQueryEngine(); void setQueryEngine(final AccumuloRyaQueryEngine queryEngine); @Override void flush(); }
AccumuloRyaDAO implements RyaDAO<AccumuloRdfConfiguration>, RyaNamespaceManager<AccumuloRdfConfiguration> { @Override public void dropAndDestroy() throws RyaDAOException { for (final String tableName : getTables()) { try { if (tableName != null) { drop(tableName); } } catch (final AccumuloSecurityException e) { logger.error(e.getMessage()); throw new RyaDAOException(e); } catch (final AccumuloException e) { logger.error(e.getMessage()); throw new RyaDAOException(e); } catch (final TableNotFoundException e) { logger.warn(e.getMessage()); } } destroy(); for(final AccumuloIndexer indexer : this.secondaryIndexers) { try { indexer.dropAndDestroy(); } catch(final Exception e) { logger.error("Failed to drop and destroy indexer", e); } } }  @Override boolean isInitialized(); @Override void init(); @Override String getVersion(); @Override void add(final RyaStatement statement); @Override void add(final Iterator<RyaStatement> iter); @Override void delete(final RyaStatement stmt, final AccumuloRdfConfiguration aconf); @Override void delete(final Iterator<RyaStatement> statements, final AccumuloRdfConfiguration conf); @Override void dropGraph(final AccumuloRdfConfiguration conf, final RyaIRI... graphs); @Override void destroy(); @Override void addNamespace(final String pfx, final String namespace); @Override String getNamespace(final String pfx); @Override void removeNamespace(final String pfx); @SuppressWarnings({ "unchecked", "rawtypes" }) @Override CloseableIteration<Namespace, RyaDAOException> iterateNamespace(); @Override RyaNamespaceManager<AccumuloRdfConfiguration> getNamespaceManager(); @Override void purge(final RdfCloudTripleStoreConfiguration configuration); @Override void dropAndDestroy(); synchronized Connector getConnector(); synchronized void setConnector(final Connector connector); BatchWriterConfig getBatchWriterConfig(); void setBatchWriterConfig(final BatchWriterConfig batchWriterConfig); @Override synchronized AccumuloRdfConfiguration getConf(); @Override synchronized void setConf(final AccumuloRdfConfiguration conf); RyaTableMutationsFactory getRyaTableMutationsFactory(); void setRyaTableMutationsFactory(final RyaTableMutationsFactory ryaTableMutationsFactory); @Override AccumuloRyaQueryEngine getQueryEngine(); void setQueryEngine(final AccumuloRyaQueryEngine queryEngine); @Override void flush();  }