java调用oracle存储过程_Java_站长学院

java调用oracle存储过程

[2008-04-22 00:00:00] 作者：Northz.com 来源：北方站长站

→Tags:←

访谈录:阿里妈妈

一：无返回值的存储过程qVp北方站长站

存储过程为：qVp北方站长站

CREATE OR REPLACE PROCEDURE TESTA（PARA1 IN VARCHAR2，PARA2 IN VARCHAR2） AS

BEGINqVp北方站长站

INSERT INTO HYQ.B_ID （I_ID，I_NAME） VALUES （PARA1， PARA2）；qVp北方站长站

END TESTA；qVp北方站长站

然后呢，在java里调用时就用下面的代码：qVp北方站长站

package com.hyq.src；

import java.sql.*；qVp北方站长站

import java.sql.ResultSet；qVp北方站长站

public class TestProcedureOne {qVp北方站长站

public TestProcedureOne（） {qVp北方站长站

}qVp北方站长站

public static void main（String[] args ）{qVp北方站长站

String driver = "oracle.jdbc.driver.OracleDriver"；qVp北方站长站

String strUrl = "jdbc：oracle：thin：@127.0.0.1：1521： hyq "；qVp北方站长站

Statement stmt = null；qVp北方站长站

ResultSet rs = null；qVp北方站长站

Connection conn = null；qVp北方站长站

CallableStatement cstmt = null；qVp北方站长站

try {qVp北方站长站

Class.forName（driver）；qVp北方站长站

conn = DriverManager.getConnection（strUrl， " hyq "， " hyq "）；qVp北方站长站

CallableStatement proc = null；qVp北方站长站

proc = conn.prepareCall（"{ call HYQ.TESTA（？，？） }"）；qVp北方站长站

proc.setString（1， "100"）；qVp北方站长站

proc.setString（2， "TestOne"）；qVp北方站长站

proc.execute（）；qVp北方站长站

}qVp北方站长站

catch （SQLException ex2） {qVp北方站长站

ex2.printStackTrace（）；qVp北方站长站

}qVp北方站长站

catch （Exception ex2） {qVp北方站长站

ex2.printStackTrace（）；qVp北方站长站

}qVp北方站长站

finally{qVp北方站长站

try {qVp北方站长站

if（rs ！= null）{qVp北方站长站

rs.close（）；qVp北方站长站

if（stmt！=null）{qVp北方站长站

stmt.close（）；qVp北方站长站

}qVp北方站长站

if（conn！=null）{qVp北方站长站

conn.close（）；qVp北方站长站

}qVp北方站长站

catch （SQLException ex1） {qVp北方站长站

}qVp北方站长站

[NextPage]qVp北方站长站
当然了，这就先要求要建张表TESTTB，里面两个字段（I_ID，I_NAME）。qVp北方站长站

二：有返回值的存储过程（非列表）qVp北方站长站

存储过程为：qVp北方站长站

CREATE OR REPLACE PROCEDURE TESTB（PARA1 IN VARCHAR2，PARA2 OUT VARCHAR2） AS

BEGINqVp北方站长站

SELECT INTO PARA2 FROM TESTTB WHERE I_ID= PARA1；qVp北方站长站

END TESTB；qVp北方站长站

在java里调用时就用下面的代码：qVp北方站长站

package com.hyq.src；

public class TestProcedureTWO {qVp北方站长站

public TestProcedureTWO（） {qVp北方站长站

}qVp北方站长站

public static void main（String[] args ）{qVp北方站长站

String driver = "oracle.jdbc.driver.OracleDriver"；qVp北方站长站

String strUrl = "jdbc：oracle：thin：@127.0.0.1：1521：hyq"；qVp北方站长站

Statement stmt = null；qVp北方站长站

ResultSet rs = null；qVp北方站长站

Connection conn = null；qVp北方站长站

try {qVp北方站长站

Class.forName（driver）；qVp北方站长站

conn = DriverManager.getConnection（strUrl， " hyq "， " hyq "）；qVp北方站长站

CallableStatement proc = null；qVp北方站长站

proc = conn.prepareCall（"{ call HYQ.TESTB（？，？） }"）；qVp北方站长站

proc.setString（1， "100"）；qVp北方站长站

proc.registerOutParameter（2， Types.VARCHAR）；qVp北方站长站

proc.execute（）；qVp北方站长站

String testPrint = proc.getString（2）；qVp北方站长站

System.out.println（"=testPrint=is="+testPrint）；qVp北方站长站

}qVp北方站长站

catch （SQLException ex2） {qVp北方站长站

ex2.printStackTrace（）；qVp北方站长站

}qVp北方站长站

catch （Exception ex2） {qVp北方站长站

ex2.printStackTrace（）；qVp北方站长站

}qVp北方站长站

finally{qVp北方站长站

try {qVp北方站长站

if（rs ！= null）{qVp北方站长站

rs.close（）；qVp北方站长站

if（stmt！=null）{qVp北方站长站

stmt.close（）；qVp北方站长站

}qVp北方站长站

if（conn！=null）{qVp北方站长站

conn.close（）；qVp北方站长站

}qVp北方站长站

catch （SQLException ex1） {qVp北方站长站

}qVp北方站长站

[NextPage]qVp北方站长站
注意，这里的proc.getString（2）中的数值2并非任意的，而是和存储过程中的out列对应的，如果out是在第一个位置，那就是proc.getString（1），如果是第三个位置，就是proc.getString（3），当然也可以同时有多个返回值，那就是再多加几个out参数了。qVp北方站长站

三：返回列表qVp北方站长站

由于oracle存储过程没有返回值，它的所有返回值都是通过out参数来替代的，列表同样也不例外，但由于是集合，所以不能用一般的参数，必须要用pagkage了。所以要分两部分，qVp北方站长站

1，建一个程序包。如下：qVp北方站长站

CREATE OR REPLACE PACKAGE TESTPACKAGE AS

TYPE Test_CURSOR IS REF CURSOR；qVp北方站长站

end TESTPACKAGE；qVp北方站长站

2，建立存储过程，存储过程为：qVp北方站长站

CREATE OR REPLACE PROCEDURE TESTC（p_CURSOR out TESTPACKAGE.Test_CURSOR） IS

BEGINqVp北方站长站

OPEN p_CURSOR FOR SELECT * FROM HYQ.TESTTB；qVp北方站长站

END TESTC；qVp北方站长站

可以看到，它是把游标（可以理解为一个指针），作为一个out 参数来返回值的。qVp北方站长站

在java里调用时就用下面的代码：qVp北方站长站

package com.hyq.src；

import java.sql.*；qVp北方站长站

import java.io.OutputStream；qVp北方站长站

import java.io.Writer；qVp北方站长站

import java.sql.PreparedStatement；qVp北方站长站

import java.sql.ResultSet；qVp北方站长站

import oracle.jdbc.driver.*；qVp北方站长站

public class TestProcedureTHREE {qVp北方站长站

public TestProcedureTHREE（） {qVp北方站长站

}qVp北方站长站

public static void main（String[] args ）{qVp北方站长站

String driver = "oracle.jdbc.driver.OracleDriver"；qVp北方站长站

String strUrl = "jdbc：oracle：thin：@127.0.0.1：1521：hyq"；qVp北方站长站

Statement stmt = null；qVp北方站长站

ResultSet rs = null；qVp北方站长站

Connection conn = null；qVp北方站长站

try {qVp北方站长站

Class.forName（driver）；qVp北方站长站

conn = DriverManager.getConnection（strUrl， "hyq"， "hyq"）；qVp北方站长站

CallableStatement proc = null；qVp北方站长站

proc = conn.prepareCall（"{ call hyq.testc（？） }"）；qVp北方站长站

proc.registerOutParameter（1，oracle.jdbc.OracleTypes.CURSOR）；qVp北方站长站

proc.execute（）；qVp北方站长站

rs = （ResultSet）proc.getObject（1）；qVp北方站长站

while（rs.next（））qVp北方站长站

{qVp北方站长站

System.out.println（"<tr><td>" + rs.getString（1） + "</td><td>"+rs.getString（2）+"</td></tr>"）；qVp北方站长站

}qVp北方站长站

catch （SQLException ex2） {qVp北方站长站

ex2.printStackTrace（）；qVp北方站长站

}qVp北方站长站

catch （Exception ex2） {qVp北方站长站

ex2.printStackTrace（）；qVp北方站长站

}qVp北方站长站

finally{qVp北方站长站

try {qVp北方站长站

if（rs ！= null）{qVp北方站长站

rs.close（）；qVp北方站长站

if（stmt！=null）{qVp北方站长站

stmt.close（）；qVp北方站长站

}qVp北方站长站

if（conn！=null）{qVp北方站长站

conn.close（）；qVp北方站长站

}qVp北方站长站

catch （SQLException ex1） {qVp北方站长站

}qVp北方站长站

1、取得存储过程返回的值qVp北方站长站

CallableStatement cs = conn.prepareCall（"{call proc_fbquery（？，？，？）}"）； //调用存储过程cs.setString（1，mem）；cs.setInt（2，n）；cs.registerOutParameter（3，oracle.jdbc.OracleTypes.CURSOR）；cs.execute（）；rs=（ResultSet）cs.getObject（3）；

2、对存储过程赋值时：qVp北方站长站

CallableStatement cs= conn.prepareCall（"{call proc_fbquery（？）}"）； //调用存储过程cs.registerOutParameter（1，oracle.jdbc.OracleTypes.CURSOR）；cs.setCursorName（cusorName）； //提供result的名称cs.setString（1，rs）；rs=cs.executeQuery（）；rs =（ResultSet）cs.getObject（1）；qVp北方站长站