jdbc調用 oracle 存儲過程操作

 

 

 

 

創建有參存儲函數findEmpNameAndSal(編號)，查詢7902號員工的的姓名和月薪，【返回多個值，演示out的用法】
當返回2個或多個值，必須使用out符號
當返回1個值，就無需out符號

create or replace function findEmpNameAndSal(pempno in number,pename out varchar2) return number
as
psal emp.sal%type;
begin
select ename,sal into pename,psal from emp where empno=pempno;
--返回月薪
return psal;
end;
/

---------------------------------------相互轉值

以下為測試調用

declare
psal emp.sal%type;
pename emp.ename%type;
begin
psal := findEmpNameAndSal(7902,pename);
dbms_output.put_line('7902號員工的姓名'||pename||'，薪水是'||psal);
end;
/

 

存儲過程

 

創建有參存儲過程findEmpNameAndSalAndJob(編號)，查詢7902號員工的的姓名，職位，月薪【演示out的用法】
create or replace procedure
findEmpNameAndSalAndJob(pempno in number,pename out varchar2,pjob out varchar2,psal out number)
as
begin
select ename,job,sal into pename,pjob,psal from emp where empno=pempno;
end;
/

以下測試調用

declare
pename emp.ename%type;
pjob emp.job%type;
psal emp.sal%type;
begin
findEmpNameAndSalAndJob(7902,pename,pjob,psal);
dbms_output.put_line('7902號員工的姓名是'||pename||':'||pjob||':'||psal);
end;
/

 

 

JDBC連接oracle

JdbcUtil.java 

package cn.itcast.web.oracle.util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class JdbcUtil {
    private static String driver = "oracle.jdbc.driver.OracleDriver";
    //1521是主端口，也可能是其它端口去連接oracle數據庫
    private static String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
    private static String username = "scott";
    private static String password = "friends";
    private static Connection conn;
    private static Statement stmt;
    private static ResultSet rs;
    //注冊數據庫驅動
    static{
        try {
            Class.forName(driver);
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException("oracle驅動注冊失敗");
        }
    }
    //獲取數據庫連接
    public static Connection getConnection(){
        Connection conn = null;
        try {
            conn = DriverManager.getConnection(url,username,password);
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException("oracle連接獲取失敗");
        }
        return conn;
    }
    //關閉連接對象
        public static void close(Connection conn){
            if(conn!=null){
                try {
                    conn.close();
                } catch (Exception e) {
                    e.printStackTrace();
                    throw new RuntimeException("oracle連接關閉失敗");
                }
            }
        }
        public static void close(Statement stmt){
            if(stmt!=null){
                try {
                    stmt.close();
                } catch (Exception e) {
                    e.printStackTrace();
                    throw new RuntimeException("oracle連接關閉失敗");
                }
            }
        }
        public static void close(ResultSet rs){
            if(rs!=null){
                try {
                    rs.close();
                } catch (Exception e) {
                    e.printStackTrace();
                    throw new RuntimeException("oracle連接關閉失敗");
                }
            }
        }
}

測試

    @Test
    public void testConnection()
    {
        Connection conn=JdbcUtil.getConnection();
        System.out.println(conn==null?"no":"yes");
    }
    

測試存儲過程

//Java調用存儲過程和函數
public class OracleDao {
    //調用存儲過程
    @Test
    public void callProcedure() throws Exception{
        Connection conn = JdbcUtil.getConnection();
        //第一參數:in  編號 7902
        //第二參數:out 姓名
        //第三參數:out 工作
        //第四參數:out 薪水
        String sql = "call findEmpNameAndSalAndJob(?,?,?,?)";
        //創建專用於調用過程或函數的對象
        CallableStatement cstmt = conn.prepareCall(sql);
        //為?占位符設置in、out值
        //hibernate從0開始，jdbc從1開始
        cstmt.setInt(1,7902);//in值
        cstmt.registerOutParameter(2,Types.VARCHAR);//out值
        cstmt.registerOutParameter(3,Types.VARCHAR);//out值
        cstmt.registerOutParameter(4,Types.INTEGER);//out值
        cstmt.execute();//拋行調用存儲過程
        //依次接收3個返回值
        String ename = cstmt.getString(2);
        String job = cstmt.getString(3);
        Integer sal = cstmt.getInt(4);
        //顯示
        System.out.println(ename+"的工作是：" + job + "，它是薪水是" + sal);
        //關閉連接對象
        JdbcUtil.close(cstmt);
        JdbcUtil.close(conn);
    }
    //調用存儲函數
    @Test
    public void callFunction() throws Exception{
        Connection conn = JdbcUtil.getConnection();
        //參數一：in  編號 數值型
        //參數二：out 姓名 字符串型
        //返回值：out 薪水 數值型
        String sql = "{? = call findEmpNameAndSal(?,?)}";
        CallableStatement cstmt = conn.prepareCall(sql);
        cstmt.setInt(2,7788);//in
        cstmt.registerOutParameter(3,Types.VARCHAR);//out
        cstmt.registerOutParameter(1,Types.INTEGER);//返回值
        cstmt.execute();//執行調用存儲函數
        String ename = cstmt.getString(3);
        Integer sal = cstmt.getInt(1);
        System.out.println(ename+"的薪水是"+sal);
        //關閉連接對象
        JdbcUtil.close(cstmt);
        JdbcUtil.close(conn);
    }
}