春季WebFlux反应性Mongo散装操作（Java）

Question

https://github.com/spring-proing-proing-projects/spring-projects/spring-data-data-data-data--data--data--data--- mongodb/eskent/2821

我一直在寻找反应式泡沫操作，以将文档作为Spring WebFlux中的批量更新。

就像在Mongo模板中一样，

var bulkOps = mongoTemplate.bulkOps()
for(dto : List<DTO> DTOs) {
  Query query = new Query();
  query.addCriteria(Criteria.where(ID).is(dto.getId()));
  Update update = new Update()
                    .set(STATUS, dto.getStatus())
  bulkOps.updateOne(query, update)
}
bulkOps.execute();

有能力以反应性的方式实施该操作，因为ReactiveVemongotemplate看起来像当前不支持该操作？

so中的similiar主题： bute vishivemongotemplate bulk更新

Answer 1

很快提醒大量与Updatemulti不同。

批量旨在在单个查询中写下多个对象，因此，更新各种对象。另一方面，UpdateMulti旨在更新所有线条，其中表达式匹配

为反应性散装，您应该能够使用 reactivemongotemplate 并实现类似的内容：

reactiveMongoTemplate.getCollection("collection_name")
    .flatMap(mongoCollection -> {
            List<UpdateOneModel<Document>> operations = DTOs.stream()
                .map(dto -> {
                    Document doc = new Document("status", dto.getStatus());
                    
                    reactiveMongoTemplate.getConverter().write(dto, doc);
                    
                    Document filter = new Document("id", dto.getId());
                    
                    return new UpdateOneModel<Document>(filter, new Document("$set", doc))
                }).toList();
        
            return Mono.from(mongoCollection.bulkWrite(operations));
    });

您还可以将自定义选项添加到 如果需要的话，bulkwrite（）。

如果需要更多过滤器，您可以将它们附加到文档

Document filter = new Document("id", dto.getId())
     .append("country", dto.getCountry);