commit dafde70fb7b32f062effa567cde2973c1f65891e
author Myrle Krantz <myrle@apache.org> Fri May 26 15:54:17 2017 +0200
committer GitHub <noreply@github.com> Fri May 26 15:54:17 2017 +0200
tree c9ad206fb44f52643db60614ce0dcac7cae73a82
parent c7ae52b78568e043ef55ac7f39f087298f5b097d
parent c8a6c6f786d46aead29c0128725ed743f5655e55

Merge pull request #9 from myrle-krantz/develop

Added ability to connect to existing db to make debugging easier.  Sp…

src/main/java/io/mifos/core/test/fixture/cassandra/CassandraInitializer.java

diff --git a/src/main/java/io/mifos/core/test/fixture/cassandra/CassandraInitializer.java b/src/main/java/io/mifos/core/test/fixture/cassandra/CassandraInitializer.java
index fd7b760..fdc954e 100644
--- a/src/main/java/io/mifos/core/test/fixture/cassandra/CassandraInitializer.java
+++ b/src/main/java/io/mifos/core/test/fixture/cassandra/CassandraInitializer.java
@@ -31,13 +31,18 @@
 @SuppressWarnings({"WeakerAccess", "unused"})
 public final class CassandraInitializer extends DataStoreTenantInitializer {
 
+  private final boolean useExistingDB;
+
   public CassandraInitializer() {
-    super();
+    this(false);
+  }
+  public CassandraInitializer(boolean useExistingDB) {
+    super();this.useExistingDB = useExistingDB;
   }
 
   @Override
   public void initialize() throws Exception {
-    CassandraInitializer.setup();
+    CassandraInitializer.setup(useExistingDB);
   }
 
   @Override
@@ -47,12 +52,18 @@
 
   @Override
   public void finish() {
-    CassandraInitializer.tearDown();
+    if (!useExistingDB) CassandraInitializer.tearDown();
   }
 
   public static void setup() throws Exception {
-    CassandraInitializer.startEmbeddedCassandra();
-    CassandraInitializer.createKeyspaceSeshat();
+    setup(false);
+  }
+
+  public static void setup(final boolean useExistingDB) throws Exception {
+    if (!useExistingDB) {
+      CassandraInitializer.startEmbeddedCassandra();
+      CassandraInitializer.createKeyspaceSeshat();
+    }
   }
 
   public static void tearDown() {

src/main/java/io/mifos/core/test/fixture/mariadb/MariaDBInitializer.java

diff --git a/src/main/java/io/mifos/core/test/fixture/mariadb/MariaDBInitializer.java b/src/main/java/io/mifos/core/test/fixture/mariadb/MariaDBInitializer.java
index 7d2781c..bfea20f 100644
--- a/src/main/java/io/mifos/core/test/fixture/mariadb/MariaDBInitializer.java
+++ b/src/main/java/io/mifos/core/test/fixture/mariadb/MariaDBInitializer.java
@@ -24,15 +24,22 @@
 
 @SuppressWarnings({"WeakerAccess", "unused", "SqlNoDataSourceInspection", "SqlDialectInspection"})
 public final class MariaDBInitializer extends DataStoreTenantInitializer {
+
+  private final boolean useExistingDB;
   private static DB db;
 
   public MariaDBInitializer() {
+    this(false);
+  }
+
+  public MariaDBInitializer(final boolean useExistingDB) {
     super();
+    this.useExistingDB = useExistingDB;
   }
 
   @Override
   public void initialize() throws Exception  {
-    MariaDBInitializer.setup();
+    MariaDBInitializer.setup(useExistingDB);
   }
 
   @Override
@@ -43,18 +50,23 @@
 
   @Override
   public void finish() {
-    try {
-      MariaDBInitializer.tearDown();
-    }
-    catch (final Exception e)
-    {
-      throw new RuntimeException(e);
+    if (!useExistingDB) {
+      try {
+        MariaDBInitializer.tearDown();
+      } catch (final Exception e) {
+        throw new RuntimeException(e);
+      }
     }
   }
 
   public static void setup() throws Exception {
-    MariaDBInitializer.startEmbeddedMariaDB();
-    MariaDBInitializer.createDatabaseSeshat();
+    setup(false);
+  }
+  public static void setup(final boolean useExistingDB) throws Exception {
+    if (!useExistingDB) {
+      MariaDBInitializer.startEmbeddedMariaDB();
+      MariaDBInitializer.createDatabaseSeshat();
+    }
   }
 
   public static void tearDown() throws Exception {