diff --git a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/CassandraBatchOperations.java b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/CassandraBatchOperations.java index c17799a5a..02bd3aec7 100644 --- a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/CassandraBatchOperations.java +++ b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/CassandraBatchOperations.java @@ -159,7 +159,7 @@ default CassandraBatchOperations update(Object entity, WriteOptions options) { Assert.notNull(entity, "Entity must not be null"); - return insert(Collections.singleton(entity), options); + return update(Collections.singleton(entity), options); } /** diff --git a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/ReactiveCassandraBatchOperations.java b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/ReactiveCassandraBatchOperations.java index fcf4cf8fd..6d4046c9a 100644 --- a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/ReactiveCassandraBatchOperations.java +++ b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/ReactiveCassandraBatchOperations.java @@ -210,7 +210,7 @@ default ReactiveCassandraBatchOperations update(Object entity, WriteOptions opti Assert.notNull(entity, "Entity must not be null"); - return insert(Collections.singleton(entity), options); + return update(Collections.singleton(entity), options); } /**