Skip to content

Commit

Permalink
Test new hash commands in CommandObjects
Browse files Browse the repository at this point in the history
  • Loading branch information
@sazzad16
sazzad16 committed May 6, 2024
1 parent 1223b69 commit e73afee
Showing 1 changed file with 162 additions and 0 deletions.
162 changes: 162 additions & 0 deletions ...test/java/redis/clients/jedis/commands/commandobjects/CommandObjectsHashCommandsTest.java
View file
Original file line number Diff line number Diff line change
@@ -1,12 +1,14 @@
package redis.clients.jedis.commands.commandobjects;

import static java.util.Arrays.asList;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.allOf;
import static org.hamcrest.Matchers.anyOf;
import static org.hamcrest.Matchers.contains;
import static org.hamcrest.Matchers.containsInAnyOrder;
import static org.hamcrest.Matchers.equalTo;
import static org.hamcrest.Matchers.everyItem;
import static org.hamcrest.Matchers.greaterThanOrEqualTo;
import static org.hamcrest.Matchers.hasEntry;
import static org.hamcrest.Matchers.hasSize;
import static org.hamcrest.Matchers.lessThanOrEqualTo;
Expand All @@ -19,6 +21,7 @@

import org.junit.Test;
import redis.clients.jedis.RedisProtocol;
import redis.clients.jedis.args.ExpiryOption;
import redis.clients.jedis.params.ScanParams;
import redis.clients.jedis.resps.ScanResult;

Expand All @@ -27,8 +30,19 @@
*/
public class CommandObjectsHashCommandsTest extends CommandObjectsStandaloneTestBase {

private final byte[] bfoo = { 0x01, 0x02, 0x03, 0x04 };
private final byte[] bcar = { 0x09, 0x0A, 0x0B, 0x0C };

private final byte[] bbar1 = { 0x05, 0x06, 0x07, 0x08, 0x0A };
private final byte[] bbar2 = { 0x05, 0x06, 0x07, 0x08, 0x0B };
private final byte[] bbar3 = { 0x05, 0x06, 0x07, 0x08, 0x0C };

public CommandObjectsHashCommandsTest(RedisProtocol protocol) {
super(protocol);
// TODO: remove -->
setUp();
exec(commandObjects.configSet("hash-max-listpack-entries", "0"));
// <-- TODO: remove
}

@Test
Expand Down Expand Up @@ -402,4 +416,152 @@ public void testHashStrlen() {
Long strlenNonExistingFieldBinary = exec(commandObjects.hstrlen(bkey, "nonExistingField".getBytes()));
assertThat(strlenNonExistingFieldBinary, equalTo(0L));
}

@Test
public void hexpireAndHttl() {
long seconds = 20;

exec(commandObjects.hset("foo", "bar", "car"));
exec(commandObjects.hset("foo", "bare", "care"));
assertThat(exec(commandObjects.hexpire("foo", seconds, "bar", "bared")), equalTo(asList(1L, -2L)));

exec(commandObjects.hset("foo", "bared", "cared"));
assertThat(exec(commandObjects.hexpire("foo", -1, ExpiryOption.NX, "bar", "bared")), equalTo(asList(0L, 2L)));

assertThat(exec(commandObjects.httl("foo", "bar", "bare", "bared")),
contains(greaterThanOrEqualTo(seconds - 1L), equalTo(-1L), equalTo(-2L)));
}

@Test
public void hpexpireAndHpttl() {
long millis = 20_000;

exec(commandObjects.hset("foo", "bar", "car"));
assertThat(exec(commandObjects.hpexpire("foo", millis, "bar", "bared")), equalTo(asList(1L, -2L)));

exec(commandObjects.hset("foo", "bared", "cared"));
assertThat(exec(commandObjects.hpexpire("foo", -100, ExpiryOption.XX, "bar", "bared")), equalTo(asList(2L, 0L)));

assertThat(exec(commandObjects.hpttl("foo", "bar", "bare", "bared")),
contains(equalTo(-2L), equalTo(-2L), equalTo(-1L)));
}

@Test
public void hexpireAtAndExpireTime() {
long currSeconds = System.currentTimeMillis() / 1000;
long unixSeconds = currSeconds + 20;

exec(commandObjects.hset("foo", "bar", "car"));
exec(commandObjects.hset("foo", "bare", "care"));
assertThat(exec(commandObjects.hexpireAt("foo", unixSeconds, "bar", "bared")), equalTo(asList(1L, -2L)));

exec(commandObjects.hset("foo", "bared", "cared"));
assertThat(exec(commandObjects.hexpireAt("foo", currSeconds - 1, ExpiryOption.LT, "bar", "bared")), equalTo(asList(2L, 0L)));

assertThat(exec(commandObjects.hexpireTime("foo", "bar", "bare", "bared")),
contains(equalTo(-2L), equalTo(-1L), equalTo(-1L)));
}

@Test
public void hpexpireAtAndPexpireTime() {
long currMillis = System.currentTimeMillis();
long unixMillis = currMillis + 20_000;

exec(commandObjects.hset("foo", "bar", "car"));
assertThat(exec(commandObjects.hpexpireAt("foo", unixMillis - 100, "bar", "bared")), equalTo(asList(1L, -2L)));

exec(commandObjects.hset("foo", "bared", "cared"));
assertThat(exec(commandObjects.hpexpireAt("foo", unixMillis, ExpiryOption.GT, "bar", "bared")), equalTo(asList(1L, 0L)));

assertThat(exec(commandObjects.hpexpireTime("foo", "bar", "bare", "bared")),
contains(equalTo(unixMillis), equalTo(-2L), equalTo(-1L)));
}

@Test
public void hpersist() {
long seconds = 20;

exec(commandObjects.hset("foo", "bar", "car"));
exec(commandObjects.hset("foo", "bare", "care"));
assertThat(exec(commandObjects.hexpire("foo", seconds, "bar", "bared")), equalTo(asList(1L, -2L)));

assertThat(exec(commandObjects.hpersist("foo", "bar", "bare", "bared")), equalTo(asList(1L, -1L, -2L)));

assertThat(exec(commandObjects.httl("foo", "bar", "bare", "bared")),
contains(equalTo(-1L), equalTo(-1L), equalTo(-2L)));
}

@Test
public void hexpireAndHttlBinary() {
long seconds = 20;

exec(commandObjects.hset(bfoo, bbar1, bcar));
exec(commandObjects.hset(bfoo, bbar2, bcar));
assertThat(exec(commandObjects.hexpire(bfoo, seconds, bbar1, bbar3)), equalTo(asList(1L, -2L)));

exec(commandObjects.hset(bfoo, bbar3, bcar));
assertThat(exec(commandObjects.hexpire(bfoo, -1, ExpiryOption.NX, bbar1, bbar3)), equalTo(asList(0L, 2L)));

assertThat(exec(commandObjects.httl(bfoo, bbar1, bbar2, bbar3)),
contains(greaterThanOrEqualTo(seconds - 1L), equalTo(-1L), equalTo(-2L)));
}

@Test
public void hpexpireAndHpttlBinary() {
long millis = 20_000;

exec(commandObjects.hset(bfoo, bbar1, bcar));
assertThat(exec(commandObjects.hpexpire(bfoo, millis, bbar1, bbar3)), equalTo(asList(1L, -2L)));

exec(commandObjects.hset(bfoo, bbar3, bcar));
assertThat(exec(commandObjects.hpexpire(bfoo, -100, ExpiryOption.XX, bbar1, bbar3)), equalTo(asList(2L, 0L)));

assertThat(exec(commandObjects.hpttl(bfoo, bbar1, bbar2, bbar3)),
contains(equalTo(-2L), equalTo(-2L), equalTo(-1L)));
}

@Test
public void hexpireAtAndExpireTimeBinary() {
long currSeconds = System.currentTimeMillis() / 1000;
long unixSeconds = currSeconds + 20;

exec(commandObjects.hset(bfoo, bbar1, bcar));
exec(commandObjects.hset(bfoo, bbar2, bcar));
assertThat(exec(commandObjects.hexpireAt(bfoo, unixSeconds, bbar1, bbar3)), equalTo(asList(1L, -2L)));

exec(commandObjects.hset(bfoo, bbar3, bcar));
assertThat(exec(commandObjects.hexpireAt(bfoo, currSeconds - 1, ExpiryOption.LT, bbar1, bbar3)), equalTo(asList(2L, 0L)));

assertThat(exec(commandObjects.hexpireTime(bfoo, bbar1, bbar2, bbar3)),
contains(equalTo(-2L), equalTo(-1L), equalTo(-1L)));
}

@Test
public void hpexpireAtAndPexpireTimeBinary() {
long currMillis = System.currentTimeMillis();
long unixMillis = currMillis + 20_000;

exec(commandObjects.hset(bfoo, bbar1, bcar));
assertThat(exec(commandObjects.hpexpireAt(bfoo, unixMillis - 100, bbar1, bbar3)), equalTo(asList(1L, -2L)));

exec(commandObjects.hset(bfoo, bbar3, bcar));
assertThat(exec(commandObjects.hpexpireAt(bfoo, unixMillis, ExpiryOption.GT, bbar1, bbar3)), equalTo(asList(1L, 0L)));

assertThat(exec(commandObjects.hpexpireTime(bfoo, bbar1, bbar2, bbar3)),
contains(equalTo(unixMillis), equalTo(-2L), equalTo(-1L)));
}

@Test
public void hpersistBinary() {
long seconds = 20;

exec(commandObjects.hset(bfoo, bbar1, bcar));
exec(commandObjects.hset(bfoo, bbar2, bcar));
assertThat(exec(commandObjects.hexpire(bfoo, seconds, bbar1, bbar3)), equalTo(asList(1L, -2L)));

assertThat(exec(commandObjects.hpersist(bfoo, bbar1, bbar2, bbar3)), equalTo(asList(1L, -1L, -2L)));

assertThat(exec(commandObjects.httl(bfoo, bbar1, bbar2, bbar3)),
contains(equalTo(-1L), equalTo(-1L), equalTo(-2L)));
}
}

0 comments on commit e73afee

Please sign in to comment.