Oh damn! forgot to add these files
This commit is contained in:
49
src/main/java/redis/clients/jedis/Jedis.java
Normal file
49
src/main/java/redis/clients/jedis/Jedis.java
Normal file
@@ -0,0 +1,49 @@
|
|||||||
|
package redis.clients.jedis;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
|
||||||
|
public class Jedis extends Client {
|
||||||
|
public Jedis(String host) {
|
||||||
|
super(host);
|
||||||
|
}
|
||||||
|
|
||||||
|
public String ping() {
|
||||||
|
// TODO: I want to be able to do the followin
|
||||||
|
// return protocol.runCommand(os,
|
||||||
|
// "PING").getSingleLineReply(inputStream);
|
||||||
|
// or even maybe
|
||||||
|
// return protocol.runCommand("PING").getSingleLineReply();
|
||||||
|
|
||||||
|
String command = protocol.buildCommand("PING");
|
||||||
|
try {
|
||||||
|
outputStream.write(command.getBytes());
|
||||||
|
return protocol.getSingleLineReply(inputStream);
|
||||||
|
} catch (IOException e) {
|
||||||
|
// TODO Not sure what to do here
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public String set(String key, String value) {
|
||||||
|
String command = protocol.buildCommand("SET", key, value);
|
||||||
|
try {
|
||||||
|
outputStream.write(command.getBytes());
|
||||||
|
return protocol.getSingleLineReply(inputStream);
|
||||||
|
} catch (IOException e) {
|
||||||
|
// TODO Not sure what to do here
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public String get(String key) {
|
||||||
|
String command = protocol.buildCommand("GET", key);
|
||||||
|
try {
|
||||||
|
outputStream.write(command.getBytes());
|
||||||
|
return protocol.getBulkReply(inputStream);
|
||||||
|
} catch (IOException e) {
|
||||||
|
// TODO Not sure what to do here
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
42
src/test/java/redis/clients/jedis/tests/JedisTest.java
Normal file
42
src/test/java/redis/clients/jedis/tests/JedisTest.java
Normal file
@@ -0,0 +1,42 @@
|
|||||||
|
package redis.clients.jedis.tests;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.net.UnknownHostException;
|
||||||
|
|
||||||
|
import junit.framework.Assert;
|
||||||
|
|
||||||
|
import org.junit.After;
|
||||||
|
import org.junit.Before;
|
||||||
|
import org.junit.Test;
|
||||||
|
|
||||||
|
import redis.clients.jedis.Jedis;
|
||||||
|
|
||||||
|
public class JedisTest extends Assert {
|
||||||
|
private Jedis jedis;
|
||||||
|
|
||||||
|
@Before
|
||||||
|
public void setUp() throws Exception {
|
||||||
|
jedis = new Jedis("localhost");
|
||||||
|
jedis.connect();
|
||||||
|
}
|
||||||
|
|
||||||
|
@After
|
||||||
|
public void tearDown() throws Exception {
|
||||||
|
jedis.disconnect();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void ping() throws UnknownHostException, IOException {
|
||||||
|
String status = jedis.ping();
|
||||||
|
assertEquals("PONG", status);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void setAndGet() throws UnknownHostException, IOException {
|
||||||
|
String status = jedis.set("foo", "bar");
|
||||||
|
assertEquals("OK", status);
|
||||||
|
|
||||||
|
String value = jedis.get("foo");
|
||||||
|
assertEquals("bar", value);
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user