scala - 使用 Scala 将参数传递给 Cassandra

Question

我想将参数传递给在 Scala 中连接到 Cassandra 的查询执行:

import com.datastax.driver.core.{Session, Cluster}

val cluster = Cluster.builder().addContactPoint("localhost").build()//withPort(8080).build()
val session = cluster.connect("MyKeySpace")

刚在 Python 中找到这个，但我想在 Scala 中做:

session.execute(
  """
  INSERT INTO users (name, credits, user_id)
  VALUES (%s, %s, %s)
  """,
  ("John O'Reilly", 42, uuid.uuid1())
)

Answer 1

要将参数传递给查询，您可以使用 String Interpolation在 Scala 中。假设您在 name、credits 和 userId 中有查询参数，那么您可以使用如下所示的内容。

val name = "John O'Reilly"
val credits = 42
val userId = java.util.UUID.randomUUID()

session.execute(
  s"""
  INSERT INTO users (name, credits, user_id)
  VALUES ($name, $credits, $userId)
  """
)