1
1
package redis .clients .jedis .commands .unified ;
2
2
3
3
import static java .util .Collections .singletonList ;
4
- import static org .junit .Assert .assertArrayEquals ;
5
- import static org .junit .Assert .assertEquals ;
6
- import static org .junit .Assert .assertFalse ;
7
- import static org .junit .Assert .assertNotNull ;
8
- import static org .junit .Assert .assertNull ;
4
+ import static org .junit .Assert .*;
9
5
import static redis .clients .jedis .params .ScanParams .SCAN_POINTER_START ;
10
6
import static redis .clients .jedis .params .ScanParams .SCAN_POINTER_START_BINARY ;
11
7
import static redis .clients .jedis .util .AssertUtil .assertByteArrayListEquals ;
12
8
13
- import java .util .ArrayList ;
14
- import java .util .Arrays ;
15
- import java .util .Collections ;
16
- import java .util .HashMap ;
17
- import java .util .Iterator ;
18
- import java .util .List ;
19
- import java .util .Map ;
20
-
9
+ import java .util .*;
21
10
import org .junit .Test ;
11
+
22
12
import redis .clients .jedis .args .SortedSetOption ;
23
- import redis .clients .jedis .params .ScanParams ;
24
- import redis .clients .jedis .params .ZAddParams ;
25
- import redis .clients .jedis .params .ZIncrByParams ;
26
- import redis .clients .jedis .params .ZParams ;
27
- import redis .clients .jedis .params .ZRangeParams ;
13
+ import redis .clients .jedis .params .*;
28
14
import redis .clients .jedis .resps .ScanResult ;
29
15
import redis .clients .jedis .resps .Tuple ;
30
16
import redis .clients .jedis .util .AssertUtil ;
33
19
34
20
public abstract class SortedSetCommandsTestBase extends UnifiedJedisCommandsTestBase {
35
21
final byte [] bfoo = { 0x01 , 0x02 , 0x03 , 0x04 };
36
- final byte [] bfoo_same_hashslot = { 0x01 , 0x02 , 0x03 , 0x04 , 0x03 , 0x00 , 0x03 , 0x1b };
37
22
final byte [] bbar = { 0x05 , 0x06 , 0x07 , 0x08 };
38
23
final byte [] bcar = { 0x09 , 0x0A , 0x0B , 0x0C };
39
24
final byte [] ba = { 0x0A };
@@ -103,7 +88,7 @@ public void zaddWithParams() {
103
88
assertNull (jedis .zaddIncr ("foo" , 1d , "b" , ZAddParams .zAddParams ().nx ()));
104
89
assertEquals (Double .valueOf (2d ), jedis .zscore ("foo" , "b" ));
105
90
// incr: update elements that already exist.
106
- assertEquals (Double .valueOf (3d ), jedis .zaddIncr ("foo" , 1d , "b" , ZAddParams .zAddParams ().xx ()));
91
+ assertEquals (Double .valueOf (3d ), jedis .zaddIncr ("foo" , 1d ,"b" , ZAddParams .zAddParams ().xx ()));
107
92
assertEquals (Double .valueOf (3d ), jedis .zscore ("foo" , "b" ));
108
93
109
94
// binary
@@ -327,14 +312,14 @@ public void zrangeParams() {
327
312
328
313
@ Test
329
314
public void zrangestore () {
330
- jedis .zadd ("foo{.} " , 1 , "aa" );
331
- jedis .zadd ("foo{.} " , 2 , "c" );
332
- jedis .zadd ("foo{.} " , 3 , "bb" );
315
+ jedis .zadd ("foo" , 1 , "aa" );
316
+ jedis .zadd ("foo" , 2 , "c" );
317
+ jedis .zadd ("foo" , 3 , "bb" );
333
318
334
- long stored = jedis .zrangestore ("bar{.} " , "foo{.} " , ZRangeParams .zrangeByScoreParams (1 , 2 ));
319
+ long stored = jedis .zrangestore ("bar" , "foo" , ZRangeParams .zrangeByScoreParams (1 , 2 ));
335
320
assertEquals (2 , stored );
336
321
337
- List <String > range = jedis .zrange ("bar{.} " , 0 , -1 );
322
+ List <String > range = jedis .zrange ("bar" , 0 , -1 );
338
323
List <String > expected = new ArrayList <>();
339
324
expected .add ("aa" );
340
325
expected .add ("c" );
@@ -346,10 +331,10 @@ public void zrangestore() {
346
331
jedis .zadd (bfoo , 0.1d , bc );
347
332
jedis .zadd (bfoo , 2d , ba );
348
333
349
- long bstored = jedis .zrangestore (bfoo_same_hashslot , bfoo , ZRangeParams .zrangeParams (0 , 1 ).rev ());
334
+ long bstored = jedis .zrangestore (bbar , bfoo , ZRangeParams .zrangeParams (0 , 1 ).rev ());
350
335
assertEquals (2 , bstored );
351
336
352
- List <byte []> brange = jedis .zrevrange (bfoo_same_hashslot , 0 , 1 );
337
+ List <byte []> brange = jedis .zrevrange (bbar , 0 , 1 );
353
338
List <byte []> bexpected = new ArrayList <>();
354
339
bexpected .add (bb );
355
340
bexpected .add (ba );
@@ -649,7 +634,7 @@ public void zmscore() {
649
634
jedis .zadd (bfoo , 2d , ba );
650
635
651
636
assertEquals (Arrays .asList (10d , 0.1d , null ),
652
- jedis .zmscore (bfoo , bb , bc , SafeEncoder .encode ("s" )));
637
+ jedis .zmscore (bfoo , bb , bc , SafeEncoder .encode ("s" )));
653
638
}
654
639
655
640
@ Test
@@ -905,7 +890,7 @@ public void zrangebyscore() {
905
890
906
891
brange = jedis .zrangeByScore (bfoo , 0d , 2d , 1 , 1 );
907
892
List <byte []> brange2 = jedis .zrangeByScore (bfoo , SafeEncoder .encode ("-inf" ),
908
- SafeEncoder .encode ("(2" ));
893
+ SafeEncoder .encode ("(2" ));
909
894
assertByteArrayListEquals (bexpected , brange2 );
910
895
911
896
bexpected = new ArrayList <byte []>();
@@ -985,7 +970,7 @@ public void zrevrangebyscore() {
985
970
assertByteArrayListEquals (bexpected , brange );
986
971
987
972
List <byte []> brange2 = jedis .zrevrangeByScore (bfoo , SafeEncoder .encode ("+inf" ),
988
- SafeEncoder .encode ("(2" ));
973
+ SafeEncoder .encode ("(2" ));
989
974
990
975
bexpected = new ArrayList <byte []>();
991
976
bexpected .add (bb );
@@ -1343,7 +1328,7 @@ public void zinter() {
1343
1328
assertEquals (singletonList ("a" ), jedis .zinter (params , "foo" , "bar" ));
1344
1329
1345
1330
assertEquals (singletonList (new Tuple ("a" , new Double (7 ))),
1346
- jedis .zinterWithScores (params , "foo" , "bar" ));
1331
+ jedis .zinterWithScores (params , "foo" , "bar" ));
1347
1332
1348
1333
// Binary
1349
1334
jedis .zadd (bfoo , 1 , ba );
@@ -1356,7 +1341,7 @@ public void zinter() {
1356
1341
AssertUtil .assertByteArrayListEquals (singletonList (ba ), jedis .zinter (params , bfoo , bbar ));
1357
1342
1358
1343
assertEquals (singletonList (new Tuple (ba , new Double (7 ))),
1359
- jedis .zinterWithScores (bparams , bfoo , bbar ));
1344
+ jedis .zinterWithScores (bparams , bfoo , bbar ));
1360
1345
}
1361
1346
1362
1347
@ Test
@@ -1413,22 +1398,22 @@ public void zintertoreParams() {
1413
1398
1414
1399
@ Test
1415
1400
public void zintercard () {
1416
- jedis .zadd ("foo{.} " , 1 , "a" );
1417
- jedis .zadd ("foo{.} " , 2 , "b" );
1418
- jedis .zadd ("bar{.} " , 2 , "a" );
1419
- jedis .zadd ("bar{.} " , 1 , "b" );
1401
+ jedis .zadd ("foo" , 1 , "a" );
1402
+ jedis .zadd ("foo" , 2 , "b" );
1403
+ jedis .zadd ("bar" , 2 , "a" );
1404
+ jedis .zadd ("bar" , 1 , "b" );
1420
1405
1421
- assertEquals (2 , jedis .zintercard ("foo{.} " , "bar{.} " ));
1422
- assertEquals (1 , jedis .zintercard (1 , "foo{.} " , "bar{.} " ));
1406
+ assertEquals (2 , jedis .zintercard ("foo" , "bar" ));
1407
+ assertEquals (1 , jedis .zintercard (1 , "foo" , "bar" ));
1423
1408
1424
1409
// Binary
1425
1410
jedis .zadd (bfoo , 1 , ba );
1426
1411
jedis .zadd (bfoo , 2 , bb );
1427
- jedis .zadd (bfoo_same_hashslot , 2 , ba );
1428
- jedis .zadd (bfoo_same_hashslot , 2 , bb );
1412
+ jedis .zadd (bbar , 2 , ba );
1413
+ jedis .zadd (bbar , 2 , bb );
1429
1414
1430
- assertEquals (2 , jedis .zintercard (bfoo , bfoo_same_hashslot ));
1431
- assertEquals (1 , jedis .zintercard (1 , bfoo , bfoo_same_hashslot ));
1415
+ assertEquals (2 , jedis .zintercard (bfoo , bbar ));
1416
+ assertEquals (1 , jedis .zintercard (1 , bfoo , bbar ));
1432
1417
}
1433
1418
1434
1419
@ Test
0 commit comments