Phantom Scala Cassandra 连接器：如何指定节点的端口、用户名、密码答案

【问题标题】：Phantom Scala Cassandra connector: how to specify port, username, password of nodesPhantom Scala Cassandra 连接器：如何指定节点的端口、用户名、密码
【发布时间】：2015-07-19 14:11:11
【问题描述】：

我正在尝试使用 websudos phantom

有谁知道如何为 Cassandra 指定连接参数，例如用户名和密码？

谢谢

【问题讨论】：

标签： scala cassandra phantom-dsl

【解决方案1】：

Phantom 尚不支持 phantom-connectors 框架中的 Kerberos 身份验证，但它已在未来几周的路线图中。

但是，当使用连接器时，可以覆盖 createCluster 方法并以您想要的任何方式连接到集群。

object CustomCassandraManger extends DefaultCasandraManager {

  override protected[this] def createCluster: Cluster = {
    val inets = hosts.toSeq.map(_.getAddress)

    Cluster.builder()
     .addContactPoints(inets: _*)
     ...
     .withUsernameAndPassword(..)
  }
}

我可能没有使用正确的方法，但这就是您控制集群创建方式的方式。然后你只需要在一个连接器中注入这个管理器：

trait MyConnector extends SimpleCassandraConnector {
  override val manager = CustomCassandraMananger
}

然后你将这个连接器混入你的所有表中，就像你通常在使用幻像时所做的那样。

幻影的最新版本

在最新版本的 phantom 中，API 基于 ContactPoints，您可以使用以下 DSL 指定您想要的任何 ClusterBuilder 选项。

import com.datastax.driver.core.PlainTextAuthProvider

lazy val local = ContactPoint.local.withClusterBuilder(
  _.withAuthProvider(new PlainTextAuthProvider("user", "pass"))
).keySpace("phantom")

【讨论】：