最近使用了spring中的JdbcTemplate实现数据库的查询和插入操作,发现spring的JdbcTemplate 不象HibernateTemplate那么好,已经实现了分页功能。所以要自己实现,使用getJdbcTemplate().queryForList(string sql)得到的结果集是所有的。
如果你的查询有10000条记录,或者更多,速度肯定慢了,当然你可以通过resultset中的游标控制查询的起始和结束。我这里用的是Oracle数据库,使用伪列ROWNUM来实现分页。我的分页代码如下:
package com.deity.ranking.util;import java.util.List;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.support.JdbcDaoSupport;
/** * 分页函数 * * @author allenpan */public class Pagination extends JdbcDaoSupport{
public static final int NUMBERS_PER_PAGE = 10;
//一页显示的记录数
private int numPerPage;
//记录总数
private int totalRows;
//总页数
private int totalPages;
//当前页码
private int currentPage;
//起始行数
private int startIndex;
//结束行数
private int lastIndex;
//结果集存放List
private List resultList;
//JdbcTemplate jTemplate
private JdbcTemplate jTemplate;
/**
* 每页显示10条记录的构造函数,使用该函数必须先给Pagination设置currentPage,jTemplate初值
* @param sql oracle语句
*/
public Pagination(String sql){
if(jTemplate == null){
throw new IllegalArgumentException("com.deity.ranking.util.Pagination.jTemplate is null,please initial it first. ");
}else if(sql.equals("")){
throw new IllegalArgumentException("com.deity.ranking.util.Pagination.sql is empty,please initial it first. ");
}
new Pagination(sql,currentPage,NUMBERS_PER_PAGE,jTemplate);
}
/**分页构造函数
* @param sql 根据传入的sql语句得到一些基本分页信息
* @param currentPage 当前页
* @param numPerPage 每页记录数
* @param jTemplate JdbcTemplate实例
*/
public Pagination(String sql,int currentPage,int numPerPage,JdbcTemplate jTemplate){
if(jTemplate == null){
throw new IllegalArgumentException("com.deity.ranking.util.Pagination.jTemplate is null,please initial it first. ");
}else if(sql == null || sql.equals("")){
throw new IllegalArgumentException("com.deity.ranking.util.Pagination.sql is empty,please initial it first. ");
}
//设置每页显示记录数
setNumPerPage(numPerPage);
//设置要显示的页数
setCurrentPage(currentPage);
//计算总记录数
StringBuffer totalSQL = new StringBuffer(" SELECT count(*) FROM ( ");
totalSQL.append(sql);
totalSQL.append(" ) totalTable ");
//给JdbcTemplate赋值
setJdbcTemplate(jTemplate);
//总记录数
setTotalRows(getJdbcTemplate().queryForInt(totalSQL.toString()));
//计算总页数
setTotalPages();
//计算起始行数
setStartIndex();
//计算结束行数
setLastIndex();
System.out.println("lastIndex="+lastIndex);//////////////////
//构造oracle数据库的分页语句
StringBuffer paginationSQL = new StringBuffer(" SELECT * FROM ( ");
paginationSQL.append(" SELECT temp.* ,ROWNUM num FROM ( ");
paginationSQL.append(sql);
paginationSQL.append(" ) temp where ROWNUM <= " + lastIndex);
paginationSQL.append(" ) WHERE num > " + startIndex);
//装入结果集
setResultList(getJdbcTemplate().queryForList(paginationSQL.toString()));
}
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub }
public int getCurrentPage() {
return currentPage;
}
public void setCurrentPage(int currentPage) {
this.currentPage = currentPage;
}
public int getNumPerPage() {
return numPerPage;
}
public void setNumPerPage(int numPerPage) {
this.numPerPage = numPerPage;
}
public List getResultList() {
return resultList; }
public void setResultList(List resultList) {
this.resultList = resultList;
}
public int getTotalPages() {
return totalPages;
}
//计算总页数
public void setTotalPages() {
if(totalRows % numPerPage == 0){
this.totalPages = totalRows / numPerPage;
}else{
this.totalPages = (totalRows / numPerPage) + 1;
}
}
public int getTotalRows() {
return totalRows;
}
public void setTotalRows(int totalRows) {
this.totalRows = totalRows;
}
public int getStartIndex() {
return startIndex;
}
public void setStartIndex() {
this.startIndex = (currentPage - 1) * numPerPage;
}
public int getLastIndex() {
return lastIndex;
}
public JdbcTemplate getJTemplate() {
return jTemplate;
}
public void setJTemplate(JdbcTemplate template) {
jTemplate = template;
}
//计算结束时候的索引
public void setLastIndex() {
System.out.println("totalRows="+totalRows);///////////
System.out.println("numPerPage="+numPerPage);///////////
if( totalRows < numPerPage){
this.lastIndex = totalRows;
}else if((totalRows % numPerPage == 0) || (totalRows % numPerPage != 0 && currentPage < totalPages)){
this.lastIndex = currentPage * numPerPage;
}else if(totalRows % numPerPage != 0 && currentPage == totalPages){//最后一页
this.lastIndex = totalRows ;
}
}}在我的业务逻辑代码中:
/**
* find season ranking list from DC
* @param areaId 选手区域id
* @param rankDate 赛季
* @param category 类别
* @param characterName 角色名
* @return List
*/
public List findSeasonRankingList(Long areaId, int rankYear,int rankMonth,
Long categoryId,String characterName) {
//SQL语句
StringBuffer sql = new StringBuffer(" SELECT C.USERID userid,D.POSNAME posname,C.GAMEID gameid,C.AMOUNT amount,C.RANK rank FROM ");
//表 sql.append(" (SELECT B.USERID USERID,");
sql.append(" B.POSID POSID,");
sql.append(" A.DISTRICT_CODE DISTRICTCODE,");
sql.append(" A.GAMEID GAMEID,");
sql.append(" AMOUNT AMOUNT,");
sql.append(" RANK RANK ");
sql.append(" FROM TB_FS_RANK A ");
sql.append(" LEFT JOIN TB_CHARACTER_INFO B ");
sql.append(" ON A.DISTRICT_CODE = B.DISTRICT_CODE ");
sql.append(" AND A.GAMEID = B.GAMEID ");
//附加条件
if(areaId != null && areaId.intValue() != 0){
sql.append(" and A.DISTRICT_CODE = " + areaId.intValue());
}
if( rankYear > 1970 && rankMonth > 0){
//hql.append(" and sas.id.dt >= to_date('" + rankYear + "-" + rankMonth + "-01 00:00:00'," + "YYYY-MM-DD HH24:MI:SS");
//hql.append(" and sas.id.dt <= to_date('" + rankYear + "-" + rankMonth + "-" + TimeTool.findMaxDateInMonth(rankYear,rankMonth) + " 23:59:59'," + "YYYY-MM-DD HH24:MI:SS");
sql.append(" and A.DT = fn_time_convert(to_date('" + rankYear + "-" + rankMonth + "'," + "'YYYY-MM')) ");
}
if(categoryId != null && categoryId.intValue() != 0){
sql.append(" and A.CID = " + categoryId.intValue());
}
if(characterName != null && !characterName.trim().equals("")){
sql.append(" and A.GAMEID = '" + characterName.trim()+"' ");
}
sql.append(" ORDER BY RANK ASC) C ");
sql.append(" LEFT JOIN TB_FS_POSITION D ");
sql.append(" ON C.POSID = D.POSID ");
sql.append(" ORDER BY C.RANK ");
System.out.println("hql="+sql.toString());////////////////
//使用自己的分页程序控制结果集
Pagination pageInfo = new Pagination(sql.toString(),1,10,getJdbcTemplate());
return pageInfo.getResultList();
//return getJdbcTemplate().queryForList(sql.toString());
}
分享到:
相关推荐
使用Spring的JdbcTemplate实现分页功能
NULL 博文链接:https://wangking717.iteye.com/blog/774953
SpringJdbcTemplate封装工具包,包括规范model格式接口,封装SpringJdbcTemplate,实现分页,自适应多种数据库
1. Oracle 存储过程分页 2. Java 调用 Oracle 存储过程 3. Flex 分页
jdbcTemplate分页彻底解决,使用游标滚动,看了Spring源码才解决了问题
。。。
实现添加,修改,删除,批量删除,分页查询功能 要求: 通过Spring搭建底层框架,运用Spring jdbcTemplate进行数据底层操作 测试: 1.导入HomeWork.sql脚本 2.启动tomcat,访问...
适用于初学者理解spring、springmvc、jdbctemplate,使用oracle数据库,实现单表增删改查、条件查询和分页、文件上传
springmvc3的学习,使用springmvc+jdbcTemplate,并通过poi实现数据的导入和导出
经过历时一年的重大调整改版而成的,本书延续了上一版本追求深度,注重原理,不停留在技术表面的写作风格,力求使读者在熟练使用Spring的各项功能的同时,还能透彻理解Spring的内部实现,真正做到知其然知其所以然。...
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate; import com.flong.commons.lang.exception.DaoAccessException; import ...
BaseDao,jdbcTemplate,Spring AOP 事务 MVC分层 BaseDao,jdbcTemplate,Spring AOP,SpringMVC,JSP 事务
分页 |— Pagination 主键策略 |— UUID |— INCREMENT 注:Hibernate 有冬眠之意,Squirrel ( 松鼠 ) 具有冬眠的习性,项目中众多类名称沿袭自 Hibernate,如 Criteria、Criterion、Restrictions 等。 Query ...
经过历时一年的重大调整改版而成的,本书延续了上一版本追求深度,注重原理,不停留在技术表面的写作风格,力求使读者在熟练使用Spring的各项功能的同时,还能透彻理解Spring的内部实现,真正做到知其然知其所以然。...
234 <br>10.5.2.5 用Spring 2.0 的@Transactional标注解决事务提交问题(最佳方案) 238 <br>10.5.2.6 使用 HibernateTemplate 实现分页查询... 241 <br>10.6 小结... 242 <br>10.7 参考资料... 242...
actuator(监控)、admin(可视化监控)、logback(日志)、aopLog(通过AOP记录...JdbcTemplate(通用JDBC操作数据库)、JPA(强大的ORM框架)、mybatis(强大的ORM框架)、通用Mapper(快速操作Mybatis)、PageHelper(通用的Mybatis...
spring-boot-demo 项目介绍 本教程是Spring Boot使用和集成...[Spring Boot:实现MyBatis分页] [Spring Boot:集成Druid数据源] [Spring Boot:实现MyBatis动态数据源] [Spring Boot:实现MyBatis动态创建表] [Spring B
spring boot 的项目,该项目已成功集成 actuator(监控)、admin(可视化监控)、logback(日志)、aopLog(通过AOP记录web请求日志)、统一异常处理(json级别和页面级别)、freemarker(模板引擎)、thymeleaf(模板引擎)、...
模板引擎)、JdbcTemplate( 通用JDBC操作数据库)、JPA( 强大的ORM框架) 、mybatis( 强大的ORM框架)、通用Mapper( 快速操作Mybatis)、PageHelper( 通用的Mybatis分页插件)、mybatis-plus( 快速操作Mybatis)、BeetlSQL...
一个基于Spring依赖注入特性的二级插件的模型,里面主要封装了如下特性:数据库连接池(常用的4-5个)、分页查询(oracle,mysql,sqlserver等)、数据转码(空值、特定、列名等)、数据导出(Pdf,excel,html,...