Merge pull request #395 from ksilin/stringListsinClusterBuilder

added handling for string lists in ClusterBuilder

quill-cassandra/src/main/scala/io/getquill/sources/cassandra/cluster/ClusterBuilder.scala

@@ -6,6 +6,7 @@ import com.typesafe.config.Config
 import com.typesafe.config.ConfigValueType
 import java.lang.reflect.Method
 import scala.collection.JavaConversions._
+import scala.collection.JavaConverters._
 import com.datastax.driver.core.Cluster
 
 object ClusterBuilder {
@@ -58,10 +59,14 @@ object ClusterBuilder {
     instance
   }
 
+  val stringArrayClass = java.lang.reflect.Array.newInstance(classOf[String], 0).getClass()
+
   private def param(key: String, tpe: Class[_], cfg: Config) =
     Try {
       if (tpe == classOf[String])
         cfg.getString(key)
+      else if (tpe == stringArrayClass)
+        cfg.getStringList(key).asScala.toArray
       else if (tpe == classOf[Int] || tpe == classOf[Integer])
         cfg.getInt(key)
       else if (tpe.isEnum)

quill-cassandra/src/test/scala/io/getquill/sources/cassandra/cluster/ClsuterBuilderSpec.scala

@@ -0,0 +1,34 @@
+package io.getquill.sources.cassandra.cluster
+
+import java.net.InetSocketAddress
+
+import com.datastax.driver.core.Cluster.Builder
+import com.typesafe.config.ConfigFactory
+import io.getquill.Spec
+
+class ClusterBuilderSpec extends Spec {
+
+  val hosts = List("127.0.0.1", "127.0.0.2", "127.0.0.3")
+  val contactPoints = hosts.map(new InetSocketAddress(_, 9042))
+
+  "creates Builder" - {
+
+    "with a single host" in {
+      val cfgString = s"contactPoint = ${hosts.head}"
+      val clusterBuilder: Builder = ClusterBuilder(ConfigFactory.parseString(cfgString))
+      clusterBuilder.getContactPoints must contain theSameElementsAs (contactPoints.take(1))
+    }
+
+    "with a single host in an array" in {
+      val cfgString = s"contactPoints = [${hosts.head}]"
+      val clusterBuilder: Builder = ClusterBuilder(ConfigFactory.parseString(cfgString))
+      clusterBuilder.getContactPoints must contain theSameElementsAs (contactPoints.take(1))
+    }
+
+    "with multiple hosts" in {
+      val cfgString = s"""contactPoints = [${hosts.mkString(",")}] """
+      val clusterBuilder: Builder = ClusterBuilder(ConfigFactory.parseString(cfgString))
+      clusterBuilder.getContactPoints must contain theSameElementsAs (contactPoints)
+    }
+  }
+}