ReactiveMongo FindAndModify澄清

Question

我在我的MongoDB數據庫中有一個集合，裏面有幾個鍵。現在我想用一個新字段更新這個集合。所以這是我到目前爲止有：

def confirm(hash: String) = { 

    val myDb = dbConn.db(dbName) 
    val userCollection = myDb[BSONCollection]("user") 

    val selector = BSONDocument(idKey -> BSONObjectID(hash)) 
    val modifier = BSONDocument(
     "$set" -> BSONDocument("date" -> BSONString(now.toString)) // Line 1 
    ) 

    val command = FindAndModify(
     userCollection.name, 
     selector, 
     Update(modifier, fetchNewObject = true) 
    ) 

    myDb.command(command) 
     .map { user => // Line 2 
     Right(bidList) 
    }.recover { 
     case LastError(ok,err, code, errMsg, _) => 
     Left(ServiceError(errMsg.getOrElse("failure!"))) 
    } 
    } 

我有兩個問題上面的實現：

1號線：這會更新一個名爲date新領域存在的文件呢？

在線2：映射myDb.command（命令）給了我一個選項[BSONDocument]，但我很驚訝的是我有一個隱式轉換範圍。所以我會期待它返回一個選項[用戶]！

Answer 1

你可以看看.findAndUpdate和FindAndModifyResult，它提供了一個.result操作來根據可用的BSON閱讀器獲取結果。

val person: Future[Option[AType]] = collection.findAndUpdate(
    BSONDocument("name" -> "James"), 
    BSONDocument("$set" -> BSONDocument("age" -> 17)), 
    fetchNewObject = true).map(_.result[AType]) 

Answer 2

我剛剛花了一些時間尋找play-reactivemongo等價物。也許這個例子將來有助於某人。

val collectionFut: Future[JSONCollection] = reactiveMongoApi.database.map(_.collection[JSONCollection]("sale.numberingCounter")) 

def updateIdx(nsId: NumberingSeriesId, month: Option[Int], year: Option[Int], value: Int): Future[Option[NumberingCounter]] = { 
val selector = Json.obj("numberingSeriesId" -> nsId, "month" -> month, "year" -> year)   
val modifier = Json.obj("$set" -> Json.obj("idx" -> value)) 
    for { 
     collection <- collectionFut 
     writeResult <- collection.findAndUpdate(selector,modifier,upsert = true) 
    } yield { 
     writeResult.value.map(_.as[NumberingCounter]) 
    } 
    }