@Test public void dropCatalogTest() throws ExecutionException, UnsupportedException { mongoMetadataEngine.dropCatalog(new CatalogName(DB_NAME), connection); verify(client, times(1)).dropDatabase(Matchers.anyString()); }
@Override protected void dropCatalog(CatalogName name, Connection<MongoClient> connection) throws ExecutionException { try { connection.getNativeConnection().dropDatabase(name.getName()); } catch (MongoException e) { logger.error("Error dropping the catalog: " + e.getMessage()); throw new ExecutionException(e.getMessage(), e); } }
MongoMetadataEngine extends CommonsMetadataEngine<MongoClient> { @Override protected void dropCatalog(CatalogName name, Connection<MongoClient> connection) throws ExecutionException { try { connection.getNativeConnection().dropDatabase(name.getName()); } catch (MongoException e) { logger.error("Error dropping the catalog: " + e.getMessage()); throw new ExecutionException(e.getMessage(), e); } } }
MongoMetadataEngine extends CommonsMetadataEngine<MongoClient> { @Override protected void dropCatalog(CatalogName name, Connection<MongoClient> connection) throws ExecutionException { try { connection.getNativeConnection().dropDatabase(name.getName()); } catch (MongoException e) { logger.error("Error dropping the catalog: " + e.getMessage()); throw new ExecutionException(e.getMessage(), e); } } private  MongoMetadataEngine(MongoConnectionHandler connectionHandler); }
MongoMetadataEngine extends CommonsMetadataEngine<MongoClient> { @Override protected void dropCatalog(CatalogName name, Connection<MongoClient> connection) throws ExecutionException { try { connection.getNativeConnection().dropDatabase(name.getName()); } catch (MongoException e) { logger.error("Error dropping the catalog: " + e.getMessage()); throw new ExecutionException(e.getMessage(), e); } } private  MongoMetadataEngine(MongoConnectionHandler connectionHandler); static MongoMetadataEngine getInstance(MongoConnectionHandler connectionHandler); }
MongoMetadataEngine extends CommonsMetadataEngine<MongoClient> { @Override protected void dropCatalog(CatalogName name, Connection<MongoClient> connection) throws ExecutionException { try { connection.getNativeConnection().dropDatabase(name.getName()); } catch (MongoException e) { logger.error("Error dropping the catalog: " + e.getMessage()); throw new ExecutionException(e.getMessage(), e); } } private  MongoMetadataEngine(MongoConnectionHandler connectionHandler); static MongoMetadataEngine getInstance(MongoConnectionHandler connectionHandler);  }