《Spring Data 官方文档》5.7 查询CQL表

5.7. 查询CQL表

有几种选择和查询的风格，您可以从中选择。 请参阅CassandraTemplate API文档，了解所有可用的重载。

查询表的多行数据，并将结果映射到POJO。

String cqlAll = "select * from person"; List<Person> results = cassandraOperations.select(cqlAll, Person.class); for (Person p : results) { LOG.info(String.format("Found People with Name [%s] for id [%s]", p.getName(), p.getId())); }

查询表的单行数据，并将结果映射到POJO。

String cqlOne = "select * from person where id = '123123123'"; Person p = cassandraOperations.selectOne(cqlOne, Person.class); LOG.info(String.format("Found Person with Name [%s] for id [%s]", p.getName(), p.getId()));

使用DataStax Java驱动程序中的QueryBuilder.Select对象来查询表。.

Select select = QueryBuilder.select().from("person"); select.where(QueryBuilder.eq("id", "123123123")); Person p = cassandraOperations.selectOne(select, Person.class); LOG.info(String.format("Found Person with Name [%s] for id [%s]", p.getName(), p.getId()));

这些方法总会过时。 您可以编写自己的CQL语句，并且有几个回调处理程序用于映射结果。 该示例使用RowMapper接口。

String cqlAll = "select * from person"; List<Person> results = cassandraOperations.query(cqlAll, new RowMapper<Person>() { public Person mapRow(Row row, int rowNum) throws DriverException { Person p = new Person(row.getString("id"), row.getString("name"), row.getInt("age")); return p; } }); for (Person p : results) { LOG.info(String.format("Found People with Name [%s] for id [%s]", p.getName(), p.getId())); }

转载自 并发编程网 - ifeve.com

相关资源：spring data Neo4j 整合demo