java - 使用 Java/Groovy 读取 MongoDB oplog

Question

这个问题已经被反复讨论了一些，我保证我已尽力使用以前的答案:)

使用 Mongo shell，我可以使用 find 并查看 oplog 中的所有文档。但是，如果我尝试使用 find() 通过 java 进行访问，它会返回 null。我什至只是尝试使用 count()，它返回 0。

//this does indeed return oplog.rs as a valid collection
def collections = db.getCollectionNames();
println(collections);

DBCollection coll = db.getCollection("opslog.rs")

DBCursor cursor = coll.find();

while(cursor.hasNext()) {
println("something here" + cursor.next())
}

似乎没有返回任何内容。或者，如果我只是尝试打印出光标，我会得到: Cursor id=0, ns=local.opslog.rs, query={ }, numIterated=0, readPreference=primary我在另一个集合上运行相同的代码并且它有效。我必须在 java/Groovy 中以不同的方式对待 oplog 吗？如果有任何 Java 示例就太好了。

**顺便说一句 - 我尝试访问“local”、system.replset 和startup_log 中的其他2 个集合，并且能够取回数据。

谢谢，如果我在搜索中错过了这个答案，请提前道歉。

Answer 1

您的代码中有拼写错误，opslog.rs 应该是 oplog.rs。