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 068e360cd..b2b6fd0e8 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 @@ -116,7 +116,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 c0d5abf9b..45a6c0bdb 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 @@ -139,7 +139,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); } /**