diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/RedisServerCommands.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/RedisServerCommands.java index d1aa2cc1c..09e236225 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/RedisServerCommands.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/RedisServerCommands.java @@ -31,6 +31,8 @@ public interface RedisServerCommands { Long lastSave(); + void save(); + Long dbSize(); void flushDb(); @@ -44,4 +46,6 @@ public interface RedisServerCommands { List getConfig(String pattern); void setConfig(String param, String value); + + void resetConfigStats(); } diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/jedis/JedisConnection.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/jedis/JedisConnection.java index 7e0be18eb..1c46fa6fb 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/jedis/JedisConnection.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/jedis/JedisConnection.java @@ -250,6 +250,18 @@ public class JedisConnection implements RedisConnection { } } + @Override + public void save() { + try { + if (isQueueing()) { + throw new UnsupportedOperationException(); + } + jedis.save(); + } catch (Exception ex) { + throw convertJedisAccessException(ex); + } + } + @Override public List getConfig(String param) { try { @@ -298,6 +310,19 @@ public class JedisConnection implements RedisConnection { } } + + @Override + public void resetConfigStats() { + try { + if (isQueueing()) { + throw new UnsupportedOperationException(); + } + jedis.configResetStat(); + } catch (Exception ex) { + throw convertJedisAccessException(ex); + } + } + @Override public void shutdown() { try { diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/jredis/JredisConnection.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/jredis/JredisConnection.java index b4487000f..2ea1532f5 100644 --- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/jredis/JredisConnection.java +++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/jredis/JredisConnection.java @@ -177,6 +177,15 @@ public class JredisConnection implements RedisConnection { } } + @Override + public void save() { + try { + jredis.save(); + } catch (RedisException ex) { + throw JredisUtils.convertJredisAccessException(ex); + } + } + @Override public List getConfig(String pattern) { throw new UnsupportedOperationException(); @@ -205,6 +214,11 @@ public class JredisConnection implements RedisConnection { throw new UnsupportedOperationException(); } + @Override + public void resetConfigStats() { + throw new UnsupportedOperationException(); + } + @Override public void shutdown() { throw new UnsupportedOperationException();