`

用Spring的JdbcTemplate实现分页功能

阅读更多
最近使用了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实现分页功能

    使用Spring的JdbcTemplate实现分页功能

    jdbcTemplate分页彻底解决,使用游标滚动

    总结起来,使用JdbcTemplate的游标滚动技术,我们可以实现高效、低内存消耗的分页,这对于处理大量数据的系统来说至关重要。同时,这种方式也使得代码更加灵活,能够适应各种数据库的差异,提高了程序的可移植性。

    Spring jdbctemplate + mysql 分页封装

    综上所述,Spring JdbcTemplate结合MySQL的分页查询封装涉及到的主要知识点有:Spring的JdbcTemplate用法、MySQL的分页查询(LIMIT和OFFSET)、结果集映射、分页结果对象的构建、以及代码封装与复用。通过这些技术,...

    SpringJdbcTemplate封装工具类

    SpringJdbcTemplate能够自适应多种数据库,这是因为它的底层使用了JDBC的规范,而不同的数据库厂商都实现了JDBC API。这使得你可以使用相同的代码来连接MySQL、Oracle、PostgreSQL等不同类型的数据库,只需更换相应...

    Oracle + jdbcTemplate + Spring + Java + Flex 实现分页

    ### Oracle + jdbcTemplate + Spring + Java + Flex 实现分页 #### 一、Oracle存储过程分页 在Oracle数据库中,为了实现高效的分页查询,通常会采用存储过程的方式来完成。这种方式能够有效地减少网络传输的数据量...

    spring jdbctemplate实例

    此外,JdbcTemplate还提供了其他高级功能,如批量操作、分页查询、存储过程调用等。同时,它也支持PreparedStatement,可以防止SQL注入攻击。对于性能要求较高的互联网应用,JdbcTemplate的这些特性使其成为理想的...

    Oracle + jdbcTemplate + Spring + Java + Flex 实现分页.docx

    本文档主要讨论如何利用Oracle存储过程、jdbcTemplate(Spring框架的一个组件)以及Flex前端实现这一功能。 首先,Oracle存储过程是实现分页的关键部分。在Oracle中,可以通过创建存储过程来动态构造SQL语句,以...

    Spring--JdbcTemplate.pdf

    标签"spring 尚硅谷 JdbcTemplate"说明这个文档可能是由"尚硅谷"发布,"尚硅谷"是一家专注于IT教育和培训的机构,他们提供的文档可能会对Spring框架及其JdbcTemplate的使用有详细的讲解和实例。 在介绍JdbcTemplate...

    ssh2分页查询

    - **设计DAO接口与实现**:定义用于分页查询的DAO接口,然后使用Hibernate或Spring的JdbcTemplate实现这些方法。 - **编写Service层**:在Service层调用DAO接口的方法,处理业务逻辑,如计算总页数等。 - **创建...

    JDBCTemplate+JavaPOJO实现通用DAO

    6. **定制化操作**:虽然JDBCTemplate提供了很多通用功能,但有时仍需编写自定义SQL,这时可以使用`NamedParameterJdbcTemplate`,它支持参数化的SQL,使代码更加清晰。 7. **异常处理**:JDBCTemplate会自动处理...

    使用spring框架,实现单表增删改查、条件查询和分页、文件上传

    在本文中,我们将深入探讨如何使用Spring框架,特别是Spring MVC和JdbcTemplate,来实现一个功能齐全的数据操作系统,包括单表的增删改查、条件查询以及分页功能,并涉及文件上传。对于初学者来说,这是一个很好的...

    匹配实体类的实现了大部分功能分页 网页分页

    这里我们关注的标题是“匹配实体类的实现了大部分功能分页 网页分页”,描述中提到了使用了数据库MySQL以及Spring 3.0框架来实现这一功能。下面将详细讨论这些知识点。 1. 分页原理与实现: 分页通常由两个关键...

    SpringMvc+jdbcTemplate+mysql(注解)

    Spring MVC支持动态页面参数,可以配合JdbcTemplate的查询方法实现分页。开发者可以通过设置SQL的LIMIT和OFFSET子句来获取特定范围的数据,然后传递这些数据到视图进行渲染。同时,可以使用Spring提供的Pageable接口...

    easyframework-data:基于 Spring JdbcTemplate 的数据访问框架

    总之,EasyFramework-Data 是一个旨在简化数据库访问的框架,它借助Spring JdbcTemplate的强大功能,提供了便捷、安全的数据操作接口。无论你是新手还是经验丰富的开发者,都能从中受益,提高开发效率。

    Hibernate+spring+struts2分页

    在实际项目中,"spring07"可能包含了一些关于Spring框架的第七个版本相关的配置文件或代码示例,这些内容可能涉及Spring的事务管理、AOP配置、...深入地理解如何在Spring环境中整合Hibernate和Struts2实现分页功能...

    spring mvc学习+数据分页+数据导入导出

    例如,使用Spring Data JPA的Pageable接口可以方便地实现分页查询。 数据导入导出部分,主要涉及Apache POI库,这是一个用于处理Microsoft Office格式文件的Java库。POI可以用来读写Excel文件,非常适合在Web应用中...

    Spring登录Demo

    实现添加,修改,删除,批量删除,分页查询功能 要求: 通过Spring搭建底层框架,运用Spring jdbcTemplate进行数据底层操作 测试: 1.导入HomeWork.sql脚本 2.启动tomcat,访问...

    SpringMVC+JDBC:分页示例

    这个例子展示了如何使用SpringMVC和JDBC实现分页功能。注意,实际项目中可能还需要考虑其他因素,如错误处理、安全性、性能优化等。此外,随着NoSQL数据库的普及和ORM框架的流行,如Hibernate和MyBatis,开发者在...

    使用分页控件(page_targetlib)实现分页

    本文将详细介绍如何使用名为`page_targetlib`的分页控件来实现高效、简洁的分页功能。 `page_targetlib`是一个Java库,它提供了一个名为`page_targetlib.jar`的可执行文件,这个文件包含了实现分页功能所需的所有类...

Global site tag (gtag.js) - Google Analytics