0

我是 Reactivemongo 数据库（2.6）的新手，因为我正在尝试从我的本地系统上传/插入 json 对象（它是键/值对，我在单击我的 UI 中的提交按钮后将其发送到数据库中）到使用 Play Framework/Scala 存储在 Mongodb 中（使用 Play 2.2.3 和 2.3.8 进行了尝试）。我试过了：

import play.api.libs.json.{JsObject, JsValue, OWrites}
import play.api.mvc.{Action, Controller}
import play.modules.reactivemongo.MongoController
import play.modules.reactivemongo.json.collection._

import scala.concurrent.ExecutionContext.Implicits.global

object Application extends Controller with MongoController {
  def jsinfocollection: JSONCollection = db.collection[JSONCollection]("mycollection")

  implicit val jsvalueWrites = new OWrites[JsValue] {
    println("implicit val jsvalueWrites ...")//getting the message on Play console
    override def writes(o: JsValue): JsObject = o match {
      case o : JsObject => o
      case _ => throw new IllegalArgumentException("Only JsObjects can be stored")
    }
  }

  def createJson = Action.async(parse.json) {
    println("createJson calling...")//getting the message on Play console
    request =>
        jsinfocollection.insert(request.body).map{
    println("jsinfocollection.insert...")//getting the message on Play console
        r => Created(s"JsonInfo is Saved with result $r")
      }
  }
}

我已经在 Mongodb 中创建了一个集合，例如：>db.createCollection("mycollection")

{ "ok" : 1 }

但如果我给：>db.mycollection.count()- 是给 0，否则如果我给：db.mycollection.find()- 什么都不给

请让我知道如何将我的 json 数据插入我所需的集合（"mycollection"）中。提前致谢。

我在控制台上得到以下信息：

implicit val jsvalueWrites ...
createJson calling...
jsinfocollection.insert...
[error] play - Cannot invoke the action, eventually got an error: java.lang.IllegalArgumentException: Only JsObjects can be stored

Internal server error, for (POST) [/createJson]
4

1 回答 1

1

当您使用 Action.async(parse.json) 时，您在 request.body 中有一个 JsValue

jsinfocollection 只能存储 JsObjects（JsObjects 只是 JsValues 的一种类型，其他类型有 JsArray、JsString、...）

以下代码应该可以满足您的需求

import play.api.libs.json.{JsObject, JsValue, OWrites}
import play.api.mvc.{Action, Controller}
import play.modules.reactivemongo.MongoController
import play.modules.reactivemongo.json.collection._

import scala.concurrent.ExecutionContext.Implicits.global

object Application extends Controller with MongoController {
  def jsinfocollection: JSONCollection = db.collection[JSONCollection]("mycollection")

  implicit val jsvalueWrites = new OWrites[JsValue] {
    override def writes(o: JsValue): JsObject = o match {
      case o : JsObject => o
      case _ => throw new IllegalArgumentException("Only JsObjects can be stored")
    }
  }

  def createJson = Action.async(parse.json) {
    request =>
      jsinfocollection.insert(request.body).map{
        r => Created(s"JsonInfo is Saved with result $r")
      }
  }
}

也许有一种更简单的方法来创建 jsvalueWrites No Json 序列化程序作为 JsObject 找到类型 play.api.libs.json.JsObject 也许更新到最新版本有帮助

注意：验证字符串是有效的 JsValue 将由 parse.json 中的框架完成，如果您需要完全控制，则可以在 jsvalueWrites 中完成作为对象的验证，您可以实现 OWrites[String] 并删除 parse.json

于 2016-03-07T16:04:53.987 回答