Scala, casbah aggregate query

Question

Я новичок в MongoDB и Casbah, и мне интересно, может ли кто-нибудь мне помочь.

У меня есть следующий MongoDB Query, который работает,

db.getCollection('holidayRequests').aggregate 
(
    [ 
    { $match: { $and: [ { email: "leeroy.jenkins@company.com" } , { status: "APPROVED" } ] }}, 
     { 
      $group: 
     { 
      _id: { email: "$email" }, 
      totalAmount: { $sum: "$daysTaken" } 
     } 
    } 
    ] 
); 

Как преобразовать это в запрос драйвер Касбы поймет?

Answer 1

Нечто подобное:

import com.mongodb.casbah.commons.MongoDBObject 
import com.mongodb.casbah.commons.MongoDBList 
import com.mongodb.casbah.MongoClient 

object testCasbah { 

    val mongoClient = MongoClient() /* database connections parameters */ 
    val db = mongoClient("databaseName") 

    val email = MongoDBObject("email" -> "leeroy.jenkins@company.com") 
    val status = MongoDBObject("status" -> "APPROVED") 

    val and = MongoDBObject("$and" -> List(email, status)) 

    val pipeline = MongoDBList(MongoDBObject("$match" -> and)) ++ 
       MongoDBList(MongoDBObject("$group" -> 
        MongoDBObject("_id" -> MongoDBObject("email" -> "$email"), 
            "totalAmount" -> MongoDBObject("$sum" -> "$daysTaken")))) 

    db.command(MongoDBObject("aggregate" -> "holidayRequests", "pipeline" -> pipeline))        

} 

должен работать.