Java 中MongoCursor<ChangeStreamDocument<Document>>如何获取删除前内容

在 Java 中，可以使用 MongoDB 的 Java 驱动程序提供的 Change Streams API 来监视集合中的实时更改。如果你想获取文档被删除前的内容，可以在 `ChangeStreamDocument` 中使用 `fullDocument` 方法，并将其设置为 `updateLookup`。这将在文档被删除前将其完整内容返回给应用程序，以便进行处理。以下是一个使用 `fullDocument` 方法的 Change Streams 示例：

MongoCollection<Document> collection = database.getCollection("myCollection");
List<Bson> pipeline = Arrays.asList(
    Aggregates.match(Filters.eq("operationType", "delete")),
    Aggregates.project(Projections.fields(Projections.include("fullDocument")))
);

MongoCursor<ChangeStreamDocument<Document>> cursor = collection.watch(pipeline, ChangeStreamDocument.class).iterator();
while (cursor.hasNext()) {
    ChangeStreamDocument<Document> document = cursor.next();
    Document deletedDocument = document.getFullDocument(Document.class);
    System.out.println("Deleted document: " + deletedDocument.toJson());
}

这个示例将监视 `myCollection` 集合中的删除操作，并在每次删除时获取删除前的完整文档。注意，`fullDocument` 方法只在更新和替换操作中可用，但是在删除操作中也可以使用。