Есть ли способ выполнять массовые обновления на ReactiveMongo?

Question

Предположим, я хочу сделать следующее (в оболочке Монго):

var bulk = db.vectors.initializeOrderedBulkOp()

bulk.find({"_id" : ObjectId("53f265da13d3f885ed8bf75d")}).updateOne({"$pop": {"v": 1}})

bulk.find({"_id" : ObjectId("53f265da13d3f885ed8bf75d")}).updateOne({"$push": {"v": 5}})

bulk.execute()

Answer 1

Я нашел ответ! ReactiveMongo имеет команду RawCommand, которая позволяет нам запускать любую команду MongoDB (например, обновление, в данном случае >> http://docs.mongodb.org/manual/reference/command/update/):

  val commandDoc =
        BSONDocument(
          "update" -> COLLECTION,
          "updates" -> BSONArray(
            BSONDocument("q" -> <query>, "u" -> BSONDocument("$pop" -> BSONDocument("v" -> 1))),
            BSONDocument("q" -> <query>, "u" -> BSONDocument("$push" -> BSONDocument("v" -> 5)))
          ),
          "ordered" -> true
        )

      // we get a Future[BSONDocument]
      val futureResult = db.command(RawCommand(commandDoc))

      futureResult.map { result => // result is a BSONDocument
           //...
      }

Answer 2

Я использую реактивный монго 0.11.9:

import collection.BatchCommands._
import UpdateCommand._ 
import reactivemongo.bson._

collection.runCommand(Update(
  UpdateElement(q = document(...), u = document(...)), 
  UpdateElement(q = document(...), u = document(...))...
))