我有一个集合:
public class Message {
@Id
ObjectId id;
String group;
}
我需要计算每个组的消息数量。是否可以避免遍历整个集合?
mongo 中的查询语言以及 morphia 并不真正支持这一点。 然而,聚合框架确实如此,这是个好消息。 (几乎)n个坏消息是morphia(还)不支持聚合。 我实际上在分支上构建了支持,但它依赖于 java 驱动程序的 2.12 版本。 以下是跟踪此功能的问题:https://github.com/mongodb/morphia/issues/449
在这个工作示例中,MessageEntry 代表 Message,linf 代表组:
DBCollection myColl = ds.getCollection(MessageEntry.class);
DBObject key = new BasicDBObject("linf",true);
DBObject initial = new BasicDBObject("cnt",true);
String reduce = "function(item,prev){prev.cnt+=1;}";
DBObject group = myColl.group(key, null, initial, reduce);
HashMap<String,Long> ret = new HashMap();
for(String k:group.keySet()){
BasicDBObject l = (BasicDBObject) group.get(k);
DBRef dbRef = (DBRef) l.get("linf");
Linf linf = ds.get(Linf.class,dbRef.getId() );
Double cnt = (Double) l.get("cnt");
ret.put(linf.limad,cnt.longValue());
}
return ret;