fix: RedisEnchanceKeyValueAdapter#put make DEL/HMSET combo in a pipeline

redis · Aug 6, 2024 · 5396979 · 5396979
1 parent f3fbd0c
commit 5396979
Showing 1 changed file with 2 additions and 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
@@ -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);