时间戳

首页 > 解决方案 > 如何更新数组内的部分文档？（MongoDB SpringBoot 反应式）

java - 如何更新数组内的部分文档？（MongoDB SpringBoot 反应式）

问题描述

我知道这个问题已经回答了很多。但是，我无法找到“正确”执行此操作的 Spring Boot 方式。我找到了例子，但我无法让它为我的项目工作。

{"_id":"5b45572047f84e3d10c59b8a"
,"userRoomDatas":[{"isInGame":false,"isReady":true,"isSpectator":false,"userId":"5b45572047f84e3d10c59b84"}]
,"selectedScreen":"MATCHMAKING"
,"privacySetting":"PUBLIC"
,"roomLeaderId":"5b45572047f84e3d10c59b84"
,"botHostId":"5b45572047f84e3d10c59b84"
,"matchmakingData":   {"selectedQueId":"5b45572047f84e3d10c59b85","matchmakingRating":"M3"}
,"currentRoomStatus":"IN_ROOM"
,"canStartSearch":false
,"password":"AA=="
,"quickJoinEnabled":true
,"roomRating":"MEMERS_ONLY"
,"_class":"room"}

这是我的文件。我希望能够更改 userRoomDatas 中一个对象的值。例如 "isSpectator":false 到 "isSpectator":true

public Mono<RoomData> findAndModifyUserSpectate(String roomId, String requestUserId,
        boolean isSpecator){
    Query query = new Query();
    query.addCriteria(Criteria.where("id").is(roomId).and("userRoomDatas")
            .elemMatch(Criteria.where("userId").is(requestUserId)));
    Update update = new Update();
    update.set("userRoomDatas.$.isSpectator : " + isSpecator, new Query(Criteria
            .where("userRoomDatas").elemMatch(Criteria.where("userId").is(requestUserId))));
    FindAndModifyOptions options = FindAndModifyOptions.options();
    options.returnNew(true);
    return template.findAndModify(query, update, options, RoomData.class);
}

这是我得到的最好的。我尝试了不同的方法，但我知道它们都错了。

根据我的理解，第一个查询过滤掉了我的 RoomData 对象。但是更新部分我不知道如何引用数组中的文档并告诉它用新值更新其中一个变量。我知道关键部分没有多大意义。我尝试了不同的方法，但我不知道将查询与值放在哪里。

标签： javaspring-bootmongodb-queryreactive-programming

解决方案

这是一个旧帖子，但我希望这可以帮助其他人。更新数组内文档的最通用方法是使用 MongoDB arrayFilters。使用 springboot 没有使用 MongoTemplate 的直接连接，但可以使用 MongoDatabase 对象。

一个实际的例子很简单。假设有一个像

{ _id: "132456",
  statistics:
    2018: [
      {
         offset: 5,
         results: {
            a: 1,
            b: 2
         }
      },
      {
         offset: 4,
         results: {
            a: 13,
            b: 24
         }
      }
    ]
}

更新的 Java 代码看起来像

// Defines the query which selects the document
Bson filter = Filters.and(Filters.eq("_id", "132456"), Filters.exists("statistics"));

// Defines the udpate command. Notice the filtered positional operator $[element]
Bson update = Updates.set("statistics.$[element].results.b", result);

// IMPORTANT! This select the document into the array. 
// Notice that the document does not really contain a key called "element": 
// it is only a parametric variable later referenced in the arrayFilters
UpdateOptions updateOptions = new UpdateOptions();
List<Bson> arrayFilters = new ArrayList();
Bson arrayElement = Filters.eq("element.daysOffset", -4);
arrayFilters.add(arrayElement);
updateOptions.arrayFilters(arrayFilters);

// Finally update the element matching both the document in the collection 
// and the document in the inner array
mongoTemplate.getDb().getCollection("MyCollection").updateOne(filter, update, updateOptions);

推荐阅读