MongoTemplate批量操作以及nosuchmethoderror BulkOperations.execute()

java中操作MongoDB最常见的就是MongoTemplate。

接下记录写常见的基本操作：

Spring boot 添加包：

        <!-- mongodb -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
        </dependency>

注入

@Autowired
private MongoTemplate mongoTemplate;

1.添加。

保存会判断存在，存在就会修改。如果不写collectname。会根据mongoData.class来生成Collect名字。

MongoData mongoData = new MongoData();
mongoData.setId(1);
mongoData.setCreatedTime(new Date());
mongoData.setUpdatedTime(new Date());

mongoTemplate.save(mongoData, collectName);
        

2.单个修改

updateMuti是修改符合的所有记录。

Query queryUpdate = new Query();
queryUpdate.addCriteria(where("_id").is(mongoData.get_id()));
String newFieldsMD5 = MD5Utils.getMD5(JSON.toJSONString(jsonStr));
Update update = new Update();
update.set("changeColumn", newFieldsMD5).set("updatedTime", new Date()));
mongoTemplate.updateFirst(query, update, MDocumentData.class, collectionName);

3.批量添加方式一：

azMongoTemplate.insert(addList, collectName);

4.批量添加方式二：

   BulkOperations operations = azMongoTemplate.bulkOps(BulkOperations.BulkMode.UNORDERED, collectName);

 if (allIds != null && !allIds.isEmpty()) {
            allIds.forEach((key, value) -> {

                MongoData mongoData = new MongoData();
                mongoData.setCreatedTime(new Date());
                mongoData.setUpdatedTime(new Date());
 
                operations.insert(mongoData)
                    }
            );
            operations.execute();
}

5.批量修改：

这个需要用到的人才多：

BulkOperations operations = azMongoTemplate.bulkOps(BulkOperations.BulkMode.UNORDERED, collectName);

            updateList.forEach(
                    mongoData -> {
                        String jsonStr = allIds.get(mongoData.getId());
                        Query queryUpdate = new Query();
                        queryUpdate.addCriteria(where("_id").is(mongoData.get_id()));
                        String newFieldsMD5 = MD5Utils.getMD5(JSON.toJSONString(jsonStr));
                        Update update = new Update();
                        update.set("changeColumn", newFieldsMD5).set("updatedTime", new Date())
                                .set("jsonStr", jsonStr).set("updatedStatus", StatusEnum.HANDLED.getStatus());
                        operations.updateOne(queryUpdate, update);
                    }
            );
  BulkWriteResult result =operations.execute();


//这个修改当值没有改变时  result.getModifiedCount()是为0;

所以看到第4点和第5点。可以一起执行修改和添加。算是事务。

可能出现的问题：

org.springframework.data.mongodb.core.BulkOperations.execute()Lcom/mongodb/bulk/BulkWriteResult

这是引入包的问题。不同的版本会有冲突。建议Spring boot 按最上面的引入包

另外关于不区分大小写的精确查找

query.addCriteria(Criteria.where("字段").regex("^" + 字段值 + "$", "i"));