在 Java 3.2 中对 Mongodb 进行排序和区分答案

【问题标题】：Sort and distinct Mongodb in Java 3.2在 Java 3.2 中对 Mongodb 进行排序和区分
【发布时间】：2016-06-13 10:35:43
【问题描述】：

我的 mongodb 中有 80,000 个文档。我正在使用 Java 驱动程序查询这些文档。我尝试根据特定字段对文档进行排序，然后对此结果应用不同的过滤器。排序选项工作正常，但我无法获得不同的文档。我附上了我的工作示例。

    Document query = new Document("RetweetCount",-1);
    MongoCursor<Document> cursor = collection.find().sort(query).iterator();
    try{
    while(cursor.hasNext()) {
        Document dr = (Document) cursor.next();
        String stat = dr.getString("status");
        int retweetcount = dr.getInteger("RetweetCount");
        //Sort works fine. I have to apply distinct here!!! distinct is based on status field
        System.out.println(retweetcount+"--->"+stat);
    }
    }finally{
        cursor.close();
    }
}

【问题讨论】：

你有没有看过api.mongodb.com/java/3.2/com/mongodb/operation/…如果你给我你的示例数据库，我可以做一点弄清楚
@Netwon，我的数据库结构是这样的 {status:x,retweetcount:2},{status:y,retweetcount:5},{status:x,retweetcount:3}。每次它存储新状态及其转推数。我必须获得最高转发次数的状态，但我的数据库中有重复的状态。我想获取 status:x 和 retweetcount:3，该状态的转推数最高。
您可以发送您收藏的备份吗？
@Newton，是的，但是我如何将我的收藏发送给您？
上传到谷歌驱动器或其他东西并分享链接

标签： mongodb-java

【解决方案1】：

我试过这个方法，但它会获取一些不相关的字段。I referred this link

    ArrayList<Document> dd = new ArrayList<Document>();
    //MongoCursor<Document> cursor1 = collection.find().sort(query).iterator();

    Document grouping = new Document("_id","$status");
    grouping.append("text", new Document("$first","$_id"));
    grouping.append("RetweetCount", new Document("$first","$RetweetCount"));
    grouping.append("screen_name", new Document("$first","screen_name") );
    Document group = new Document("$group",grouping);
    System.out.println(group);

    Document sortfields = new Document("RetweetCount",-1);
    Document sort = new Document("$sort",sortfields);

    Document projectfields = new Document("_id",0);
    projectfields.append("_id", "$text");
    projectfields.append("RetweetCount", "$RetweetCount");
    projectfields.append("sn", "$screen_name");
    Document projects = new Document("$project",projectfields);



    AggregateIterable<Document> iterable = collection.aggregate(asList(new Document(group),new Document(sort),new Document(projects)));
    iterable.forEach(new Block<Document>() {
        @Override
        public void apply(final Document document) {
            System.out.println(document.toJson());
        }
    });

输出：

{ "_id" : { "$oid" : "576124fafbfb870794452ac6" }, "RetweetCount" : 643, "sn" : "screen_name" }

它省略了我的文本字段，而是返回 id 字段。我的转发顺序也不正确。这种方法效果很好，但结果不同。谁能指正我！！！

【讨论】：

我得到了解决方案。