使用Java Sync驱动更新MongoDB指定日期区间字段未生效问题

使用Java Sync驱动更新MongoDB数据库中的整数类型Status字段，仅更新FromDate与ToDate日期区间内的数据。操作过程无错误或警告，但数据库中未体现更新结果。

数据结构示例 #

[{
  "_id": {
    "$oid": "6523d6f1af7d835017c39fcf"
  },
  "StudentName": "John Doe",
  "TutoringCourse": "Excel",
  "Course_details": [
    {
      "DateOfClass": "2023-03-21T00:00:00.000+00:00",
      "SessionStart": "16:00",
      "SessionEnd": "18:00",
      "HourlyWage": 12.5,
      "Duration": 2,
      "Cost": 25,
      "Status": 1,
      "Notes": ""
    },
    {
      "DateOfClass": "2023-03-31T00:00:00.000+00:00",
      "SessionStart": "15:00",
      "SessionEnd": "17:00",
      "HourlyWage": 12.5,
      "Duration": 2,
      "Cost": 25,
      "Status": 1,
      "Notes": ""
    }
  ]
}]

相关Java代码 #

public void UpdateOneCourseDetailsPerIntervalOfDate() {

    List <Bson> updateOperation = new ArrayList<Bson>() ;
    Bson update4,update5,update6,update7,update8,update9,update10;
//t[2]是输入起始日期的输入框，t[3]是输入结束日期的输入框
    LocalDate FromDate = LocalDate.parse(t[2].getText());
    LocalDate ToDate = LocalDate.parse(t[3].getText());
    //nameList存储所有学生姓名
    if(nameList.contains(t[0].getText()) && !t[0].getText().isEmpty()) {
        Iterator<String> iterator = SelectedFieldsItems.iterator();
        while (iterator.hasNext())
        {
            String tmp = iterator.next();
            if(tmp instanceof String && tmp != "") {
            
            if(tmp == "SessionStart") {
                update4 = Updates.set("Course_details.$[].SessionStart", t[4].getText());
                updateOperation.add(update4);
            }
            if(tmp == "SessionEnd") {
                update5 = Updates.set("Course_details.$[].SessionEnd", t[5].getText());
                updateOperation.add(update5);
            }
            if(tmp == "HourlyWage") {
                update6 = Updates.set("Course_details.$[].HourlyWage", t[6].getText());
                updateOperation.add(update6);
            }
            if(tmp == "Duration") {
                update7 = Updates.set("Course_details.$[].Duration", t[7].getText());
                updateOperation.add(update7);
            }
            if(tmp == "Cost") {
                update8 = Updates.set("Course_details.$[].Cost", t[8].getText());
                updateOperation.add(update8);
            }
            if(tmp == "Status") {
                update9 = Updates.set("Course_details.$[].Status", t[9].getText());
                updateOperation.add(update9);
                }
            if(tmp == "Notes") {
                update10 = Updates.set("Course_details.$[].Notes", t10.getText());
                updateOperation.add(update10);
                }
            }
            else
            {
                JOptionPane.showMessageDialog(this,"未选择任何字段..." ,"更新操作失败",JOptionPane.INFORMATION_MESSAGE);
                return;
            }
    
        }//while循环结束
        
       try{
            DBConnection db = new DBConnection();
            Bson query = Filters.and(Filters.eq("StudentName", t[0].getText()),Filters.lte("Course_details.$[].DateOfClass", ToDate),
                    Filters.gte("Course_details.$[].DateOfClass",FromDate));

            UpdateResult r = db.getCollection().updateMany(query, Updates.combine(updateOperation));
            statusBar.setMessage("已更新字段 - 数量: " + r.getMatchedCount());
            }
        catch (MongoException me) {
            statusBar.setMessage("无法更新字段: " + me);
            }
        }
        else
        {
            statusBar.setMessage("学生不在数据库中!");
            JOptionPane.showMessageDialog(this,"学生不在数据库中！请检查学生姓名..." ,"不在数据库中",JOptionPane.INFORMATION_MESSAGE);
        }
            
}

截图说明 #

• 更新数据表单：包含待更新数据的表单界面
• MongoDB日期字段：数据库集合中的日期字段展示

1. 字符串比较逻辑错误 #

Java中==是比较对象引用，而非字符串内容，代码中用tmp == "SessionStart"这类判断会导致字段匹配失败，无法生成正确的更新操作。
修复： 改用equals()方法比较字符串内容：

if("SessionStart".equals(tmp)) {
    // 对应更新逻辑
}

2. 日期类型不匹配 #

数据库中DateOfClass是带时间戳的Date类型，代码中用LocalDate直接比较，MongoDB无法正确匹配类型，导致查询条件失效。
修复： 将LocalDate转换为Instant类型，与数据库字段类型对齐：

// 转换起始日期为UTC当天0点的Instant
Instant fromInstant = FromDate.atStartOfDay(ZoneOffset.UTC).toInstant();
// 转换结束日期为UTC当天23:59:59的Instant，确保包含当天所有数据
Instant toInstant = ToDate.atStartOfDay(ZoneOffset.UTC)
                          .plusDays(1)
                          .minusSeconds(1)
                          .toInstant();

// 构造查询条件时使用Instant
Bson query = Filters.and(
    Filters.eq("StudentName", t[0].getText()),
    Filters.lte("Course_details.DateOfClass", toInstant),
    Filters.gte("Course_details.DateOfClass", fromInstant)
);

3. 数组更新范围错误 #

当前更新用Course_details.$[].Status会修改数组中所有元素的对应字段，且查询时Course_details.$[].DateOfClass的写法错误（数组查询无需加$[]）。需要用数组过滤器指定仅更新日期区间内的数组元素。
修复： 添加数组过滤器并指定更新占位符：

// 定义数组过滤器，匹配日期区间内的Course_details元素
ArrayFilter arrayFilter = Filters.and(
    Filters.gte("elem.DateOfClass", fromInstant),
    Filters.lte("elem.DateOfClass", toInstant)
);

// 设置更新选项，传入数组过滤器
UpdateOptions options = new UpdateOptions().arrayFilters(List.of(arrayFilter));

// 更新时用$[elem]指定要修改的数组元素
if("Status".equals(tmp)) {
    update9 = Updates.set("Course_details.$[elem].Status", Integer.parseInt(t[9].getText()));
    updateOperation.add(update9);
}

// 执行更新时传入options参数
UpdateResult r = db.getCollection().updateMany(query, Updates.combine(updateOperation), options);

4. 数值类型转换错误 #

Status是整数类型，代码中直接传入字符串会导致类型不匹配，更新不生效或字段类型被篡改。同理HourlyWage、Duration、Cost也需要转换为对应数值类型。
修复： 将输入文本转为对应数值类型：

// Status转Integer
update9 = Updates.set("Course_details.$[elem].Status", Integer.parseInt(t[9].getText()));
// HourlyWage转Double
update6 = Updates.set("Course_details.$[elem].HourlyWage", Double.parseDouble(t[6].getText()));
// Duration转Integer
update7 = Updates.set("Course_details.$[elem].Duration", Integer.parseInt(t[7].getText()));
// Cost转Double
update8 = Updates.set("Course_details.$[elem].Cost", Double.parseDouble(t[8].getText()));

5. 空字符串判断错误 #

代码中tmp != ""是引用比较，无法正确判断空字符串，应改为!tmp.isEmpty()。
修复：

if(tmp instanceof String && !tmp.isEmpty()) {
    // 字段处理逻辑
}

内容的提问来源于stack exchange，提问作者Jean pierre Atanas