spring-data-MongoDB的MongoTemplate使用实例代码演示
1、首先使用Eclipse的git插件把spring提供的示例下载下来
https://github.com/SpringSource/spring-data-document-examples.git
下载之后导入maven工程
2、首先看我们的domain定义，也就是entity。
org.springframework.data.mongodb.examples.hello.domain.Person
package org.springframework.data.mongodb.examples.hello.domain;import java.util.ArrayList;
import java.util.List;
import org.springframework.data.annotation.Id;
import org.springframework.data.document.mongodb.mapping.Document;
@Document
public class Person {
@Id
private String id;
private String name;
private int age;
private List
public Person() {
}
public Person(String name, int age) {
super();
this.name = name;
this.age = age;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
public List
return accounts;
}
public void addAccount(Account account) {
this.accounts.add(account);
}
public void setAccounts(List
this.accounts = accounts;
}
public String toString() {
return "Person [id=" + id + ", name=" + name + ", age=" + age
+ ", accounts=" + accounts + "]";
}
}
dao层的类org.springframework.data.mongodb.examples.hello.HelloMongo
package org.springframework.data.mongodb.examples.hello;
import java.io.File;
import java.io.IOException;
import java.util.List;
import java.util.Random;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoOperations;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.data.mongodb.examples.hello.domain.Account;
import org.springframework.data.mongodb.examples.hello.domain.Person;
import org.springframework.stereotype.Repository;
import com.mongodb.BasicDBObject;
import com.mongodb.BasicDBObjectBuilder;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.gridfs.GridFS;
import com.mongodb.gridfs.GridFSDBFile;
import com.mongodb.gridfs.GridFSInputFile;
/**
*
* @author xiaofancn
*
* 参考 http://static.springsource.org/spring-data/data-document/docs/1.0.0.M2/reference/html/
* 参考 http://nosql.mypopescu.com/post/816470307/tutorial-mongodb-in-java
*
*/
@Repository
public class HelloMongo {
@Autowired
MongoOperations mongoOperations;
public void gridFSInput(String inputFilepath) {
DB db = mongoOperations.getCollection(
mongoOperations.getCollectionName(Person.class)).getDB();
db.requestStart();
File inputFile = new File(inputFilepath);
GridFSInputFile gfsInput;
try {
gfsInput = new GridFS(db, "fs")
.createFile(inputFile);
gfsInput.setFilename("qq123456789logo");// 保存到数据库的文件名为qq123456789logo
gfsInput.save();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
db.requestDone();
}
public void gridFSOutput(String outputFilepath) {
DB db = mongoOperations.getCollection(
mongoOperations.getCollectionName(Person.class)).getDB();
GridFSDBFile gfsFile = new GridFS(db, "fs").findOne("qq123456789logo");// 查找文件名qq123456789logo输出保存
try {
gfsFile.writeTo(outputFilepath);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void insert(int count) {
if (mongoOperations.collectionExists(Person.class)) {
mongoOperations.dropCollection(Person.class);
}
mongoOperations.createCollection(Person.class);
for (int i = 0; i < count; i++) {
Person p = new Person("小樊", i);
Account a = new Account("1234-59873-893-1", Account.Type.SAVINGS,
123.45D);
p.addAccount(a);
mongoOperations.insert(p);
}
}
public void delete(int age) {
// 删除查询到的年龄
mongoOperations.remove(new Query(new Criteria("age").is(age)),
Person.class);
}
public void alert(int age) {
// 根据age查询，更新查询到的age字段为随机数
mongoOperations.updateMulti(new Query(new Criteria("age").is(age)),
new Update().inc("age", new Random().nextInt()), Person.class);
}
public void alert(String name) {
// 根据name查询，更新查询到的name字段为xiaofancn
mongoOperations.updateMulti(new Query(new Criteria("name").in(name)),
new Update().set("name", "xiaofancn"), Person.class);
}
public void query(int age) {
// 根据age查询
List
"age").is(age)), Person.class);
for (Person p : persons) {
System.out.println(p.toString());
}
// ===========================jdbc原生的类
DBCollection personColl = mongoOperations.getCollection(mongoOperations
.getCollectionName(Person.class));
BasicDBObject parameter = new BasicDBObject();
parameter.put("age", age);
DBCursor item = personColl.find(parameter);
while (item.hasNext()) {
System.out.println(item.next());
}
}
/**
* 统计这个年龄的人数
* @param age
* @return
*/
public Long count(int age) {
DBCollection personColl = mongoOperations.getCollection(mongoOperations
.getCollectionName(Person.class));
BasicDBObject parameter = new BasicDBObject();
parameter.put("age", age);
return personColl.count(parameter);
}
public void showAllOrederByAge(int startPage, DBObject sort,
int countPerPage) {
if (sort == null) {// 默认按照年龄的升序
sort = BasicDBObjectBuilder.start().add("age", 1).get();
}
DBCollection personColl = mongoOperations.getCollection(mongoOperations
.getCollectionName(Person.class));
DBCursor item = personColl.find().sort(sort)
.skip((startPage-1) * countPerPage).limit(countPerPage);
while (item.hasNext()) {
// Person p = item.next();错误
DBObject parameter = item.next();
System.out.println(parameter);
}
}
public void showAll() {
List
for (Person p : list) {
System.out.println(p);
}
// =================大批量的查询尽量使用原生的函数,也要对应原生的文档结构。
DBObject sort = BasicDBObjectBuilder.start().add("age", -1).get();
DBCollection personColl = mongoOperations.getCollection(mongoOperations
.getCollectionName(Person.class));
DBCursor item = personColl.find();// 查询前100条记录
while (item.hasNext()) {
// Person p = item.next();错误
DBObject parameter = item.next();
System.out.println(parameter);
}
}
}
// 参考 http://www.mongodb.org/display/DOCS/Updating#Updating-ModifierOperations
// 对数组对象有效，数组对象后添加数据
mongoOperations.updateMulti(new Query(new Criteria("age").is(0)),
new Update().push("name", "小樊"), Person.class);
//找到数据，加法属性 age = age +-10
mongoOperations
.updateMulti(new Query(new Criteria("age").is(0)), new Update().inc("age", -10), Person.class);
//unset 重置属性值，数字为0，字符其他为null
mongoOperations.updateMulti(new Query(new Criteria("age").is(0)),
new Update().set("name", "小樊").set("age", -1), Person.class);
客户端org.springframework.data.mongodb.examples.hello.App
package org.springframework.data.mongodb.examples.hello;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* Hello Mongo!
*/
public class App {
public static void main(String[] args) {
System.out.println("Bootstrapping HelloMongo");
ConfigurableApplicationContext context = null;
// use @Configuration using Java:
context = new ClassPathXmlApplicationContext(
"META-INF/spring/bootstrap.xml");
// use XML application context:
// context = new
// ClassPathXmlApplicationContext("META-INF/spring/applicationContext.xml");
HelloMongo hello = context.getBean(HelloMongo.class);
hello.delete(39);
hello.query(39);
//hello.showAll();
System.out.println("DONE!");
}
}
参考
http://static.springsource.org/spring-data/data-document/docs/1.0.0.M2/reference/html/
spring-data-MongoDB的MongoTemplate使用实例代码演示
