java實現調用ORACLE中的游標和包

今天把oracle中的包和游標學習了下，不廢話，網上的的有些代碼是錯誤的，抄來抄去，就自己實踐了下，做個記錄。直接上圖，上代碼

通過plsql創建自己的的包，包分為包頭和包體。

1.包頭如下：

CREATE OR REPLACE PACKAGE JAVALINKTEST
IS
  TYPE CURSOR_TYPE IS REF CURSOR;      --定義游標
  PROCEDURE TEST_CURSOR(INPUT STRING, CURSOR_BACK OUT CURSOR_TYPE);

END JAVALINKTEST;

 

2.包體如下：

CREATE OR REPLACE PACKAGE BODY JAVALINKTEST IS

PROCEDURE TEST_CURSOR(INPUT STRING, CURSOR_BACK OUT CURSOR_TYPE)
IS
BEGIN
IF INPUT = '物料' THEN
OPEN CURSOR_BACK FOR SELECT * 　FROM T_BD_MATERIAL WHERE CFISSYNC = 1;
ELSE
OPEN CURSOR_BACK FOR SELECT * 　FROM T_BD_CUSTOMER WHERE CFISSYNC = 1;

END IF;

END TEST_CURSOR;
END JAVALINKTEST;

 

3.java環境，用的時eclispe，oracle 11g，java代碼如下，需要的小伙伴自己引一下jdbc包吧

package cursorTest;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import oracle.jdbc.OracleTypes;
import oracle.jdbc.oracore.OracleType;

public class cursorUse {
    static ResultSet rs = null;
    static Statement stmt = null;
    static Connection conn = null;
    static CallableStatement proc = null;
    static int i;  

    public static void main(String[] args) {

        try {
            // 加載驅動
            Class.forName("oracle.jdbc.driver.OracleDriver");
            // 與數據庫建立物理連接
            conn = DriverManager.getConnection(
                    "jdbc:oracle:thin:@127.0.0.1:1521:orcl", "easdb", "easdb");
            // 調用 游標
            proc = conn.prepareCall("call JAVALINKTEST.TEST_CURSOR(?,?)");
            proc.setString(1, "hhe");
            proc.registerOutParameter(2, OracleTypes.CURSOR);
            proc.execute();
            rs = (ResultSet) proc.getObject(2);
            
            while (rs.next()) {
                i+=1;
                System.out.println("fid:" + rs.getString(1)+
                        "   編碼："+rs.getString("fnumber")+"  名稱："+rs.getString("fname_l2"));
                
            }
            System.out.println("返回結果集：共"+i+"行");
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            if (rs != null) {
                try {
                    rs.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            if (stmt != null) {
                try {
                    stmt.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }

    }

}

運行結果如下：