MongoDB aggregation mit Java-Treiber

Brauche ich Eure Hilfe für die Verwendung von MongoDB aggregation framework mit java-Treiber.
Ich verstehe nicht, wie das schreiben meiner Anfrage auch mit diese Dokumentation.

Möchte ich, um die 200 ältesten Ansichten von allen Sachen in meiner Sammlung. Hier ist mein mongo-Abfrage (was funktioniert, will ich im console-Modus):

db.myCollection.aggregate(
    {$unwind : "$views"},
    {$match : {"views.isActive" : true}},
    {$sort : {"views.date" : 1}},
    {$limit : 200},
    {$project : {"_id" : 0, "url" : "$views.url", "date" : "$views.date"}}
)

Elemente in dieser Auflistung eine oder viele Ansichten.
Meine Frage ist nicht über den Antrag Ergebnis, ich möchte wissen, die java-syntaxe.

Zeigen Sie uns, was Sie versucht haben, für die jetzt-Ereignis, wenn es nicht funktioniert. Nicht zu erwarten, SO schreiben Sie Ihren code für Sie

InformationsquelleAutor Opsse | 2015-07-26

  1. 30

    Endlich die Lösung gefunden, ich bekomme das gleiche Ergebnis als mit der original-Anfrage.

    Mongo Treiber 3 :

    Aggregat doc

    MongoCollection<Document> collection = database.getCollection("myCollection");

AggregateIterable<Document> output = collection.aggregate(Arrays.asList(
        new Document("$unwind", "$views"),
        new Document("$match", new Document("views.isActive", true)),
        new Document("$sort", new Document("views.date", 1)),
        new Document("$limit", 200),
        new Document("$project", new Document("_id", 0)
                    .append("url", "$views.url")
                    .append("date", "$views.date"))
        ));

//Print for demo
for (Document dbObject : output)
{
    System.out.println(dbObject);
}

    Können Sie machen es besser lesbar mit statisch importieren :

    import static com.mongodb.client.model.Aggregates.*;.

    Sehen koulini Antwort für complet Beispiel.

    Mongo Fahrer 2 :

    Aggregat doc

    Iterable<DBObject> output = collection.aggregate(Arrays.asList(
        (DBObject) new BasicDBObject("$unwind", "$views"),
        (DBObject) new BasicDBObject("$match", new BasicDBObject("views.isActive", true)),
        (DBObject) new BasicDBObject("$sort", new BasicDBObject("views.date", 1)),
        (DBObject) new BasicDBObject("$limit", 200),
        (DBObject) new BasicDBObject("$project", new BasicDBObject("_id", 0)
                    .append("url", "$views.url")
                    .append("date", "$views.date"))
        )).results();

//Print for demo
for (DBObject dbObject : output)
{
    System.out.println(dbObject);
}

    Abfrage-Konvertierung Logik :
    MongoDB aggregation mit Java-Treiber
    Dank dieser link

    Das Dokument, das Sie verwenden genau, ich benutze Mongo Treiber 3.4, und in dieser Klasse : com.mongodb.DBCollection, es ist das einzige Aggregat-Funktion, die Nutzung DBObject nicht Dokumentieren ? => public AggregationOutput Aggregat(final List<? extends DBObject - > pipeline)
    Es ist ein MongoCollection aus com.mongodb.async.client. Wo die Methode : aggregate(List<? extends Bson> pipeline). Und Document implementiert Bson, so ist alles in Ordnung.

    InformationsquelleAutor Opsse

  2. 3

    Mithilfe vorherigen Beispiel als guide, hier ist, wie tun Sie es mit mongo Treiber 3:

    MongoCollection<Document> collection = database.getCollection("myCollection");
AggregateIterable<Document> output = collection.aggregate(Arrays.asList(
    new Document("$unwind", "$views"),
    new Document("$match", new Document("views.isActive", true))
));

for (Document doc : output) {
    ...
}

    InformationsquelleAutor Andres

  3. 3

    Darauf hinzuweisen ist, dass Sie erheblich verbessern kann der code durch die Antworten hier, mit der Java-Aggregation Methoden für MongoDB.

    Nehmen wir als Beispiel die OP ' s Antwort auf seine eigene Frage.

    AggregateIterable<Document> output = collection.aggregate(Arrays.asList(
        new Document("$unwind", "$views"),
        new Document("$match", new Document("views.isActive", true)),
        new Document("$sort", new Document("views.date", 1)),
        new Document("$limit", 200),
        new Document("$project", new Document("_id", 0)
                    .append("url", "$views.url")
                    .append("date", "$views.date"))
));

    Wir können schreiben Sie den obigen code wie folgt;

    import static com.mongodb.client.model.Aggregates.*;

AggregateIterable output = collection.aggregate(Arrays.asList(
                unwind("$views"),
                match(new Document("views.isActive",true)),
                sort(new Document("views.date",1)),
                limit(200),
                project(new Document("_id",0)
                        .append("url","$views.url")
                        .append("date","$views.date"))
));

    Offensichtlich benötigen Sie die entsprechenden statischen import aber darüber hinaus, dass der code im zweiten Beispiel ist cleaner, sicherer (wie Sie nicht haben, um geben die Betreiber selbst jedes mal), mehr lesbar und mehr schöne IMO.

    InformationsquelleAutor Nikiforos

  4. -1

    Hier eine einfache Möglichkeit, die Anzahl der Mitarbeiter von departmentId..
    Details unter: Aggregation mit Hilfe der Java-API

            Map<Long, Integer> empCountMap = new HashMap<>();

        AggregateIterable<Document> iterable = getMongoCollection().aggregate(Arrays.asList(
                new Document("$match",
                        new Document("active", Boolean.TRUE)
                                .append("region", "India")),
                new Document("$group",
                        new Document("_id", "$" + "deptId").append("count", new Document("$sum", 1)))));

        iterable.forEach(new Block<Document>() {
            @Override
            public void apply(final Document document) {
                empCountMap.put((Long) document.get("_id"), (Integer) document.get("count"));
            }
        });

    InformationsquelleAutor Ashutosh Srivastav

Schreibe einen Kommentar