diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundHashOperations.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundHashOperations.java index f531d5628..4ed2aece3 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundHashOperations.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundHashOperations.java @@ -36,7 +36,7 @@ class DefaultBoundHashOperations extends DefaultKeyBound implement */ public DefaultBoundHashOperations(H key, RedisOperations operations) { super(key); - this.ops = operations.hashOps(); + this.ops = operations.getHashOps(); } @Override diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundListOperations.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundListOperations.java index c69181acb..5793f57ae 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundListOperations.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundListOperations.java @@ -36,7 +36,7 @@ class DefaultBoundListOperations extends DefaultKeyBound implements Bou */ public DefaultBoundListOperations(K key, RedisOperations operations) { super(key); - this.ops = operations.listOps(); + this.ops = operations.getListOps(); } diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundSetOperations.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundSetOperations.java index b2770c0d9..8050abc2b 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundSetOperations.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundSetOperations.java @@ -37,7 +37,7 @@ class DefaultBoundSetOperations extends DefaultKeyBound implements Boun */ DefaultBoundSetOperations(K key, RedisOperations operations) { super(key); - this.ops = operations.setOps(); + this.ops = operations.getSetOps(); } @Override diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundValueOperations.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundValueOperations.java index 8de451738..3e459ff78 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundValueOperations.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundValueOperations.java @@ -32,7 +32,7 @@ class DefaultBoundValueOperations extends DefaultKeyBound implements Bo */ public DefaultBoundValueOperations(K key, RedisOperations operations) { super(key); - this.ops = operations.valueOps(); + this.ops = operations.getValueOps(); } @Override diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundZSetOperations.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundZSetOperations.java index 44740a7c5..412ee6a19 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundZSetOperations.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundZSetOperations.java @@ -36,7 +36,7 @@ class DefaultBoundZSetOperations extends DefaultKeyBound implements Bou */ public DefaultBoundZSetOperations(K key, RedisOperations oeprations) { super(key); - this.ops = oeprations.zSetOps(); + this.ops = oeprations.getZSetOps(); } @Override diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/RedisTemplate.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/RedisTemplate.java index bf9231745..acc89699d 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/RedisTemplate.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/RedisTemplate.java @@ -561,12 +561,12 @@ public class RedisTemplate extends RedisAccessor implements RedisOperation } @Override - public BoundValueOperations forValue(K key) { + public BoundValueOperations boundValueOps(K key) { return new DefaultBoundValueOperations(key, this); } @Override - public ValueOperations valueOps() { + public ValueOperations getValueOps() { return new DefaultValueOperations(); } @@ -725,12 +725,12 @@ public class RedisTemplate extends RedisAccessor implements RedisOperation } @Override - public ListOperations listOps() { + public ListOperations getListOps() { return new DefaultListOperations(); } @Override - public BoundListOperations forList(K key) { + public BoundListOperations boundListOps(K key) { return new DefaultBoundListOperations(key, this); } @@ -913,12 +913,12 @@ public class RedisTemplate extends RedisAccessor implements RedisOperation // @Override - public BoundSetOperations forSet(K key) { + public BoundSetOperations boundSetOps(K key) { return new DefaultBoundSetOperations(key, this); } @Override - public SetOperations setOps() { + public SetOperations getSetOps() { return new DefaultSetOperations(); } @@ -1073,12 +1073,12 @@ public class RedisTemplate extends RedisAccessor implements RedisOperation // @Override - public BoundZSetOperations forZSet(K key) { + public BoundZSetOperations boundZSetOps(K key) { return new DefaultBoundZSetOperations(key, this); } @Override - public ZSetOperations zSetOps() { + public ZSetOperations getZSetOps() { return new DefaultZSetOperations(); } @@ -1267,12 +1267,12 @@ public class RedisTemplate extends RedisAccessor implements RedisOperation // @Override - public BoundHashOperations forHash(K key) { + public BoundHashOperations boundHashOps(K key) { return new DefaultBoundHashOperations(key, this); } @Override - public HashOperations hashOps() { + public HashOperations getHashOps() { return new DefaultHashOperations(); } diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/ZSetOperations.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/ZSetOperations.java index fe212f78f..9f897e42f 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/ZSetOperations.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/ZSetOperations.java @@ -34,10 +34,6 @@ public interface ZSetOperations { Set reverseRange(K key, long start, long end); - void removeRange(K key, long start, long end); - - void removeRangeByScore(K key, double min, double max); - void unionAndStore(K key, K destKey, Collection keys); Boolean add(K key, V value, double score); @@ -50,6 +46,10 @@ public interface ZSetOperations { Boolean remove(K key, Object o); + void removeRange(K key, long start, long end); + + void removeRangeByScore(K key, double min, double max); + Long size(K key); RedisOperations getOperations(); diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/atomic/RedisAtomicInteger.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/atomic/RedisAtomicInteger.java index 9bc40c1eb..d2dcb53a7 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/atomic/RedisAtomicInteger.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/atomic/RedisAtomicInteger.java @@ -54,7 +54,7 @@ public class RedisAtomicInteger extends Number implements Serializable, KeyBound */ public RedisAtomicInteger(String redisCounter, RedisOperations operations, int initialValue) { this.key = redisCounter; - this.operations = operations.valueOps(); + this.operations = operations.getValueOps(); this.generalOps = operations; this.operations.set(redisCounter, initialValue); } diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/atomic/RedisAtomicLong.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/atomic/RedisAtomicLong.java index 05c6b1c4e..210504c0b 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/atomic/RedisAtomicLong.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/atomic/RedisAtomicLong.java @@ -54,7 +54,7 @@ public class RedisAtomicLong extends Number implements Serializable, KeyBound operations, long initialValue) { this.key = redisCounter; - this.operations = operations.valueOps(); + this.operations = operations.getValueOps(); this.operations.set(redisCounter, initialValue); } diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisList.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisList.java index 7d9072f7a..44a421dc4 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisList.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisList.java @@ -67,7 +67,7 @@ public class DefaultRedisList extends AbstractRedisCollection implements R * @param operations */ public DefaultRedisList(String key, RedisOperations operations) { - this(operations.forList(key)); + this(operations.boundListOps(key)); } /** diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisMap.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisMap.java index 649b6d198..e04a53552 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisMap.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisMap.java @@ -67,7 +67,7 @@ public class DefaultRedisMap implements RedisMap { * @param operations */ public DefaultRedisMap(String key, RedisOperations operations) { - this.hashOps = operations.forHash(key); + this.hashOps = operations.boundHashOps(key); } /** diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisSet.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisSet.java index 79e663800..4f00ce4da 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisSet.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisSet.java @@ -53,7 +53,7 @@ public class DefaultRedisSet extends AbstractRedisCollection implements Re */ public DefaultRedisSet(String key, RedisOperations operations) { super(key, operations); - boundSetOps = operations.forSet(key); + boundSetOps = operations.boundSetOps(key); } /** @@ -74,7 +74,7 @@ public class DefaultRedisSet extends AbstractRedisCollection implements Re @Override public RedisSet diffAndStore(String destKey, Collection> sets) { boundSetOps.diffAndStore(destKey, CollectionUtils.extractKeys(sets)); - return new DefaultRedisSet(boundSetOps.getOperations().forSet(destKey)); + return new DefaultRedisSet(boundSetOps.getOperations().boundSetOps(destKey)); } @Override @@ -85,7 +85,7 @@ public class DefaultRedisSet extends AbstractRedisCollection implements Re @Override public RedisSet intersectAndStore(String destKey, Collection> sets) { boundSetOps.intersectAndStore(destKey, CollectionUtils.extractKeys(sets)); - return new DefaultRedisSet(boundSetOps.getOperations().forSet(destKey)); + return new DefaultRedisSet(boundSetOps.getOperations().boundSetOps(destKey)); } @Override @@ -96,7 +96,7 @@ public class DefaultRedisSet extends AbstractRedisCollection implements Re @Override public RedisSet unionAndStore(String destKey, Collection> sets) { boundSetOps.unionAndStore(destKey, CollectionUtils.extractKeys(sets)); - return new DefaultRedisSet(boundSetOps.getOperations().forSet(destKey)); + return new DefaultRedisSet(boundSetOps.getOperations().boundSetOps(destKey)); } @Override diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisZSet.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisZSet.java index 243a65131..4a51b59e4 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisZSet.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/support/collections/DefaultRedisZSet.java @@ -64,7 +64,7 @@ public class DefaultRedisZSet extends AbstractRedisCollection implements R */ public DefaultRedisZSet(String key, RedisOperations operations, double defaultScore) { super(key, operations); - boundZSetOps = operations.forZSet(key); + boundZSetOps = operations.boundZSetOps(key); this.defaultScore = defaultScore; } @@ -93,7 +93,7 @@ public class DefaultRedisZSet extends AbstractRedisCollection implements R @Override public RedisZSet intersectAndStore(String destKey, Collection> sets) { boundZSetOps.intersectAndStore(destKey, CollectionUtils.extractKeys(sets)); - return new DefaultRedisZSet(boundZSetOps.getOperations().forZSet(destKey), getDefaultScore()); + return new DefaultRedisZSet(boundZSetOps.getOperations().boundZSetOps(destKey), getDefaultScore()); } @Override @@ -126,7 +126,7 @@ public class DefaultRedisZSet extends AbstractRedisCollection implements R @Override public RedisZSet unionAndStore(String destKey, Collection> sets) { boundZSetOps.unionAndStore(destKey, CollectionUtils.extractKeys(sets)); - return new DefaultRedisZSet(boundZSetOps.getOperations().forZSet(destKey), getDefaultScore()); + return new DefaultRedisZSet(boundZSetOps.getOperations().boundZSetOps(destKey), getDefaultScore()); } @Override diff --git a/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisListTests.java b/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisListTests.java index e8df0bfd2..f09b3c8c4 100644 --- a/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisListTests.java +++ b/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisListTests.java @@ -279,7 +279,7 @@ public abstract class AbstractRedisListTests extends AbstractRedisCollectionT @Test public void testCappedCollection() throws Exception { - RedisList cappedList = new DefaultRedisList(template.forList(collection.getKey() + ":capped"), 1); + RedisList cappedList = new DefaultRedisList(template.boundListOps(collection.getKey() + ":capped"), 1); T first = getT(); cappedList.offer(first); assertEquals(1, cappedList.size()); diff --git a/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisMapTests.java b/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisMapTests.java index 741423d6b..24697f57d 100644 --- a/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisMapTests.java +++ b/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisMapTests.java @@ -164,7 +164,7 @@ public abstract class AbstractRedisMapTests { @Test public void testNotEquals() { RedisOperations ops = map.getOperations(); - RedisStore newInstance = new DefaultRedisMap(ops. forHash(map.getKey() + ":new")); + RedisStore newInstance = new DefaultRedisMap(ops. boundHashOps(map.getKey() + ":new")); assertFalse(map.equals(newInstance)); assertFalse(newInstance.equals(map)); } diff --git a/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisSetTests.java b/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisSetTests.java index c8ca6f707..90fa1b059 100644 --- a/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisSetTests.java +++ b/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisSetTests.java @@ -59,7 +59,7 @@ public abstract class AbstractRedisSetTests extends AbstractRedisCollectionTe } private RedisSet createSetFor(String key) { - return new DefaultRedisSet((BoundSetOperations) set.getOperations().forSet(key)); + return new DefaultRedisSet((BoundSetOperations) set.getOperations().boundSetOps(key)); } @Test diff --git a/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisZSetTest.java b/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisZSetTest.java index 1e29571d5..f8223047d 100644 --- a/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisZSetTest.java +++ b/spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/support/collections/AbstractRedisZSetTest.java @@ -183,7 +183,7 @@ public abstract class AbstractRedisZSetTest extends AbstractRedisCollectionTe } private RedisZSet createZSetFor(String key) { - return new DefaultRedisZSet((BoundZSetOperations) zSet.getOperations().forZSet(key)); + return new DefaultRedisZSet((BoundZSetOperations) zSet.getOperations().boundZSetOps(key)); } @Test