diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/RedisCommands.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/RedisCommands.java
index c802332d0..6e1497c4e 100644
--- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/RedisCommands.java
+++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/RedisCommands.java
@@ -50,4 +50,5 @@ public interface RedisCommands extends RedisTxCommands, RedisStringCommands, Red
 
 	void select(int dbIndex);
 
+	void flushDb();
 }
\ No newline at end of file
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 fd1e94692..25672176b 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
@@ -120,6 +120,19 @@ public class JedisConnection implements RedisConnection {
 		}
 	}
 
+
+	@Override
+	public void flushDb() {
+		try {
+			if (isQueueing()) {
+				transaction.flushDB();
+			}
+			jedis.flushDB();
+		} catch (Exception ex) {
+			throw convertJedisAccessException(ex);
+		}
+	}
+
 	@Override
 	public Integer del(byte[]... keys) {
 		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 511ba6296..94bced134 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
@@ -84,6 +84,15 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
+	@Override
+	public void flushDb() {
+		try {
+			jredis.flushall();
+		} catch (RedisException ex) {
+			throw JredisUtils.convertJredisAccessException(ex);
+		}
+	}
+
 	@Override
 	public Integer del(byte[]... keys) {
 		try {