前言
創(chuàng)新互聯(lián)是一家專注于成都網(wǎng)站設(shè)計(jì)、成都做網(wǎng)站與策劃設(shè)計(jì),南部網(wǎng)站建設(shè)哪家好?創(chuàng)新互聯(lián)做網(wǎng)站,專注于網(wǎng)站建設(shè)10余年,網(wǎng)設(shè)計(jì)領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:南部等地區(qū)。南部做網(wǎng)站價格咨詢:13518219792
本文重點(diǎn)是要將MongoDB與spring整合到項(xiàng)目中去，在實(shí)踐中發(fā)現(xiàn)問題，追蹤問題，然后解決問題。下面話不多說了，來一起看看詳細(xì)的介紹吧。
一、準(zhǔn)備
- Maven、Spring(spring-data-mongodb)
- spring Data for MongoDB是Spring Data的一個子模塊。 目標(biāo)是為mongodb提供一個相近的一致的基于Spring的編程模型。
- Spring Data for MongoDB核心功能是映射POJO到Mongo的DBCollection中的文檔，并且提供Repository 風(fēng)格數(shù)據(jù)訪問層。
二、特性
- MongoDB的提供了一個面向文檔存儲，操作起來比較簡單和容易。
- 你可以在MongoDB記錄中設(shè)置任何屬性的索引 (如：FirstName="Ning",Address="Beijing")來實(shí)現(xiàn)更快的排序。
- 你可以通過本地或者網(wǎng)絡(luò)創(chuàng)建數(shù)據(jù)鏡像，這使得MongoDB有更強(qiáng)的擴(kuò)展性。
- 如果負(fù)載的增加（需要更多的存儲空間和更強(qiáng)的處理能力） ，它可以分布在計(jì)算機(jī)網(wǎng)絡(luò)中的其他節(jié)點(diǎn)上這就是所謂的分片。
- Mongo支持豐富的查詢表達(dá)式。查詢指令使用JSON形式的標(biāo)記，可輕易查詢文檔中內(nèi)嵌的對象及數(shù)組。
- MongoDb 使用update()命令可以實(shí)現(xiàn)替換完成的文檔（數(shù)據(jù)）或者一些指定的數(shù)據(jù)字段 。
- Mongodb中的Map/reduce主要是用來對數(shù)據(jù)進(jìn)行批量處理和聚合操作。
- Map和Reduce。Map函數(shù)調(diào)用emit(key,value)遍歷集合中所有的記錄，將key與value傳給Reduce函數(shù)進(jìn)行處理。
- Map函數(shù)和Reduce函數(shù)是使用Javascript編寫的，并可以通過db.runCommand或mapreduce命令來執(zhí)行MapReduce操作。
- GridFS是MongoDB中的一個內(nèi)置功能，可以用于存放大量小文件。
- MongoDB允許在服務(wù)端執(zhí)行腳本，可以用Javascript編寫某個函數(shù)，直接在服務(wù)端執(zhí)行，也可以把函數(shù)的定義存儲在服務(wù)端，下次直接調(diào)用即可。
- MongoDB支持各種編程語言:RUBY，PYTHON，JAVA，C++，PHP，C#等多種語言。
三、依賴包
org.springframework.data
spring-data-mongodb
1.5.0.RELEASE
org.slf4j
slf4j-log4j12
1.5.10
spring 相關(guān)依賴
org.springframework
spring-web
${spring.version}
org.springframework
spring-webmvc
3.1.2.RELEASE
org.springframework
spring-test
4.3.1.RELEASE
四、集成MongoDB
【注：MongoDB添加權(quán)限管理請參見我的這篇文章:MongDB開啟權(quán)限認(rèn)證】
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"?>
spring-contex.xml
<?xml version="1.0" encoding="UTF-8"?>
五、代碼實(shí)現(xiàn)
基礎(chǔ)實(shí)現(xiàn)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 findOne(Query query, Class entityClass)
{
ApplicationContext context=new ClassPathXmlApplicationContext("mongoDB.xml");
MongoTemplate mongoTemplate= (MongoTemplate) context.getBean("mongoTemplate");
// 可以直接調(diào)用
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
{
/**
* 獲取單個廣告的觀看次數(shù)，查詢不到則返回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;
}
}實(shí)體類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專用統(tǒng)計(jì)單個用戶的單個廣告觀看次數(shù)
* @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();
}
}
}總結(jié)
以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，如果有疑問大家可以留言交流，謝謝大家對創(chuàng)新互聯(lián)的支持。
分享題目：如何優(yōu)雅的進(jìn)行Spring整合MongoDB詳解
網(wǎng)站網(wǎng)址：
http://weahome.cn/article/gjghoo.html
重慶分公司
重慶分公司
