SpringBoot整合MongoDB的步骤详解

  org.springframework.bootspring-boot-starter-data-mongodb

 #spring.data.mongodb.host=127.0.0.1 #spring.data.mongodb.port=27017 #spring.data.mongodb.database=books ###这种类似于关系型数据库url配置 spring.data.mongodb.uri=mongodb://127.0.0.1:27017/books

 @Document(collection = "comment") //如果省略集合属性，默认为类名首字母小写 //设置复合索引 //@CompoundIndex(def="{'userId':1},{'nickName':-1}") public class Comment implements Serializable { @Id  //对应comment中的_id private String id; @Field("content")//属性对应mongodb字段名，如果一致，无须该注解 private String content;//吐槽内容 private String articleId;//文章id private Date publishTime;//发布日期 @Indexed  //添加一个单字段的索引 private String userId;//发布人id private String nickName;//发布人昵称 private Date createDateTime;//评论的日期时间 private Integer likeNum;//点赞数 private Integer replyNum;//回复数 private String state;//状态 private String parentId;//上级id // 此处忽略getter与setter方法 }　

 @Service public class CommentService { @Autowired private CommentRepository commentRepository;  // 注入DAO @Autowired private MongoTemplate mongoTemplate;  // 注入Mongodb提供的操作模板 // 保存一个 public void saveComment(Comment comment){ commentRepository.save(comment); // mongoTemplate.save(comment); // mongoTemplate.insert(comment); } // 批量保存 public void mutilSaveComment(List list){ commentRepository.saveAll(list); // mongoTemplate.insertAll(list); } // 更新一个 public void updateComment(Comment comment){ commentRepository.save(comment); } // 查询全部 public List findCommentAll(){ // return  commentRepository.findAll(); return mongoTemplate.findAll(Comment.class); } // 条件查询 public List findCommentByContion(Query query){ return  mongoTemplate.find(query,Comment.class); } // 查询全部并以id排序返回结果 public List findCommentAllOrder(){ //  return  commentRepository.findAll(Sort.by(Sort.Order.desc("_id"))); Query query=new Query(); query.with(Sort.by(Sort.Direction.DESC,"id")); return mongoTemplate.find(query,Comment.class); } // 通过id查询 public Comment findCommentById(String id){ //return  commentRepository.findById(id).get(); return mongoTemplate.findById(id,Comment.class); } /** * @param parentId * @param page * @param size * @return */ public Page findByparentIdPage1(String parentId, int page,int size){ return  commentRepository.findByParentId(parentId, PageRequest.of(page-1,size)); } // 方式二 public List findByparentIdPage2(String parentId, int page,int size){ Query query=Query.query(Criteria.where("parentId").is(parentId)); query.with(PageRequest.of(page-1,size)); return  mongoTemplate.find(query,Comment.class); } // 通过id删除 public void deleteById(String id){ // commentRepository.deleteById(id); Comment comment=new Comment(); comment.setId(id); mongoTemplate.remove(comment); } // 删除全部数据 public void deleteAll(){ commentRepository.deleteAll(); } // 批量删除 public void deleteMulti(List list){ commentRepository.deleteAll(list); } // 根据id更新一条文档：点赞数加1 public void updateCommentLikeNumm(String id){ // 点赞数加一，效率低，增加id开销 // Comment comment=commentRepository.findById(id).get(); // comment.setLikeNum(comment.getLikeNum()+1); // commentRepository.save(comment); // 拿到查询对象 Query query=Query.query(Criteria.where("_id").is(id)); // 拿到更新对象 Update update=new Update(); // 局部更新 相当于$set // update.set(key,value); // 递增$inc // update.inc("likeNum",1); update.inc("likeNum");  // 指定字段自增1 mongoTemplate.updateFirst(query,update,"comment"); } // 有条件的统计 public Long commentCount(Query query){ return mongoTemplate.count(query,Comment.class); } }

 public interface CommentRepository extends MongoRepository { 　　//新增按父id分页查询 Page findByParentId(String parentId,Pageable pageable); }　　

 @RunWith(SpringRunner.class) @SpringBootTest public class CommentServiceTest { @Autowired private CommentService commentService; @Test public void saveCommentTest(){  // 新增单个 Comment comment=new Comment(); //comment.setId("2"); comment.setArticleId("777"); comment.setContent("添加数据测试"); comment.setPublishTime(new Date()); comment.setUserId("1001"); comment.setNickName("张三"); comment.setCreateDateTime(new Date()); comment.setLikeNum(1); comment.setReplyNum(0); comment.setState("1"); comment.setParentId("0"); commentService.saveComment(comment); } @Test public void mutilSaveComment(){  // 批量新增 List list=new ArrayList<>(); Comment comment; for(int i=1;i<=10;i++){ comment=new Comment(); comment.setId(""+i); comment.setArticleId(""+i); comment.setContent("添加数据测试"+i); comment.setPublishTime(new Date()); comment.setUserId("1001"); comment.setNickName("张三"); comment.setCreateDateTime(new Date()); comment.setLikeNum(0); comment.setReplyNum(0); comment.setState("1"); comment.setParentId("0"); list.add(comment); } commentService.mutilSaveComment(list); } @Test public void findCommentListTest() {  // 查询全部 List list=commentService.findCommentAll(); for(Comment comment:list){ System.out.println(comment); } } @Test public void findCommentListOrderTest() {  // 查全部并通对id排序 List list=commentService.findCommentAllOrder(); for(Comment comment:list){ System.out.println(comment); } } @Test public void findCommentById() {  // 通过id删除 Comment comment=commentService.findCommentById("1"); System.out.println(comment); } @Test public void findByParentId(){  // 通过父id分页查询1 Page page=commentService.findByparentIdPage1("0",1,10);  // 第1页，每页10个 System.out.println(page.getTotalElements()); System.out.println(page.getContent()); } @Test public void findByparentIdPage2(){  //  通过父id分页查询2 List list=commentService.findByparentIdPage2("0",1,10);  // 第1页，每页10个 for(Comment comment1:list){ System.out.println(comment1); } } @Test public void deleteById(){  // 通过id删除评论 commentService.deleteById("1"); } @Test public void deleteAll(){  // 删除全部 commentService.deleteAll(); } @Test public void deleteMulti(){  // 批量删除 List list=new ArrayList<>(); Comment comment; for(int i=1;i<=10;i++) { comment = new Comment(); comment.setId("" + i); list.add(comment); } commentService.deleteMulti(list); } @Test public void findCommentByContion(){ // 多条件查询in // 拿到查询范围 List list=new ArrayList<>(); list.add("1"); list.add("2"); list.add("3"); // 根据范围拿到查询对象 Query query=Query.query(Criteria.where("_id").in(list)); // 根据查询条件拿到结果 List list2=commentService.findCommentByContion(query); for(Comment comment1:list2){ System.out.println(comment1); } } @Test public void findCommentContionByGtLt(){  // 多条件查询大于2小于等于6 // 拿到查询对象 Query query=Query.query(Criteria.where("likeNum").gte(2).lte(6)); // 根据查询条件拿到结果 List list =commentService.findCommentByContion(query); for(Comment comment1:list){ System.out.println(comment1); } } @Test public void findCommentContionByAnd(){  // 多条件查询and //查询对象 Query query=Query.query(new Criteria().andOperator(Criteria.where("likeNum").gte(2) ,Criteria.where("state").is("1"))); List list =commentService.findCommentByContion(query); for(Comment comment1:list){ System.out.println(comment1); } } @Test public void findCommentContionByOr(){ // 多条件查询or //查询对象 Query query=Query.query(new Criteria().orOperator(Criteria.where("likeNum").gte(2) ,Criteria.where("state").is("0"))); List list =commentService.findCommentByContion(query); for(Comment comment1:list){ System.out.println(comment1); } } @Test public void updateCommentLikeNumm(){  // 更新 点赞数加一 commentService.updateCommentLikeNumm("1"); } @Test public void commentCount(){  // 统计查询 Query query=Query.query(Criteria.where("likeNum").gte(2));  // 拿到查询器 Query query1=new Query(); Long count1=commentService.commentCount(query);  // 查符合条件的文档个数 Long count2=commentService.commentCount(query1);  // 查全部 System.out.println("点赞数大于等于2的文档有======="+count1); System.out.println("统计总数======="+count2); } }