Comment puis-je examiner la chaîne de requête générée par Spring données Cassandra Mapper

Question

Si j'annoter une classe avec des annotations de com.datastax.driver.mapping.annotations, je peux écrire un test le long des lignes de:

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

MyAnnotatedClass entity = ...; 

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

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

Cependant, j'ai classes d'entités annotée avec org.springframework.data.cassandra.mapping annotations. J'ai été incapable de trouver un ressort équivalent à saveQuery(), getQuery() et deleteQuery() de Mapper.

Comment puis-je écrire (idéalement léger lors de l'exécution) des tests concernant le CQL généré à partir des classes d'entités annotées Cassandra de Spring Data?

Answer 1

avec des données Spring pour Apache Cassandra 1.5, vous pouvez écrire le code suivant pour créer Statement s:

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()); 

Note: Les données Spring pour Apache Cassandra 1.5 utilise BATCH déclarations pour les insertions, qui va changer avec la version 2.0.

CassandraTemplate et CassandraConverter sont les classes clés impliquées dans la création de requêtes pour la version 1.5. Dans Spring Data 2.0, les choses vont changer un peu car 2.0 va être livré avec des types supplémentaires Query et Update pour les mises à jour d'entités partielles. La création de requêtes passe ainsi de CassandraTemplate.create…Query(…) à QueryUtils.create…Query(…).