mongo的upsert（spring的mongo template）

男娘i 2022-06-10 07:59 342阅读 0赞

mongo的api在某些方面表现的异常优秀，这几天体会了一下mongo的upsert方法。

我的目的是想在某个项号下记录每天的评论，并且能够查到某段日期间按时间倒叙排列的评论。我的设计是这样：

1 类设计

首先是记录每天的评论汇总

**\[html\]** [ view plain][view plain] [ copy][view plain]

1.  @Document(collection="comments")  
2.  public class Comments \{  
3.        
4.      @Id  
5.      private String id;  
6.        
7.      private String itemId;//项目号  
8.        
9.      private String commentsDate;//评论日期格式是以yyyy-MM-dd保存  
10.       
11.     private List comments;//每天的评论列表  
12.       
13.     private Comment c;//评论  
14.       
15.       
16.     //setter,getter  
17. \}

**\[html\]** [ view plain][view plain] [ copy][view plain]

1.  <span style="white-space:pre">    </span>评论的详细信息

**\[html\]** [ view plain][view plain] [ copy][view plain]

1.  <span style="white-space:pre">    </span><pre name="code" class="html">public class Comment \{  
2.        
3.      private String userid;//用户id  
4.        
5.      private String comment;//评论内容

dao接口

**\[html\]** [ view plain][view plain] [ copy][view plain]

1.  void upsert(Comments c)throws Exception; //添加每天评论  
2.    
3.  List<Comments> selectByItemId(String itemId)throws Exception; //根据项目id查询 按日期倒叙排列

![41693161][]

实现

**\[html\]** [ view plain][view plain] [ copy][view plain]

1.  @Override  
2.      public void upsert(Comments c) throws Exception \{  
3.          Query query = new Query();  
4.          query.addCriteria(Criteria.where("itemId").is(c.getItemId()));  
5.          query.addCriteria(Criteria.where("commentsDate").is(c.getCommentsDate()));  
6.          Update update = new Update();  
7.          update.push("comments", c.getC());  
8.          mongoTemplate.upsert(query, update, Comments.class);  
9.    
10.     \}  
11.   
12.     @Override  
13.     public List<Comments> selectByItemId(String itemId) throws Exception \{  
14.         Order order = new Order(Direction.DESC, "commentsDate");  
15.         Sort sort = new Sort(order);  
16.         List<Comments> list =mongoTemplate.find(new Query(Criteria.where("itemId").is(itemId)).with(sort), Comments.class);  
17.         return list;  
18.     \}

![41693161][]

[测试][Link 1]一下

现在[数据库][Link 2]中没有数据

![Center][]

![41693161][]

结果是

![Center 1][]

![41693161][]

现在修改一下评论内容其他不变

![41693161][]![Center 2][]

数据库数据

![Center 3][]

![41693161][]

看comments的数组个数变成2了

下面我们来修改一下日期，其它与上条数据保持一致

![41693161][]![Center 4][]

![Center 5][]

![41693161][]

看又增加了一条日期不同的数据哎，这正是我想要的（相同的itemid以天为单位增加数据）

换一个itemId试试吧，其它与上条测试数据相同

![Center 6][]

![41693161][]

看数据库中，又会增加一条数据

![Center 7][]

![41693161][]

这也是我期望的结果当itemid不同的同一日期也要单独记录

现在总结一下upsert这个api

首先是查询itemid和commentsDate当这两个字段都一致时就会在原有的记录中修改

当查询的这两个字段中有一个发生变化了，数据库中没有，就会使插入新数据的操作。

[view plain]: /images/20220610/67d5a1ab71a3455f9df5418b7b3a3e1a.png#
[41693161]: /images/20220610/67d5a1ab71a3455f9df5418b7b3a3e1a.png
[Link 1]: http://lib.csdn.net/base/softwaretest
[Link 2]: http://lib.csdn.net/base/mysql
[Center]: /images/20220610/0da3aa1e347d4cb78334f8aa5e5aad54.png
[Center 1]: /images/20220610/c5c36b19b2c341c5a7b522c4b6b9ff85.png
[Center 2]: /images/20220610/ce31dfbacaa344d49c74ede12ac0568c.png
[Center 3]: /images/20220610/eb09797dd5c244a4a21f7917fbbcaf57.png
[Center 4]: /images/20220610/6b193b18a01543fab535cc24d68f0223.png
[Center 5]: /images/20220610/41f1985d3a234bfd8d5d3565e8182516.png
[Center 6]: /images/20220610/35bcf176b00f4ba0a956e8f59842a574.png
[Center 7]: /images/20220610/7088ac65f16e4f31988bfd7f7d598861.png