oracle java 分页的一个包

d11gh6414j

----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_OutCursor      out refCursorType);
END;

---包体

create or replace package body CURSPKG is

procedure sp_Page(p_PageSize       int, --每页记录数
                    p_PageNo         int, --当前页码,从 1 开始
                    p_SqlSelect      varchar2, --查询语句,含排序部分
                    p_SqlCount       varchar2, --获取记录总数的查询语句
                    p_OutRecordCount out int, --返回总记录数
                    p_OutCursor      out refCursorType) is
    v_sql       varchar2(3000);
    v_count     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_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代码  */

public Object[] findStuffByQuary(String name,String qualitiy,String type,String level, int Npage, int PageSize) {
String sql_data = "";
String sql_count = "";


String call = "{call CURSPKG.SP_PAGE(?,?,?,?,?,?)}";
Connection conn = connectionMgr.getCon();
CallableStatement ps;
Object[] obj = new Object[2];
List<VTmarketTgoods> list = new ArrayList<VTmarketTgoods>();
int countsize = 0;
try {
ps = conn.prepareCall(call);
ps.setInt(1, PageSize); // 每页数量
ps.setInt(2, Npage); // 页码
// 查询商店能购买的物品
// 取数据的sql
ps.setString(3, sql_data);
// 取数据个数的sql
ps.setString(4, sql_count);
// 输出数据行数
ps.registerOutParameter(5,OracleTypes.INTEGER);
// 输出游标记录集
ps.registerOutParameter(6, OracleTypes.CURSOR);
ps.execute();
countsize = ((OracleCallableStatement) ps).getInt(5);
ResultSet rs = ((OracleCallableStatement) ps).getCursor(6);
while (rs.next()) {
VTmarketTgoods tsg = new VTmarketTgoods();
filldata(tsg, rs);
list.add(tsg);
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
obj[0] = list; obj[1] = countsize;
return obj;
}