Correctly invoke update from CassandraBatchOperations.update.

Previously, we've called `insert` instead of `update`. Closes #1534
spring-projects · Nov 14, 2024 · 2390b31 · 2390b31
1 parent 4cddca9
commit 2390b31
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...andra/src/main/java/org/springframework/data/cassandra/core/CassandraBatchOperations.java b/...andra/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/...c/main/java/org/springframework/data/cassandra/core/ReactiveCassandraBatchOperations.java b/...c/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);
 	}
 
 	/**
-Original file line number
+Diff line change
@@ Expand Up @@
     		Assert.notNull(entity, "Entity must not be null");
-    		return insert(Collections.singleton(entity), options);
+    		return update(Collections.singleton(entity), options);
     	}
     	/**
@@ Expand Down @@