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

Fix RJC zRevRangeWithScores returns incorrect results

Browse Source 
DATAREDIS-137
This commit is contained in:
Jennifer Hickey
2013-04-01 10:27:39 -07:00
parent 97ebd34b2d
commit a421238403
3 changed files with 2 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/springframework/data/redis/connection/rjc/RjcConnection.java
View File

@@ -1670,16 +1670,14 @@ public class RjcConnection implements RedisConnection {
public Set<Tuple> zRevRangeWithScores(byte[] key, long start, long end) {
String stringKey = RjcUtils.decode(key);
String minString = Long.toString(start);
String maxString = Long.toString(end);
try {
if (isPipelined()) {
pipeline.zrevrangeByScoreWithScores(stringKey, minString, maxString);
pipeline.zrevrangeWithScores(stringKey, (int) start, (int) end);
return null;
}
return RjcUtils.convertElementScore(session.zrevrangeByScoreWithScores(stringKey, minString, maxString));
return RjcUtils.convertElementScore(session.zrevrangeWithScores(stringKey, (int) start, (int) end));
} catch (Exception ex) {
throw convertRjcAccessException(ex);
}

4
src/test/java/org/springframework/data/redis/connection/rjc/RjcConnectionIntegrationTests.java
View File

@@ -104,10 +104,6 @@ public class RjcConnectionIntegrationTests extends AbstractConnectionIntegration
public void testPubSubWithPatterns() {
}
@Ignore("DATAREDIS-137 zRevRangeWithScores returns incorrect results")
public void testZRevRangeWithScores() {
}
@Ignore("DATAREDIS-148 Syntax error on RJC zUnionStore")
public void testZUnionStoreAggWeights() {
}

4
src/test/java/org/springframework/data/redis/connection/rjc/RjcConnectionPipelineIntegrationTests.java
View File

@@ -85,10 +85,6 @@ public class RjcConnectionPipelineIntegrationTests extends
public void testStrLen() {
}
@Ignore("DATAREDIS-137 zRevRangeWithScores returns incorrect results")
public void testZRevRangeWithScores() {
}
@Ignore("DATAREDIS-148 Syntax error on RJC zUnionStore")
public void testZUnionStoreAggWeights() {
}