--編寫用於分頁的包
create or replace package pageDividepackage as
type page_divide_cursor is ref cursor;
end;
--編寫分頁過程
create or replace procedure pageDivide
(tableName in varchar2, --表名
myPageSize in number , --每頁顯示的記錄數
pageNow in number , --當前頁面
myRowCount out number, --總記錄數
myPageCount out number ,-- 總頁數
page_cursor out pageDividepackage.page_divide_cursor --遊標,返回記錄值
) is
--定義部分
--定義sql語句
v_sql varchar2(1000);
v_beginIndex number:=(pageNow-1)*myPageSize+1 ; --取值起始處
v_endIndex number:=pageNow*myPageSize; --取值偏移量(就是取多少值)
--執行部分
begin
v_sql:= 'select * from (select a.* ,rownum rm from (select * from '||tableName||') a where rownum<='||v_endIndex||') where rm>='||v_beginIndex;
--打開遊標
open page_cursor for v_sql;
--計算myRowCount
v_sql:= 'select count(*) from '|| tableName;
execute immediate v_sql into myRowCount;
--計算myPageCount
if mod(myRowCount, myPageSize)=0 then //若是使用myRowCount%myPageSize=0,好像出錯,緣由不明?
myPageCount:=myRowCount/myPageSize;
else
myPageCount:=myRowCount/myPageSize+1;
end if;
--關閉遊標(還沒搞清楚應該在什麼地方關閉遊標??)
--close page_cursor;
end;
使用pl/sql塊測試存儲過程,這個地方我寫的不全,就是試了試分頁的過程能不能經過。
--調用含有返回值的存儲過程
declare
myRowCount number;
myPageCount number;
page_cursor pageDividepackage.page_divide_cursor;
begin
pageDivide('emp',4,1,myRowCount,myPageCount, page_cursor);
end;
package com.hcc;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
public class TestPageDivide {
public static void main(String[] args) {
// TODO Auto-generated method stub
Connection conn = null;
CallableStatement cs = null;
ResultSet rs = null;
try {
Class.forName("oracle.jdbc.driver.OracleDriver");
conn = DriverManager.getConnection("jdbc:oracle:thin:@10.5.82.251:1521:myoracle","scott","lab2012");
// 調用存儲過程
cs = conn.prepareCall("{call pageDivide(?,?,?,?,?,?)}");
// 給?賦值
// 表名
cs.setString(1,"emp");
// 每頁記錄數
cs.setInt(2,4);
// 當前頁
cs.setInt(3,2);
// 接受總記錄數myRowCoun
cs.registerOutParameter(4, oracle.jdbc.driver.OracleTypes.INTEGER);
// 總頁數myPageCount
cs.registerOutParameter(5, oracle.jdbc.driver.OracleTypes.INTEGER);
// 遊標返回值
cs.registerOutParameter(6, oracle.jdbc.driver.OracleTypes.CURSOR);
// 執行
cs.execute();
// 取出總記錄數 ,此處要注意, getInt(4) 是由 該參數的位置決定的
int myRowCoun = cs.getInt(4);
// 取出總頁數
int myPageCount = cs.getInt(5);
// 取出結果集
rs = (ResultSet) cs.getObject(6);
System.out.format("總頁數: %d\n 總記錄數:%d\n", myPageCount,myRowCoun);
while(rs.next()){
System.out.println(rs.getString(2));//此處的數字表示第二列,數據庫表中列從1開始,第二列爲varchar類型,故使用getString()
// 若爲number類型,則應該是getInt()
// System.out.format("Empno: %d\nEname: %s\n", rs.getInt(1),rs.getString(2));
}
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
if(conn != null){
try {
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(cs != null){
try {
cs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(rs != null){
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}