java cursor_使用3.0驱动程序的Java中的Tailable Cursor示例?
有人可以在
Java中提供完整的tailable游標(biāo)示例嗎?我使用3.0驅(qū)動程序,所有示例似乎是2.x.我的classpath中只有mongo-java-driver-3.0.0.jar.我希望得到所有文件,因為它們被插入到我的上限集合中.
//this does not work...
MongoCollection col = database.getCollection(colName, BasicDBObject.class);
DBCursor cur = col.find().sort(new BasicDBObject("$natural", 1))
.addOption(Bytes.QUERYOPTION_TAILABLE)
.addOption(Bytes.QUERYOPTION_AWAITDATA);
// And this does not work...
BasicDBObjectBuilder builder = BasicDBObjectBuilder.start();
builder.add("messageType","STATUS_REQUEST");
DBObject searchQuery = builder.get();
DBObject sortBy = BasicDBObjectBuilder.start("$natural", 1).get();
BasicDBObjectBuilder builderForFields = BasicDBObjectBuilder.start();
DBObject fields = builderForFields.get();
DBCursor cursor = new DBCursor(col, searchQuery, fields, ReadPreference.primary() );
cursor.sort(sortBy);
cursor.addOption(Bytes.QUERYOPTION_AWAITDATA);
cursor.addOption(Bytes.QUERYOPTION_TAILABLE);
//this does work but only returns the messageNumber field. I need the doc.
MongoCursor c = database.getCollection(colName).distinct("messageNumber", Long.class).iterator();
我看到MongoCursor接口是在3.0中添加的.這是什么,它取代了DBCursor?
非常感謝
總結(jié)
以上是生活随笔為你收集整理的java cursor_使用3.0驱动程序的Java中的Tailable Cursor示例?的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: java 多线程 异步日志_精彩技巧(1
- 下一篇: 如何清理水草泥里的粑粑?