Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions src/main/java/org/redis/Main.java
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@

public class Main {
public static void main(String[] args) {

System.out.println("Hello world!");
}
}
117 changes: 117 additions & 0 deletions src/main/java/org/redis/RedisMap.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,117 @@
package org.redis;

import redis.clients.jedis.Jedis;

import java.util.AbstractMap;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.Set;

public class RedisMap implements Map<String, String> {

private final Jedis jedis;

public RedisMap(Jedis jedis) {

this.jedis = jedis;
}

@Override
public int size() {

long size = jedis.dbSize();
return Math.toIntExact(size);
}

@Override
public boolean isEmpty() {

if (size() == 0) {
return true;
}

return false;
}

@Override
public boolean containsKey(Object key) {

return jedis.exists(String.valueOf(key));
}

@Override
public boolean containsValue(Object value) {

for (String k : jedis.keys("*")) {
if (Objects.equals(jedis.get(k), value)) {
return true;
}
}
return false;
}

@Override
public String get(Object key) {
return jedis.get(String.valueOf(key));
}

@Override
public String put(String key, String value) {

String oldValue = jedis.get(key);
jedis.set(key, value);
return oldValue;
}

@Override
public String remove(Object key) {

String oldValue = jedis.get((String) key);
jedis.del(String.valueOf(key));
return oldValue;
}

@Override
public void putAll(Map<? extends String, ? extends String> m) {
for (Entry<? extends String, ? extends String> entry : m.entrySet()) {
jedis.set(entry.getKey(), entry.getValue());
}
}

@Override
public void clear() {

jedis.flushDB();
}

@Override
public Set<String> keySet() {

return jedis.keys("*");
}

@Override
public Collection<String> values() {

List<String> values = new ArrayList<>();
for (String key : keySet()) {
values.add(jedis.get(key));
}
return values;
}

@Override
public Set<Entry<String, String>> entrySet() {

Set<Entry<String, String>> entries = new HashSet<>();
for (String key : keySet()) {
entries.add(new AbstractMap.SimpleEntry<>(key, jedis.get(key)));
}

return entries;
}
}
57 changes: 57 additions & 0 deletions src/test/java/org/redis/RedisMapTest.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,57 @@
package org.redis;

import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
import redis.clients.jedis.Jedis;

import java.util.Map;

import static org.junit.jupiter.api.Assertions.*;

class RedisMapTest {

private static Jedis jedis;
private static Map<String, String> redisMap;

@BeforeAll
static void setup() {
jedis = new Jedis("localhost", 6379);
redisMap = new RedisMap(jedis);
redisMap.clear();
}

@AfterEach
void cleanup() {
redisMap.clear();
}

@Test
void testPutAndGet() {
redisMap.put("key1", "value1");
assertEquals("value1", redisMap.get("key1"));
}

@Test
void testRemove() {
redisMap.put("key1", "value1");
assertEquals("value1", redisMap.remove("key1"));
assertNull(redisMap.get("key1"));
}

@Test
void testContainsKeyAndValue() {
redisMap.put("key1", "value1");
assertTrue(redisMap.containsKey("key1"));
assertTrue(redisMap.containsValue("value1"));
}

@Test
void testSizeAndClear() {
redisMap.put("a", "1");
redisMap.put("b", "2");
assertEquals(2, redisMap.size());
redisMap.clear();
assertTrue(redisMap.isEmpty());
}
}