wie man mongodb mit java abfragt

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" }}}])

Wie man die obige Abfrage in Java abfragt, habe ich versucht, den folgenden Code zu verwenden

    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));

aber ich werde in der Ausgabe leer. Die obige Abfrage gibt die genaue Ausgabe an, die ich möchte, während ich in cmd ausgeführt werde.

Answer 1

Sie können die AggregationOperation-Klasse verwenden, wie in diesem Link angegeben

Etwas wie das:

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

Sie können eine Spring-Boot-Anwendung mit Spring-Daten schreiben https://spring.io/guides/gs/accessing-data-mongodb/