一个Oracle分页的存储过程

aoazpgoeta

　　Oracle下通用的分页脚本：
　　

CREATE OR REPLACE PACKAGE "CURSPKG"
AS
TYPE refCursorType IS REF CURSOR;
procedure sp_Page(p_PageSize       int, --每页记录数
p_PageNo         int, --当前页码,从 1 开始
p_SqlSelect      varchar2, --查询语句,含排序部分
p_SqlCount       varchar2, --获取记录总数的查询语句
p_OutRecordCount out int, --返回总记录数
p_PageRecordCount out int, --返回当前页记录数
p_OutCursor      out refCursorType);
END;

CREATE OR REPLACE PACKAGE BODY "CURSPKG" as
procedure sp_Page(p_PageSize       int, --每页记录数
p_PageNo         int, --当前页码,从 1 开始
p_SqlSelect      varchar2, --查询语句,含排序部分
p_SqlCount       varchar2, --获取记录总数的查询语句
p_OutRecordCount out int, --返回总记录数
p_PageRecordCount out int, --返回当前页记录数
p_OutCursor      out refCursorType) is
v_sql       varchar2(3000);
v_countsql       varchar2(3000);
v_count     int;
v_pagecount     int;
v_heiRownum int;
v_lowRownum int;
begin
----取记录总数
execute immediate p_SqlCount
into v_count;
p_OutRecordCount := v_count;

v_heiRownum := p_PageNo * p_PageSize;
v_lowRownum := v_heiRownum - p_PageSize + 1;
----取当前页记录数
v_countsql := 'SELECT COUNT(1) FROM (SELECT A.*, rownum rn
FROM (' || p_SqlSelect || ') A
WHERE rownum <= ' || to_char(v_heiRownum) || ') B
WHERE rn >= ' || to_char(v_lowRownum);
execute immediate v_countsql
into v_pagecount;
p_PageRecordCount := v_pagecount;
----执行分页查询
v_sql := 'SELECT * FROM (SELECT A.*, rownum rn
FROM (' || p_SqlSelect || ') A
WHERE rownum <= ' || to_char(v_heiRownum) || ') B
WHERE rn >= ' || to_char(v_lowRownum);
--注意对rownum别名的使用,第一次直接用rownum,第二次一定要用别名rn
OPEN p_OutCursor FOR v_sql;

end sp_Page;
end;

 　　
　　
　　Java调用方式：

/**
* 功能说明：获得一页数据
*
* @param bean
*            分页对象
* @return String[][] 返回数据以二维数组的格式保存
* @date 2008-5-6
*/
public String[][] getPageData(SysFormPage bean) {
String[][] result = null;//
int pageSize = 0;// 当前页面记录条数
int fieldNum = 0;// 字段个数
String sql = "{ call CURSPKG.SP_PAGE(?,?,?,?,?,?,?)}";
String rsSql = bean.getRsSql();
String countSql = bean.getCountSql();
Connection conn = null;
CallableStatement proc = null;
ResultSet rs = null;
ResultSetMetaData meta = null;
try {
conn = dataSource.getConnection();
proc = conn.prepareCall(sql);
proc.setInt(1, bean.getFormCount());
proc.setInt(2, bean.getTarget());
proc.setString(3, rsSql);
proc.setString(4, countSql);
proc.registerOutParameter(5, OracleTypes.INTEGER);
proc.registerOutParameter(6, OracleTypes.INTEGER);
proc.registerOutParameter(7, OracleTypes.CURSOR);
proc.execute();
bean.setTotal(((OracleCallableStatement) proc).getInt(5));// 总记录数
pageSize = ((OracleCallableStatement) proc).getInt(6);// 当前页面记录条数
rs = ((OracleCallableStatement) proc).getCursor(7);
meta = rs.getMetaData();
fieldNum = meta.getColumnCount() - 1;
result = new String[pageSize][fieldNum];
for (int j = 0; j < pageSize; j++) {
rs.next();
for (int i = 1; i <= fieldNum; i++) {
result[j][i - 1] = rs.getString(meta.getColumnName(i));
}
}
rs.close();
proc.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
bean.setErrorCode(3);
}
return result;
}