JDBC调用存储过程的例子

下面是我学到了Oracle存储过程，在这里跟大家简单的分享一下利用JDBC调用存储过程的例子：

废话就不啰嗦，现在就直接上机代码。

首先我利用的是Oracle中默认的 scott 数据库里的 emp员工信息表作为本次的例子：

如果你的Oracle里没有 emp默认的员工表，需要创建类似以下的 emp表。

在PL/SQL中需要写以下的调用存储过程的代码：

 --在初次打开PL/SQL时要运行以下这行代码

 set serveroutput on

 --创建一个存储过程包

 CREATE OR REPLACE PACKAGE mypack

 IS

    TYPE mycursor IS REF CURSOR;

 END mypack;

 --创建存储过程方法

 CREATE OR REPLACE PROCEDURE findEmpJob(

    myempno IN NUMBER,

    myename OUT varchar2,

    myjob OUT VARCHAR2,

    other_name OUT mypack.mycursor

 )

 AS

 BEGIN

   SELECT ename,job INTO myename,myjob FROM emp WHERE empno=myempno;

   OPEN other_name FOR

   SELECT ename,job FROM emp WHERE empno IN(

      SELECT empno FROM emp

      MINUS

      SELECT empno FROM emp WHERE empno=myempno

   );

 END;

先在eclipse中创建一个项目，比如JDBC_procedure。创建好后类似如下这样：

例子用的数据库是Oracle，需要导入的Oracle的jar包

一、创建一个JdbcUtil底层类用来连接数据库，代码如下：

 package testjdbc;

 import java.sql.*;

 public class JdbcUtil {

     private String driver = "oracle.jdbc.driver.OracleDriver";

     // 1521是主端口，也可能是其它端口去连接oracle数据库

     private String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";

     private String username = "scott";

     private String password = "123456";

     private Connection conn;

     private CallableStatement cstmt;

     public String findEmpJob(int myempno) {

         // 加载驱动

         try {

             Class.forName(driver);

         } catch (Exception e) {

             e.printStackTrace();

             throw new RuntimeException("oracle驱动注册失败");

         }

         // 获取一个连接

         try {

             conn = DriverManager.getConnection(url, username, password);

         } catch (Exception e) {

             e.printStackTrace();

             throw new RuntimeException("oracle连接获取失败");

         }

         //findEmpJob(1.通过员工号返回ename和job  2.返回其他的员工信息)

         String sql = "{call findEmpJob(?,?,?,?)}";

         try {

             cstmt = conn.prepareCall(sql);

             //hibernate从0开始，jdbc从1开始

             cstmt.setInt(1,myempno);//in值

             cstmt.registerOutParameter(2,Types.VARCHAR);//out值

             cstmt.registerOutParameter(3,Types.VARCHAR);//out值

             //注册输出游标

             cstmt.registerOutParameter(4, oracle.jdbc.OracleTypes.CURSOR);

             //执行调用存储过程

             cstmt.execute();

             String ename = cstmt.getString(2);

             String job = cstmt.getString(3);

             ResultSet rs = (ResultSet) cstmt.getObject(4);

             //简单测验一下在控制台输出

             System.out.println("员工编号："+myempno);

             System.out.println(ename+"的工作是：" + job);

             System.out.println("\n"+"其他员工信息如下：");

             //遍历输出其他员工信息

             while(rs.next()){

                 System.out.println(    rs.getString("ename") +"的工作是："+ rs.getString("job"));

             }

             rs.close();

             cstmt.close();

             conn.close();

             return job;

         } catch (SQLException e) {

             // TODO Auto-generated catch block

             System.out.println("执行过程中异常:"+e.getMessage());

         }

         return "";

     }

 }

二、创建一个servlet类比如 Test.java

 package testjdbc;

 import java.io.IOException;

 import javax.servlet.ServletException;

 import javax.servlet.annotation.WebServlet;

 import javax.servlet.http.HttpServlet;

 import javax.servlet.http.HttpServletRequest;

 import javax.servlet.http.HttpServletResponse;

 /**

  * Servlet implementation class Test

  */

 @WebServlet("/Test")

 public class Test extends HttpServlet {

     private static final long serialVersionUID = 1L;

     /**

      * @see HttpServlet#HttpServlet()

      */

     public Test() {

         super();

         // TODO Auto-generated constructor stub

     }

     protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

         // TODO Auto-generated method stub

         int empno = Integer.parseInt( request.getParameter("empno") );

         JdbcUtil ju = new JdbcUtil();

         ju.findEmpJob(empno);

     }

     protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

         // TODO Auto-generated method stub

         doGet(request, response);

     }

 }

三、在写一个jsp页面，例如：index.jsp

 <%@ page language="java" contentType="text/html; charset=UTF-8"

     pageEncoding="UTF-8"%>

 <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">

 <html>

 <head>

 <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

 <title>测试JDBC调用存储过程</title>

 </head>

 <body>

 <form action="Test" method="post">

 员工编号：<input name="empno" type="text">

         <input type="submit">

 </form>

 </body>

 </html>

下面是运行项目的效果：在控制台中检验输出结果。

成功运行，并跳转到jsp页面

在控制台可以看到如下输出：

到这里利用JDBC调用Oracle的存储过程就介绍完了。

感谢大家的支持！

如需转载请注明出处：http://www.cnblogs.com/ZRJ-boke/p/6626851.html

巴特西

JDBC调用存储过程的例子

最新文章

热门文章