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

DATACASS-142: fixed reported issue

Browse Source
This commit is contained in:
Matthew Adams
2014-09-12 11:13:17 -05:00
parent c86b32fba7
commit 1f7cbc4100
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/convert/MappingCassandraConverter.java
View File

@@ -299,6 +299,18 @@ public class MappingCassandraConverter extends AbstractCassandraConverter implem
protected void writeDeleteWhereFromWrapper(final BeanWrapper<Object> wrapper, final Where where, protected void writeDeleteWhereFromWrapper(final BeanWrapper<Object> wrapper, final Where where,
CassandraPersistentEntity<?> entity) { CassandraPersistentEntity<?> entity) {
// if the entity itself if a composite primary key, then we've recursed, so just add columns & return
if (entity.isCompositePrimaryKey()) {
entity.doWithProperties(new PropertyHandler<CassandraPersistentProperty>() {
@Override
public void doWithPersistentProperty(CassandraPersistentProperty p) {
where.and(QueryBuilder.eq(p.getColumnName().toCql(), wrapper.getProperty(p)));
}
});
return;
}
// else, wrapper is an entity with an id
Object id = getId(wrapper, entity); Object id = getId(wrapper, entity);
if (id == null) { if (id == null) {
String msg = String.format("no id value found in object {}", wrapper.getBean()); String msg = String.format("no id value found in object {}", wrapper.getBean());
@@ -335,7 +347,7 @@ public class MappingCassandraConverter extends AbstractCassandraConverter implem
final BeanWrapper<?> wrapper = object instanceof BeanWrapper ? (BeanWrapper<?>) object : BeanWrapper.create(object, final BeanWrapper<?> wrapper = object instanceof BeanWrapper ? (BeanWrapper<?>) object : BeanWrapper.create(object,
conversionService); conversionService);
object = wrapper == null ? object : wrapper.getBean(); object = wrapper.getBean();
if (!entity.getType().isAssignableFrom(object.getClass())) { if (!entity.getType().isAssignableFrom(object.getClass())) {
throw new IllegalArgumentException(String.format( throw new IllegalArgumentException(String.format(