diff --git a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/exception/UnsupportedCassandraOperationException.java b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/exception/UnsupportedCassandraOperationException.java new file mode 100644 index 000000000..2a12a7942 --- /dev/null +++ b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/exception/UnsupportedCassandraOperationException.java @@ -0,0 +1,16 @@ +package org.springframework.data.cassandra.exception; + +import org.springframework.dao.InvalidDataAccessApiUsageException; + +public class UnsupportedCassandraOperationException extends InvalidDataAccessApiUsageException { + + private static final long serialVersionUID = 4921001859094231277L; + + public UnsupportedCassandraOperationException(String msg) { + super(msg); + } + + public UnsupportedCassandraOperationException(String msg, Throwable cause) { + super(msg, cause); + } +} diff --git a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/mapping/BasicCassandraPersistentEntity.java b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/mapping/BasicCassandraPersistentEntity.java index 3e97477dc..74fb9fd2c 100644 --- a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/mapping/BasicCassandraPersistentEntity.java +++ b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/mapping/BasicCassandraPersistentEntity.java @@ -20,7 +20,10 @@ import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContextAware; import org.springframework.context.expression.BeanFactoryAccessor; import org.springframework.context.expression.BeanFactoryResolver; +import org.springframework.data.cassandra.exception.UnsupportedCassandraOperationException; import org.springframework.data.cassandra.util.CassandraNamingUtils; +import org.springframework.data.mapping.Association; +import org.springframework.data.mapping.AssociationHandler; import org.springframework.data.mapping.model.BasicPersistentEntity; import org.springframework.data.util.TypeInformation; import org.springframework.expression.Expression; @@ -69,6 +72,16 @@ public class BasicCassandraPersistentEntity extends BasicPersistentEntity association) { + throw new UnsupportedCassandraOperationException("Cassandra does not support associations"); + } + + @Override + public void doWithAssociations(AssociationHandler handler) { + throw new UnsupportedCassandraOperationException("Cassandra does not support associations"); + } + @Override public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {