今天来记录一下，项目中使用到的mongoTemplate.upsert，在批量更新数据上的用法。
// mongoTemplate.upsert有三种用法，主要功能是更新数据，如果数据不存在就新增
mongoTemplate.upsert(query,update, MongoDbJavaTest.class);
//"mongodb_java_test"这里的字符串可以按照MongoDbJavaTest.class实体类对应的表格名称
mongoTemplate.upsert(query,update,"mongodb_java_test");
mongoTemplate.upsert(query,update, MongoDbJavaTest.class,"mongodb_java_test");
下面直接举实例：
import org.springframework.data.util.Pair;//Pair的包地址
public void upsertUser(List<userpo> users){
List<pair<query, update>> updateList = new ArrayList<>(userTagDocs.size());
users.forEach(data -> {
Query query = new Query(new
Criteria("phone").is(data.getPhone()).and("deleted").is(false);
Update update = new Update();
//如果userId是主键，必须使用setOnInsert()。当满足查询条件的记录存在，则不执行setOnInsert中的操作，当满足条件的记录不存在则执行setOnInsert操作。与set指令配合使用，可以作为set指令的补充。
update.setOnInsert("userId", data.getUserId());
update.set("name", data.getName());
update.set("phone", data.getPhone());
update.setOnInsert("deleted", false);
Pair<query, update> updatePair = Pair.of(query, update);
updateList.add(updatePair);
});
//BulkMode.UNORDERED:表示并行处理，遇到错误时能继续执行不影响其他操作；
//BulkMode.ORDERED：表示顺序执行，遇到错误时会停止所有执行
mongoTemplate.bulkOps(BulkOperations.BulkMode.UNORDERED, userPo.class).upsert(updateList);
//一定要加.execute()才能执行
BulkWriteResult result = operations.execute();
}</query,></pair<query,></userpo>
附录一些可以参考的帖子：
mongoTemplate批量更新保存子文档集合_隔壁的老司机的博客-CSDN博客_mongotemplate批量保存项目中遇到批量保存或者更新文档,使用mongotemplate的upsert来处理，发现会直接覆盖之前的子集，而不是按照自己的规则去追加，或者更新子集最后想到一个思路，记录一下List 
https://blog.csdn.net/chenxing1990/article/details/113250330?utm_medium=distribute.pc_aggpage_search_result.none-task-blog-2~aggregatepage~first_rank_ecpm_v1~rank_v31_ecpm-2-113250330-null-null.pc_agg_new_rank&utm_term=mongotemplate%20upsert%20%E6%89%B9%E9%87%8F&spm=1000.2123.3001.4430 ;
springboot mongodb 批量(bulkOps)插入或更新(upsert)数据_sms technonogy的博客-CSDN博客_mongodb 批量upsert 参与的项目中有一个业务场景，有两个消费者从kafka中拉取数据消费：1、订单消费者：从订单队列中拉取订单数据，插入到mongodb，集合名称为order（主要包含id、orderNo、orderName、status）2、订单状态消费者：从订单状态队列中拉取数据，更新order集合中的状态字段（status）存在问题：1、订单状态消费者消费依赖于订单消费者，如果订单消费者消费速度慢了，订单还没有插入到mongodb中，订单状态根据订单号orderNo去更新数据，则会找不到订单数据…https://blog.csdn.net/maxi1234/article/details/114088805?spm=1001.2101.3001.6650.2&utm_medium=distribute.pc_relevant.none-task-blog-2~default~BlogCommendFromBaidu~default-2-114088805-blog-84794894.pc_relevant_vip_default&depth_1-utm_source=distribute.pc_relevant.none-task-blog-2~default~BlogCommendFromBaidu~default-2-114088805-blog-84794894.pc_relevant_vip_default&utm_relevant_index=1 ;
Original: https://blog.csdn.net/hahaha_1112/article/details/126004721
Author: 热爱生活的猴子
Title: mongodb/mongoTemplate.upsert批量插入更新数据的实现
原创文章受到原创版权保护。转载请注明出处：https://www.johngo689.com/785142/
转载文章受原作者版权保护。转载请注明原作者出处！