java mongodb upsert() 方法

╰半夏微凉° 2023-01-22 13:55 23阅读 0赞

需求：通过mongodb的批量操作，对数据进行保存或者修改；  
如果数据在mongodb不存在就保存数据，如果数据存在，就修改数据；

String collectionName = "collectionName";
    		// 这了是数据来源
            JSONArray array = messageStatus.getJsonObject().getJSONArray("objs");
            if (array != null && array.size() > 0) {
            	//mongo的批量操作
                BulkOperations operations = mongoTemplate.bulkOps(BulkOperations.BulkMode.UNORDERED, collectionName);
                for (int i = 0; i < array.size(); i++) {
                    JSONObject json = array.getJSONObject(i);
    
                    String id = json.getString("id");
                    String tid = json.getString("tid");
                    // 这里是查询语句
                    Query query = new Query(Criteria.where("tid").is(tid).and("id").is(id));
                    Document doc = Document.parse(json.toJSONString());
                    Update update = Update.fromDocument(doc);
                    update.currentDate("lastModified");
                    // 这里先根据查询找，有就插入，没有就修改
                    operations.upsert(query, update);
                }
                // 批量执行
                operations.execute();
            }

**问题：根据tid与id在mongodb能找到数据，但是通过mongodb的upsert方法操作之后，一直在插入数据，而不是修改数据；**

Query query = new Query(Criteria.where("tid").is(tid).and("id").is(id));
    mongoTemplate.find(query,JSONObject.class,"collectionName");
    能查到数据

通过比对数据类型，发现：我查询是使用的tid与id使用了String类型，而mongodb中保存的是int类型，这样造成的不完整匹配，所以一直插入，而不是修改；  
![在这里插入图片描述][20210520101513133.png]  
解决：  
将我的查询语句改成了Integer或Long类型就好了

。。。
       				Integer id = json.getInteger("id");
                    Integer tid = json.getInteger("tid");
                    。。。

[20210520101513133.png]: /images/20221020/43e691510f5d473c9ea2bf1f157b0f86.png