Merge pull request #89 from rayokota/postgres

Test postgres
rayokota · Mar 7, 2021 · 81e4264 · 81e4264
2 parents a254bc5 + 7c7f7c6
commit 81e4264
Show file tree

Hide file tree

Showing 4 changed files with 28 additions and 0 deletions.
diff --git a/kcache-rdbms/pom.xml b/kcache-rdbms/pom.xml
@@ -57,6 +57,13 @@
             <scope>test</scope>
         </dependency>
         -->
+        <!--
+        <dependency>
+            <groupId>org.postgresql</groupId>
+            <artifactId>postgresql</artifactId>
+            <version>42.2.19.jre7</version>
+        </dependency>
+        -->
         <dependency>
             <groupId>com.h2database</groupId>
             <artifactId>h2</artifactId>

diff --git 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<K, V> 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
@@ -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
@@ -37,6 +37,11 @@ protected Cache<Bytes, byte[]> 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<Bytes, byte[]> createCache() throws Exception {
         cache.configure(configs);
         return cache;
     }
+
+    @After
+    public void clearCache() {
+        getCache().clear();
+    }
 }