SpringMVC+mongodb应用实例

/** * yangcheng * * Create Version: 1.0 * Author: * Create Date: 2016年2月26日 * * Copyright (c) 2016 CMCCIOT. All Right Reserved. */ package com.demo.test; import java.sql.SQLException; import java.text.DateFormat; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Map; import org.bson.NewBSONDecoder; import org.junit.Test; 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.Criteria; import org.springframework.data.mongodb.core.query.Query; import org.springframework.jdbc.core.BatchPreparedStatementSetter; import org.springframework.jdbc.core.JdbcTemplate; import com.demo.pojo.Position; import com.demo.pojo.User; import com.demo.service.UserService; /** * yangcheng （类说明） * * @author （参与开发人员姓名） */ public class MongoDBTest { @Test public void test1(){ // long begin=System.currentTimeMillis(); // ApplicationContext ac=new ClassPathXmlApplicationContext(new String[]{"spring/applicationcontext-service.xml"}); // UserService bean=(UserService)ac.getBean("userService"); // List<User> userlist = bean.findUserList(100); // long end=System.currentTimeMillis(); // // System.out.println("userlist size is "+ userlist.size()+";time is "+ (end-begin)/1000+"s"); } private Query getQuery(User criteriaUser) { if (criteriaUser == null) { criteriaUser = new User(); } Query query = new Query(); if (criteriaUser.getId() != null) { Criteria criteria = Criteria.where("id").is(criteriaUser.getId()); query.addCriteria(criteria); } if (criteriaUser.getAge() > 0) { Criteria criteria = Criteria.where("age").is(criteriaUser.getAge()); query.addCriteria(criteria); } if (criteriaUser.getName() != null) { Criteria criteria = Criteria.where("name").regex("^" + criteriaUser.getName()); query.addCriteria(criteria); } return query; } @Test public void test2(){ // long begin0 = System.currentTimeMillis(); // ApplicationContext ac=new ClassPathXmlApplicationContext(new String[]{"mongodb/mongodb-config.xml"}); // MongoTemplate mongoTemplate=(MongoTemplate)ac.getBean("mongoTemplate"); // long end0=System.currentTimeMillis(); // System.out.println("ApplicationContext init time is "+ (end0-begin0)/1000+"s"); // long begin = System.currentTimeMillis(); //// Query query = new Query(Criteria.where("id").is("22147037331623345536")); //// User user = mongoTemplate.findOne(query, User.class,"user"); // User userQuery= new User(); // userQuery.setId("1"); // userQuery.setAge(1); // userQuery.setName("name1"); // User user = mongoTemplate.findOne(getQuery(userQuery), User.class,"user"); // long end=System.currentTimeMillis(); // // System.out.println("user is "+ user.toString()+";time is "+ (end-begin)); } @Test public void test3(){ // long begin0 = System.currentTimeMillis(); // ApplicationContext ac=new ClassPathXmlApplicationContext(new String[]{"mongodb/mongodb-config.xml"}); // MongoTemplate mongoTemplate=(MongoTemplate)ac.getBean("mongoTemplate"); // long end0=System.currentTimeMillis(); // System.out.println("ApplicationContext init time is "+ (end0-begin0)/1000+"s"); // long begin = System.currentTimeMillis(); //// Query query = new Query(Criteria.where("id").is("22147037331623345536")); //// User user = mongoTemplate.findOne(query, User.class,"user"); // // List<User> userList = mongoTemplate.find(new Query(new Criteria("age").gt(100000).lt(100020)), User.class); // long end=System.currentTimeMillis(); // // int nSize = userList.size(); // System.out.println("time duration:"+(end-begin)); // System.out.println("userList size is " + nSize); // for (User user : userList) { // System.out.println(user.toString()); // } // } @Test public void test4() throws ParseException{ long begin0 = System.currentTimeMillis(); ApplicationContext ac=new ClassPathXmlApplicationContext(new String[]{"mongodb/mongodb-config.xml"}); MongoTemplate mongoTemplate=(MongoTemplate)ac.getBean("mongoTemplate"); long end0=System.currentTimeMillis(); System.out.println("ApplicationContext init time is "+ (end0-begin0)/1000+"s"); long begin = System.currentTimeMillis(); // Query query = new Query(Criteria.where("id").is("22147037331623345536")); // User user = mongoTemplate.findOne(query, User.class,"user"); Query query = new Query(); DateFormat df = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss"); Criteria criteriaid = Criteria.where("devid").is("99999999916"); Date timestart = df.parse("2016-8-10 10:20:00"); Date timeend = df.parse("2016-8-10 10:25:00"); Criteria criteriapt = Criteria.where("pt").gt(timestart).lt(timeend); query.addCriteria(criteriaid); query.addCriteria(criteriapt); List<Position> postionList = mongoTemplate.find(query, Position.class); long end=System.currentTimeMillis(); int nSize = postionList.size(); System.out.println("time duration:"+(end-begin)); System.out.println("postionList size is " + nSize); for (Position position : postionList) { System.out.println(position.toString()); } } }