MongoDB aggregation with Java driver

Question

I need your help for using MongoDB aggregation framework with java driver. I don't understand how to write my request, even with this documentation.

I want to get the 200 oldest views from all items in my collection. Here is my mongo query (which works like I want in console mode):

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

Items in this collection have one or many views. My question is not about the request result, I want to know the java syntaxe.

Show us what you have tried for now event if it isn't working. Do not expect SO to write your code for you — Martin
– Martin, Commented Jul 27, 2015 at 13:54

Community · Accepted Answer · 2020-06-20 09:12:55Z

51

Finally found the solution, I get the same result than with the original request.

Mongo Driver 3 :

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

You can make it more readable with static import :
import static com.mongodb.client.model.Aggregates.*;.
See koulini answer for complet example.

Mongo Driver 2 :

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

Query conversion logic : Thank to this link

edited Jun 20, 2020 at 9:12

CommunityBot

11 silver badge

answered Jul 28, 2015 at 16:35

Victor Yon

1,9312 gold badges24 silver badges41 bronze badges

Sign up to request clarification or add additional context in comments.

3 Comments

Antoine Over a year ago

Which Document you use exactly, I use Mongo driver 3.4, and in this class : com.mongodb.DBCollection, there is only aggregate function which use DBObject not Document ? => public AggregationOutput aggregate(final List<? extends DBObject> pipeline)

Victor Yon Over a year ago

It's a MongoCollection from com.mongodb.async.client. Where the method is : aggregate(List<? extends Bson> pipeline). And Document implements Bson, so everything is fine.

Milan Over a year ago

You saved my day.

arxakoulini · Accepted Answer · 2018-04-19 15:23:50Z

It is worth pointing out, that you can greatly improve the code shown by the answers here, by using the Java Aggregation methods for MongoDB.

Let's take as a code example, the OP's answer to his own question.

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

We can rewrite the above code as follows;

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

Obviously, you will need the corresponding static import but beyond that, the code in the second example is cleaner, safer (as you don't have to type the operators yourself every time), more readable and more beautiful IMO.

do you have to iterate through the AggregateIterable in order for the aggregate pipeline to execute?

Andres · Accepted Answer · 2016-05-24 02:12:24Z

3

Using previous example as a guide, here's how to do it using mongo driver 3 and up:

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) {
    ...
}

answered May 24, 2016 at 2:12

Andres

1,15415 silver badges31 bronze badges

Comments

Ashutosh Srivastav · Accepted Answer · 2017-09-09 10:45:49Z

Here is a simple way to count employee by departmentId.. Details at: Aggregation using 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"));
            }
        });

Collectives™ on Stack Overflow

MongoDB aggregation with Java driver

4 Answers 4

Mongo Driver 3 :

Mongo Driver 2 :

3 Comments

1 Comment

Comments

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

4 Answers 4

Mongo Driver 3 :

Mongo Driver 2 :

3 Comments

1 Comment

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related