`
beyond429
  • 浏览: 93674 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

java中调用oracle存储过程

    博客分类:
  • java
阅读更多
在网上找到一个帖子,照着做了一下,成功。

下面是测试代码和数据表存储过程

import java.sql.*;

/**
数据库表
CREATE TABLE TB_MONITOR (
   ID                   NUMBER(20)                      NOT NULL,
   MONITOR_OBJECT_CODE CHAR(10),
   MONITOR_OBJECT_NAME VARCHAR2(180),
   BRANCH_CODE          CHAR(10),
   SYSTEM_CODE          CHAR(10),
   DIREC_NAME           VARCHAR2(180),
   FILE_NUM             NUMBER,
   STATUS               CHAR(10),
   BEGIN_TIME           TIMESTAMP,
   END_TIME             TIMESTAMP,
   DATA_TIME            TIMESTAMP,
   MONITOR_TIME         TIMESTAMP,
   REMARK               VARCHAR2(180),
   CONSTRAINT PK_TB_MONITOR PRIMARY KEY (ID)
);
*/
public class OracleProcedureCall {

private static String driver = "oracle.jdbc.driver.OracleDriver";
private static String strUrl = "jdbc:oracle:thin:@192.168.1.90:1521:odsdb";
private static String userName = "odsdb";
private static String password = "ods";

private static Connection conn = null;

//获得数据库连接
public static Connection getConnection(){
   try{
    if(conn == null){
     Class.forName(driver);
     conn = DriverManager.getConnection(strUrl, userName, password);
    }
   }catch(ClassNotFoundException e){
    e.printStackTrace();
   }catch(SQLException e){
    e.printStackTrace();
   }
 
     return conn;
}

/*无返回值的存储过程
CREATE OR REPLACE PROCEDURE AddMonInfo
(
n_id tb_monitor.id%TYPE,
n_oc tb_monitor.monitor_object_code%TYPE,
n_on tb_monitor.monitor_object_name%TYPE,
n_bc tb_monitor.branch_code%TYPE,
n_sc tb_monitor.system_code%TYPE,
n_fn tb_monitor.file_num%TYPE,
n_st tb_monitor.status%TYPE,
n_rk tb_monitor.remark%TYPE
)
AS
BEGIN
--向表中插入数据
INSERT INTO tb_monitor(id,monitor_object_code,monitor_object_name,branch_code,system_code,file_num,status,remark)
VALUES(n_id,n_oc,n_on,n_bc,n_sc,n_fn,n_st,n_rk);
END AddMonInfo;
*/
public void testInsert(){
     try {
     CallableStatement proc = getConnection().prepareCall("{ call odsdb.AddMonInfo(?,?,?,?,?,?,?,?) }");
     proc.setString(1, "100");
     proc.setString(2, "o_code");
     proc.setString(3, "o_name");
     proc.setString(4, "b_code");
     proc.setString(5, "s_code");
     proc.setString(6, "1");
     proc.setString(7, "status");
     proc.setString(8, "remark");
      
     proc.execute();
     }
     catch (SQLException ex2) {
     ex2.printStackTrace();
     }
     catch (Exception ex2) {
     ex2.printStackTrace();
     }
     finally{
     try {
        if(conn!=null){
         conn.close();
           }
     }
     catch (SQLException ex1) {
     }
     }
}

/*有返回值的存储过程(非列表)
CREATE OR REPLACE PROCEDURE QueryMonInfo
(
   n_id IN tb_monitor.id%TYPE,
   n_oc OUT VARCHAR2,
   n_on OUT VARCHAR2
) AS
BEGIN
    SELECT monitor_object_code, monitor_object_name into n_oc,n_on FROM tb_monitor WHERE ID= n_id;
END QueryMonInfo;
*/
public String[] testQueryArray(){
 
   String[] resultArr = null;
 
   try {
    CallableStatement proc = getConnection().prepareCall("{ call odsdb.QueryMonInfo(?,?,?) }");
    proc.setInt(1, 100);
    proc.registerOutParameter(2, Types.VARCHAR);
    proc.registerOutParameter(3, Types.VARCHAR);
    proc.execute();
     
    resultArr = new String[2];
    resultArr[0] = proc.getString(2);
    resultArr[1] = proc.getString(3);
    System.out.println("=code=is= "+resultArr[0]);
    System.out.println("=name=is= "+resultArr[1]);
   }
   catch (SQLException ex2) {
    ex2.printStackTrace();
   }
   catch (Exception ex2) {
    ex2.printStackTrace();
   }
   finally{
    try {
     if(conn!=null){
      conn.close();
     }
    }
    catch (SQLException ex1) {
     ex1.printStackTrace();
    }
   }
   return resultArr;
}

/*返回列表,需要使用package方式
先创建Package
CREATE OR REPLACE PACKAGE TESTPACKAGE AS TYPE Test_CURSOR IS REF CURSOR;
end TESTPACKAGE;
然后创建procedure
CREATE OR REPLACE PROCEDURE QueryMonResultSet(p_CURSOR out TESTPACKAGE.Test_CURSOR) IS
BEGIN
     OPEN p_CURSOR FOR SELECT * FROM tb_monitor;
END QueryMonResultSet;
*/
public ResultSet testQueryResultSet(){
 
   ResultSet rs = null;

     try {
     CallableStatement proc = getConnection().prepareCall("{ call odsdb.QueryMonResultSet(?) }");
     proc.registerOutParameter(1,oracle.jdbc.OracleTypes.CURSOR);
     proc.execute();
     rs = (ResultSet)proc.getObject(1);

     while(rs.next()) {
        System.out.println("ID:" + rs.getString(1) + "\tCODE:"+rs.getString(2)+"");
     }
     }
     catch (SQLException ex2) {
     ex2.printStackTrace();
     }
     catch (Exception ex2) {
     ex2.printStackTrace();
     }
     finally{
     try {
        if(rs != null){
         rs.close();
         if(conn!=null){
          conn.close();
         }
        }
     }
     catch (SQLException ex1) {
     }
     }
   return rs;
}

public static void main(String[] args){
   OracleProcedureCall call = new OracleProcedureCall();
   call.testQueryResultSet();
}
}

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics