zoukankan      html  css  js  c++  java
  • java调用oracle存储过程总结

    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路径里,否则会报错。

  • 相关阅读:
    dotnet 新项目格式与对应框架预定义的宏
    dotnet 线程静态字段
    dotnet 线程静态字段
    dotnet 通过 WMI 拿到显卡信息
    dotnet 通过 WMI 拿到显卡信息
    dotnet 通过 WMI 获取指定进程的输入命令行
    dotnet 通过 WMI 获取指定进程的输入命令行
    dotnet 通过 WMI 获取系统信息
    dotnet 通过 WMI 获取系统信息
    PHP show_source() 函数
  • 原文地址:https://www.cnblogs.com/xuewater/p/2731878.html
Copyright © 2011-2022 走看看