`

一个Oracle分页的存储过程

阅读更多

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;
	}
 

 

 

 

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics