详解MongoDB和Spring整合的实例代码

MongoDB现在用的非常非常多，如何和Spring整合也是经常碰到的问题。

Spring提供了MongoTemplate这样一个模板类的实现方法，简化了具体操作。

下面讲一下具体实现：

添加依赖

org.springframework.data
spring-data-mongodb
1.10.3.RELEASE

其余Spring相关的忽略

Spring的配置applicationContext-mongo.xml

mongo:mongo-client是定义MongoDB的客户端连接，需要host和port参数，如果需要账号密码的话，需要增加credentials配置

mongo:db-factory配置连接工厂，指定具体的连接数据库，本例默认为test

defaultMongoTypeMapper默认Mongodb类型映射

mongo:mapping-converterMongoDB的实体映射

mongoTemplate这是最主要的，定义模板类，依赖连接工厂和实体映射

这里举一个article的增删改查的例子。

相关实体Article.java

@Document(collection="article_info")
publicclassArticle{
@Id
privateStringid;//id
@Field("title")
privateStringtitle;//标题
@Field("url")
privateStringurl;//链接
@Field("author")
privateStringauthor;//作者
@Field("tags")
privateListtags;//tag标签
@Field("visit_count")
privateLongvisitCount;//访问次数
@Field("add_time")
privateDateaddTime;//添加时间
//getset方法省略

@Document(collection="article_info")这个注解和Hibernate的注解Entiry非常相似，就是定义一个文档，对象MongoDB存储的Collection的名称是article_info

@Id指该字段是主键，不能缺少

@Field("add_time")指该字段映射MongoDB的实际字段，如果一致可以省略

ArticleRepository实际访问接口

@Repository("ArticleRepository")
publicinterfaceArticleRepositoryextendsPagingAndSortingRepository{

//分页查询
publicPage
findAll(Pageablepageable);


//根据author查询
publicList
findByAuthor(Stringauthor);

//根据作者和标题查询
publicList
findByAuthorAndTitle(Stringauthor,Stringtitle);

//忽略参数大小写
publicList
findByAuthorIgnoreCase(Stringauthor);

//忽略所有参数大小写
publicList
findByAuthorAndTitleAllIgnoreCase(Stringauthor,Stringtitle);

//排序
publicList
findByAuthorOrderByVisitCountDesc(Stringauthor);
publicList
findByAuthorOrderByVisitCountAsc(Stringauthor);

//自带排序条件
publicList
findByAuthor(Stringauthor,Sortsort);

}

Spring的datarepository封装了一套增删改查的方法，就和JPA实现的一样，ArticleRepository继承PagingAndSortingRepository，就集成了常用的增删改查方法，比如save、findOne、exists、findAll、delete等等，可以采用默认实现方式来完成常用的增删改查操作。

测试上述各个方法ArticleRepositoryTest.java

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations={"classpath*:applicationContext-mongo.xml"})
publicclassArticleRepositoryTest{

@Autowired
privateArticleRepositoryarticleRepository;

/**
*新增记录
*/
@Test
publicvoidadd(){
//增加一条记录
Articlearticle=newArticle();
article.setId("1");
article.setTitle("MongoTemplate的基本使用");
article.setAuthor("kcy");
article.setUrl("http://jianshu.com/");
article.setTags(Arrays.asList("java","mongodb","spring"));
article.setVisitCount(0L);
article.setAddTime(newDate());
articleRepository.save(article);

//批量添加
List
articles=newArrayList<>(10);
for(inti=0;i<10;i++){
Articlearticle2=newArticle();
article2.setId(String.valueOf(i+1));
article2.setTitle("MongoTemplate的基本使用");
article2.setAuthor("kcy");
article2.setUrl("http://jianshu.com"+i);
article2.setTags(Arrays.asList("java","mongodb","spring"));
article2.setVisitCount(0L);
article2.setAddTime(newDate());
articles.add(article2);
}
articleRepository.save(articles);
}

/**
*修改记录，修改id为1的访问次数+1
*/
@Test
publicvoidupdate(){
Articlearticle=articleRepository.findOne("1");
article.setVisitCount(article.getVisitCount()+1);
articleRepository.save(article);
}

/**
*批量修改,查看author为kcy的统一修改为kcy2
*/
@Test
publicvoidbatchUpdate(){
List
articles=articleRepository.findByAuthor("kcy");
articles.forEach(article->{
article.setAuthor("kcy2");
});
articleRepository.save(articles);
}

/**
*删除记录,删除id为10的
*/
@Test
publicvoiddelete(){
Articlearticle=articleRepository.findOne("10");
articleRepository.delete(article);
}

@Test
publicvoidbatchDelete(){
List
articles=articleRepository.findByAuthor("kcy2");
articleRepository.delete(articles);
}

/**
*查询所有
*
*@author孔垂云
*/
@Test
publicvoidfindAll(){
Iterable
articles=articleRepository.findAll();
articles.forEach(article->{
System.out.println(article.toString());
});
}

/**
*根据author查询
*
*@author孔垂云
*/
@Test
publicvoidfindByAuthor(){
List
articles=articleRepository.findByAuthor("kcy");
articles.forEach(article->{
System.out.println(article.toString());
});
}

/**
*按照author和title查询
*
*@author孔垂云
*/
@Test
publicvoidfindByAuthorAndTitle(){
List
articles=articleRepository.findByAuthorAndTitle("kcy","MongoTemplate的基本使用");
articles.forEach(article->{
System.out.println(article.toString());
});
}

/**
*根据作者查询，忽略大小写
*
*@author孔垂云
*/
@Test
publicvoidfindByAuthorIgnoreCase(){
List
articles=articleRepository.findByAuthorIgnoreCase("JASON");
articles.forEach(article->{
System.out.println(article.getId());
});
}

/**
*忽略所有参数的大小写
*
*@author孔垂云
*/
@Test
publicvoidfindByAuthorAndTitleAllIgnoreCase(){
List
articles=articleRepository.findByAuthorAndTitleAllIgnoreCase("KCY","MONGOTEMPLATE的基本使用");
articles.forEach(article->{
System.out.println(article.toString());
});
}

/**
*根据author查询，并且以访问次数降序排序显示
*
*@author孔垂云
*/
@Test
publicvoidfindByAuthorOrderByVisitCountDesc(){
List
articles=articleRepository.findByAuthorOrderByVisitCountDesc("kcy");
articles.forEach(article->{
System.out.println(article.toString());
});
}


/**
*根据作者查询，并且以访问次数升序排序显示
*
*@author孔垂云
*/
@Test
publicvoidfindByAuthorOrderByVisitCountAsc(){
List
articles=articleRepository.findByAuthorOrderByVisitCountAsc("kcy");
articles.forEach(article->{
System.out.println(article.toString());
});
}

/**
*自带排序条件
*
*@author孔垂云
*/
@Test
publicvoidfindByAuthorBySort(){
List
articles=articleRepository.findByAuthor("kcy",newSort(Direction.ASC,"VisitCount"));
articles.forEach(article->{
System.out.println(article.toString());
});
}

/**
*分页查询所有，并且排序
*/
@Test
publicvoidfindByPage(){
intpage=1;
intsize=2;
Pageablepageable=newPageRequest(page,size,newSort(Direction.ASC,"VisitCount"));
Page
pageInfo=articleRepository.findAll(pageable);
//总数量
System.out.println(pageInfo.getTotalElements());
//总页数
System.out.println(pageInfo.getTotalPages());
for(Articlearticle:pageInfo.getContent()){
System.out.println(article.toString());
}
}
}

上面一段代码较长，基本上MongoDB常用的各种例子都讲清楚了，比如增加、批量增加、修改、删除、按id查找、按标题查询、分页等等。

源码下载

本工程详细源码

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。