Add load config from file test

Stratio · Feb 22, 2017 · 3c838cc · 3c838cc
1 parent 64c2248
commit 3c838cc
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 6 deletions.
diff --git a/core/src/test/resources/zookeeper-catalog.conf b/core/src/test/resources/zookeeper-catalog.conf
@@ -5,9 +5,9 @@
 ##########################################
 
 
-crossdata-core.catalog.zookeeper.connectionString = "localhost:2181"
-crossdata-core.catalog.zookeeper.connectionTimeout = 15000
-crossdata-core.catalog.zookeeper.sessionTimeout = 60000
-crossdata-core.catalog.zookeeper.retryAttempts = 5
-crossdata-core.catalog.zookeeper.retryInterval = 10000
-crossdata-core.catalog.prefix = "crossdataCluster"
+crossdata-core.config.catalog.zookeeper.connectionString = "localhost:2181"
+crossdata-core.config.catalog.zookeeper.connectionTimeout = 15000
+crossdata-core.config.catalog.zookeeper.sessionTimeout = 60000
+crossdata-core.config.catalog.zookeeper.retryAttempts = 5
+crossdata-core.config.catalog.zookeeper.retryInterval = 10000
+crossdata-core.config.catalog.prefix = "crossdataCluster"
diff --git a/core/src/test/scala/org/apache/spark/sql/crossdata/XDSessionIT.scala b/core/src/test/scala/org/apache/spark/sql/crossdata/XDSessionIT.scala
@@ -15,6 +15,7 @@
  */
 package org.apache.spark.sql.crossdata
 
+import java.io.File
 import java.nio.file.Paths
 
 import com.typesafe.config.ConfigFactory
@@ -68,7 +69,22 @@ class XDSessionIT extends SharedXDSession with ScalaFutures {
     whenReady(sessionsFuture) { sessions: Seq[XDSession] =>
       sessions.map(_.id).toSet should have size 10
     } (PatienceConfig(timeout = 2 seconds))
+  }
+
+  it should "load catalog config from file" in {
+
+    val session = XDSession
+      .builder()
+      .config("src/test/resources/zookeeper-catalog.conf")
+      .create("user")
 
+    session.catalogConfig.isEmpty shouldBe false
+    session.catalogConfig.getString("zookeeper.connectionString") shouldBe "localhost:2181"
+    session.catalogConfig.getInt("zookeeper.connectionTimeout") shouldBe 15000
+    session.catalogConfig.getInt("zookeeper.sessionTimeout") shouldBe 60000
+    session.catalogConfig.getInt("zookeeper.retryAttempts") shouldBe 5
+    session.catalogConfig.getInt("zookeeper.retryInterval") shouldBe 10000
+    session.catalogConfig.getString("prefix") shouldBe "crossdataCluster"
   }
 
 /*