como consultar mongodb usando java

Question

 db.FNTeams.aggregate([ { "$unwind": "$mailIDs" },{ "$lookup": {"from": "FNContacts", "localField": "mailIDs", "foreignField": "_id", "as": "productObjects" }}, { "$group": { "_id": "$_id", "mailIDs": { "$push": 
 "$mailIDs" }, "UserID":{"$push":"$UserID"},"TeamName": {"$push":"$TeamName"},"productObjects": { "$push": "$productObjects" }}}])

Como consultar a consulta acima em java, tentei usar o código abaixo

    DBCollection collection = db.getCollection("FNActivity");
    DBObject unwind1 = new BasicDBObject("$unwind", "$mailIDs"); DBObject lookup = new BasicDBObject("$lookup", new BasicDBObject("from", 
    "FNContacts")
    .append("localField", "mailIDs").append("foreignField", 
    "_id").append("as", "mailWithID"));

    BasicDBObject pushField = new BasicDBObject();
    pushField.append("_id", "$_id"); pushField.append("UserID", new BasicDBObject("$push", "$UserID")); pushField.append("TeamName", new BasicDBObject("$push", "$TeamName")); pushField.append("TeamDesc", new BasicDBObject("$push", "$TeamDesc")); pushField.append("Status", new BasicDBObject("$push", "$Status")); pushField.append("MailWithID", new BasicDBObject("$push", 
    "$mailWithID")); DBObject group = new BasicDBObject("$group", pushField);

    AggregationOutput output = collection.aggregate(Arrays.asList(group, 
    lookup, unwind1));

mas estou ficando vazio na saída. A consulta acima fornece a saída exata que desejo durante a execução em cmd.

Answer 1

Você pode usar a classe AggregationOperation, conforme especificado neste link

Algo assim:

public static void checkMongoOperations(){
    ApplicationContext ctx = new AnnotationConfigApplicationContext(MongoConfig.class);
    MongoOperations mongoOperation = (MongoOperations) ctx.getBean("mongoTemplate"); 

    AggregationOperation match = Aggregation.match(Criteria.where("country").is("tiro"));
    AggregationOperation unwind = Aggregation.unwind("myDetails");
    AggregationOperation match2 = Aggregation.match(Criteria.where("myDetails.type").is("health"));
    AggregationOperation sort = Aggregation.sort(Sort.Direction.ASC, "myDetails.datetime");
    AggregationOperation limit = Aggregation.limit(1);

    Aggregation aggregation = Aggregation.newAggregation(match, unwind, match2, sort, limit);
    System.out.println("Aggregation = "+aggregation);
    AggregationResults<AggregateFactoryResult> output = mongoOperation.aggregate(aggregation, "gui_data", AggregateFactoryResult.class);
    System.out.println("output = "+output.getMappedResults().get(0).getCountry());
}

Answer 2

você pode escrever um aplicativo de boot com spring-data https://spring.io/guides/gs/accessing-data-mongodb/