1.分頁實現類

SpringDataPageable.java

package com.ceair.dao;

import java.io.Serializable;

import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;

public class SpringDataPageable implements Serializable, Pageable {
	private static final long serialVersionUID = 1;
	// 當前頁
	private Integer pagenumber = 1;
	// 當前頁面條數
	private Integer pagesize = 1000;
	// 排序條件
	private Sort sort;

	// 當前頁面
	@Override
	public int getPageNumber() {
		return getPagenumber();
	}

	// 每一頁顯示的條數
	@Override
	public int getPageSize() {
		return getPagesize();
	}

	// 第二頁所需要增加的數量
	@Override
	public int getOffset() {
		return (getPagenumber() - 1) * getPagesize();
	}

	@Override
	public Sort getSort() {
		return sort;
	}

	public Integer getPagenumber() {
		return pagenumber;
	}

	public void setPagenumber(Integer pagenumber) {
		this.pagenumber = pagenumber;
	}

	public Integer getPagesize() {
		return pagesize;
	}

	public void setPagesize(Integer pagesize) {
		this.pagesize = pagesize;
	}

	public void setSort(Sort sort) {
		this.sort = sort;
	}

	@Override
	public Pageable first() {
		return null;
	}

	@Override
	public boolean hasPrevious() {
		return false;
	}

	@Override
	public Pageable next() {
		return null;
	}

	@Override
	public Pageable previousOrFirst() {
		return null;
	}
}
 

package com.ceair.dao;

import org.springframework.data.domain.Page;
import org.springframework.data.domain.Sort;
import org.springframework.data.mongodb.core.query.Query;

/**
 * Title: 分頁 <br/>
 * Description: <br/>
 * 
 * @author: wangzs <br/>
 * @date: 2017年5月10日
 */
public interface PageDao<E> {
	/**
	 * @param pageNum
	 *            開始頁
	 * @param pagesize
	 *            每頁大小
	 * @param query
	 *            查詢條件
	 * @param sort
	 *            排序條件
	 * @param collections
	 *            集合名字
	 * @return
	 */
	public Page<E> paginationQuery(Integer pageNum, Integer pagesize, Query query, Sort sort, Class collections);
}
 

package com.ceair.dao;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageImpl;
import org.springframework.data.domain.Sort;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Query;

/**
 * Title: 分頁 impl <br/>
 * Description: <br/>
 * 
 * @author: wangzs <br/>
 * @date: 2017年5月10日
 */
public class PageDaoImpl<E> implements PageDao<E> {
	@Autowired
	private MongoTemplate mongoTemplate;

	/**
	 * @param pageNum
	 *            開始頁
	 * @param pagesize
	 *            每頁大小
	 * @param query
	 *            查詢條件
	 * @param sort
	 *            排序條件
	 * @param collections
	 *            集合名字
	 * @return
	 */
	@Override
	public Page<E> paginationQuery(Integer pageNum, Integer pagesize, Query query, Sort sort, Class collections) {
		SpringDataPageable pageable = new SpringDataPageable();
		// 開始頁
		pageable.setPagenumber(pageNum);
		// 每頁條數
		pageable.setPagesize(pagesize);
		// 排序
		pageable.setSort(sort);
		// 查詢出一共的條數
		Long count = mongoTemplate.count(query, collections);
		// 查詢
		List<E> list = mongoTemplate.find(query.with(pageable), collections);
		// 將集合與分頁結果封裝
		Page<E> pagelist = new PageImpl<E>(list, pageable, count);
		return pagelist;
	}

}
 

2.測試實體bean

IndividualTemp.java

package com.ceair.bean;

import java.util.Date;

public class IndividualTemp {

	public IndividualTemp() {
		super();
	}

	public IndividualTemp(String partyId, boolean etermToTsdata, boolean tsdataToCmp, Date lastUpdateTime) {
		super();
		this.partyId = partyId;
		this.etermToTsdata = etermToTsdata;
		this.tsdataToCmp = tsdataToCmp;
		this.lastUpdateTime = lastUpdateTime;
	}

	private String partyId;
	private boolean etermToTsdata;// 根據黑屏重新整理tsdata資料標識
	private boolean tsdataToCmp;// 根據tsdata重新整理cmp行程標識
	private Date lastUpdateTime;

	public String getPartyId() {
		return partyId;
	}

	public void setPartyId(String partyId) {
		this.partyId = partyId;
	}

	public boolean isEtermToTsdata() {
		return etermToTsdata;
	}

	public void setEtermToTsdata(boolean etermToTsdata) {
		this.etermToTsdata = etermToTsdata;
	}

	public boolean isTsdataToCmp() {
		return tsdataToCmp;
	}

	public void setTsdataToCmp(boolean tsdataToCmp) {
		this.tsdataToCmp = tsdataToCmp;
	}

	public Date getLastUpdateTime() {
		return lastUpdateTime;
	}

	public void setLastUpdateTime(Date lastUpdateTime) {
		this.lastUpdateTime = lastUpdateTime;
	}

	@Override
	public String toString() {
		return "IndividualTemp [partyId=" + partyId + ", etermToTsdata=" + etermToTsdata + ", tsdataToCmp=" + tsdataToCmp + ", lastUpdateTime="
				+ lastUpdateTime + "]";
	}

}

3.測試類

IndividualTempPageTest.java

package com.ceair.data;

import java.util.ArrayList;
import java.util.List;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Sort.Direction;
import org.springframework.data.domain.Sort.Order;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import com.ceair.bean.Individual;
import com.ceair.bean.IndividualTemp;
import com.ceair.dao.PageDao;

/**
 * Title: IndividualTemp分頁測試 <br/>
 * Description: <br/>
 * 
 * @author: wangzs <br/>
 * @date: 2017年5月10日
 */
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = { //
		"classpath*:beans/applicationContext-*.xml", //
		"classpath*:spring/applicationContext-*.xml"//
})
public class IndividualTempPageTest {
	private static final Logger logger = LoggerFactory.getLogger(IndividualTempPageTest.class);
	@Autowired
	private PageDao<IndividualTemp> pageDao;

	@Test
	public void testCopyIndividual() {
		Query query = new Query();
		List<Order> orders = new ArrayList<Order>(); // 排序
		orders.add(new Order(Direction.ASC, "partyId"));
		Sort sort = new Sort(orders);

		for (int i = 1; i < 1500; i++) {
			Page<IndividualTemp> pages = pageDao.paginationQuery(i, 10, query, sort, IndividualTemp.class);
			for (IndividualTemp temp : pages) {
				System.out.println(temp);
			}
			System.out.println("page=" + i);
			logger.info("page=" + i);
		}
	}
}