上一篇分享了MongoDB的配置文件魁淳，現(xiàn)在準(zhǔn)備正式在已有項目中使用，完成那個公告配置的需求。
整合Spring和MongoDB需要兩個jar包：
1.mongodb官方j(luò)dbc驅(qū)動 mongo-java-driver
2.spring基于mongo-java-driver的連接池管理和ORM的中間件 spring-data-mongodb
因為公司項目的架構(gòu)所用的技術(shù)比較舊，spring還是3.1.2版本的屎鳍。看了下截止目前能夠支持的最高的spring-data-mongodb版本只有1.3.5了问裕，而我的mongodb是3.2版本的逮壁，所以能夠兼容的最高的mongo-java-driver只有2.14.2。
下面是maven的pom.xml引入的這兩個包的依賴：
spring-data-mongodb
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-mongodb</artifactId>
<version>1.3.5.RELEASE</version>
</dependency>
mongo-java-driver
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
<version>2.14.2</version>
</dependency>
Spring配置中添加對應(yīng)的依賴注入：
applicationContext.xml
xml標(biāo)簽引用
<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.0.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.0.xsd">
MonggoDb連接池依賴注入配置(相關(guān)配置具體含義請參考底部引用的官方文檔)
<bean id="propertyConfigurer"
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<list>
<value>classpath:mongo.properties</value>
</list>
</property>
</bean>
<!--連接池配置-->
<mongo:mongo host="${mongo.host}" port="${mongo.port}">
<mongo:options connections-per-host="${mongo.options.connections-per-host}"
threads-allowed-to-block-for-connection-multiplier="${mongo.options.threads-allowed-to-block-for-connection-multiplier}"
connect-timeout="${mongo.options.connect-timeout}"
max-wait-time="${mongo.options.max-wait-time}"
auto-connect-retry="${mongo.options.auto-connect-retry}"
socket-keep-alive="${mongo.options.socket-keep-alive}"
socket-timeout="${mongo.options.socket-timeout}"
slave-ok="${mongo.options.slave-ok}"
write-number="${mongo.options.write-number}"
write-timeout="${mongo.options.write-timeout}"
write-fsync="${mongo.options.write-fsync}"/>
</mongo:mongo>
<!--連接池工廠配置-->
<mongo:db-factory 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="mongoDbFactory"/>
</bean>
<!--實體映射自動掃描注入的包-->
<mongo:mapping-converter>
<mongo:custom-converters base-package="com.shunova.core.entity.mongo" />
</mongo:mapping-converter>
mongo.properties
mongo.host=localhost
mongo.port=27017
mongo.dbname=dbname
mongo.username=username
mongo.password=password
mongo.options.connections-per-host=20
mongo.options.threads-allowed-to-block-for-connection-multiplier=4
mongo.options.connect-timeout=1000
mongo.options.max-wait-time=1500
mongo.options.auto-connect-retry=false
mongo.options.socket-keep-alive=true
mongo.options.socket-timeout=1500
mongo.options.slave-ok=false
mongo.options.write-number=1
mongo.options.write-timeout=0
mongo.options.write-fsync=true
實體類：
項目需求中的公告實體類粮宛，Notice
package com.shunova.core.entity.mongo;
import org.springframework.data.annotation.Id;
import org.springframework.data.annotation.PersistenceConstructor;
import org.springframework.data.mongodb.core.index.IndexDirection;
import org.springframework.data.mongodb.core.index.Indexed;
import org.springframework.data.mongodb.core.mapping.Document;
import java.util.Date;
/**
* Created by mhq on 16/10/28.
*/
@Document
public class Notice {
public Notice(){}
@PersistenceConstructor
public Notice(String id, int siteId, String creator, String title, String content,
Date createTime, Date updateTime){
this.id = id;
this.siteId = siteId;
this.creator = creator;
this.title = title;
this.content = content;
this.createTime = createTime;
this.updateTime = updateTime;
}
@Id
private String id;
@Indexed
private int siteId;
private String creator;
private String title;
private String content;
@Indexed(direction = IndexDirection.DESCENDING)
private Date createTime;
private Date updateTime;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public int getSiteId() {
return siteId;
}
public void setSiteId(int siteId) {
this.siteId = siteId;
}
public String getCreator() {
return creator;
}
public void setCreator(String creator) {
this.creator = creator;
}
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public Date getUpdateTime() {
return updateTime;
}
public void setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
}
}
相關(guān)實體類注解的解釋
@Id - 文檔的唯一標(biāo)識窥淆，在mongodb中為ObjectId，它是唯一的窟勃，通過時間戳+機器標(biāo)識+進(jìn)程ID+自增計數(shù)器（確保同一秒內(nèi)產(chǎn)生的Id不會沖突）構(gòu)成祖乳。
@Document - 把一個java類聲明為mongodb的文檔逗堵，可以通過collection參數(shù)指定這個類對應(yīng)的文檔秉氧。@Document(collection="mongodb") mongodb對應(yīng)表
@DBRef - 聲明類似于關(guān)系數(shù)據(jù)庫的關(guān)聯(lián)關(guān)系。ps：暫不支持級聯(lián)的保存功能蜒秤，當(dāng)你在本實例中修改了DERef對象里面的值時汁咏，單獨保存本實例并不能保存DERef引用的對象，它要另外保存作媚，如下面例子的Person和Account攘滩。
@Indexed - 聲明該字段需要索引，建索引可以大大的提高查詢效率纸泡。
@CompoundIndex - 復(fù)合索引的聲明漂问，建復(fù)合索引可以有效地提高多字段的查詢效率。
@GeoSpatialIndexed - 聲明該字段為地理信息的索引女揭。
@Transient - 映射忽略的字段蚤假，該字段不會保存到mongodb。
@PersistenceConstructor - 聲明構(gòu)造函數(shù)吧兔，作用是把從數(shù)據(jù)庫取出的數(shù)據(jù)實例化為對象磷仰。該構(gòu)造函數(shù)傳入的值為從DBObject中取出的數(shù)據(jù)
基本的增刪改查
在dao中注入xml中配置的mongoTemplate
MongoOperations是MongoTemplate的父類
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoOperations;
@Autowired
protected MongoOperations mongoOperations;
增刪改查
public String save(int siteId, String creator, Notice notice){
Date now = new Date();
notice.setSiteId(siteId);
notice.setCreator(creator);
notice.setCreateTime(now);
notice.setUpdateTime(now);
mongoOperations.insert(notice);
return notice.getId();
}
public int update(int siteId, String id, Notice notice){
Query query = new Query();
query.addCriteria(Criteria.where("id").is(id).and("siteId").is(siteId));
Update update = new Update();
update.set("title", notice.getTitle());
update.set("content", notice.getContent());
update.set("updateTime", new Date());
WriteResult result = mongoOperations.updateFirst(query, update, Notice.class);
return result.getN();
}
public Pager page(Pager pager, int siteId, NoticeSearchParams searchParams){
Query query = new Query();
query.addCriteria(Criteria.where("siteId").is(siteId));
if(!StringTool.isNullOrEmpty(searchParams.getTitleKey())){
query.addCriteria(Criteria.where("title").regex(searchParams.getTitleKey(), "i"));
}
if(searchParams.getSortMode() == NoticeSearchParams.SORT_MODE_CREATE_TIME_DESC){
query.with(new Sort(new Sort.Order(Sort.Direction.DESC, "createTime")));
}
int skipCount = (pager.getPageNo() > 0 ? pager.getPageNo() - 1 : 0) * pager.getPageSize();
query.skip(skipCount);
query.limit(pager.getPageSize());
List<Notice> notices = mongoOperations.find(query, Notice.class);
pager.setResult(notices);
return pager;
}
public Notice get(int siteId, String id){
Notice notice = mongoOperations.findOne(
Query.query(Criteria.where("id").is(id).and("siteId").is(siteId)), Notice.class);
return notice;
}
public void remove(int siteId, String id){
mongoOperations.remove(
Query.query(Criteria.where("id").is(id).and("siteId").is(siteId)), Notice.class);
}
至此就完成了基本Spring和MongoDB的整合，以上代碼都經(jīng)過實際測試通過境蔼。
本篇內(nèi)容參考自Spring官方文檔Spring Data MongoDB - Reference Documentation
歡迎來我的個人博客逛逛: https://blog.52xtg.com
