欧美一级特黄大片做受成人-亚洲成人一区二区电影-激情熟女一区二区三区-日韩专区欧美专区国产专区

如何優(yōu)雅的進(jìn)行Spring整合MongoDB詳解

前言

創(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)站價(jià)格咨詢: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的一個(gè)子模塊。 目標(biāo)是為mongodb提供一個(gè)相近的一致的基于Spring的編程模型。
  • Spring Data for MongoDB核心功能是映射POJO到Mongo的DBCollection中的文檔，并且提供Repository 風(fēng)格數(shù)據(jù)訪問層。

二、特性

  • MongoDB的提供了一個(gè)面向文檔存儲(chǔ)，操作起來比較簡單和容易。
  • 你可以在MongoDB記錄中設(shè)置任何屬性的索引 (如：FirstName="Ning",Address="Beijing")來實(shí)現(xiàn)更快的排序。
  • 你可以通過本地或者網(wǎng)絡(luò)創(chuàng)建數(shù)據(jù)鏡像，這使得MongoDB有更強(qiáng)的擴(kuò)展性。
  • 如果負(fù)載的增加（需要更多的存儲(chǔ)空間和更強(qiáng)的處理能力） ，它可以分布在計(jì)算機(jī)網(wǎng)絡(luò)中的其他節(jié)點(diǎn)上這就是所謂的分片。
  • Mongo支持豐富的查詢表達(dá)式。查詢指令使用JSON形式的標(biāo)記，可輕易查詢文檔中內(nèi)嵌的對(duì)象及數(shù)組。
  • MongoDb 使用update()命令可以實(shí)現(xiàn)替換完成的文檔（數(shù)據(jù)）或者一些指定的數(shù)據(jù)字段 。
  • Mongodb中的Map/reduce主要是用來對(duì)數(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中的一個(gè)內(nèi)置功能，可以用于存放大量小文件。
  • MongoDB允許在服務(wù)端執(zhí)行腳本，可以用Javascript編寫某個(gè)函數(shù)，直接在服務(wù)端執(zhí)行，也可以把函數(shù)的定義存儲(chǔ)在服務(wù)端，下次直接調(diào)用即可。
  • 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 相關(guān)依賴

<!-- spring web相關(guān)依賴 -->
 <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添加權(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"?>
<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對(duì)象，對(duì)應(yīng)的是mongodb官方j(luò)ar包中的Mongo，replica-set設(shè)置集群副本的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>

五、代碼實(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> T findOne(Query query, Class<T> 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
{
 /**
 * 獲取單個(gè)廣告的觀看次數(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ì)單個(gè)用戶的單個(gè)廣告觀看次數(shù)
 * @author cancer
 *
 */
@Document(collection="userAdCount")
public class UserAdCount
{
 private int timesCount;
 
 /**
 * 用戶賬號(hào)
 */
 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;
 } 
}

最后寫一個(gè)測試類來測試下

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)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問大家可以留言交流，謝謝大家對(duì)創(chuàng)新互聯(lián)的支持。

網(wǎng)站欄目：如何優(yōu)雅的進(jìn)行Spring整合MongoDB詳解
路徑分享：http://aaarwkj.com/article0/gjghoo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站營銷、域名注冊、企業(yè)網(wǎng)站制作、電子商務(wù)、微信公眾號(hào)、云服務(wù)器

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)

成都做網(wǎng)站
青青草国产成人自拍视频在线观看| 麻豆视传媒短视频网站| 99精品欧美一区二区三区视频 | 韩国三级福利在线观看| 日韩一区二区三区中文字幕| 欧美亚洲国产精品久久久| 国产精品亚洲av三区国产毛片 | 日韩一区二区三区成人| 蜜桃精品国产一区二区三区| 日韩中文不卡人成在线视频| 日韩精品人妻中文字幕满员| 国产亚洲视频一区二区观看| 日韩黄片大全在线观看| 日本韩国视频一区二区| 婷婷不卡中文字幕三区| 久久伊人这里都是精品| 国产欧美日韩精品久久久久久| 麻豆精品情欲人妻一区 | 国产精品久久久久久爽| 色橹橹欧美午夜精品福利| 日本少妇三级网站大全| 日韩高清在线不卡视频| 黄色永久网站在线播放| 亚洲免费av一区在线观看| 久久精品夜夜夜夜夜久久| 精品一区二区三区乱码中文| 国产a天堂一区二区专区| 日本一道二区三区我不卡| 久久精品亚洲天然东京热 | 亚洲国产高清国产拍精品| 一本之道久久成人综合| 九九九视频在线观看免费| 亚洲精品污一区二区三区| 免费亚洲一区二区三区| 日韩黄色一级片免费看| 色偷拍亚洲偷自拍二区| 成人黄色一级电影免费看| 深夜毛片一区二区三区| 久久人妻一区二区三区免费| 国产日韩欧美亚洲中文国| 少妇特黄a一区二区三区|