mongodb - 使用响应式 mongo 将案例类映射到 mongodb 文档
问题描述
下面是我的代表链接的简单文档。为此,我在 scala 中使用了 reactivemongo。
我在编译期间收到此错误:
app/components/Link.scala:60:11:没有为 components.Link 类型找到 Json 反序列化器。尝试为此类型实现隐式读取或格式。[error] .one[Link]) [error] ^ [error] 发现一个错误
我在我的 Link 伴随对象中创建了隐式,我也将它导入到我的 LinkRepo 类中。
我是否正确处理了 mongo 文档 _id?
我是否应该使用字符串映射到文档 ID,不知道最佳做法是什么?我是否必须在某个时候将字符串转换为 BSONObjectID?
package components
import javax.inject.Inject
import reactivemongo.bson._
import reactivemongo.api.ReadPreference
import reactivemongo.api.collections.bson.BSONCollection
import reactivemongo.bson.{ BSONDocument, BSONObjectID }
import reactivemongo.api.commands.{ UpdateWriteResult, WriteResult, Upserted }
import reactivemongo.api.commands.bson.BSONUpdateCommand._
import reactivemongo.api.commands.bson.BSONUpdateCommandImplicits._
case class Link(id: Link.ID,
name: String,
url: String)
object Link {
type ID = String
implicit val linkReader: BSONDocumentReader[Link] =
BSONDocumentReader[Link] { doc: BSONDocument =>
Link(
doc.getAs[String]("id").getOrElse(""),
doc.getAs[String]("name").getOrElse(""),
doc.getAs[String]("url").getOrElse(""))
}
implicit val linkWriter: BSONDocumentWriter[Link] =
BSONDocumentWriter[Link] { link: Link =>
BSONDocument(
"id" -> link.id,
"name" -> link.name,
"url" -> link.url)
}
}
import scala.concurrent.{ ExecutionContext, Future }
import reactivemongo.bson.{ BSONDocument, BSONObjectID }
import reactivemongo.api.{ Cursor, ReadPreference }
import reactivemongo.api.commands.WriteResult
import reactivemongo.play.json._
import reactivemongo.play.json.collection.JSONCollection
import play.modules.reactivemongo.ReactiveMongoApi
class LinkRepo @Inject()(implicit ec: ExecutionContext, reactiveMongoApi: ReactiveMongoApi) {
import Link._
def linksCol: Future[JSONCollection] = reactiveMongoApi.database.map(_.collection("links"))
def byId(id: Link.ID): Future[Option[Link]] = {
linksCol.flatMap(_.find(
selector = BSONDocument("_id" -> id),
projection = Option.empty[BSONDocument])
.one[Link])
}
}
我的 sbt 有这些库版本:
scalaVersion := "2.12.7"
libraryDependencies += guice
libraryDependencies ++= Seq(
guice,
"joda-time" % "joda-time" % "2.9.9",
"net.ruippeixotog" %% "scala-scraper" % "2.1.0",
"org.reactivemongo" %% "play2-reactivemongo" % "0.16.0-play26",
"org.scalatestplus.play" %% "scalatestplus-play" % "3.1.2" % Test
)
插件:
addSbtPlugin("com.typesafe.play" % "sbt-plugin" % "2.6.20")
解决方案
据我所知,您不需要使用 BSONObjectID,但建议您这样做。但是您应该在 mongo 中使用“_id”字段,否则默认行为将是在您创建新文档时在文档上创建一个 _id ......所以您的文档将具有 _id 和 id。
因此,即使您的案例类是 id,您也应该从“_id”获取 id 并将其写入“_id”。
根据处理程序,对于基本案例类,您可以使用它们提供的宏:
implicit val linkHandler: BSONDocumentHandler[Link] = Macros.handler
这将为您的链接生成 Reader 和 Writer。
使用宏时,您有一个注释可用于突出显示您的 id,在 mongo 上将是“_id”:
import reactivemongo.bson.Macros.Annotations.Key
case class Link(
@Key("_id")
id: Link.ID,
name: String,
url: String
)