posts - 0, comments - 77, trackbacks - 0, articles - 356
            BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理

          用java調用oracle存儲過程總結

          Posted on 2007-09-07 15:48 semovy 閱讀(253) 評論(0)  編輯  收藏 所屬分類: Oracle數據庫方面

          一:無返回值的存儲過程

          存儲過程為:

          CREATE OR REPLACE PROCEDURE TESTA(PARA1 IN VARCHAR2,PARA2 IN VARCHAR2)  AS

          BEGIN

             INSERT INTO HYQ.B_ID (I_ID,I_NAME) VALUES (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_IDI_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路徑里,否則會報錯的。

          主站蜘蛛池模板: 绵竹市| 安陆市| 南宫市| 永仁县| 临武县| 福建省| 平凉市| 图片| 辽中县| 阳朔县| 织金县| 石柱| 平遥县| 黄大仙区| 湾仔区| 庄浪县| 井研县| 鹿邑县| 老河口市| 威海市| 饶平县| 调兵山市| 昌图县| 筠连县| 牡丹江市| 乌鲁木齐市| 荥经县| 陈巴尔虎旗| 土默特左旗| 双柏县| 鞍山市| 中方县| 凤城市| 武城县| 成都市| 石嘴山市| 曲沃县| 昆山市| 绥滨县| 苍南县| 峡江县|