DatabaseRepositoryImpl extends AbstractCRUDRepository<Database> implements DatabaseRepository { @Override public Database read(Identifier identifier) { if (identifier == null || identifier.isEmpty()) { return null; } BoundStatement bs = new BoundStatement(readStmt); bs.bind(identifier.getDatabaseName()); return marshalRow(getSession().execute(bs).one()); } DatabaseRepositoryImpl(Session session); @Override Database create(Database entity); @Override Database update(Database entity); @Override List<Database> readAll(); @Override List<Database> readAll(Identifier id); @Override boolean exists(Identifier identifier); @Override Database read(Identifier identifier); @Override void delete(Database entity); @Override void delete(Identifier identifier);  }
@Test public void testRead() { System.out.println("read"); Database entity = Fixtures.createTestDatabase(); DatabaseRepository instance = new DatabaseRepositoryImpl(f.getSession()); assertNull(instance.read(entity.getId())); instance.create(entity); assertEquals(entity, instance.read(entity.getId())); }