diff --git a/kcache-rdbms/pom.xml b/kcache-rdbms/pom.xml
index 957e1228..5e07bbd8 100644
--- a/kcache-rdbms/pom.xml
+++ b/kcache-rdbms/pom.xml
@@ -57,6 +57,13 @@
test
-->
+
com.h2database
h2
diff --git a/kcache-rdbms/src/main/java/io/kcache/rdbms/RdbmsCache.java b/kcache-rdbms/src/main/java/io/kcache/rdbms/RdbmsCache.java
index f2a0b5a3..8da7637f 100644
--- a/kcache-rdbms/src/main/java/io/kcache/rdbms/RdbmsCache.java
+++ b/kcache-rdbms/src/main/java/io/kcache/rdbms/RdbmsCache.java
@@ -312,6 +312,12 @@ protected KeyValueIterator all(boolean isDescending) {
public void flush() {
}
+ @Override
+ public void clear() {
+ // For testing
+ dsl().deleteFrom(KV).execute();
+ }
+
@Override
protected void closeDB() {
}
diff --git a/kcache-rdbms/src/test/java/io/kcache/rdbms/KafkaRdbmsCacheTest.java b/kcache-rdbms/src/test/java/io/kcache/rdbms/KafkaRdbmsCacheTest.java
index 37a9d443..422a8eee 100644
--- a/kcache-rdbms/src/test/java/io/kcache/rdbms/KafkaRdbmsCacheTest.java
+++ b/kcache-rdbms/src/test/java/io/kcache/rdbms/KafkaRdbmsCacheTest.java
@@ -34,6 +34,11 @@ protected Properties getKafkaCacheProperties() throws Exception {
//props.put(prefix + RdbmsCache.DIALECT_CONFIG, "MYSQL");
//props.put(prefix + RdbmsCache.USERNAME_CONFIG, "root");
+ //props.put(prefix + RdbmsCache.JDBC_URL_CONFIG, "jdbc:postgresql:postgres");
+ //props.put(prefix + RdbmsCache.DIALECT_CONFIG, "POSTGRES");
+ //props.put(prefix + RdbmsCache.USERNAME_CONFIG, "postgres");
+ //props.put(prefix + RdbmsCache.PASSWORD_CONFIG, "postgres");
+
//props.put(prefix + RdbmsCache.JDBC_URL_CONFIG, "jdbc:h2:" + dir.newFolder().getAbsolutePath() + "/kcache");
//props.put(prefix + RdbmsCache.DIALECT_CONFIG, "H2");
diff --git a/kcache-rdbms/src/test/java/io/kcache/rdbms/RdbmsCacheTest.java b/kcache-rdbms/src/test/java/io/kcache/rdbms/RdbmsCacheTest.java
index b8d12635..9f3e0d0d 100644
--- a/kcache-rdbms/src/test/java/io/kcache/rdbms/RdbmsCacheTest.java
+++ b/kcache-rdbms/src/test/java/io/kcache/rdbms/RdbmsCacheTest.java
@@ -37,6 +37,11 @@ protected Cache createCache() throws Exception {
//configs.put(RdbmsCache.DIALECT_CONFIG, "MYSQL");
//configs.put(RdbmsCache.USERNAME_CONFIG, "root");
+ //configs.put(RdbmsCache.JDBC_URL_CONFIG, "jdbc:postgresql:postgres");
+ //configs.put(RdbmsCache.DIALECT_CONFIG, "POSTGRES");
+ //configs.put(RdbmsCache.USERNAME_CONFIG, "postgres");
+ //configs.put(RdbmsCache.PASSWORD_CONFIG, "postgres");
+
//configs.put(RdbmsCache.JDBC_URL_CONFIG, "jdbc:h2:" + dir.newFolder().getAbsolutePath() + "/kcache");
//configs.put(RdbmsCache.DIALECT_CONFIG, "H2");
@@ -49,4 +54,9 @@ protected Cache createCache() throws Exception {
cache.configure(configs);
return cache;
}
+
+ @After
+ public void clearCache() {
+ getCache().clear();
+ }
}