今天来记录一下,项目中使用到的mongoTemplate.upsert,在批量更新数据上的用法。
// mongoTemplate.upsert有三种用法,主要功能是更新数据,如果数据不存在就新增
mongoTemplate.upsert(query,update,MongoDbJavaTest.class);
//"mongodb_java_test"这里的字符串可以按照MongoDbJavaTest.class实体类对应的表格名称
mongoTemplate.upsert(query,"mongodb_java_test");
mongoTemplate.upsert(query,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();
}
附录一些可以参考的帖子:
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
原文地址:https://www.jb51.cc/mongodb/4325360.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。