JSP分页技术实现2(转)
summary:使用工具类实现通用分页处理
author: evan_zhao
email: evan_zhao@hotmail.com
[code]
///////////////////////////////////
//
// PagedStatement.java
// author: evan_zhao@hotmail.com
//
///////////////////////////////////
package page;
import foo.DBUtil;
import java.math.java/math/BigDecimal.java.html" target="_blank">BigDecimal;
import java.util.java/util/List.java.html" target="_blank">List;
import java.util.java/util/Iterator.java.html" target="_blank">Iterator;
import java.util.java/util/Collections.java.html" target="_blank">Collections;
import java.sql.java/sql/Connection.java.html" target="_blank">Connection;
import java.sql.java/sql/SQLException.java.html" target="_blank">SQLException;
import java.sql.java/sql/ResultSet.java.html" target="_blank">ResultSet;
import java.sql.java/sql/Statement.java.html" target="_blank">Statement;
import java.sql.java/sql/PreparedStatement.java.html" target="_blank">PreparedStatement;
import java.sql.java/sql/Timestamp.java.html" target="_blank">Timestamp;
import javax.sql.javax/sql/RowSet.java.html" target="_blank">RowSet;
/**
* <p>Title: 分页查询</p>
* <p>Description: 根据查询语句和页码查询出当页数据</p>
* <p>Copyright: Copyright (c) 2002</p>
* @author evan_zhao@hotmail.com
* @version 1.0
*/
public abstract class PagedStatement {
public final static int MAX_PAGE_SIZE = Page.MAX_PAGE_SIZE;
protected java/lang/String.java.html" target="_blank">String countSQL, querySQL;
protected int pageNo,pageSize,startIndex,totalCount;
protected javax.sql.javax/sql/RowSet.java.html" target="_blank">RowSet rowSet;
protected RowSetPage rowSetPage;
private java/util/List.java.html" target="_blank">List boundParams;
/**
* 构造一查询出所有数据的PageStatement
* @param sql query sql
*/
public PagedStatement(java/lang/String.java.html" target="_blank">String sql){
this(sql,1,MAX_PAGE_SIZE);
}
/**
* 构造一查询出当页数据的PageStatement
* @param sql query sql
* @param pageNo 页码
*/
public PagedStatement(java/lang/String.java.html" target="_blank">String sql, int pageNo){
this(sql, pageNo, Page.DEFAULT_PAGE_SIZE);
}
/**
* 构造一查询出当页数据的PageStatement，并指定每页显示记录条数
* @param sql query sql
* @param pageNo 页码
* @param pageSize 每页容量
*/
public PagedStatement(java/lang/String.java.html" target="_blank">String sql, int pageNo, int pageSize){
this.pageNo = pageNo;
this.pageSize = pageSize;
this.startIndex = Page.getStartOfAnyPage(pageNo, pageSize);
this.boundParams = java/util/Collections.java.html" target="_blank">Collections.synchronizedList(new java.util.java/util/LinkedList.java.html" target="_blank">LinkedList());
this.countSQL = "select count(*) from ( " + sql +") ";
this.querySQL = intiQuerySQL(sql, this.startIndex, pageSize);
}
/**
*生成查询一页数据的sql语句
*@param sql 原查询语句
*@startIndex 开始记录位置
*@size 需要获取的记录数
*/
protected abstract java/lang/String.java.html" target="_blank">String intiQuerySQL(java/lang/String.java.html" target="_blank">String sql, int startIndex, int size);
/**
*使用给出的对象设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param obj 包含参数值的对象
*/
public void setObject(int index, java/lang/Object.java.html" target="_blank">Object obj) throws java/sql/SQLException.java.html" target="_blank">SQLException{
BoundParam bp = new BoundParam(index, obj);
boundParams.remove(bp);
boundParams.add( bp);
}
/**
*使用给出的对象设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param obj 包含参数值的对象
*@param targetSqlType 参数的数据库类型
*/
public void setObject(int index, java/lang/Object.java.html" target="_blank">Object obj, int targetSqlType) throws java/sql/SQLException.java.html" target="_blank">SQLException{
BoundParam bp = new BoundParam(index, obj, targetSqlType);
boundParams.remove(bp);
boundParams.add(bp );
}
/**
*使用给出的对象设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param obj 包含参数值的对象
*@param targetSqlType 参数的数据库类型(常量定义在java.sql.Types中)
*@param scale 精度，小数点后的位数
* （只对targetSqlType是Types.NUMBER或Types.DECIMAL有效，其它类型则忽略）
*/
public void setObject(int index, java/lang/Object.java.html" target="_blank">Object obj, int targetSqlType, int scale) throws java/sql/SQLException.java.html" target="_blank">SQLException{
BoundParam bp = new BoundParam(index, obj, targetSqlType, scale) ;
boundParams.remove(bp);
boundParams.add(bp);
}
/**
*使用给出的字符串设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param str 包含参数值的字符串
*/
public void setString(int index, java/lang/String.java.html" target="_blank">String str)throws java/sql/SQLException.java.html" target="_blank">SQLException{
BoundParam bp = new BoundParam(index, str) ;
boundParams.remove(bp);
boundParams.add(bp);
}
/**
*使用给出的字符串设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param timestamp 包含参数值的时间戳
*/
public void setTimestamp(int index, java/sql/Timestamp.java.html" target="_blank">Timestamp timestamp)throws java/sql/SQLException.java.html" target="_blank">SQLException{
BoundParam bp = new BoundParam(index, timestamp) ;
boundParams.remove(bp);
boundParams.add( bp );
}
/**
*使用给出的整数设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param value 包含参数值的整数
*/
public void setInt(int index, int value)throws java/sql/SQLException.java.html" target="_blank">SQLException{
BoundParam bp = new BoundParam(index, new java/lang/Integer.java.html" target="_blank">Integer(value)) ;
boundParams.remove(bp);
boundParams.add( bp );
}
/**
*使用给出的长整数设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param value 包含参数值的长整数
*/
public void setLong(int index, long value)throws java/sql/SQLException.java.html" target="_blank">SQLException{
BoundParam bp = new BoundParam(index, new java/lang/Long.java.html" target="_blank">Long(value)) ;
boundParams.remove(bp);
boundParams.add( bp );
}
/**
*使用给出的双精度浮点数设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param value 包含参数值的双精度浮点数
*/
public void setDouble(int index, double value)throws java/sql/SQLException.java.html" target="_blank">SQLException{
BoundParam bp = new BoundParam(index, new java/lang/Double.java.html" target="_blank">Double(value)) ;
boundParams.remove(bp);
boundParams.add( bp);
}
/**
*使用给出的BigDecimal设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param bd 包含参数值的BigDecimal
*/
public void setBigDecimal(int index, java/math/BigDecimal.java.html" target="_blank">BigDecimal bd)throws java/sql/SQLException.java.html" target="_blank">SQLException{
BoundParam bp = new BoundParam(index, bd ) ;
boundParams.remove(bp);
boundParams.add( bp);
}
private void setParams(java/sql/PreparedStatement.java.html" target="_blank">PreparedStatement pst) throws java/sql/SQLException.java.html" target="_blank">SQLException{
if (pst==null || this.boundParams==null || this.boundParams.size()==0 ) return ;
BoundParam param;
for (java/util/Iterator.java.html" target="_blank">Iterator itr = this.boundParams.iterator();itr.hasNext();){
param = (BoundParam) itr.next();
if (param==null) continue;
if (param.sqlType == java.sql.java/sql/Types.java.html" target="_blank">Types.OTHER){
pst.setObject(param.index, param.value);
}else{
pst.setObject(param.index, param.value, param.sqlType, param.scale);
}
}
}
/**
* 执行查询取得一页数据，执行结束后关闭数据库连接
* @return RowSetPage
* @throws SQLException
*/
public RowSetPage executeQuery() throws java/sql/SQLException.java.html" target="_blank">SQLException{
java/lang/System.java.html" target="_blank">System.out.println("executeQueryUsingPreparedStatement");
java/sql/Connection.java.html" target="_blank">Connection conn = DBUtil.getConnection();
java/sql/PreparedStatement.java.html" target="_blank">PreparedStatement pst = null;
java/sql/ResultSet.java.html" target="_blank">ResultSet rs = null;
try{
pst = conn.prepareStatement(this.countSQL);
setParams(pst);
rs =pst.executeQuery();
if (rs.next()){
totalCount = rs.getInt(1);
} else {
totalCount = 0;
}
rs.close();
pst.close();
if (totalCount < 1 ) return RowSetPage.EMPTY_PAGE;
pst = conn.prepareStatement(this.querySQL);
java/lang/System.java.html" target="_blank">System.out.println(querySQL);
pst.setFetchSize(this.pageSize);
setParams(pst);
rs =pst.executeQuery();
//rs.setFetchSize(pageSize);
this.rowSet = populate(rs);
rs.close();
rs = null;
pst.close();
pst = null;
this.rowSetPage = new RowSetPage(this.rowSet,startIndex,totalCount,pageSize);
return this.rowSetPage;
}catch(java/sql/SQLException.java.html" target="_blank">SQLException sqle){
//System.out.println("executeQuery SQLException");
sqle.printStackTrace();
throw sqle;
}catch(java/lang/Exception.java.html" target="_blank">Exception e){
e.printStackTrace();
throw new java/lang/RuntimeException.java.html" target="_blank">RuntimeException(e.toString());
}finally{
//System.out.println("executeQuery finally");
DBUtil.close(rs, pst, conn);
}
}
/**
*将ResultSet数据填充进CachedRowSet
*/
protected abstract javax/sql/RowSet.java.html" target="_blank">RowSet populate(java/sql/ResultSet.java.html" target="_blank">ResultSet rs) throws java/sql/SQLException.java.html" target="_blank">SQLException;
/**
*取封装成RowSet查询结果
*@return RowSet
*/
public javax.sql.javax/sql/RowSet.java.html" target="_blank">RowSet getRowSet(){
return this.rowSet;
}
/**
*取封装成RowSetPage的查询结果
*@return RowSetPage
*/
public RowSetPage getRowSetPage() {
return this.rowSetPage;
}
/**
*关闭数据库连接
*/
public void close(){
//因为数据库连接在查询结束或发生异常时即关闭，此处不做任何事情
//留待扩充。
}
private class BoundParam {
int index;
java/lang/Object.java.html" target="_blank">Object value;
int sqlType;
int scale;
public BoundParam(int index, java/lang/Object.java.html" target="_blank">Object value) {
this(index, value, java.sql.java/sql/Types.java.html" target="_blank">Types.OTHER);
}
public BoundParam(int index, java/lang/Object.java.html" target="_blank">Object value, int sqlType) {
this(index, value, sqlType, 0);
}
public BoundParam(int index, java/lang/Object.java.html" target="_blank">Object value, int sqlType, int scale) {
this.index = index;
this.value = value;
this.sqlType = sqlType;
this.scale = scale;
}
public boolean equals(java/lang/Object.java.html" target="_blank">Object obj){
if (obj!=null && this.getClass().isInstance(obj)){
BoundParam bp = (BoundParam)obj;
if (this.index==bp.index) return true;
}
return false;
}
}
}
///////////////////////////////////
//
// PagedStatementOracleImpl.java
// author: evan_zhao@hotmail.com
//
///////////////////////////////////
package page;
import java.sql.java/sql/ResultSet.java.html" target="_blank">ResultSet;
import java.sql.java/sql/SQLException.java.html" target="_blank">SQLException;
import javax.sql.javax/sql/RowSet.java.html" target="_blank">RowSet;
import oracle.jdbc.rowset.OracleCachedRowSet;
/**
* <p>Title: 分页查询Oracle数据库实现</p>
* <p>Copyright: Copyright (c) 2002</p>
* @author evan_zhao@hotmail.com
* @version 1.0
*/
public class PagedStatementOracleImpl extends PagedStatement {
/**
* 构造一查询出所有数据的PageStatement
* @param sql query sql
*/
public PagedStatementOracleImpl(java/lang/String.java.html" target="_blank">String sql){
super(sql);
}
/**
* 构造一查询出当页数据的PageStatement
* @param sql query sql
* @param pageNo 页码
*/
public PagedStatementOracleImpl(java/lang/String.java.html" target="_blank">String sql, int pageNo){
super(sql, pageNo);
}
/**
* 构造一查询出当页数据的PageStatement，并指定每页显示记录条数
* @param sql query sql
* @param pageNo 页码
* @param pageSize 每页容量
*/
public PagedStatementOracleImpl(java/lang/String.java.html" target="_blank">String sql, int pageNo, int pageSize){
super(sql, pageNo, pageSize);
}
/**
*生成查询一页数据的sql语句
*@param sql 原查询语句
*@startIndex 开始记录位置
*@size 需要获取的记录数
*/
protected java/lang/String.java.html" target="_blank">String intiQuerySQL(java/lang/String.java.html" target="_blank">String sql, int startIndex, int size){
java/lang/StringBuffer.java.html" target="_blank">StringBuffer querySQL = new java/lang/StringBuffer.java.html" target="_blank">StringBuffer();
if (size != super.MAX_PAGE_SIZE) {
querySQL.append("select * from (select my_table.*,rownum as my_rownum from(")
.append( sql)
.append(") my_table where rownum<").append(startIndex + size)
.append(") where my_rownum>=").append(startIndex);
} else {
querySQL.append("select * from (select my_table.*,rownum as my_rownum from(")
.append(sql)
.append(") my_table ")
.append(") where my_rownum>=").append(startIndex);
}
return querySQL.toString();
}
/**
*将ResultSet数据填充进CachedRowSet
*/
protected javax/sql/RowSet.java.html" target="_blank">RowSet populate(java/sql/ResultSet.java.html" target="_blank">ResultSet rs) throws java/sql/SQLException.java.html" target="_blank">SQLException{
OracleCachedRowSet ocrs = new OracleCachedRowSet();
ocrs.populate(rs);
return ocrs;
}
}
[/code]
相关连接：
javaresearch.org/article/showarticle.jsp?column=106&thread=8512' target='_blank' class='l2'>JSP页面查询显示常用模式,介绍查询结果集封装的几种常用模式。本程序使用了其中部分代码
RowSet规范原来是JDBC(TM) 2.0 Optional Package的一部分，现在已经并入JDBC3.0规范，并且将成为J2SE1.5的组成部分。
关于RowSet的实现各个数据库的jdbc driver应该都有提供,oracle实现可以到java/sqlj_jdbc/content.html' target='_blank' class='l2'>http://otn.oracle.com/software/tech/java/sqlj_jdbc/content.html下载(Additional RowSet support)
Sun也提供了RowSet的参考实现，应该可以支持大多数数据库：java.sun.com/products/jdbc/download.html' target='_blank' class='l2'>http://java.sun.com/products/jdbc/download.html
java.sun.com/blueprints/code/index.html#java_pet_store_demo' target='_blank' class='l2'>PetStore 是Sun关于java.sun.com/blueprints/enterprise/' target='_blank' class='l2'>J2EE设计模式的一个示例程序。