Scala中使用RethinkDB等非关系型数据库的类型适配问题

方案1：直接转换为Scala Map处理 #

RethinkDB Java API返回的AnyRef本质是java.util.Map[String, AnyRef]，你可以把它转换成Scala的Map后直接按字段名取值：

import scala.collection.JavaConverters._

// 假设result是查询返回的单个元素（AnyRef类型）
val doc = result.asInstanceOf[java.util.Map[String, AnyRef]].asScala
val name = doc("name").asInstanceOf[String]
val age = doc("age").asInstanceOf[Integer].toInt
val tags = doc("tags").asInstanceOf[java.util.List[String]].asScala.toList

这种方式适合快速验证，但需要手动做类型转换，字段名拼写错误或类型不匹配会在运行时报错，安全性较低。

方案2：用样例类+JSON库实现类型安全映射 #

更规范的方式是定义对应文档结构的Scala样例类，通过JSON库把RethinkDB返回的对象转成样例类，这里以Jackson为例（RethinkDB Java API本身依赖Jackson）：

1. 定义匹配文档结构的样例类：

case class User(
  name: String,
  age: Int,
  tags: List[String]
)

2. 添加Jackson Scala模块依赖到build.sbt：

libraryDependencies += "com.fasterxml.jackson.module" %% "jackson-module-scala" % "2.15.2"

3. 编写转换逻辑：

import com.fasterxml.jackson.databind.ObjectMapper
import com.fasterxml.jackson.module.scala.DefaultScalaModule
import scala.collection.JavaConverters._

val mapper = new ObjectMapper()
mapper.registerModule(DefaultScalaModule)

// 遍历查询结果游标
val cursor = r.table("test").run(connection)
while (cursor.hasNext) {
  val javaMap = cursor.next().asInstanceOf[java.util.Map[String, AnyRef]]
  val user = mapper.convertValue(javaMap, classOf[User])
  // 直接调用样例类字段
  println(s"Name: ${user.name}, Age: ${user.age}, Tags: ${user.tags.mkString(",")}")
}
cursor.close()

这种方式能在编译时检查字段类型和结构，运行时若文档结构不匹配会抛出明确错误，更适合生产环境。

方案3：使用RethinkDB的Scala封装库 #

如果不想直接操作Java API，可以尝试第三方Scala封装库（比如rethinkdb-scala），这类库已内置类型映射逻辑，直接返回Scala类型结果：

// 示例（具体API以对应库文档为准）
import com.rethinkscala._

val r = RethinkDB()
val conn = r.connect(host = "localhost", port = 28015)
val users = r.table("test").run[User](conn)
users.foreach(user => println(user.name))

注意选择与你使用的RethinkDB版本兼容的封装库，确认其维护状态。

内容的提问来源于stack exchange，提问作者Nordwald