今天来记录一下，项目中使用到的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();
}

附录一些可以参考的帖子：

mongoTemplate批量更新保存子文档集合_隔壁的老司机的博客-CSDN博客_mongotemplate批量保存项目中遇到批量保存或者更新文档,使用mongotemplate的upsert来处理，发现会直接覆盖之前的子集，而不是按照自己的规则去追加，或者更新子集最后想到一个思路，记录一下List<DayAir> dayAirList = mergeList(currentTime, syncMinutes);if (!dayAirList.isEmpty()) { //按照唯一键查询出对应文档 dayAirList.forEach(air -> { ...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

mongodb的BulkOperations，springboot批量插入数据时若数据库存在数据则更新，同时更新elasticSearch_小龙飞2的博客-CSDN博客// mongodb 的批量插入或者更新 List<Pair<Query, Update>> updateList = new ArrayList<>(userTagDocs.size()); BulkOperations operations = mongoTemplate.bulkOps(BulkOpera...https://blog.csdn.net/weixin_40898368/article/details/103485123