您的位置: 首页  >  文章  >  MongoDB整合Spring 详细讲解(含代码)

MongoDB整合Spring 详细讲解(含代码)

分类: 文章 • 2024-07-04 16:16:10

写这篇文章也做了下思考，首先是本人技术欠佳。但就是喜欢研究一些东西。因为在此之前有很多的朋友已经写过类似的，很多我也看过，但是讲解的不够深入。对有些朋友提出的问题不能给出答案。在这里，我根据我目前的能力对其进行整理。并最终运行成功。

在测试过程中出现过一下问题：

1、org/springframework/data/mapping/context/MappingContextAware

2、src-resolve: Cannot resolve the name 'repository:repository' to a(n) 'type definition'

以上都是版本不匹配引起的。特别是第二个错误我看有些解决时候提到了jpa，但是我这里没有使用jpa后来我是把spring-data-commons的包替换了个版本就不出现了。

我先说下我的开发环境：

myeclipse 6.5

mongodb 2.0.8

spring 3.0.4

最后就是下面2个(这两个版本不对就容易出现各种各样的，杂七杂八的问题) 这里我就给出我所采用的版本

spring-data-document

spring-data-commons

有所改变所有版本必须要对应好下面是jar下载地址
http://www.springsource.org/spring-data/mongodb
http://www.springsource.org/spring-data/commons

下载版本分别为：

spring-data-commons-dist-1.4.0.M1

spring-data-document-1.0.0.M2.zip
下面给出我工程的图片

MongoDB整合Spring 详细讲解(含代码)

然后就开始我们开发之旅吧!

首先新建application.xml配置文件

[html]view plaincopyMongoDB整合Spring 详细讲解(含代码)MongoDB整合Spring 详细讲解(含代码)
  1. <spanstyle="font-size:18px;color:#3366ff;"><?xmlversion="1.0"encoding="UTF-8"?>
  2. <beansxmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:context="http://www.springframework.org/schema/context"
  5. xmlns:mongo="http://www.springframework.org/schema/data/mongo"
  6. xsi:schemaLocation="http://www.springframework.org/schema/context
  7. http://www.springframework.org/schema/context/spring-context-3.0.xsd
  8. http://www.springframework.org/schema/data/mongo
  9. http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd
  10. http://www.springframework.org/schema/beans
  11. http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
  13. <mongo:mongohost="192.168.0.138"port="27017"/>
  17. <beanid="mongoTemplate"class="org.springframework.data.document.mongodb.MongoTemplate">
  18. <constructor-argref="mongo"/>
  19. <constructor-argname="databaseName"value="db"/>
  20. <constructor-argname="defaultCollectionName"value="person"/>
  21. </bean>
  23. <beanid="personRepository"class="com.mongo.dao.impl.PersonRepository">
  24. <propertyname="mongoTemplate"ref="mongoTemplate"></property>
  25. </bean>
  27. <context:annotation-config/>
  29. </beans>
  30. </span>


然后编写操作mongodb的接口

[java]view plaincopyMongoDB整合Spring 详细讲解(含代码)MongoDB整合Spring 详细讲解(含代码)
  1. <spanstyle="font-size:18px;color:#3366ff;">/**
  2. *AbstractRepository.java
  3. *版权所有(C)2012
  4. *创建:cuiran2012-12-1211:40:40
  5. */
  6. packagecom.mongo.dao;
  8. importjava.util.List;
  10. importcom.mongo.bean.Person;
  12. /**
  13. *TODO
  14. *@authorcuiran
  15. *@versionTODO
  16. */
  17. publicinterfaceAbstractRepository{
  19. /**
  20. *
  21. *<b>function:</b>添加对象
  22. *@authorcuiran
  23. *@createDate2012-12-1211:41:30
  24. */
  25. publicvoidinsert(Personperson);
  27. /**
  28. *
  29. *<b>function:</b>根据ID查找对象
  30. *@authorcuiran
  31. *@createDate2012-12-1211:41:41
  32. */
  33. publicPersonfindOne(Stringid);
  34. /**
  35. *
  36. *<b>function:</b>查询所有
  37. *@authorcuiran
  38. *@createDate2012-12-1216:26:06
  39. */
  40. publicList<Person>findAll();
  42. publicList<Person>findByRegex(Stringregex);
  43. /**
  44. *
  45. *<b>function:</b>删除指定的ID对象
  46. *@authorcuiran
  47. *@createDate2012-12-1216:26:16
  48. */
  49. publicvoidremoveOne(Stringid);
  50. /**
  51. *
  52. *<b>function:</b>删除所有
  53. *@authorcuiran
  54. *@createDate2012-12-1216:25:40
  55. */
  56. publicvoidremoveAll();
  57. /**
  58. *通过ID找到并修改
  59. *<b>function:</b>
  60. *@authorcuiran
  61. *@createDate2012-12-1216:25:51
  62. */
  63. publicvoidfindAndModify(Stringid);
  66. }
  67. </span>


再写对应接口的实现类：

[java]view plaincopyMongoDB整合Spring 详细讲解(含代码)MongoDB整合Spring 详细讲解(含代码)
  1. <spanstyle="font-size:18px;color:#3366ff;">/**
  2. *PersonRepository.java
  3. *版权所有(C)2012
  4. *创建:cuiran2012-12-1211:42:51
  5. */
  6. packagecom.mongo.dao.impl;
  8. importjava.util.List;
  9. importjava.util.regex.Pattern;
  11. importorg.springframework.data.document.mongodb.MongoTemplate;
  12. importorg.springframework.data.document.mongodb.query.Criteria;
  13. importorg.springframework.data.document.mongodb.query.Query;
  14. importorg.springframework.data.document.mongodb.query.Update;
  15. importcom.mongo.bean.Person;
  16. importcom.mongo.dao.AbstractRepository;
  18. /**
  19. *TODO
  20. *@authorcuiran
  21. *@versionTODO
  22. */
  23. publicclassPersonRepositoryimplementsAbstractRepository{
  25. privateMongoTemplatemongoTemplate;
  27. /*(non-Javadoc)
  28. *@seecom.mongo.dao.AbstractRepository#findAll()
  29. */
  30. @Override
  31. publicList<Person>findAll(){
  32. //TODOAuto-generatedmethodstub
  33. returngetMongoTemplate().find(newQuery(),Person.class);
  35. }
  37. /*(non-Javadoc)
  38. *@seecom.mongo.dao.AbstractRepository#findAndModify(java.lang.String)
  39. */
  40. @Override
  41. publicvoidfindAndModify(Stringid){
  42. //TODOAuto-generatedmethodstub
  43. //newQuery(Criteria.where("id").is(id)),newUpdate().inc("age",3)
  45. getMongoTemplate().updateFirst(newQuery(Criteria.where("id").is(id)),newUpdate().inc("age",3));
  47. }
  49. /*(non-Javadoc)
  50. *@seecom.mongo.dao.AbstractRepository#findByRegex(java.lang.String)
  51. */
  52. @Override
  53. publicList<Person>findByRegex(Stringregex){
  54. //TODOAuto-generatedmethodstub
  55. Patternpattern=Pattern.compile(regex,Pattern.CASE_INSENSITIVE);
  56. Criteriacriteria=newCriteria("name").regex(pattern.toString());
  57. returngetMongoTemplate().find(newQuery(criteria),Person.class);
  59. }
  61. /*(non-Javadoc)
  62. *@seecom.mongo.dao.AbstractRepository#findOne(java.lang.String)
  63. */
  64. @Override
  65. publicPersonfindOne(Stringid){
  66. //TODOAuto-generatedmethodstub
  67. returngetMongoTemplate().findOne(newQuery(Criteria.where("id").is(id)),Person.class);
  69. }
  71. /*(non-Javadoc)
  72. *@seecom.mongo.dao.AbstractRepository#insert(com.mongo.bean.Person)
  73. */
  74. @Override
  75. publicvoidinsert(Personperson){
  76. //TODOAuto-generatedmethodstub
  77. getMongoTemplate().insert(person);
  78. }
  80. /*(non-Javadoc)
  81. *@seecom.mongo.dao.AbstractRepository#removeAll()
  82. */
  83. @Override
  84. publicvoidremoveAll(){
  85. //TODOAuto-generatedmethodstub
  86. List<Person>list=this.findAll();
  87. if(list!=null){
  88. for(Personperson:list){
  89. getMongoTemplate().remove(person);
  90. }
  91. }
  93. }
  95. /*(non-Javadoc)
  96. *@seecom.mongo.dao.AbstractRepository#removeOne(java.lang.String)
  97. */
  98. @Override
  99. publicvoidremoveOne(Stringid){
  100. //TODOAuto-generatedmethodstub
  101. Criteriacriteria=Criteria.where("id").in(id);
  102. if(criteria==null){
  103. Queryquery=newQuery(criteria);
  104. if(query!=null&&getMongoTemplate().findOne(query,Person.class)!=null)
  105. getMongoTemplate().remove(getMongoTemplate().findOne(query,Person.class));
  106. }
  108. }
  110. /**
  111. *@returnthemongoTemplate
  112. */
  113. publicMongoTemplategetMongoTemplate(){
  114. returnmongoTemplate;
  115. }
  117. /**
  118. *@parammongoTemplatethemongoTemplatetoset
  119. */
  120. publicvoidsetMongoTemplate(MongoTemplatemongoTemplate){
  121. this.mongoTemplate=mongoTemplate;
  122. }
  124. }
  125. </span>

这里也给出对应Person对象代码

[java]view plaincopyMongoDB整合Spring 详细讲解(含代码)MongoDB整合Spring 详细讲解(含代码)
  1. <spanstyle="font-size:18px;color:#3366ff;">/**
  2. *Person.java
  3. *版权所有(C)2012
  4. *创建:cuiran2012-12-1211:37:16
  5. */
  6. packagecom.mongo.bean;
  8. importjava.io.Serializable;
  10. /**
  11. *TODO
  12. *@authorcuiran
  13. *@versionTODO
  14. */
  15. publicclassPersonimplementsSerializable{
  17. /**
  18. *
  19. */
  20. privatestaticfinallongserialVersionUID=3617931430808763429L;
  22. privateStringid;
  23. privateStringname;
  24. privateintage;
  25. publicPerson(){
  26. super();
  27. }
  28. publicPerson(Stringid,Stringname,intage){
  29. super();
  30. this.id=id;
  31. this.name=name;
  32. this.age=age;
  33. }
  34. /**
  35. *@returntheid
  36. */
  37. publicStringgetId(){
  38. returnid;
  39. }
  40. /**
  41. *@paramidtheidtoset
  42. */
  43. publicvoidsetId(Stringid){
  44. this.id=id;
  45. }
  46. /**
  47. *@returnthename
  48. */
  49. publicStringgetName(){
  50. returnname;
  51. }
  52. /**
  53. *@paramnamethenametoset
  54. */
  55. publicvoidsetName(Stringname){
  56. this.name=name;
  57. }
  58. /**
  59. *@returntheage
  60. */
  61. publicintgetAge(){
  62. returnage;
  63. }
  64. /**
  65. *@paramagetheagetoset
  66. */
  67. publicvoidsetAge(intage){
  68. this.age=age;
  69. }
  70. /**
  71. *
  72. *@paramname
  73. *@paramage
  74. */
  75. publicPerson(Stringname,intage){
  76. super();
  77. this.name=name;
  78. this.age=age;
  79. }
  81. publicStringtoString(){
  82. return"Person[id="+id+",name="+name+",age="+age+"]";
  83. }
  86. }
  87. </span>

最后写出我们的测试类开始进行测试

[java]view plaincopyMongoDB整合Spring 详细讲解(含代码)MongoDB整合Spring 详细讲解(含代码)
  1. <spanstyle="font-size:18px;color:#3366ff;">/**
  2. *MongoTest.java
  3. *版权所有(C)2012
  4. *创建:cuiran2012-12-1211:54:30
  5. */
  6. packagecom.mongo.test;
  8. importjava.util.List;
  10. importorg.apache.commons.logging.Log;
  11. importorg.apache.commons.logging.LogFactory;
  12. importorg.springframework.context.ApplicationContext;
  13. importorg.springframework.context.support.ClassPathXmlApplicationContext;
  15. importcom.mongo.bean.Person;
  16. importcom.mongo.dao.AbstractRepository;
  17. importcom.mongo.dao.impl.PersonRepository;
  21. /**
  22. *TODO
  23. *@authorcuiran
  24. *@versionTODO
  25. */
  26. publicclassMongoTest{
  28. privatestaticLoglog=LogFactory.getLog(MongoTest.class.getName());
  30. privateAbstractRepositorypr=null;
  32. /**
  33. *
  34. *<b>function:</b>
  35. *@authorcuiran
  36. *@createDate2012-12-1216:08:02
  37. */
  38. publicvoidinit(){
  39. log.debug("开始启动");
  40. ApplicationContextctx=newClassPathXmlApplicationContext("applicationContext.xml");
  41. pr=(PersonRepository)ctx.getBean("personRepository");
  45. }
  46. /**
  47. *
  48. *<b>function:</b>添加
  49. *@authorcuiran
  50. *@createDate2012-12-1216:11:01
  51. */
  52. publicvoidinsert(){
  54. Personp=newPerson("cuiran",27);
  55. pr.insert(p);
  56. log.debug("添加成功");
  57. }
  58. /**
  59. *
  60. *<b>function:</b>根据输入的ID查找对象
  61. *@authorcuiran
  62. *@createDate2012-12-1216:24:10
  63. */
  64. publicvoidfindOne(){
  65. Stringid="50c83cb552c2ceb0463177d6";
  66. Personp=pr.findOne(id);
  67. log.debug(p);
  68. }
  71. /**
  72. *
  73. *<b>function:</b>查询所有
  74. *@authorcuiran
  75. *@createDate2012-12-1216:08:54
  76. */
  77. publicvoidlistAll(){
  79. List<Person>list=pr.findAll();
  80. log.debug("查询结果如下:");
  81. for(Personp:list){
  82. log.debug(p.toString());
  83. }
  86. }
  88. /**
  89. *
  90. *<b>function:</b>测试方法
  91. *@authorcuiran
  92. *@createDate2012-12-1216:11:37
  93. */
  94. publicvoidstart(){
  95. init();
  97. //insert();
  98. //listAll();
  100. findOne();
  101. }
  103. /**
  104. *<b>function:</b>main函数
  105. *@authorcuiran
  106. *@createDate2012-12-1211:54:30
  107. */
  108. publicstaticvoidmain(String[]args){
  109. //TODOAuto-generatedmethodstub
  110. MongoTestt=newMongoTest();
  111. t.start();
  112. }
  114. }
  115. </span>


运行出现一下日志，就没什么问题。

[java]view plaincopyMongoDB整合Spring 详细讲解(含代码)MongoDB整合Spring 详细讲解(含代码)
  1. <spanstyle="font-size:18px;color:#3366ff;">2012-12-1216:23:59:DEBUGcom.mongo.test.MongoTest-开始启动
  2. 2012-12-1216:23:59:INFOorg.springframework.context.support.ClassPathXmlApplicationContext-Refreshingorg.springframework.context.support.ClassPathXmlApplicationContext@253498:startupdate[WedDec1216:23:59CST2012];rootofcontexthierarchy
  3. 2012-12-1216:23:59:INFOorg.springframework.beans.factory.xml.XmlBeanDefinitionReader-LoadingXMLbeandefinitionsfromclasspathresource[applicationContext.xml]
  4. 2012-12-1216:24:00:INFOorg.springframework.beans.factory.support.DefaultListableBeanFactory-Pre-instantiatingsingletonsinorg.springframework.beans.factory.support.DefaultListableBeanFactory@12a0f6c:definingbeans[mongo,mongoTemplate,personRepository,org.springframework.context.annotation.internalConfigurationAnnotationProcessor,org.springframework.context.annotation.internalAutowiredAnnotationProcessor,org.springframework.context.annotation.internalRequiredAnnotationProcessor,org.springframework.context.annotation.internalCommonAnnotationProcessor];rootoffactoryhierarchy
  5. 2012-12-1216:24:00:DEBUGcom.mongo.test.MongoTest-Person[id=50c83cb552c2ceb0463177d6,name=cuiran,age=27]
  6. </span>


由于这些程序只是作为测试使用，对出现的问题， 欢迎留言咨询。谢谢大家。

在此附上demo源码欢迎朋友下载学习

百度网盘：http://pan.baidu.com/s/188Lnr

相关推荐