以下代码展示了mongodb和spring的集成的使用，主要是mongoTemplate类的使用。
import static org.springframework.data.mongodb.core.query.Criteria.where; import java.util.ArrayList; import java.util.List; import com.jd.bse.incubator.mongo.entity.Home; import com.jd.bse.incubator.mongo.entity.User; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.mongodb.core.MongoTemplate; 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.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; @RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration(locations={"classpath:/spring/mongodb-config.xml"})//这里要用到mongodb的配置文件 public class MongoSpringTest{ @Autowired private MongoTemplate mongoTemplate; /** * 插入用户信息 */ @Test public void testAddUser() { User zhanggc = new User(); zhanggc.setName1("zhangguochen"); zhanggc.setAge(29); List<String> interests = new ArrayList<String>(); interests.add("stuty"); interests.add("hadoop"); zhanggc.setInterest(interests); Home home = new Home("henan"); zhanggc.setHome(home); //插入数据 mongoTemplate.insert(zhanggc); } /** * 查询用户信息 */ @Test public void testQueryUser() { //查询主要用到Query和Criteria两个对象 Query query = new Query(); Criteria criteria = where("age").gt(22); // criteria.and("name").is("cuichongfei");等于 // List<String> interests = new ArrayList<String>(); // interests.add("study"); // interests.add("linux"); // criteria.and("interest").in(interests); in查询 // criteria.and("home.address").is("henan"); 内嵌文档查询 // criteria.and("").exists(false); 列存在 // criteria.and("").lte(); 小于等于 // criteria.and("").regex(""); 正则表达式 // criteria.and("").ne(""); 不等于 query.addCriteria(criteria); List<User> userList1 = mongoTemplate.find(query, User.class); printList(userList1); //排序查询sort方法,按照age降序排列 // query.sort().on("age", Order.DESCENDING); // List<User> userList2 = mongoTemplate.find(query, User.class); // printList(userList2); //指定字段查询,只查询age和name两个字段 // query.fields().include("age").include("name"); // List<User> userList3 = mongoTemplate.find(query, User.class); // printList(userList3); //分页查询 // query.skip(2).limit(3); // List<User> userList4 = mongoTemplate.find(query, User.class); // printList(userList4); //查询所有 // printList(mongoTemplate.findAll(User.class)); //统计数据量 // System.out.println(mongoTemplate.count(query, User.class)); } /** * 更新用户数据 */ @Test public void testUpdateUser() { //update(query,update,class) //Query query:需要更新哪些用户,查询参数 //Update update:操作符,需要对数据做什么更新 //Class class:实体类 //更新age大于24的用户信息 Query query = new Query(); query.addCriteria(where("age").gt(24)); Update update = new Update(); //age值加2 update.inc("age", 2); // update.set("name", "zhangsan"); 直接赋值 // update.unset("name"); 删去字段 // update.push("interest", "java"); 把java追加到interest里面,interest一定得是数组 // update.pushAll("interest", new String[]{".net","mq"}) 用法同push,只是pushAll一定可以追加多个值到一个数组字段内 // update.pull("interest", "study"); 作用和push相反,从interest字段中删除一个等于value的值 // update.pullAll("interest", new String[]{"sing","dota"})作用和pushAll相反 // update.addToSet("interest", "study") 把一个值添加到数组字段中,而且只有当这个值不在数组内的时候才增加 // update.rename("oldName", "newName") 字段重命名 //只更新第一条记录,age加2,name值更新为zhangsan mongoTemplate.updateFirst(query, new Update().inc("age", 2).set("name", "zhangsan"), User.class); //批量更新,更新所有查询到的数据 mongoTemplate.updateMulti(query, update, User.class); } /** * 测试删除数据 */ @Test public void testRemoveUser() { Query query = new Query(); // query.addCriteria(where("age").gt(22)); Criteria criteria = where("age").gt(22); //删除年龄大于22岁的用户 query.addCriteria(criteria); mongoTemplate.remove(query, User.class); } public MongoTemplate getMongoTemplate() { return mongoTemplate; } public void setMongoTemplate(MongoTemplate mongoTemplate) { this.mongoTemplate = mongoTemplate; } public void printList(List<User> userList) { System.out.println("**********************************************************************************************************"); for(User user:userList) { System.out.println(user); } System.out.println("**********************************************************************************************************"); } }
4.以下是/mongodb-config.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:mongo="http://www.springframework.org/schema/data/mongo" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-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/data/mongo http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd"> <context:component-scan base-package="com.jd.mongo"/> <context:annotation-config /> <!-- config db property file location --> <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="locations"> <list> <value>classpath:conf/mongo.properties</value> </list> </property> </bean> <!-- 定义mongo对象，对应的是mongodb官方jar包中的Mongo --> <mongo:mongo host="${mongo.host.job}" port="${mongo.port.job}"/> <!-- 一些连接属性的设置,属性意义详见http://www.cnblogs.com/zsuxiong/archive/2012/09/05/2671960.html --> <!--<mongo:mongo id="mongo" replica-set="localhost:27017"> <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的工厂，通过它来取得mongo实例,dbname为mongodb的数据库名，没有的话会自动创建 --> <mongo:db-factory id="mongoDbFactory" dbname="${mongo.dbname.job}" username="${mongo.username.job}" password="${mongo.password.job}" mongo-ref="mongo"/> <!-- mongodb的主要操作对象，所有对mongodb的增删改查的操作都是通过它完成 --> <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate"> <constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/> </bean> </beans>
5.以下是配置文件mongo.properties，也就是mongodb的连接信息
mongo.host.job=192.168.232.62:27017 mongo.dbname.job=erp mongo.needauth.job=true mongo.username.job=erp mongo.password.job=erp
