ITableRepositoryImpl implements ITableRepository { @Override public void createITable(Index index) { logger.info("Creating iTable for index: " + index.toString()); PreparedStatement createStmt = PreparedStatementFactory.getPreparedStatement(generateTableCreationSyntax(index), session); BoundStatement bs = new BoundStatement(createStmt); session.execute(bs); } ITableRepositoryImpl(Session session); @Override boolean iTableExists(Index index); @Override boolean iTableExists(IndexIdentifier indexId); @Override void createITable(Index index); @Override void deleteITable(Index index); @Override void deleteITable(IndexIdentifier indexId); @Override void deleteITable(String tableName);  }
@Test public void testCreateITable() { System.out.println("createITable"); Index index = Fixtures.createTestIndexOneField(); ITableRepository instance = new ITableRepositoryImpl(f.getSession()); boolean result = instance.iTableExists(index); assertEquals(false, result); instance.createITable(index); result = instance.iTableExists(index); assertEquals(true, result); Index index2 = Fixtures.createTestIndexTwoField(); result = instance.iTableExists(index2); assertEquals(false, result); instance.createITable(index2); result = instance.iTableExists(index2); assertEquals(true, result); }