Превод на mongodb агрегат функция към ReactiveMongo и скала - mongodb, скала, playframework-2.1, reactivemongo

Опитвам се да внедря агрегиран метод в ReactiveMongo, но малко се забих.

Имам следната набор от данни:

{
"_id" : ObjectId("522891aa40ef0b5d11cb9232"),
"created" : 1378390442167,
"origin" : 2,
"originIpAddress" : "",
"rating" : 3,
"remindersSent" : 1,
"status" : 4,
"text" : "",
"updated" : 1378563426223,
"userInfo" : {
"firstName" : "Person",
"lastName" : "Person",
"email" : "person@person.com",
"fbPublish" : false
},
"venueInfo" : {
"isAgent" : false,
"name" : "Company",
"id" : 1234
}
},
{
"_id" : ObjectId("522891aa40ef0b5d11cb9233"),
"created" : 1378390442167,
"origin" : 2,
"originIpAddress" : "",
"rating" : 3,
"remindersSent" : 1,
"status" : 4,
"text" : "",
"updated" : 1378563426223,
"userInfo" : {
"firstName" : "Person2",
"lastName" : "Person2",
"email" : "person2@person.com",
"fbPublish" : false
},
"venueInfo" : {
"isAgent" : false,
"name" : "Company2",
"id" : 4321
}
},
{
"_id" : ObjectId("522891aa40ef0b5d11cb9234"),
"created" : 1378390442167,
"origin" : 2,
"originIpAddress" : "",
"rating" : 3,
"remindersSent" : 1,
"status" : 4,
"text" : "",
"updated" : 1378563426223,
"userInfo" : {
"firstName" : "Person3",
"lastName" : "Person3",
"email" : "person3@person.com",
"fbPublish" : false
},
"venueInfo" : {
"isAgent" : false,
"name" : "Company",
"id" : 1234
}
}

Следната агрегатна функция:

db.reviews.aggregate(
{$match:{status:{"$ne":1}}},
{$group: { _id: "$venueInfo.id", total:{"$sum":1}}}
)

ми дава:

{
"result" : [
{
"_id" : 1234,
"total" : 2
},
{
"_id" : 4321,
"total" : 1
}
]
}

Опитах се да го приложа в ReactiveMongo:

def aggregate() = {
val command = Aggregate(collection.name, Seq(
GroupField("venueInfo.id")("total" -> SumValue(1)),
Match(BSONDocument("status" -> 1))
))
val result = collection.db.command(command)
result.map { value => {
println(s"got value $value")
}

}

И това ми дава:

got value Stream(BSONDocument(<non-empty>), ?)

Както можете да видите, връщам Поток обратно. Така че въпросът ми е: Как да се справя правилно с този поток, за да мога да работя със стойностите и да ги покажа по-късно в изгледа?

Отговори:

Ако искате да извлечете всички стойности на даденото Stream можете да се позовете toSeq или toList върху него:

import play.modules.reactivemongo.json.BSONFormats._
import SomeResult

collection.db.command(command) map { result =>
result.toSeq map (Json.toJson(_).as[SomeResult])
}

което води до a Future[Seq[SomeResult]], където SomeResult ще бъде случай от типа, както следва:

import play.api.libs.json.Json

case class SomeResult(_id: Long, total: Int)

object SomeResult {
implicit val someResultFormat = Json.format[SomeResult]
}