zoukankan      html  css  js  c++  java
  • springmvc+mongodb+maven 项目测试代码

    你看我有一篇文章配置,或许还会有。mongodb性能测试结果。一个“快”字

    源代码包,请留下邮箱

    代码结构图


    直接上代码

    BaseDao.java

    package com.yiyuwanglu.basecore.dao;
    
    import java.util.List;
    
    public interface BaseDao {
    
    	<T> T findById(Class<T> entityClass, String id);
    
    	<T> List<T> findAll(Class<T> entityClass);
    
    	void remove(Object obj);
    
    	void add(Object obj);
    
    	void saveOrUpdate(Object obj);
    }
    


    MongoDBBaseDao.java

    package com.yiyuwanglu.basecore.dao.mongodb;
    
    import java.util.Collection;
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.data.mongodb.core.MongoTemplate;
    import org.springframework.data.mongodb.core.query.Query;
    import org.springframework.stereotype.Repository;
    
    import com.yiyuwanglu.basecore.dao.BaseDao;
    import com.yiyuwanglu.basecore.page.Page;
    
    /**
     * mongodb数据泛型dao类
     * 
     * @author hjn
     * @version 1.0 2014-09-16
     */
    @Repository(value = "mongoDBBaseDao")
    public class MongoDBBaseDao implements BaseDao {
    	@Autowired
    	@Qualifier("mongoTemplate")
    	protected MongoTemplate mongoTemplate;
    
    	/**
    	 * 依据主键id返回对象
    	 * 
    	 * @param id
    	 *            唯一标识
    	 * @return T 对象
    	 */
    	public <T> T findById(Class<T> entityClass, String id) {
    		return this.mongoTemplate.findById(id, entityClass);
    	}
    
    	/**
    	 * 依据类获取所有的对象列表
    	 * 
    	 * @param entityClass
    	 *            返回类型
    	 * @return List<T> 返回对象列表
    	 */
    	public <T> List<T> findAll(Class<T> entityClass) {
    		return this.mongoTemplate.findAll(entityClass);
    	}
    
    	/**
    	 * 删除一个对象
    	 * 
    	 * @param obj
    	 *            要删除的Mongo对象
    	 */
    	public void remove(Object obj) {
    		this.mongoTemplate.remove(obj);
    	}
    
    	/**
    	 * 加入对象
    	 * 
    	 * @param obj
    	 *            要加入的Mongo对象
    	 */
    	public void add(Object obj) {
    		this.mongoTemplate.insert(obj);
    
    	}
    
    	/**
    	 * 改动对象
    	 * 
    	 * @param obj
    	 *            要改动的Mongo对象
    	 */
    	public void saveOrUpdate(Object obj) {
    		this.mongoTemplate.save(obj);
    	}
    
    	/**
    	 * 查询并分页
    	 * 
    	 * @param entityClass
    	 *            对象类型
    	 * @param query
    	 *            查询条件
    	 * @param page
    	 *            分页
    	 * @return
    	 */
    	public <T> List<T> findByQuery(Class<T> entityClass, Query query, Page page) {
    		Long count = this.count(entityClass, query);
    		page.setCount(count);
    		int pageNumber = page.getCurrent();
    		int pageSize = page.getPageCount();
    		query.skip((pageNumber - 1) * pageSize).limit(pageSize);
    		return this.mongoTemplate.find(query, entityClass);
    	}
    
    	/**
    	 * 
    	 * @param entityClass
    	 *            查询对象
    	 * @param query
    	 *            查询条件
    	 * @return
    	 */
    	public <T> Long count(Class<T> entityClass, Query query) {
    		return this.mongoTemplate.count(query, entityClass);
    	}
    	
    	/**
    	 * 批量插入
    	 * @param entityClass 对象类
    	 * @param collection  要插入的对象集合
    	 */
    	public <T> void addCollection(Class<T> entityClass, Collection<T> collection){
    		this.mongoTemplate.insert(collection, entityClass);
    	}
    
    	public MongoTemplate getMongoTemplate() {
    		return mongoTemplate;
    	}
    	
    	
    }
    

    Page.java

    package com.yiyuwanglu.basecore.page;
    
    import java.io.IOException;
    import java.io.Serializable;
    
    import javax.servlet.jsp.JspException;
    import javax.servlet.jsp.JspWriter;
    import javax.servlet.jsp.tagext.SimpleTagSupport;
    
    
    public class Page extends SimpleTagSupport implements Serializable {
    
        private static final long serialVersionUID = 1L;//序列号
        private Integer current;//当前页码
        private Long count;//记录总数
        private Integer pageCount;//每页记录数
        private String path;//页面链接
        private String param;//传入的參数
        private boolean notQueryCount = false;//为false在翻页时查询记录总数。默认false
    
        public Page() {
            this.current = 1; // 默认第一页
            this.count = 0L; // 共多少条记录
            this.pageCount = 10; // 默认每页10条记录
        }
    
        @Override
        public void doTag() throws JspException, IOException {
            int pageSize = (int) (this.count / this.pageCount + (this.count % this.pageCount > 0 ? 1 : 0));//共多少页
            //显示当前页和总页数
            JspWriter out = this.getJspContext().getOut();//指定输入流,用于页面输出分页信息
            StringBuffer sb = new StringBuffer();//构建StringBuffer对象,用户拼接分页标签
            sb.append("<div class="page">");
            sb.append("<ul>");
            //假设当前页在第一页,则首页和上一页没有超链接
            if (this.current == 1) {
                sb.append("<li class="disabled">首页</li><li class="disabled">上一页</li>");
            } else {
                sb.append("<li><a href="");
                sb.append(this.path);
                sb.append("?current=");
                sb.append(1);
                if (this.param != null && !"".equals(this.param)) {
                    sb.append("&");
                    sb.append(this.param);
                }
                sb.append("">首页</a></li>");
                sb.append("<li><a href="");
                sb.append(this.path);
                sb.append("?

    current="); sb.append(this.current - 1); if (this.param != null && !"".equals(this.param)) { sb.append("&"); sb.append(this.param); } sb.append("">上一页</a></li>"); } //以下的代码显示页码。当前页在中间位置 if (pageSize <= 10) { for (int i = 1; i <= pageSize; i++) { //假设页数小于等于10页,则所有显示 if (i == this.current) {//假设页码等于当前页,则该页数没有超链接 sb.append("<li class="current">"); sb.append(i); sb.append("</li>"); } else {//否则给出超链接 sb.append("<li><a href=""); sb.append(this.path); sb.append("?

    current="); sb.append(i); if (this.param != null && !"".equals(this.param)) { sb.append("&"); sb.append(this.param); } sb.append("">"); sb.append(i); sb.append("</a></li>"); } } } else {//假设大于10页。则从当前页为中心仅仅显示当中10页 int index = 1; if (this.current > 4) {//而且假设当前页大于4页,从当前页前4页開始显示10个页数 if (this.current + 4 >= pageSize) {//假设当前页+4 >= 总页数。最后10页所有显示出来 for (int j = pageSize - 9; j <= pageSize; j++) { if (j == this.current) {//假设页码等于当前页。则该页数没有超链接 sb.append("<li class="current">"); sb.append(j); sb.append("</li>"); } else {//否则给定超链接 sb.append("<li><a href=""); sb.append(this.path); sb.append("?current="); sb.append(j); if (this.param != null && !"".equals(this.param)) { sb.append("&"); sb.append(this.param); } sb.append("">"); sb.append(j); sb.append("</a></li>"); } } } else { for (int j = this.current - 4; j <= pageSize; j++) { if (j == this.current) {//假设页码等于当前页,则该页数没有超链接 sb.append("<li class="current">"); sb.append(j); sb.append("</li>"); } else {//否则给定超链接 sb.append("<li><a href=""); sb.append(this.path); sb.append("?current="); sb.append(j); if (this.param != null && !"".equals(this.param)) { sb.append("&"); sb.append(this.param); } sb.append("">"); sb.append(j); sb.append("</a></li>"); } index++; if (index > 10) {//假设循环到10次则退出循环 break; } } } } else { for (int i = 1; i <= pageSize; i++) { //假设页数小于等于10页,则所有显示 if (i == this.current) {//假设页码等于当前页,则该页数没有超链接 sb.append("<li class="current">"); sb.append(i); sb.append("</li>"); } else {//否则给出超链接 sb.append("<li><a href=""); sb.append(this.path); sb.append("?current="); sb.append(i); if (this.param != null && !"".equals(this.param)) { sb.append("&"); sb.append(this.param); } sb.append("">"); sb.append(i); sb.append("</a></li>"); } index++; if (index > 10) { break; } } } } //假设当前页是最后一页,则末页和下一页没有超链接 if (this.current.equals(pageSize) || this.count == 0) { sb.append("<li class="disabled">下一页</li><li class="disabled">末页</li>"); } else { sb.append("<li><a href=""); sb.append(this.path); sb.append("?current="); sb.append(this.current + 1); if (this.param != null && !"".equals(this.param)) { sb.append("&"); sb.append(this.param); } sb.append("">下一页</a></li>"); sb.append("<li><a href=""); sb.append(this.path); sb.append("?current="); sb.append(pageSize); if (this.param != null && !"".equals(this.param)) { sb.append("&"); sb.append(this.param); } sb.append("">末页</a></li>"); } sb.append("</ul>"); sb.append("</div>"); out.print(sb); } /** * 获取总记录条数 * * @return */ public Long getCount() { return this.count; } /** * 设置总记录条数 * * @param count */ public void setCount(Long count) { this.count = count; } /** * 获取当前第几页 * * @return */ public Integer getCurrent() { return this.current; } /** * 设置当前第几页 * * @param current */ public void setCurrent(Integer current) { try { if (current <= 0) { this.current = 1; } else { this.current = current; } } catch (Exception e) { this.current = 1; } } /** * 获取每页多少条记录 * * @return */ public Integer getPageCount() { return this.pageCount; } /** * 设置每页多少条记录 * * @param pageCount */ public void setPageCount(Integer pageCount) { this.pageCount = pageCount; } /** * 获取URI地址 * * @return */ public String getPath() { return path; } /** * 设置URI地址 * * @param path */ public void setPath(String path) { this.path = path; } /** * 获取參数值 * * @return */ public String getParam() { return param; } /** * 设置參数值 * * @param param */ public void setParam(String param) { String[] x = param.split("&"); StringBuilder sb = new StringBuilder(); for (int i = 0; i < x.length; i++) { String[] y = x[i].split("="); if (y.length > 1 && !"".equals(y[1].trim())) { sb.append(x[i]); sb.append("&"); } } this.param = sb.toString().substring(0, sb.toString().lastIndexOf("&")); } /** * 获取总页数 * * @return */ public int getPages() { if (this.count % this.pageCount == 0) { return (int) (this.count / this.pageCount); } else { return (int) (this.count / this.pageCount + 1); } } /** * 是否为第一页 * * @return */ public boolean firstEnable() { return previoEnable(); } /** * 是否为最后一页 * * @return */ public boolean lastEnable() { return nextEnable(); } /** * 是否有下一页 * * @return */ public boolean nextEnable() { return this.current * this.pageCount < this.count; } /** * 是否有上一页 * * @return */ public boolean previoEnable() { return this.current > 1; } public boolean isNotQueryCount() { return this.notQueryCount; } public void setNotQueryCount(boolean notQueryCount) { this.notQueryCount = notQueryCount; } /** * 获取任一页第一条数据在数据集的位置. * * @param pageNo 从1開始的页号 * @param pageSize 每页记录条数 * @return 该页第一条数据 */ public int getStartOfPage(long pageNo, long pageSize) { return (int) ((pageNo - 1) * pageSize); } }


    User.java

    package com.yiyuwanglu.test.entity;
    
    import java.util.Date;
    
    import org.springframework.data.mongodb.core.mapping.Document;
    
    @Document
    public class User {
    
    	private String id;
    	private String username;
    	private int age;
    	private Date createTime;
    
    	public User() {
    
    	}
    
    	public User(String username, int age, Date createTime) {
    		super();
    		this.username = username;
    		this.age = age;
    		this.createTime = createTime;
    	}
    
    	public String getId() {
    		return id;
    	}
    
    	public void setId(String id) {
    		this.id = id;
    	}
    
    	public String getUsername() {
    		return username;
    	}
    
    	public void setUsername(String username) {
    		this.username = username;
    	}
    
    	public int getAge() {
    		return age;
    	}
    
    	public void setAge(int age) {
    		this.age = age;
    	}
    
    	public Date getCreateTime() {
    		return createTime;
    	}
    
    	public void setCreateTime(Date createTime) {
    		this.createTime = createTime;
    	}
    
    }
    

    BaseTest.java

    package basetest;
    
    import org.junit.runner.RunWith;
    import org.springframework.test.context.ContextConfiguration;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    
    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration(locations={"classpath:config/spring/applicationContext.xml"})
    public class BaseTest {
       
    }
    
    TestBaseDao.java

    package basetest.dao;
    
    import java.util.ArrayList;
    import java.util.Date;
    import java.util.List;
    
    import javax.annotation.Resource;
    
    import org.junit.Test;
    import org.springframework.data.mongodb.core.query.Criteria;
    import org.springframework.data.mongodb.core.query.Query;
    
    import basetest.BaseTest;
    
    import com.yiyuwanglu.basecore.dao.mongodb.MongoDBBaseDao;
    import com.yiyuwanglu.test.entity.User;
    
    public class TestBaseDao extends BaseTest {
    
    	@Resource(name = "mongoDBBaseDao")
    	MongoDBBaseDao mongoDBBaseDao;
    
    	/**
    	 * 插入单条数据。id自己定义
    	 */
    	public void testAdd() {
    		User user = new User();
    		Date creatTime = new Date();
    		user.setCreateTime(creatTime);
    		user.setAge(10);
    		user.setUsername("福東江a");
    		this.mongoDBBaseDao.add(user);
    	}
    
    	/**
    	 * 插入100万条数据,id自己定义
    	 */
    	@Test
    	public void testAddCollection() {
    		List<User> userList = new ArrayList<User>();
    		for (int j = 0; j < 10; j++) {
    			for (int i = 0; i < 100000; i++) {
    				User user = new User();
    				Date creatTime = new Date();
    				user.setCreateTime(creatTime);
    				user.setAge(10);
    				user.setUsername("册南");
    				userList.add(user);
    			}
    		}
    		this.mongoDBBaseDao.add(userList);
    	}
    
    	@Test
    	public void testFindAll() {
    		List<User> userList = this.mongoDBBaseDao.findAll(User.class);
    		for (User user : userList) {
    			System.out.println("id:" + user.getId() + " username:" + user.getUsername() + "   age:" + user.getAge());
    		}
    		System.out.println("获取所有的数据----------------------");
    	}
    
    	@Test
    	public void testFindById() {
    		User user = this.mongoDBBaseDao.findById(User.class, "1234567");
    		System.out.println(user.getUsername());
    		System.out.println("获取单个对象----------------------");
    	}
    
    	@Test
    	public void testUpdate() {
    		User user = this.mongoDBBaseDao.findById(User.class, "1234567");
    		user.setUsername("反倒是淮");
    		this.mongoDBBaseDao.saveOrUpdate(user);
    		User newUser = this.mongoDBBaseDao.findById(User.class, "1234567");
    		System.out.println(newUser.getUsername());
    		System.out.println("改动数据成功");
    		this.mongoDBBaseDao.saveOrUpdate(user);
    	}
    
    	@Test
    	public void testRemove() {
    		User user = this.mongoDBBaseDao.findById(User.class, "1234567");
    		this.mongoDBBaseDao.remove(user);
    		User oldUser = this.mongoDBBaseDao.findById(User.class, "1234567");
    		if (oldUser == null) {
    			System.out.println(oldUser == null);
    			System.out.println("删除对象成功");
    		}
    		this.mongoDBBaseDao.add(user);
    	}
    
    	@Test
    	public void testCount() {
    		Query query = new Query();
    		Criteria criteria = new Criteria();
    		criteria.and("username").is("福東");
    		query.addCriteria(criteria);
    		long total = this.mongoDBBaseDao.count(User.class, query);
    		System.out.println("用户总数:" + total);
    	}
    	
    	
    }
    


    版权声明:本文博客原创文章,博客,未经同意,不得转载。

  • 相关阅读:
    不用再去找rem了,你想要的rem都在这
    linux下ftp配置文件详解
    Linux chmod命令修改文件与文件夹权限命令代码
    如何在linux下开启FTP服务
    解决ftp客户端连接验证报错Server sent passive reply with unroutable address. Using server address instead
    预定义编译器宏
    类的成员变量修饰 const 和static
    【转】svn http://提示svn: Unrecognized URL scheme错误
    EVEREST Ultimate Edition 5.50 正式版 序列号
    [转]Linux下查看文件和文件夹大小
  • 原文地址:https://www.cnblogs.com/lcchuguo/p/4716059.html
Copyright © 2011-2022 走看看