SpringBoot整合MongoDB的步驟詳解
項目結構:
1.pom引入mongodb依賴
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongodb</artifactId> </dependency>
2 配置application.properties
#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
3.創建mongodb文檔映射實體類
@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方法 }
SpringBoot中MongoDB常用註解:
- @Document
標註在實體類上,將java類聲明為mongodb的文檔,可以通過collection參數指定這個類對應的文檔。類似於Hibernate的entity註解,表明由mongo來維護該集合(表)。
- @id
主鍵,不可重復,自帶索引,可以在定義的列名上標註,需要自己生成並維護不重復的約束。
如果自己不設置@Id主鍵,mongo會自動生成一個唯一主鍵,插入效率遠高於自己設置主鍵。
在實際業務中不建議自己設置主鍵,應交給mongo自己生成,可以另外設置一個業務id,如int型字段,用自己設置的業務id來維護相關聯的集合(表)。
- @Indexed
聲明該字段需要加索引,加索引後以該字段為條件檢索將大大提高速度。
唯一索引的話是@Indexed(unique = true)。
也可以對數組進行索引,如果被索引的列是數組時,MongoDB會索引這個數組中的每一個元素。
也可以對整個Document進行索引,排序是預定義的按插入BSON數據的先後升序排列。
- @CompoundIndex
復合索引,加復合索引後通過復合索引字段查詢將大大提高速度。
- @Field
實體類屬性對應集合(表)字段名,如果一致,無須該註解
4.service業務層
CommonService,操作mongo的具體業務類
采用Repository和MongoTemplate兩種方式來實現的;Repository 提供最基本的數據訪問功能,其幾個子接口則擴展瞭一些功能。
MongoTemplate核心操作類:Criteria和Query
- Criteria類:封裝所有的語句,以方法的形式查詢。
- Query類:將語句進行封裝或者添加排序之類的操作。
@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<Comment> list){ commentRepository.saveAll(list); // mongoTemplate.insertAll(list); } // 更新一個 public void updateComment(Comment comment){ commentRepository.save(comment); } // 查詢全部 public List<Comment> findCommentAll(){ // return commentRepository.findAll(); return mongoTemplate.findAll(Comment.class); } // 條件查詢 public List<Comment> findCommentByContion(Query query){ return mongoTemplate.find(query,Comment.class); } // 查詢全部並以id排序返回結果 public List<Comment> 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<Comment> findByparentIdPage1(String parentId, int page,int size){ return commentRepository.findByParentId(parentId, PageRequest.of(page-1,size)); } // 方式二 public List<Comment> 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<Comment> 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); } }
5.DAO層
dao層CommentRepository 繼承MongoRepository,MongoRepository中已經預定義瞭一些增刪查的方法,根據JPA的命名規范可以定義一些查詢方法,不需要具體實現,底層會幫你實現。
public interface CommentRepository extends MongoRepository<Comment,String> { //新增按父id分頁查詢 Page<Comment> findByParentId(String parentId,Pageable pageable); }
6.測試
@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<Comment> 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<Comment> list=commentService.findCommentAll(); for(Comment comment:list){ System.out.println(comment); } } @Test public void findCommentListOrderTest() { // 查全部並通對id排序 List<Comment> 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<Comment> 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<Comment> 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<Comment> 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<String> list=new ArrayList<>(); list.add("1"); list.add("2"); list.add("3"); // 根據范圍拿到查詢對象 Query query=Query.query(Criteria.where("_id").in(list)); // 根據查詢條件拿到結果 List<Comment> 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<Comment> 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<Comment> 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<Comment> 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); } }
到此已經在SpringBoot項目中引入瞭MongoDB,並通過MongoRepository和MongoTemplate兩種方式來實現瞭基本的增刪改查操。
以上就是SpringBoot整合MongoDB的步驟詳解的詳細內容,更多關於SpringBoot整合MongoDB的資料請關註WalkonNet其它相關文章!
推薦閱讀:
- SpringBoot整合Mongodb實現增刪查改的方法
- SpringBoot整合MongoDB的實現步驟
- SpringBoot輕松整合MongoDB的全過程記錄
- springboot整合mongodb並實現crud步驟詳解
- Spring Boot中快速操作Mongodb數據庫指南