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

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

你的核心困惑点解析

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

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

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

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

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

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

修正后的完整代码

// 构建要插入的目标文档
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) {