Java MongoDB: 避免重复文档插入并正确处理异常

我来帮你一步步理清这些问题，先拆解你的核心困惑，再给出修正后的代码方案：

你的核心困惑点解析

1. findOne() 返回值类型的疑惑

你用到的DBObject是MongoDB旧版驱动（3.x及更早）的API，在新版驱动（4.x+）中，MongoCollection的findOne()方法返回的是Document对象，而非DBObject。所以你需要把接收返回值的变量类型改成Document，这就能解决类型匹配的问题。

2. 判断findOne()返回null是否正确？

完全正确！当数据库中没有匹配你定义的filter的文档时，findOne()会返回null，这就是判断“无重复文档”的标准方式。

3. 代码逻辑与异常抛出的问题

你当前的逻辑完全搞反了，而且异常抛出的时机也不对：

• 当duplicate != null时，说明数据库里已经存在相同的文档，这时候应该抛出异常，而不是执行插入
• 只有当duplicate == null时，才应该执行插入操作
• 你现在的代码不管逻辑分支如何，都会直接抛出异常，导致即使插入成功也会进入catch块，这显然不符合需求

修正后的完整代码

// 构建要插入的目标文档
Document zeroCmd = new Document();
zeroCmd.put("name", item[1]);
zeroCmd.put("supplier", item[2]);
zeroCmd.put("food", item[3]);
zeroCmd.put("country of origin", item[4]);

// 构建重复判断过滤器（匹配除_id外的所有字段）
Bson filter = Filters.and(
    Filters.eq("name", item[1]),
    Filters.eq("supplier", item[2]),
    Filters.eq("food", item[3]),
    Filters.eq("country of origin", item[4])
);

// 用Document接收findOne的返回结果（新版驱动的正确类型）
Document duplicate = match.findOne(filter);

try {
    if (duplicate != null) {
        // 检测到重复文档，抛出异常
        throw new Exception("[Error] duplicate insertion: document already exists in collection");
    } else {
        // 无重复，执行插入操作
        InsertOneResult result = match.insertOne(zeroCmd);
        System.out.println("Document inserted successfully, ID: " + result.getInsertedId());
    }
} catch (Exception e) {
    // 捕获异常并打印错误信息
    System.err.println(e.getMessage());
}

额外优化建议：数据库层面保证唯一性

如果你的场景存在并发插入的可能，仅靠提前查询的方式可能会出现竞态问题（两个请求同时查询到无重复，然后都执行插入）。这时候建议给这些字段创建复合唯一索引，从数据库层面杜绝重复：

// 创建复合唯一索引，确保name、supplier、food、country of origin的组合唯一
match.createIndex(
    Indexes.ascending("name", "supplier", "food", "country of origin"),
    new IndexOptions().unique(true)
);

创建索引后，你甚至可以省略提前查询的步骤，直接执行插入，捕获MongoDB抛出的唯一索引冲突异常即可，代码更简洁且更安全：

try {
    InsertOneResult result = match.insertOne(zeroCmd);
    System.out.println("Document inserted successfully, ID: " + result.getInsertedId());
} catch (MongoWriteException e) {
    // 11000是MongoDB唯一索引冲突的错误码
    if (e.getError().getCode() == 11000) {
        System.err.println("[Error] duplicate insertion: document already exists");
    } else {
        // 处理其他写入异常
        System.err.println("Insert failed with error: " + e.getMessage());
    }
} catch (Exception e) {
    System.err.println("Unexpected error occurred: " + e.getMessage());
}

内容的提问来源于stack exchange，提问作者Shangjie Zheng