The diversity on NoSQL databases
public interface ColumnFamilyManagerFactory<SYNC extends ColumnFamilyManager> extends AutoCloseable {
SYNC get(String database);
}CassandraConfiguration condition = new CassandraConfiguration();
try(CassandraDocumentEntityManagerFactory managerFactory = condition.get()) {
CassandraColumnFamilyManager columnEntityManager = managerFactory.get(KEY_SPACE);
ColumnEntity entity = ColumnEntity.of(COLUMN_FAMILY);
Column id = Column.of("id", 10L);
entity.add(id);
entity.add(Column.of("version", 0.001));
entity.add(Column.of("name", "Diana"));
entity.add(Column.of("options", Arrays.asList(1, 2, 3)));
columnEntityManager.save(entity);
//common implementation
ColumnQuery query = ColumnQuery.of(COLUMN_FAMILY);
query.and(ColumnCondition.eq(id));
Optional<ColumnEntity> result = columnEntityManager.singleResult(query);
//cassandra implementation
columnEntityManager.save(entity, ConsistencyLevel.THREE);
List<ColumnEntity> entities = columnEntityManager.cql("select * from newKeySpace.newColumnFamily");
System.out.println(entities);
}Last updated