将 MongoDB 文档映射到具有类型但没有嵌入文档的案例类

Subset https://github.com/osinka/subset看起来像一个有趣的、薄的 MongoDB 包装器。

在给出的示例之一中，有推文和用户。然而，User is a 子文档 of Tweet。在经典 SQL 中，这将被规范化为两个单独的表，并具有从 Tweet 到 User 的外键。在 MongoDB 中，这不需要DBRef，存储用户的ObjectId就足够了。

在 Subset 和 Salat 中，这都会导致这些案例类别：

case class Tweet(_id: ObjectId, content: String, userId: ObjectId)
case class User(_id: ObjectId, name: String)

因此，无法保证 Tweet 中的 ObjectId 实际上解析为 User（使其类型安全性较差）。我还必须为引用 User 的每个类编写相同的查询（或将其移动到某个特征）。

所以我想要实现的是case class Tweet(_id: ObjectId, content: String, userId: User)，在代码中，以及ObjectId在数据库中。这可能吗？如果可能的话，如何实现？什么是好的替代方案？

是的，这是可能的。实际上，它比在“推文”中包含“用户”子文档还要简单。当“user”是引用时，它只是一个标量值，MongoDB和“Subset”没有查询子文档字段的机制。

我为您准备了一个简单的可 REPLable 代码片段（假设您有两个集合——“tweets”和“users”）。

准备...

import org.bson.types.ObjectId
import com.mongodb._
import com.osinka.subset._
import Document.DocumentId

val db = new Mongo("localhost") getDB "test"
val tweets = db getCollection "tweets"
val users = db getCollection "users"

Our User案例类

case class User(_id: ObjectId, name: String)

推文和用户的许多字段

val content = "content".fieldOf[String]
val user = "user".fieldOf[User]
val name = "name".fieldOf[String]

这里开始发生更复杂的事情。我们需要的是一个ValueReader能够得到ObjectId基于字段名称，但然后转到另一个集合并从那里读取对象。

这可以写成一段代码，一次完成所有事情（您可能会在答案历史记录中看到这样的变体），但将其表达为读者的组合会更惯用。假设我们有一个ValueReader[User]读取自DBObject:

val userFromDBObject = ValueReader({
  case DocumentId(id) ~ name(name) => User(id, name)
})

剩下的就是通用的了ValueReader[T]期望ObjectId并使用提供的底层读取器从特定集合中检索对象：

class RefReader[T](val collection: DBCollection, val underlying: ValueReader[T]) extends ValueReader[T] {
  override def unpack(o: Any):Option[T] =
    o match {
      case id: ObjectId =>
        Option(collection findOne id) flatMap {underlying.unpack _}
      case _ =>
        None
    }
}

然后，我们可以说我们的阅读类型类User参考文献中的 s 只是

implicit val userReader = new RefReader[User](users, userFromDBObject)

（我很感谢你提出这个问题，因为这个用例非常 很少见，而且我没有真正的动机去开发通用解决方案。我认为 我最终需要将这种助手包含到“子集”中.. 我将感谢您对这种方法的反馈）

这就是你将如何使用它：

import collection.JavaConverters._

tweets.find.iterator.asScala foreach { 
  case Document.DocumentId(id) ~ content(content) ~ user(u) =>
    println("%s - %s by %s".format(id, content, u))
}