mongodb--与spring整合

zj2092

　　一、spring-data-mongodb
　　Spring Data是Spring专门用来数据处理的一个子项目，Spring Data除了spring-data-mongodb之外还包括spring-data-jp、spring-data-redis等项目。spring-data-mongodb就是针对mongodb的一个项目。通过它我们可以对nongodb进行操作。spring-data-mongodb的项目地址为：http://projects.spring.io/spring-data-mongodb/ 。
　　二、实例
　　例子使用maven构建并使用spring-test运行。
　　pom.xml 内容如下：




4.0.0
com.yichun.test
test_yichun
0.0.1-SNAPSHOT
jar
test_yichun
http://maven.apache.org

UTF-8
4.11
4.1.1.RELEASE



org.springframework
spring-core
${spring.version}


org.springframework
spring-context
${spring.version}


org.springframework
spring-context-support
${spring.version}


org.springframework
spring-test
${spring.version}


org.mongodb
mongo-java-driver
2.12.4


org.springframework.data
spring-data-mongodb
1.6.1.RELEASE


junit
junit
${junit.version}
test



　　spring-config-mongodb.xml 配置文件如下：











　　Person.java 对应于保存的文档　　



package com.yichun.test.test_yichun;
public class Person {
private String id;
private String name;
private int age;
public Person() {
}
public Person(String name, int age) {
this.name = name;
this.age = age;
}
public Person(String id, String name, int age) {
this.id = id;
this.name = name;
this.age = age;
}
public String getId() {
return id;
}
public String getName() {
return name;
}
public int getAge() {
return age;
}
@Override
public String toString() {
return "Person [id=" + id + ", name=" + name + ", age=" + age + "]";
}
}
　　MongoTest 主运行类



  1 package com.yichun.test.test_yichun;
  2
  3 import java.util.ArrayList;
  4 import java.util.List;
  5
  6 import javax.annotation.Resource;
  7
  8 import org.junit.Test;
  9 import org.junit.runner.RunWith;
10 import org.springframework.data.domain.Sort;
11 import org.springframework.data.domain.Sort.Direction;
12 import org.springframework.data.mongodb.core.FindAndModifyOptions;
13 import org.springframework.data.mongodb.core.MongoTemplate;
14 import org.springframework.data.mongodb.core.query.Criteria;
15 import org.springframework.data.mongodb.core.query.Query;
16 import org.springframework.data.mongodb.core.query.Update;
17 import org.springframework.test.context.ContextConfiguration;
18 import org.springframework.test.context.junit4.AbstractJUnit4SpringContextTests;
19 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
20
21 import com.mongodb.WriteResult;
22
23 @RunWith(SpringJUnit4ClassRunner.class)
24 @ContextConfiguration(locations = "classpath:spring-config-mongodb.xml")
25 public class MongoTest extends AbstractJUnit4SpringContextTests {
26
27     @Resource
28     private MongoTemplate mongoTemplate;
29
30     @Test
31     public void testAddDoc() {
32         Person p = new Person("Joe", 34);
33         Person p2 = new Person("1001", "Joe", 34);
34         Person p11 = new Person("1011", "zhangsan", 20);
35         Person p12 = new Person("1012", "zhangsan2", 21);
36         Person p13 = new Person("1013", "zhangsan3", 23);
37         List list = new ArrayList();
38         list.add(p11);
39         list.add(p12);
40         list.add(p13);
41         this.mongoTemplate.insert(p);// 默认保存在person集合中(与类名称一致)
42         this.mongoTemplate.insert(p2, "person2");// 指定保存在person2集合中
43         this.mongoTemplate.insertAll(list);// 默认保存在person集合中(与类名称一致)
44         // mongoTemplate.insert(list, collectionName);//指定保存的集合
45         // mongoTemplate.insert(list, Person.class);// 默认保存在person集合中(与类名称一致)
46     }
47
48     @Test
49     public  void testFindDoc() {
50         // 根据id查询,此id为mongo生成的id
51         Person person = this.mongoTemplate.findById("1011", Person.class);
52         System.out.println(person);
53
54         // 使用query对象查询
55         Query query = new Query(Criteria.where("age").is(34));
56         person = this.mongoTemplate.findOne(query, Person.class);
57         System.out.println(person);
58
59         // 使用query对象查询列表
60         query = new Query(Criteria.where("age").lt(30)).// age小于30
61                 with(new Sort(Direction.ASC, "age"));// age 升序
62         // query.with(Pageable );//可分页查询
63
64         List list = this.mongoTemplate.find(query.with(new Sort(Direction.ASC, "age")), Person.class);
65         System.out.println(list);
66     }
67     
68     @Test
69     public void testUpdateDoc() {
70         // age为34的person，age加1
71         Query query = new Query(Criteria.where("id").is(1011));
72         Update update = new Update().inc("age", 1);
73         Person p = this.mongoTemplate.findAndModify(query, update, Person.class);
74         System.out.println(p);
75
76         p = this.mongoTemplate.findAndModify(query, update, new FindAndModifyOptions().returnNew(true), Person.class);// returnNew(true)将更新后的对象返回
77         System.out.println(p);
78
79         // 将age为21的name改成zhangsan22，如果有多个age为21的，则只改变第一个
80         query = new Query(Criteria.where("age").is(21));
81         update = new Update().set("name", "zhangsan22");
82         WriteResult result = this.mongoTemplate.updateFirst(query, update, Person.class);
83         System.out.println(result);
84
85         // 将age为21的name改成zhangsan22，如果有多个age为21的，全部更新
86         result = mongoTemplate.upsert(query, update, Person.class);
87         System.out.println(result);
88     }
89     
90     
91     @Test
92     public void testRemoveDoc(){
93         Query query = new Query(Criteria.where("age").is(35));
94         // mongoTemplate.findAndRemove(query, Person.class);//删除文档
95         // mongoTemplate.findAndRemove(query, Person.class,
96         // collectionName)//删除指定集合内的文档
97         Person person = this.mongoTemplate.findOne(query, Person.class);
98         WriteResult result = this.mongoTemplate.remove(person);
99         System.out.println(result);
100         this.mongoTemplate.remove(query, Person.class);// 根据query对象删除文档
101
102         // mongoTemplate.remove(person, collection);//从指定的集合中删除文档
103         // mongoTemplate.remove(query, collectionName);//从指定的集合中根据query对象删除文档
104         // mongoTemplate.remove(query, entityClass, collectionName)//从指定的集合中根据query对象和class类型删除文档
105
106     }
107     
108 }