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

wip: Completed delete aync first pass. Still have to add QueryOptions

Browse Source 
to everything
This commit is contained in:
dwebb
2013-11-13 16:57:09 -05:00
parent 810b217fd7
commit 897f05e3b3
1 changed files with 33 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
src/main/java/org/springframework/data/cassandra/core/CassandraTemplate.java
View File

@@ -644,7 +644,14 @@ public class CassandraTemplate implements CassandraOperations {
*/
@Override
public <T> void delete(T entity) {
delete(entity, determineTableName(entity.getClass()));
Assert.notNull(entity);
String tableName = getTableName(entity.getClass());
Assert.notNull(tableName);
delete(entity, tableName);
}
/* (non-Javadoc)
@@ -696,8 +703,14 @@ public class CassandraTemplate implements CassandraOperations {
*/
@Override
public <T> void deleteAsychronously(T entity) {
// TODO Auto-generated method stub
Assert.notNull(entity);
String tableName = getTableName(entity.getClass());
Assert.notNull(tableName);
deleteAsychronously(entity, tableName);
}
/* (non-Javadoc)
@@ -705,8 +718,15 @@ public class CassandraTemplate implements CassandraOperations {
*/
@Override
public <T> void deleteAsychronously(List<T> entities) {
// TODO Auto-generated method stub
Assert.notNull(entities);
Assert.notEmpty(entities);
String tableName = getTableName(entities.get(0).getClass());
Assert.notNull(tableName);
deleteAsychronously(entities, tableName);
}
/* (non-Javadoc)
@@ -714,8 +734,12 @@ public class CassandraTemplate implements CassandraOperations {
*/
@Override
public <T> void deleteAsychronously(T entity, String tableName) {
// TODO Auto-generated method stub
CassandraPersistentEntity<?> entityClass = getEntity(entity);
Assert.notNull(entityClass);
doDelete(entity, tableName, true);
}
/* (non-Javadoc)
@@ -723,8 +747,12 @@ public class CassandraTemplate implements CassandraOperations {
*/
@Override
public <T> void deleteAsychronously(List<T> entities, String tableName) {
// TODO Auto-generated method stub
Assert.notNull(entities);
Assert.notEmpty(entities);
Assert.notNull(tableName);
doBatchDelete(tableName, entities, true);
}
/* (non-Javadoc)