mongodb集成spring

1：首先需要下载mongodb的java驱动包

https://github.com/mongodb/mongo-java-driver/downloads

2：需要下载spring集成mongodb的包

下载途径：

a:去csdn下

b：去http://projects.spring.io/spring-data-mongodb/ 使用Maven方式下载

c：网上其他地方找

要下载的包如下

spring-data-commons-core-1.2.0.M2.jar

spring-data-mongodb-1.0.0.M4.jar

spring-data-mongodb-cross-store-1.0.0.M4.jar

spring-data-mongodb-log4j-1.0.0.M4.jar

为什么选择很老的1.0.0版本，是因为我的spring框架是3.0.5的，不知道是不是spring版本低了的原因，选择高点的如1.4.0反正会报错

3：ok  包包都⑦了，开始编码了，先说说配置文件

web.xml

[html] view plaincopy

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
  5. http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
  6. <!-- spring配置文件目录-->
  7. <context-param>
  8. <param-name>contextConfigLocation</param-name>
  9. <param-value>classpath:spring/*.xml</param-value>
  10. </context-param>
  11. <listener>
  12. <listener-class>
  13. org.springframework.web.context.ContextLoaderListener
  14. </listener-class>
  15. </listener>
  16. </web-app>

application-global.xml

[html] view plaincopy

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:aop="http://www.springframework.org/schema/aop"
  5. xmlns:context="http://www.springframework.org/schema/context"
  6. xmlns:mvc="http://www.springframework.org/schema/mvc"
  7. xmlns:mongo="http://www.springframework.org/schema/data/mongo"
  8. xsi:schemaLocation="http://www.springframework.org/schema/beans
  9. http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
  10. http://www.springframework.org/schema/aop
  11. http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
  12. http://www.springframework.org/schema/context
  13. http://www.springframework.org/schema/context/spring-context-3.0.xsd
  14. http://www.springframework.org/schema/mvc
  15. http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd
  16. http://www.springframework.org/schema/data/mongo
  17. http://www.springframework.org/schema/data/mongo/spring-mongo.xsd">
  18. <!-- 获取配置文件属性 -->
  19. <bean id="placeholderConfig"
  20. class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
  21. <property name="location">
  22. <value>classpath:db.properties</value>
  23. </property>
  24. </bean>
  25. <!-- Default bean name is ‘mongo‘ -->
  26. <!-- 连接池配置详细查看http://api.mongodb.org/java/2.7.2/com/mongodb/MongoOptions.html#connectionsPerHost
  27. 或者http://www.cnblogs.com/huangfox/archive/2012/04/01/2428947.html
  28. -->
  29. <mongo:mongo host="${datasource.host}" port="${datasource.port}">
  30. <mongo:options connections-per-host="10"
  31. threads-allowed-to-block-for-connection-multiplier="10"
  32. auto-connect-retry="true" />
  33. </mongo:mongo>
  34. <!-- Spring提供的mongodb操作模板-->
  35. <bean id="mongoTemplate"
  36. class="org.springframework.data.mongodb.core.MongoTemplate">
  37. <constructor-arg ref="mongo" />
  38. <constructor-arg name="databaseName" value="${datasource.dbname}" />
  39. </bean>

</beans>

[html] view plaincopy

  1. <strong><span style="color:#ff0000;">db.properties</span></strong>

#datasource.host=localhost
datasource.host=12.35.174.48
#datasource.port=27017
datasource.port=9933
datasource.dbname=logDB

datasource.username=test
datasource.passwd=test

4：spring的db操作模板MongoTemplate

具体使用参考百度或者官网http://docs.spring.io/spring-data/data-mongodb/docs/current/api/org/springframework/data/mongodb/core/MongoTemplate.html#getDb()

程序启动时，注入MongoTemplate模板

[java] view plaincopy

  1. package dao.impl;
  2. import org.springframework.beans.BeansException;
  3. import org.springframework.context.ApplicationContext;
  4. import org.springframework.context.ApplicationContextAware;
  5. import org.springframework.data.mongodb.core.MongoTemplate;
  6. import com.mongodb.DB;
  7. public class AbstractBaseMongoTemplete  implements ApplicationContextAware {
  8. protected MongoTemplate mongoTemplate;
  9. protected DB db;
  10. /**
  11. * 设置mongoTemplate
  12. * @param mongoTemplate the mongoTemplate to set
  13. */
  14. public void setMongoTemplate(MongoTemplate mongoTemplate) {
  15. this.mongoTemplate = mongoTemplate;
  16. }
  17. public void setApplicationContext(ApplicationContext applicationContext)
  18. throws BeansException {
  19. //System.out.println("ApplicationContextAware开始执行setApplicationContext方法");
  20. MongoTemplate mongoTemplate = applicationContext.getBean("mongoTemplate", MongoTemplate.class);
  21. setMongoTemplate(mongoTemplate);
  22. db=mongoTemplate.getDb();
  23. }
  24. }

[java] view plaincopy

[java] view plaincopy

5：具体操作类接口

[java] view plaincopy

  1. public interface  IDbDao {
  2. /**
  3. * 插入单个
  4. * @param obj
  5. * @return
  6. */
  7. public abstract DBObject insert(DBObject obj);
  8. /**
  9. * 插入json格式字符串
  10. * @param jsonStr
  11. * @return
  12. */
  13. public abstract WriteResult insert(String jsonStr);
  14. /**
  15. * 批量插入
  16. * @param list
  17. */
  18. public abstract void insertBatch(List<DBObject> list);
  19. /**
  20. * 插入json文件
  21. * @param list
  22. */
  23. public abstract void insertFile(String fileName);
  24. /**
  25. * 删除单个
  26. * @param obj
  27. */
  28. public abstract void delete(DBObject obj);
  29. /**
  30. * 批量删除
  31. * @param list
  32. */
  33. public abstract void deleteBatch(List<DBObject> list);
  34. /**
  35. * 修改
  36. * @param searchFields  要修改的查询条件
  37. * @param updateFields  修改的值
  38. */
  39. public abstract void update(DBObject searchFields,DBObject updateFields);
  40. /**
  41. * 按条件查询
  42. * @return
  43. */
  44. public abstract List<BasicDBObject> find();
  45. /**
  46. * 按条件查询
  47. * @param query 查询条件
  48. * @return
  49. */
  50. public abstract List<BasicDBObject> find(DBObject query);
  51. /**
  52. * 排序查询
  53. * @param query
  54. * @param sort   new BasicDBObject("age", true)   则对age字段降序  注意1是升序，－1是降序
  55. * @param _class  要返回的实体bean类型
  56. * @return
  57. */
  58. public abstract List<BasicDBObject> find(DBObject query,DBObject sort);
  59. /**
  60. * 分页查询
  61. * @param query 查询条件
  62. * @param start 起始
  63. * @param limit 每页多少数据
  64. * @return
  65. */
  66. public abstract List<BasicDBObject> find(DBObject query,int start,int limit);
  67. /**
  68. * 分页查询
  69. * @param query 查询条件
  70. * @param sort  排序
  71. * @param start 起始
  72. * @param limit 每页多少数据
  73. * @return
  74. */
  75. public abstract List<BasicDBObject> find(DBObject query,DBObject sort,int start,int limit);
  76. /**
  77. * 按条件查询
  78. * @param _class  要返回的实体bean类型
  79. * @return
  80. */
  81. public abstract List<Object> find(Class _class);
  82. /**
  83. * 按条件查询
  84. * @param query 查询条件
  85. * @param _class  要返回的实体bean类型
  86. * @return
  87. */
  88. public abstract List<Object> find(DBObject query,Class _class);
  89. /**
  90. * 排序查询
  91. * @param query 查询条件
  92. * @param sort   new BasicDBObject("age", true)   则对age字段降序  注意1是升序，－1是降序
  93. * @param _class  要返回的实体bean类型
  94. * @return
  95. */
  96. public abstract List<Object> find(DBObject query,DBObject sort,Class _class);
  97. /**
  98. * 分页查询
  99. * @param query 查询条件
  100. * @param start 起始
  101. * @param limit 每页多少数据
  102. * @param _class  要返回的实体bean类型
  103. * @return
  104. */
  105. public abstract List<Object> find(DBObject query,int start,int limit,Class _class);
  106. /**
  107. * 分页查询
  108. * @param query 查询条件
  109. * @param sort  排序
  110. * @param start 起始
  111. * @param limit 每页多少数据
  112. * @param _class  要返回的实体bean类型
  113. * @return
  114. */
  115. public abstract List<Object> find(DBObject query,DBObject sort,int start,int limit,Class _class);
  116. /**
  117. * 按条件查询，返回查询个数
  118. * @param query 查询条件
  119. * @return
  120. */
  121. public abstract int findCount(DBObject query);
  122. /**
  123. * 排序查询，返回查询个数
  124. * @param query
  125. * @param sort   new BasicDBObject("age", true)   则对age字段降序  注意1是升序，－1是降序
  126. * @param _class  要返回的实体bean类型
  127. * @return
  128. */
  129. public abstract int findCount(DBObject query,DBObject sort);
  130. /**
  131. * 获取总数
  132. * @param obj
  133. * @return
  134. */
  135. public abstract long getCount(DBObject obj);
  136. /**
  137. * 获取总数
  138. * @param obj
  139. * @return
  140. */
  141. public abstract long getCount();
  142. /**
  143. * 利用java驱动自带函数分组查询
  144. * @param key 用来分组文档的字段
  145. * @param cond 执行过滤的条件
  146. * @param initial reduce中使用变量的初始化
  147. * @param reduce reduce（参数：当前文档和累加器文档.）
  148. * @param fn
  149. * @return
  150. */
  151. public abstract DBObject group(DBObject key,DBObject cond,DBObject initial,String reduce,String fn );
  152. /**
  153. * 使用聚合框架（参考http://docs.mongodb.org/manual/reference/sql-aggregation-comparison/）
  154. * @param firstDb
  155. * @param optionDb
  156. * @return
  157. */
  158. public abstract AggregationOutput  aggregation(DBObject firstDb,DBObject ...optionDb);
  159. public abstract DBCollection getCollection();
  160. /**
  161. * 创建索引
  162. * @param obj  new BasicDBObject("name", 1)); // 1代表升序 -1代表降序
  163. */
时间： 2024-10-08 06:42:42

mongodb集成spring的相关文章

06_在web项目中集成Spring

在web项目中集成Spring 一.使用Servlet进行集成测试 1.直接在Servlet 加载Spring 配置文件 ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml"); HelloService helloService = (HelloService) applicationContext.getBean("helloS

Struts2集成Spring

转载请注明出处:jiq?钦's technical Blog 1 集成Struts: 给web工程集成Struts2比较简单,下载struts2,将所需的jar文件add进去,然后配置web.xml增加请求处理者配置: <?xml version="1.0" encoding="UTF-8"?> <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmln

apacheFtpServer集成spring由web容器控制启动和关闭

ApacheFtpServer是一个100%纯Java实现的FTP服务器,基于网络框架apache MINA实现,可支撑多并发用户.FtpServer可以独立运行作为一个Windows服务或Unix/Linux守护进程,或嵌入到Java应用程序,提供对内部集成spring应用程序支持.下面介绍apacheFtpServer与spring集成,交由spring控制ApacheFtpServer的启动与关闭. 1.      初始化创建MyFtpServer: import java.io.File

mybatis集成spring的事务管理

第一 创建一个测试实体 1 public class Order { 2 3 private int id; 4 private String orderName; 5 6 public Order(String orderName) { 7 this.orderName = orderName; 8 } 9 10 public int getId() { 11 return id; 12 } 13 public void setId(int id) { 14 this.id = id; 15

Spring学习（一）tomcat加载web.xml、以及项目集成Spring支持

tomcat容器加载web.xml 一. 1 .启动一个 WEB 项目的时候, WEB 容器会去读取它的配置文件 web.xml ,读取 <listener> 和 <context-param> 两个结点. 2 .紧急着,容创建一个 ServletContext ( servlet 上下文),这个 web 项目的所有部分都将共享这个上下文. 3 .容器将 <context-param> 转换为键值对,并交给 servletContext . 4 .容器创建 <li

Hibernate 检索查询的几种方式（HQL，QBC，本地SQL，集成Spring等）

1.非集成Spring hibernate的检索方式,主要有以下五种. 1.导航对象图检索方式.(根据已经加载的对象,导航到其他对象.) 2.OID检索方式.(按照对象的OID来检索对象.) 3.HQL检索方式.(使用面向对象的HQL查询语言.) 4.QBC检索方式.(使用QBC(Qurey By Criteria) API来检索对象.) 5.本地SQL检索方式.(使用本地数据库的SQL查询语句.) 1.导航对象图检索方式 利用类与类之间的关系来检索对象.譬如我们要查找一份订单,就可以由订单对象

MyBatis6：MyBatis集成Spring事物管理（下篇）

前言 前一篇文章<MyBatis5:MyBatis集成Spring事物管理(上篇)>复习了MyBatis的基本使用以及使用Spring管理MyBatis的事物的做法,本文的目的是在这个的基础上稍微做一点点的进阶:多数据的事物处理.文章内容主要包含两方面: 1.单表多数据的事物处理 2.多库/多表多数据的事物处理 这两种都是企业级开发中常见的需求,有一定的类似,在处理的方法与技巧上又各有不同,在进入文章前,先做一些准备工作,因为后面会用到多表的插入事物管理,前面的文章建立了一个Student相关

jersey 集成spring，并使用grizzly内置容器测试jersey

jersey集成spring相对来说比较简单,需要注意的几点是: 1.引入maven依赖jersey-spring,其中包含了spring的相关依赖,如果和项目中所使用的spring版本相冲突,可以通过exclusions清除掉. 2.确保jersey资源类所在的包路径,能被spring扫描到,即spring配置中的<context:component-scan base-package="" />. 3.确保jersey资源类打上注解@Component,这样可以注入sp

Hazelcast与MongoDB集成

Hazelcast与MongoDB集成 作者:chszs,未经博主允许不得转载.经许可的转载需注明作者和博客主页:http://blog.csdn.net/chszs 一.Hazelcast与MongoDB Hazelcast的分布式数据结构和计算性能使得它可以作为应用程序后端的"MongoDB". MongoDB是一个开源的.面向文档的数据库,其扩展性和灵活性都非常好.MongoDB不是把数据存入(关系数据库的)表和行,而类似于JSON文档的方式和是以动态模式进行存储.简而言之,Mo