Spring/spring-data-cassandra
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

wip: fixed and simplified the toBatchXXX() methods.

Browse Source
This commit is contained in:
dwebb
2013-11-15 15:31:43 -05:00
parent 0b591a5a71
commit fa7a5d2401
1 changed files with 3 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/main/java/org/springframework/data/cassandra/util/CqlUtils.java
View File

@@ -357,11 +357,9 @@ public abstract class CqlUtils {
*/
final Batch b = QueryBuilder.batch();
List<Query> queries = new ArrayList<Query>();
for (final T objectToSave : objectsToSave) {
queries.add(toUpdateQuery(keyspaceName, tableName, objectToSave, entity, optionsByName));
b.add((Statement) toUpdateQuery(keyspaceName, tableName, objectToSave, entity, optionsByName));
}
@@ -393,21 +391,12 @@ public abstract class CqlUtils {
*/
final Batch b = QueryBuilder.batch();
List<Query> queries = new ArrayList<Query>();
for (final T objectToSave : objectsToSave) {
queries.add(toInsertQuery(keyspaceName, tableName, objectToSave, entity, optionsByName));
b.add((Statement) toInsertQuery(keyspaceName, tableName, objectToSave, entity, optionsByName));
}
/*
* Add all the Queries to the batch
*/
for (Query query : queries) {
b.add((Statement) query);
}
addQueryOptions(b, optionsByName);
return b;
@@ -522,11 +511,9 @@ public abstract class CqlUtils {
*/
final Batch b = QueryBuilder.batch();
List<Query> queries = new ArrayList<Query>();
for (final T objectToSave : entities) {
queries.add(toDeleteQuery(keyspaceName, tableName, objectToSave, entity, optionsByName));
b.add((Statement) toDeleteQuery(keyspaceName, tableName, objectToSave, entity, optionsByName));
}