From e3ca3cdc87e853184fc819e5f9fb3531ac8e9dc7 Mon Sep 17 00:00:00 2001
From: Brian Sam-Bodden <bsb@redis.com>
Date: Tue, 6 Aug 2024 08:46:55 -0700
Subject: [PATCH] fix: RedisEnchanceKeyValueAdapter#put make DEL/HMSET combo in
 a pipeline

---
 .../com/redis/om/spring/RedisEnhancedKeyValueAdapter.java    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/redis-om-spring/src/main/java/com/redis/om/spring/RedisEnhancedKeyValueAdapter.java b/redis-om-spring/src/main/java/com/redis/om/spring/RedisEnhancedKeyValueAdapter.java
index 31a5b011..41753107 100644
--- a/redis-om-spring/src/main/java/com/redis/om/spring/RedisEnhancedKeyValueAdapter.java
+++ b/redis-om-spring/src/main/java/com/redis/om/spring/RedisEnhancedKeyValueAdapter.java
@@ -153,10 +153,9 @@ public Object put(Object id, Object item, String keyspace) {
       rdo.setId(converter.getConversionService().convert(id, String.class));
     }
 
-    byte[] objectKey = createKey(sanitizeKeyspace(rdo.getKeyspace()), rdo.getId());
-    redisOperations.execute((RedisCallback<Boolean>) connection -> connection.keyCommands().del(objectKey) == 0);
-
     redisOperations.executePipelined((RedisCallback<Object>) connection -> {
+      byte[] objectKey = createKey(sanitizeKeyspace(rdo.getKeyspace()), rdo.getId());
+      connection.keyCommands().del(objectKey);
       Map<byte[], byte[]> rawMap = rdo.getBucket().rawMap();
       connection.hashCommands().hMSet(objectKey, rawMap);