• 用java調用oracle存儲過程總結

    6
    Java Oracle 數據庫 C/C++ 17845 次瀏覽
    1、 什么是存儲過程。存儲過程是數據庫服務器端的一段程序,它有兩種類型。一種類似于SELECT查詢,用于檢索數據,檢索到的數據能夠以數據集的形式返回給 客戶。另一種類似于INSERT或DELETE查詢,它不返回數據,只是執行一個動作。有的服務器允許同一個存儲過程既可以返回數據又可以執行動作。
    2、什么時候需要用存儲過程
    如果服務器定義了存儲過程,應當根據需要決定是否要用存儲過程。存儲過程通常是一些經常要執行的任務,這些任務往往是針對大量的記錄而進行的。在服務器上執行存儲過程,可以改善應用程序的性能。這是因為:
    .服務器往往具有強大的計算能力和速度。
    .避免把大量的數據下載到客戶端,減少網絡上的傳輸量。
    例如,假設一個應用程序需要計算一個數據,這個數據需要涉及到許多記錄。如果不使用存儲過程的話,把這些數據下載到客戶端,導致網絡上的流量劇增。
    不僅如此,客戶端可能是一臺老掉牙的計算機,它的運算速度很慢。而改用存儲過程后,服務器會很快地把數據計算出來,并且只需傳遞一個數據給客戶端,其效率之高是非常明顯的。
    3、存儲過程的參數
    要執行服務器上的存儲過程,往往要傳遞一些參數。這些參數分為四種類型:
    第一種稱為輸入參數,由客戶程序向存儲過程傳遞值。
    第二種稱為輸出參數,由存儲過程向客戶程序返回結果。
    第三種稱為輸入/輸出參數,既可以由客戶程序向存儲過程傳遞值,也可以由存儲過程向客戶程序返回結果。
    第四種稱為狀態參數,由存儲過程向客戶程序返回錯誤信息。
    要說明的是,并不是所有的服務器都支持上述四種類型的參數,例如,InterBase就不支持狀態參數。
    4、oracle 存儲過程的基本語法

      1.基本結構
    CREATE OR REPLACEPROCEDURE 存儲過程名字
    (
        參數1 IN NUMBER,
        參數2 IN NUMBER
    ) IS
    變量1 INTEGER :=0;
    變量2 DATE;
    BEGIN 
    END 存儲過程名字 

    2.SELECT INTO STATEMENT
      將select查詢的結果存入到變量中,可以同時將多個列存儲多個變量中,必須有一條
      記錄,否則拋出異常(如果沒有記錄拋出NO_DATA_FOUND)
      例子:
      BEGIN
      SELECT col1,col2 into 變量1,變量2 FROM typestruct where xxx;
      EXCEPTION
      WHEN NO_DATA_FOUND THEN
          xxxx;
      END; 

    一:無返回值的存儲過程
    存儲過程為:
    CREATE OR REPLACE PROCEDURE TESTA(PARA1 IN VARCHAR2,PARA2 IN VARCHAR2) AS
    BEGIN 
      INSERT INTO HYQ.B_ID (I_ID,I_NAME) S (PARA1, PARA2);
    END TESTA; 
    然后呢,在java里調用時就用下面的代碼:
    package com.hyq.src;
    
    import java.sql.*;
    import java.sql.ResultSet;
    
    public class TestProcedureOne {
    public TestProcedureOne() {
    }
    public static void main(String[] args ){
        String driver = "oracle.jdbc.driver.OracleDriver";
        String strUrl = "jdbc:oracle:thin:@127.0.0.1:1521: hyq ";
        Statement stmt = null;
        ResultSet rs = null;
        Connection conn = null;
        CallableStatement cstmt = null;
    
        try {
          Class.forName(driver);
          conn = DriverManager.getConnection(strUrl, " hyq ", " hyq ");
          CallableStatement proc = null;
          proc = conn.prepareCall("{ call HYQ.TESTA(?,?) }");
          proc.setString(1, "100");
          proc.setString(2, "TestOne");
          proc.execute();
        }
        catch (SQLException ex2) {
          ex2.printStackTrace();
        }
        catch (Exception ex2) {
          ex2.printStackTrace();
        }
        finally{
          try {
            if(rs != null){
              rs.close();
              if(stmt!=null){
                stmt.close();
              }
              if(conn!=null){
                conn.close();
              }
            }
          }
          catch (SQLException ex1) {
          }
        }
    }
    } 
    當然了,這就先要求要建張表TESTTB,里面兩個字段(I_ID,I_NAME)。

    二:有返回值的存儲過程(非列表)
    存儲過程為:
    CREATE OR REPLACE PROCEDURE TESTB(PARA1 IN VARCHAR2,PARA2 OUT VARCHAR2) AS
    BEGIN 
      SELECT INTO PARA2 FROM TESTTB WHERE I_ID= PARA1; 
    END TESTB; 
    在java里調用時就用下面的代碼:
    package com.hyq.src;
    
    public class TestProcedureTWO {
    public TestProcedureTWO() {
    }
    public static void main(String[] args ){
        String driver = "oracle.jdbc.driver.OracleDriver";
        String strUrl = "jdbc:oracle:thin:@127.0.0.1:1521:hyq";
        Statement stmt = null;
        ResultSet rs = null;
        Connection conn = null;
        try {
          Class.forName(driver);
          conn = DriverManager.getConnection(strUrl, " hyq ", " hyq ");
          CallableStatement proc = null;
          proc = conn.prepareCall("{ call HYQ.TESTB(?,?) }");
          proc.setString(1, "100");
          proc.registerOutParameter(2, Types.VARCHAR);
          proc.execute();
          String testPrint = proc.getString(2);
          System.out.println("=testPrint=is="+testPrint);
        }
        catch (SQLException ex2) {
          ex2.printStackTrace();
        }
        catch (Exception ex2) {
          ex2.printStackTrace();
        }
        finally{
          try {
            if(rs != null){
              rs.close();
              if(stmt!=null){
                stmt.close();
              }
              if(conn!=null){
                conn.close();
              }
            }
          }
          catch (SQLException ex1) {
          }
        }
    }
    }
    
    } 
    注 意,這里的proc.getString(2)中的數值2并非任意的,而是和存儲過程中的out列對應的,如果out是在第一個位置,那就是 proc.getString(1),如果是第三個位置,就是proc.getString(3),當然也可以同時有多個返回值,那就是再多加幾個out 參數了。

    三:返回列表
    由于oracle存儲過程沒有返回值,它的所有返回值都是通過out參數來替代的,列表同樣也不例外,但由于是集合,所以不能用一般的參數,必須要用pagkage了.所以要分兩部分,
    1, 建一個程序包。如下:
    CREATE OR REPLACE PACKAGE TESTPACKAGE  AS
    TYPE Test_CURSOR IS REF CURSOR;
    end TESTPACKAGE; 
    2,建立存儲過程,存儲過程為:
    CREATE OR REPLACE PROCEDURE TESTC(p_CURSOR out TESTPACKAGE.Test_CURSOR) IS 
    BEGIN
        OPEN p_CURSOR FOR SELECT * FROM HYQ.TESTTB;
    END TESTC; 
    可以看到,它是把游標(可以理解為一個指針),作為一個out 參數來返回值的。
    在java里調用時就用下面的代碼:
    package com.hyq.src;
    import java.sql.*;
    import java.io.OutputStream;
    import java.io.Writer;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import oracle.jdbc.driver.*;
    
    
    public class TestProcedureTHREE {
    public TestProcedureTHREE() {
    }
    public static void main(String[] args ){
        String driver = "oracle.jdbc.driver.OracleDriver";
        String strUrl = "jdbc:oracle:thin:@127.0.0.1:1521:hyq";
        Statement stmt = null;
        ResultSet rs = null;
        Connection conn = null;
    
        try {
          Class.forName(driver);
          conn = DriverManager.getConnection(strUrl, "hyq", "hyq");
    
          CallableStatement proc = null;
          proc = conn.prepareCall("{ call hyq.testc(?) }");
          proc.registerOutParameter(1,oracle.jdbc.OracleTypes.CURSOR);
          proc.execute();
          rs = (ResultSet)proc.getObject(1);
    
          while(rs.next())
          {
              System.out.println("<tr><td>" + rs.getString(1) 
                                + "</td><td>"+rs.getString(2)+"</td></tr>");
          }
        }
        catch (SQLException ex2) {
          ex2.printStackTrace();
        }
        catch (Exception ex2) {
          ex2.printStackTrace();
        }
        finally{
          try {
            if(rs != null){
              rs.close();
              if(stmt!=null){
                stmt.close();
              }
              if(conn!=null){
                conn.close();
              }
            }
          }
          catch (SQLException ex1) {
          }
        }
    }
    } 

    在這里要注意,在執行前一定要先把oracle的驅動包放到class路徑里,否則會報錯。

    相似問題

    相關經驗

    相關資訊

    相關文檔

  • sesese色