Spring/spring-data-redis
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

+ add support for linsert (as left/right push on RedisTemplate)

Browse Source
This commit is contained in:
Costin Leau
2011-01-10 14:03:51 +02:00
parent b1499b9998
commit 4cbf84f89f
4 changed files with 46 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/BoundListOperations.java
View File

@@ -35,8 +35,12 @@ public interface BoundListOperations<K, V> extends KeyBound<K> {
Long leftPush(V value);
Long leftPush(V pivot, V value);
Long rightPush(V value);
Long rightPush(V pivot, V value);
V leftPop();
V leftPop(long timeout, TimeUnit unit);
@@ -50,5 +54,4 @@ public interface BoundListOperations<K, V> extends KeyBound<K> {
V index(long index);
void set(long index, V value);
}

10
spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/DefaultBoundListOperations.java
View File

@@ -65,6 +65,11 @@ class DefaultBoundListOperations<K, V> extends DefaultKeyBound<K> implements Bou
return ops.leftPush(getKey(), value);
}
@Override
public Long leftPush(V pivot, V value) {
return ops.leftPush(getKey(), pivot, value);
}
@Override
public Long size() {
return ops.size(getKey());
@@ -96,6 +101,11 @@ class DefaultBoundListOperations<K, V> extends DefaultKeyBound<K> implements Bou
return ops.rightPush(getKey(), value);
}
@Override
public Long rightPush(V pivot, V value) {
return ops.rightPush(getKey(), pivot, value);
}
@Override
public void trim(long start, long end) {
ops.trim(getKey(), start, end);

4
spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/ListOperations.java
View File

@@ -33,8 +33,12 @@ public interface ListOperations<K, V> {
Long leftPush(K key, V value);
Long leftPush(K key, V pivot, V value);
Long rightPush(K key, V value);
Long rightPush(K key, V pivot, V value);
void set(K key, long index, V value);
Long remove(K key, long i, Object value);

29
spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/RedisTemplate.java
View File

@@ -35,6 +35,7 @@ import org.springframework.data.keyvalue.redis.connection.DataType;
import org.springframework.data.keyvalue.redis.connection.RedisConnection;
import org.springframework.data.keyvalue.redis.connection.RedisConnectionFactory;
import org.springframework.data.keyvalue.redis.connection.SortParameters;
import org.springframework.data.keyvalue.redis.connection.RedisListCommands.POSITION;
import org.springframework.data.keyvalue.redis.serializer.JdkSerializationRedisSerializer;
import org.springframework.data.keyvalue.redis.serializer.RedisSerializer;
import org.springframework.data.keyvalue.redis.serializer.StringRedisSerializer;
@@ -927,7 +928,6 @@ public class RedisTemplate<K, V> extends RedisAccessor implements RedisOperation
}, true);
}
@Override
public Long leftPush(K key, V value) {
final byte[] rawKey = rawKey(key);
@@ -940,6 +940,19 @@ public class RedisTemplate<K, V> extends RedisAccessor implements RedisOperation
}, true);
}
@Override
public Long leftPush(K key, V pivot, V value) {
final byte[] rawKey = rawKey(key);
final byte[] rawPivot = rawValue(pivot);
final byte[] rawValue = rawValue(value);
return execute(new RedisCallback<Long>() {
@Override
public Long doInRedis(RedisConnection connection) {
return connection.lInsert(rawKey, POSITION.BEFORE, rawPivot, rawValue);
}
}, true);
}
@Override
public Long size(K key) {
final byte[] rawKey = rawKey(key);
@@ -1008,6 +1021,20 @@ public class RedisTemplate<K, V> extends RedisAccessor implements RedisOperation
}, true);
}
@Override
public Long rightPush(K key, V pivot, V value) {
final byte[] rawKey = rawKey(key);
final byte[] rawPivot = rawValue(pivot);
final byte[] rawValue = rawValue(value);
return execute(new RedisCallback<Long>() {
@Override
public Long doInRedis(RedisConnection connection) {
return connection.lInsert(rawKey, POSITION.AFTER, rawPivot, rawValue);
}
}, true);
}
@Override
public V rightPopAndLeftPush(K sourceKey, K destinationKey) {
final byte[] rawDestKey = rawKey(destinationKey);