用java语言编写针对Redis数据库操作的DBHelper类。
其中主要针对数据库的增删该查方法,方法分为单一和集合类两种。
程序分为两部分,测试方法和封装类方法。
import redis.clients.jedis.Jedis;
/**
*redis的DBHelper描述
*
*/
public class DBHelper {
//属性封装
private Jedis jedis = null;// 客户端连接
//测试主方法
public static void main(String[] args) {
//起始配置
String LOCALHOST = "localhost";
int LOCALPOST = 6379;
String key = "key001";
String value = "abc";
// String key2="key002";
String value2 = "aaa";
// String keysValues = "'key201','value201','key202','value202'";
// String keys = "'key201','key202'";
// String[] keys2 = { "key201", "key202" };
//创建对象测试方法
DBHelper test = new DBHelper();
if (test.init(LOCALHOST, LOCALPOST)) {
test.set(key, value);
test.get(key);
test.updata(key, value2);
// test.delete(key);
// test.setMap(keysValues);
// test.getMap(keys);
// test.delMap(keys2);
// test.flush();
test.uninit();
} else {
System.out.println("初始化未成功,无法执行操作!");
}
}
/**
* 初始化方法
* @param LOCALHOST:主机名称
* @param LOCALPOST:数据库端口号:默认6379.
* @return
*/
public boolean init(String LOCALHOST, int LOCALPOST) {
if (jedis == null) {
jedis = new Jedis(LOCALHOST, LOCALPOST);
return true;
} else {
return false;
}
}
/**
* 销毁方法,结束方法
*/
public void uninit() {
System.out.println("已经退出redis数据库操作。");
}
/**
* 是否存在方法
* @param key:键值
*/
public boolean exist(String key) {
if (jedis != null) {
return jedis.exists(key);
} else {
return false;
}
}
/**
* 插入方法
* @param key:键值
* @param value:保存值
*/
public String set(String key, String value) {
if (jedis != null) {
boolean exist = exist(key);
if (exist == false) {
jedis.set(key, value);
return "增加插入操作已完成。";
} else {
return "增加插入操作无法操作。";
}
} else {
return "数据库链接未创建,无法操作";
}
}
/**
* 查询方法
* @param key:键值
*/
public String get(String key) {
if (jedis != null) {
boolean exist = exist(key);
if (exist == true) {
jedis.get(key);
System.out.println("您所查询的信息如下:" + jedis.get(key));
return "查询操作已完成。";
} else {
return "无法查询该键值,或键不存在";
}
} else {
return "数据库链接未创建,无法操作";
}
}
/**
* 修改方法
* @param key:键值
* @param value:保存值,有重置和追加两种方式,是插入的另一种方式
*/
public String updata(String key, String value) {
if (jedis != null) {
boolean exist = exist(key);
if (exist == true) {
jedis.set(key, value);
return "修改插入操作已完成。";
// jedis.append(key, value);
// return "追加修改操作已经完成";
} else {
jedis.set(key, value);
return "键值不存在,已完成新增插入操作。";
}
} else {
return "数据库链接未创建,无法操作";
}
}
/**
* 删除方法
* @param key:键值
*/
public String delete(String key) {
if (jedis != null) {
boolean exist = exist(key);
if (exist == true) {
jedis.del(key);
return "删除操作已完成。";
} else {
return "键不存在,无法删除。";
}
} else {
return "数据库链接未创建,无法操作";
}
}
/**
* 插入集合方法
* @param keysvalues:键值集合
*/
public String setMap(String keysvalues) {
if (jedis != null) {
jedis.mset(keysvalues);
return "插入多个操作已完成。";
} else {
return "数据库链接未创建,无法操作";
}
}
/**
* 查询集合方法
* @param keys:键值集合
*/
public String getMap(String keys) {
if (jedis != null) {
jedis.mget(keys);
return "查询多个操作已完成。";
} else {
return "数据库链接未创建,无法操作";
}
}
/**
* 删除集合操作
* @param keys:键值集合
*/
public String delMap(String[] keys) {
if (jedis != null) {
jedis.del(keys);
return "删除多个操作已完成。";
} else {
return "数据库链接未创建,无法操作";
}
}
/**
* 表刷新重置方法
*/
public String flush() {
if (jedis != null) {
jedis.flushDB();
return "已完成表刷新操作!";
} else {
return "链接未创建,无法操作。";
}
}
}