public void update(MgBrowseRecordVo t) { Query query = new Query(); query.addCriteria(Criteria.where("sessionId").is(t.getSessionId())); query.addCriteria(Criteria.where("userName").is("mongo_")); List<MgBrowseRecordVo> list = mongoTemplate.find(query, MgBrowseRecordVo.class, collectionName); if (!EmptyUtils.isEmptyList(list)) { Update update = Update.update("userName", t.getUserName()).set("rtime", t.getRtime()); mongoTemplate.upsert(query, update, MgBrowseRecordVo.class, collectionName); } Query querys = new Query(); querys.addCriteria(Criteria.where("userName").is(t.getUserName())); querys.addCriteria(Criteria.where("modelId").is(t.getModelId())); query.addCriteria(Criteria.where("mallId").is(t.getMallId())); Update update = Update.update("sessionId", t.getSessionId()).set("rtime", t.getRtime()); List<MgBrowseRecordVo> voList = mongoTemplate.find(querys, MgBrowseRecordVo.class, collectionName); if (!EmptyUtils.isEmptyList(voList)) { mongoTemplate.upsert(querys, update, collectionName); } else { mongoTemplate.save(t, collectionName); } }
时间: 2024-04-07 16:30:26 浏览: 106
这段代码是一个更新浏览记录的方法。它首先创建一个查询对象`query`,并根据传入的`MgBrowseRecordVo`对象中的属性设置查询条件,包括`sessionId`和固定的`userName`为"mongo_"。然后,它使用这个查询对象执行查询操作,将结果保存在列表`list`中。
如果列表`list`不为空,表示已经存在符合条件的浏览记录,那么它创建一个更新对象`update`,将属性`userName`和`rtime`设置为传入的对象的对应属性,并使用`upsert`方法执行更新操作。
接下来,它创建另一个查询对象`querys`,并根据传入的`MgBrowseRecordVo`对象中的属性设置查询条件,包括`userName`、`modelId`和`mallId`。然后,它同样使用这个查询对象执行查询操作,将结果保存在列表`voList`中。
如果列表`voList`不为空,表示已经存在符合条件的浏览记录,那么它执行更新操作,将属性`sessionId`和`rtime`设置为传入的对象的对应属性,并使用`upsert`方法执行更新操作。
如果列表`voList`为空,表示不存在符合条件的浏览记录,那么它直接调用`save`方法将传入的对象保存到数据库中。
相关问题
public void save(MgBrowseRecordVo t) { Query query = new Query(); query.addCriteria(Criteria.where("sessionId").is(t.getSessionId())); query.addCriteria(Criteria.where("userName").is(t.getUserName())); query.addCriteria(Criteria.where("modelId").is(t.getModelId())); query.addCriteria(Criteria.where("mallId").is(t.getMallId())); List<MgBrowseRecordVo> list = mongoTemplate.find(query, MgBrowseRecordVo.class, collectionName); if (!EmptyUtils.isEmptyList(list)) { Update update = Update.update("rtime", t.getRtime()); mongoTemplate.upsert(query, update, MgBrowseRecordVo.class, collectionName); } else { mongoTemplate.save(t, collectionName); } }
这段代码是一个保存浏览记录的方法。它使用了Spring Data MongoDB来与MongoDB数据库进行交互。
首先,它创建了一个查询对象`query`,并添加了一些查询条件,包括`sessionId`、`userName`、`modelId`和`mallId`。
然后,通过调用`mongoTemplate.find()`方法,执行查询操作,将满足条件的浏览记录返回到列表`list`中。
接下来,通过判断列表`list`是否为空来确定是执行更新操作还是插入操作。
如果列表`list`不为空,说明已经存在满足条件的浏览记录,就创建一个更新对象`update`,将浏览时间`rtime`更新为新的值,并调用`mongoTemplate.upsert()`方法执行更新操作。
如果列表`list`为空,说明不存在满足条件的浏览记录,就直接调用`mongoTemplate.save()`方法将新的浏览记录保存到数据库中。
需要注意的是,这段代码中使用了一些自定义的类和方法,如`MgBrowseRecordVo`和`EmptyUtils.isEmptyList()`,你可能需要根据具体情况进行替换或添加相应的实现。
阅读全文