void batchUpset(List<Entity> list) {
//UNORDERED: 并行,遇到错误后继续执行
BulkOperations bulkOps = mongoTemplate.bulkOps(BulkOperations.BulkMode.UNORDERED, "entity_table");
//批量更新
for (Entity e: list) {
Query query = Query.query(Criteria.where("name").is(e.getName()));
Update update = new Update().set("score", e.getScore());
bulkOps.upsert(query,update);
}
bulkOps.execute();
//批量写入
bulkOps.insert(list);
bulkOps.execute();
//批量删除
for (Entity e: list) {
Query query = Query.query(Criteria.where("name").is(e.getName()));
bulkOps.remove(query);
}
bulkOps.execute();
}
版权声明:本文为qq_32234855原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。