spring data for mongo

vivion32

一、 运行环境：
MongoDB 1.4或更高版本
JDK1.5或更高版本
Sping3X或更高版本
二 、MAVEN配置

view sourceprint?1 <dependencies>   

2 <!-- other dependency elements omitted -->

3 <dependency>   

4 <groupId>org.springframework.data</groupId>  

5 <artifactId>spring-data-mongodb</artifactId>  

6 <version>1.1.0.RELEASE</version>   

7 </dependency>   

8 </dependencies>

三、spring 配置






view sourceprint?01 <!--指定配置文件地址-->

02  <context:property-placeholder location="classpath:/mongo.properties"/>  

03  <mongo:mongo id="mongo" host="${${mongo.host}}" port="${${mongo.port}}">  

04  <mongo:options

05  connections-per-host="${${mongo.connectionsPerHost}}"

06  threads-allowed-to-block-for-connection-multiplier="${${mongo.threadsAllowedToBlockForConnectionMultiplier}}"

07  connect-timeout="${${mongo.connectTimeout}}"

08  max-wait-time="${${mongo.maxWaitTime}}"

09  auto-connect-retry="${${mongo.autoConnectRetry}}"

10  socket-keep-alive="${${mongo.socketKeepAlive}}"

11  socket-timeout="${${mongo.socketTimeout}}"

12  slave-ok="${${mongo.slaveOk}}"

13  write-number="1"

14  write-timeout="0"

15  write-fsync="true"

16  />  

17  </mongo:mongo>  

18  <bean id="userCredentials" class="org.springframework.data.authentication.UserCredentials">  

19  <description>认证口令</description>  

20  <constructor-arg name="username" value="${${mongo.username}}"/>  

21  <constructor-arg name="password" value="${${mongo.password}}"/>  

22  </bean>  

23  <bean name="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">  

24  <constructor-arg name="mongo" ref="mongo"/>  

25  <constructor-arg name="userCredentials" ref="userCredentials"/>  

26  <constructor-arg name="databaseName" value="nq-s2s"/>  

27  </bean>

四、properties配置文件






view sourceprint?01 mongo.host=192.168.0.251  

02 mongo.port=27017  

03 mongo.connectionsPerHost=8  

04 mongo.threadsAllowedToBlockForConnectionMultiplier=4  

05 mongo.connectTimeout=1000  

06 mongo.maxWaitTime=1500  

07 mongo.autoConnectRetry=true  

08 mongo.socketKeepAlive=true  

09 mongo.socketTimeout=1500  

10 mongo.slaveOk=true  

11 mongo.username=***  

12 mongo.password=***  

13 mongo.dbname=***

五、JAVABEAN映射
AdCenter.java是一个标准的javaBean，采用注解的方式实现ORM映射。@Document、@Id是必要的两个注解，@Document映射Mongodb中的Collection，@Id映射指定Collection中的标识_id。

其他注解标签有:@Indexed索引、@Transient不映射此属性

view sourceprint?01 import org.springframework.data.annotation.Id;  

02 import org.springframework.data.mongodb.core.mapping.Document;  

03 @Document(collection = "adCenterDeduction")  

04 public class AdCenter {  

05  @Id

06  private String id;  

07  private String business;  

08  private String adCenter;  

09  private int deductNum;  

10  private int requestNum;  

11  public String getBusiness() {  

12  return business;  

13  }  

14  public void setBusiness(String business) {  

15  this.business = business;  

16  }  

17  public String getAdCenter() {  

18  return adCenter;  

19  }  

20  public void setAdCenter(String adCenter) {  

21  this.adCenter = adCenter;  

22  }  

23  public int getDeductNum() {  

24  return deductNum;  

25  }  

26  public void setDeductNum(int deductNum) {  

27  this.deductNum = deductNum;  

28  }  

29  public int getRequestNum() {  

30  return requestNum;  

31  }  

32  public void setRequestNum(int requestNum) {  

33  this.requestNum = requestNum;  

34  }  

35  public String getId() {  

36  return id;  

37  }  

38  public void setId(String id) {  

39  this.id = id;  

40  }  

41  public AdCenter() {  

42  }  

43  public AdCenter(String business, String adCenter, int deductNum, int requestNum) {  

44  this.business = business;  

45  this.adCenter = adCenter;  

46  this.deductNum = deductNum;  

47  this.requestNum = requestNum;  

48  }  

49  @Override

50  public String toString() {  

51  return "AdCenter [id=" + id + "business=" + business + ", adCenter=" + adCenter  

52  + ", deductNum=" + deductNum + ", requestNum=" + requestNum  

53  + "]";  

54  }  

55 }

六、测试
view sourceprint?01 @Before

02  public void setUp() throws Exception {  

03  System.setProperty("NetQinServerType", "REL");  

04  System.setProperty("NetQinServerLocation", "C");  

05  }  

06  @Test

07  public void testAdCenter() throws UnknownHostException {  

08  ApplicationContext ctx = new ClassPathXmlApplicationContext("spring-dao.xml&#25991;&#20214;");  

09  MongoOperations mongoOperation = (MongoOperations) ctx.getBean("mongoTemplate");  

10  AdCenter adCenter = new AdCenter("ms","test",99,98);  

11  mongoOperation.insert(adCenter);  

12  assert adCenter.getId()!=null;  

13  System.out.println("newAdCenter:"+adCenter.toString());  

14  Query query = new Query(Criteria.where("business").is(adCenter.getBusiness()));  

15  query.addCriteria(Criteria.where("adCenter").is(adCenter.getAdCenter()));  

16  //查找  

17  AdCenter exsitAdCenter = mongoOperation.findOne(query,AdCenter.class);  

18  assert exsitAdCenter!=null;  

19  System.out.println("exsitAdCenter:"+exsitAdCenter.toString());  

20  //修改  

21  Update update = new Update().set("deductNum", 0);  

22  AdCenter modifyAd = mongoOperation.findAndModify(query, update, AdCenter.class);  

23  assert modifyAd.getDeductNum()==exsitAdCenter.getDeductNum();  

24  System.out.println("beforeModifyAdCenter:"+exsitAdCenter.toString());  

25  exsitAdCenter = mongoOperation.findOne(query,AdCenter.class);  

26  assert exsitAdCenter!=null&&exsitAdCenter.getDeductNum()==0;  

27  System.out.println("AfterModifyAdCenter:"+exsitAdCenter.toString());  

28  //自增  

29  Update incUpdate = new Update().inc("deductNum", 1);  

30  mongoOperation.findAndModify(query, incUpdate, AdCenter.class);  

31  exsitAdCenter = mongoOperation.findOne(query,AdCenter.class);  

32  assert exsitAdCenter!=null&&exsitAdCenter.getDeductNum()==1;  

33  System.out.println("AfterIncAdCenter:"+exsitAdCenter.toString());  

34  //删除  

35  mongoOperation.findAndRemove(query,AdCenter.class);  

36  }

七、测试输出
view sourceprint?1 newAdCenter:AdCenter [id=51b4581bb2e9ac8f62684366business=ms, adCenter=test, deductNum=99, requestNum=98]  

2 exsitAdCenter:AdCenter [id=51b4581bb2e9ac8f62684366business=ms, adCenter=test, deductNum=99, requestNum=98]  

3 beforeModifyAdCenter:AdCenter [id=51b4581bb2e9ac8f62684366business=ms, adCenter=test, deductNum=99, requestNum=98]  

4 AfterModifyAdCenter:AdCenter [id=51b4581bb2e9ac8f62684366business=ms, adCenter=test, deductNum=0, requestNum=98]  

5 AfterIncAdCenter:AdCenter [id=51b4581bb2e9ac8f62684366business=ms, adCenter=test, deductNum=1, requestNum=98]

八、参考文档
http://www.springsource.org/spring-data/mongodb
http://static.springsource.org/spring-data/mongodb/docs/current/reference/html/mongo.core.html#mongodb-connectors
http://static.springsource.org/spring-data/mongodb/docs/current/reference/html/
https://github.com/jreijn/spring-mongo-demo