如何在MongoDB响应式Java中获取插入文档的ObjectId？

你当前通过com.mongodb.reactivestreams.client.MongoDatabase的runCommand执行插入命令后，返回结果中的$oid是集群的electionId（每次插入固定），并非插入文档的ObjectId。以下是几种可行的解决方法：

方法一：预先生成ObjectId并手动指定 #

插入前自行创建ObjectId并写入文档的_id字段，插入完成后直接使用预先生成的ID即可，无需从返回结果提取：

// 预先生成ObjectId
ObjectId documentId = new ObjectId();
// 构建插入文档，手动指定_id
Document doc = new Document("_id", documentId)
                .append("field1", "testValue1")
                .append("field2", "testValue2");
// 构建insert命令
Bson command = new Document("insert", "your_collection_name")
                .append("documents", Collections.singletonList(doc));

// 执行命令并直接使用预先生成的ID
Mono.from(database.runCommand(command))
    .subscribe(result -> {
        System.out.println("插入文档的ObjectId: " + documentId.toHexString());
    });

方法二：使用MongoCollection的插入方法（官方推荐） #

直接使用MongoCollection提供的insertOne/insertMany方法，这些方法会返回包含插入文档ID的结果对象，能直接提取ObjectId：

// 获取目标集合
MongoCollection<Document> collection = database.getCollection("your_collection_name");
// 构建待插入文档（不指定_id时MongoDB会自动生成）
Document doc = new Document("field1", "testValue1")
                .append("field2", "testValue2");

// 执行插入并提取ID
collection.insertOne(doc)
          .subscribe(result -> {
              ObjectId insertedId = result.getInsertedId().asObjectId().getValue();
              System.out.println("插入文档的ObjectId: " + insertedId.toHexString());
          });

方法三：在runCommand中添加returnDocument参数（仅适用于insert命令） #

如果必须使用runCommand执行插入，可在命令中添加returnDocument: 1参数，让MongoDB返回插入后的完整文档，从中提取_id：

Document doc = new Document("field1", "testValue1")
                .append("field2", "testValue2");
// 构建带returnDocument参数的insert命令
Bson command = new Document("insert", "your_collection_name")
                .append("documents", Collections.singletonList(doc))
                .append("returnDocument", 1);

Mono.from(database.runCommand(command))
    .subscribe(result -> {
        // 从返回结果的ops列表中获取插入的文档
        List<Document> insertedDocs = result.getList("ops", Document.class);
        if (!insertedDocs.isEmpty()) {
            ObjectId insertedId = insertedDocs.get(0).getObjectId("_id");
            System.out.println("插入文档的ObjectId: " + insertedId.toHexString());
        }
    });

注意：该参数需MongoDB服务器版本支持，请确认你的集群版本兼容。

补充说明 #

直接调用runCommand执行insert时，默认仅返回命令执行状态（如n为插入数量、ok为执行结果），不会包含插入文档的详情，因此无法直接获取自动生成的ObjectId，需通过上述方法处理。

内容的提问来源于stack exchange，提问作者Mohamed Magdy