如何优雅的进行Spring整合MongoDB详解
程序员文章站
2022-07-28 15:49:57
前言
本文重点是要将mongodb与spring整合到项目中去,在实践中发现问题,追踪问题,然后解决问题。下面话不多说了,来一起看看详细的介绍吧。
一、准备...
前言
本文重点是要将mongodb与spring整合到项目中去,在实践中发现问题,追踪问题,然后解决问题。下面话不多说了,来一起看看详细的介绍吧。
一、准备
- maven、spring(spring-data-mongodb)
- spring data for mongodb是spring data的一个子模块。 目标是为mongodb提供一个相近的一致的基于spring的编程模型。
- spring data for mongodb核心功能是映射pojo到mongo的dbcollection中的文档,并且提供repository 风格数据访问层。
二、特性
- mongodb的提供了一个面向文档存储,操作起来比较简单和容易。
- 你可以在mongodb记录中设置任何属性的索引 (如:firstname="ning",address="beijing")来实现更快的排序。
- 你可以通过本地或者网络创建数据镜像,这使得mongodb有更强的扩展性。
- 如果负载的增加(需要更多的存储空间和更强的处理能力) ,它可以分布在计算机网络中的其他节点上这就是所谓的分片。
- mongo支持丰富的查询表达式。查询指令使用json形式的标记,可轻易查询文档中内嵌的对象及数组。
- mongodb 使用update()命令可以实现替换完成的文档(数据)或者一些指定的数据字段 。
- mongodb中的map/reduce主要是用来对数据进行批量处理和聚合操作。
- map和reduce。map函数调用emit(key,value)遍历集合中所有的记录,将key与value传给reduce函数进行处理。
- map函数和reduce函数是使用javascript编写的,并可以通过db.runcommand或mapreduce命令来执行mapreduce操作。
- gridfs是mongodb中的一个内置功能,可以用于存放大量小文件。
- mongodb允许在服务端执行脚本,可以用javascript编写某个函数,直接在服务端执行,也可以把函数的定义存储在服务端,下次直接调用即可。
- mongodb支持各种编程语言:ruby,python,java,c++,php,c#等多种语言。
三、依赖包
<dependency> <groupid>org.springframework.data</groupid> <artifactid>spring-data-mongodb</artifactid> <version>1.5.0.release</version> </dependency> <dependency> <groupid>org.slf4j</groupid> <artifactid>slf4j-log4j12</artifactid> <version>1.5.10</version> </dependency>
spring 相关依赖
<!-- spring web相关依赖 --> <dependency> <groupid>org.springframework</groupid> <artifactid>spring-web</artifactid> <version>${spring.version}</version> </dependency> <dependency> <groupid>org.springframework</groupid> <artifactid>spring-webmvc</artifactid> <version>3.1.2.release</version> </dependency> <!-- spring test依赖 --> <dependency> <groupid>org.springframework</groupid> <artifactid>spring-test</artifactid> <version>4.3.1.release</version> </dependency>
四、集成mongodb
【注:mongodb添加权限管理请参见我的这篇文章:mongdb开启权限认证】
mongodb.properties
mongo.hostport=172.16.4.166:27017 mongo.dbname=ad_api_count mongo.username=hehaitao mongo.password=hehaitao mongo.connectionsperhost=8 mongo.threadsallowedtoblockforconnectionmultiplier=4 #\u8fde\u63a5\u8d85\u65f6\u65f6\u95f4 mongo.connecttimeout=1000 #\u7b49\u5f85\u65f6\u95f4 mongo.maxwaittime=1500 mongo.autoconnectretry=true mongo.socketkeepalive=true #socket\u8d85\u65f6\u65f6\u95f4 mongo.sockettimeout=1500 mongo.slaveok=true
mongodb.xml
<?xml version="1.0" encoding="utf-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/xmlschema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:mongo="http://www.springframework.org/schema/data/mongo" xsi:schemalocation="http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd http://www.springframework.org/schema/data/mongo http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd"> <!-- 加载mongodb的属性配置文件 --> <context:property-placeholder location="classpath:mongodb.properties" ignore-unresolvable="true"/> <!-- 定义mongo对象,对应的是mongodb官方jar包中的mongo,replica-set设置集群副本的ip地址和端口 --> <mongo:mongo id="mongo" replica-set="${mongo.hostport}"> <mongo:options connections-per-host="${mongo.connectionsperhost}" threads-allowed-to-block-for-connection-multiplier="${mongo.threadsallowedtoblockforconnectionmultiplier}" connect-timeout="${mongo.connecttimeout}" max-wait-time="${mongo.maxwaittime}" auto-connect-retry="${mongo.autoconnectretry}" socket-keep-alive="${mongo.socketkeepalive}" socket-timeout="${mongo.sockettimeout}" slave-ok="${mongo.slaveok}" write-number="1" write-timeout="0" write-fsync="true"/> </mongo:mongo> <mongo:db-factory id="mgfactory" dbname="${mongo.dbname}" username="${mongo.username}" password="${mongo.password}" mongo-ref="mongo" /> <bean id="mongotemplate" class="org.springframework.data.mongodb.core.mongotemplate"> <constructor-arg name="mongodbfactory" ref="mgfactory"/> </bean> </beans>
spring-contex.xml
<?xml version="1.0" encoding="utf-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:task="http://www.springframework.org/schema/task" xmlns:xsi="http://www.w3.org/2001/xmlschema-instance" xsi:schemalocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.1.xsd"> <aop:aspectj-autoproxy proxy-target-class="true"/> <!--使用注解管理bean --> <context:annotation-config/> <!-- 扫描com.lutongnet下的所有类 --> <context:component-scan base-package="com.lutong.cps"> <context:exclude-filter type = "annotation" expression = "org.springframework.stereotype.controller"/> </context:component-scan> <import resource="mongodb.xml"/> </beans>
五、代码实现
基础实现mongodbservice
/** * file name : mongodbservice.java * package : com.lutongnet.ad.service * description : todo * author : zhangfj * date : 2012-11-29 * version : v1.0 */ package com.lutong.cps.schedule.service.fj; import org.springframework.context.applicationcontext; import org.springframework.context.support.classpathxmlapplicationcontext; import org.springframework.data.mongodb.core.mongotemplate; import org.springframework.data.mongodb.core.query.query; import org.springframework.stereotype.service; /** * @author zhangfj * */ @service("mongodbservice") public class mongodbservice { /*@resource(name = "mongotemplate") protected mongotemplate mongotemplate;*/ /** * * @param query * @param entityclass * @return t */ public <t> t findone(query query, class<t> entityclass) { applicationcontext context=new classpathxmlapplicationcontext("mongodb.xml"); mongotemplate mongotemplate= (mongotemplate) context.getbean("mongotemplate"); // 可以直接调用 return mongotemplate.findone(query, entityclass); } }
继承类useradcountservice
/** * file name : useradcountservice.java * package : com.lutongnet.ad.service * description : todo * author : zhangfj * date : 2012-11-29 * version : v1.0 */ package com.lutong.cps.schedule.service.fj; import org.springframework.data.mongodb.core.query.criteria; import org.springframework.data.mongodb.core.query.query; import org.springframework.stereotype.service; import com.lutong.cps.schedule.entity.useradcount; /** * @author zhangfj * */ @service("useradcountservice") public class useradcountservice extends mongodbservice { /** * 获取单个广告的观看次数,查询不到则返回0 * * @param adcode * @return int */ public int getuseradcount(useradcount adcode) { criteria criteria = new criteria(); criteria.andoperator(criteria.where("userad").is(adcode.getuserad()), criteria.where("adcode").is(adcode.getadcode()), criteria.where("countdate").is(adcode.getcountdate())); query query = new query(criteria); useradcount result = findone(query, useradcount.class); if (null != result) { return result.gettimescount(); } return 0; } }
实体类useradcount
package com.lutong.cps.schedule.entity; import java.util.date; import org.springframework.data.annotation.persistenceconstructor; import org.springframework.data.mongodb.core.mapping.document; /** * mongo专用统计单个用户的单个广告观看次数 * @author cancer * */ @document(collection="useradcount") public class useradcount { private int timescount; /** * 用户账号 */ private string userad; private string adcode; private string countdate; private date expireat; @persistenceconstructor public useradcount(int timescount, string userad,string adcode,string countdate,date expireat) { this.timescount = timescount; this.userad = userad; this.adcode = adcode; this.countdate = countdate; this.expireat = expireat; } public useradcount(string userad,string adcode,string countdate) { this.userad = userad; this.adcode = adcode; this.countdate = countdate; } public useradcount(string userad,string adcode,string countdate,date expireat) { this.userad = userad; this.adcode = adcode; this.countdate = countdate; this.expireat = expireat; } public useradcount(string countdate) { this.countdate = countdate; } public int gettimescount() { return timescount; } public void settimescount(int timescount) { this.timescount = timescount; } public string getuserad() { return userad; } public void setuserad(string userad) { this.userad = userad; } public string getadcode() { return adcode; } public void setadcode(string adcode) { this.adcode = adcode; } public string getcountdate() { return countdate; } public void setcountdate(string countdate) { this.countdate = countdate; } public date getexpireat() { return expireat; } public void setexpireat(date expireat) { this.expireat = expireat; } }
最后写一个测试类来测试下
import java.util.list; import javax.annotation.resource; import org.junit.test; import org.junit.runner.runwith; import org.springframework.test.context.contextconfiguration; import org.springframework.test.context.junit4.springjunit4classrunner; import com.acts.web.modules.mark.model.users; import com.lutong.cps.schedule.service.fj.useradcountservice; @contextconfiguration({ "classpath:spring-context.xml", "classpath:mongodb.xml"}) @runwith(springjunit4classrunner.class) public class usertest { @resource(name = "useradcountservice") private useradcountservice useradcountservice; @test public void testdao() { try { useradcount useradcount = new useradcount("hehaitao", "pos001", datetime.now().tostring("yyyy-mm-dd")); int count = useradcountservice .getuseradcount(useradcount); system.out.println(count); } catch (exception e) { e.printstacktrace(); } } }
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对的支持。
上一篇: 杨紫要“入职”realme 代言realme真我X50 5G:明天官宣
下一篇: C#抽象类