如何检查Spring Data Cassandra Mapper生成的查询字符串

Question

如果我用来自com.datastax.driver.mapping.annotations的注解来注释一个类，我可以像下面这样写一个测试：

MappingManager manager = new MappingManager(session);
Mapper<MyAnnotatedClass> mapper = manager.mapper(MyAnnotatedClass.class);

MyAnnotatedClass entity = ...;

RegularStatement saveQuery = (RegularStatement) mapper.saveQuery(entity);

assertEquals("...", saveQuery.getQueryString());

但是，我有用org.springframework.data.cassandra.mapping注解的实体类。我一直找不到一个与Mapper的saveQuery()、getQuery()和deleteQuery()相当的Spring。

如何编写关于从Spring Data Cassandra注释的实体类生成的CQL的测试(理想情况下在运行时是轻量级的)？

Answer 1

使用Spring Data for Apache Cassandra 1.5，您可以编写以下代码来创建Statement：

CassandraTemplate template = …

Person person = …

CqlIdentifier tableName = template.getTableName(Person.class);

Insert insert = CassandraTemplate.createInsertQuery(tableName.toCql(), person, 
                    new WriteOptions(), template.getConverter());

Delete delete = CassandraTemplate.createDeleteQuery(tableName.toCql(), person,
                    new WriteOptions(), template.getConverter());

Update update = CassandraTemplate.createUpdateQuery(tableName.toCql(), person, 
                    new WriteOptions(), template.getConverter());

注意: Apache Cassandra 1.5的Spring数据使用BATCH语句进行插入，这将随着2.0版的发布而改变。

CassandraTemplate和CassandraConverter是创建1.5版查询所涉及的关键类。在Spring data2.0中，事情将发生一些变化，因为2.0将为部分实体更新提供额外的Query和Update类型。因此，查询创建从CassandraTemplate.create…Query(…)转移到QueryUtils.create…Query(…)。