oracle 使用存儲過程實現分頁(初學者,請各位大神指教)

--編寫用於分頁的包
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();
                }
            }
        }
    }

}







相關文章
相關標籤/搜索