Я использую официальный драйвер Mongo Scala: http://mongodb.github.io/mongo-scala-driver/.
Я хочу сделать запрос как:
db.test.aggregate([{"$group" : {_id:{name:"$name",details:"$details.id"}, count:{$sum:1}}}, {$sort:{"count":-1}} ])
поэтому в коде Scala я делаю:
collectionDoc.aggregate(List(
group(Document("name" -> "$name", "details" -> "$details.id"), Accumulators.sum("count", "1")),
)).toFuture()
но во всех результатах я вижу:
(count,BsonInt32{value=0}))
Из журналов драйверов Монго я вижу, что его отправка:
{
"aggregate": "test",
"pipeline": [
{
"$group": {
"_id": {
"name": "$name",
"details": "$details.id"
},
"count": {
"$sum": "1"
}
}
}
],
"cursor": {
"batchSize": 2147483647
},
"$db": "my-db",
"$readPreference": {
"mode": "primaryPreferred"
}
}
Если я выполняю этот запрос в Монго, он считает эти записи в порядке.. Любая идея, как решить эту проблему?
Спасибо!