总结java中调用存储过程的方法

本帖最后由王文正于 2013-2-12 16:08 编辑

之前看到在论坛上有人提问关于java中调用存储过程的方法，其实这个东西确实有很多种分类，不同的分类的存储方法也不太一样，我这里查了很多资料，分类为以下四种，根据调用返回值的不同，对应的代码如下，有用得着的同学，还望多多支持，我的辛苦也就值得了！
1:调用有返回值的存储过程
程序如下：
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class TestProc {

private static Connection connection = null;
public static Connection getConnection(){
try {
Class.forName(“com.microsoft.jdbc.sqlserver.SQLServerDriver”);
connection = DriverManager.getConnection(“jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=mydb”,”sa”,”sa”);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}

public static void main(String[] args) {

Connection connection = TestProc.getConnection();
try{
String poetName = “silas”;
int id = 0;
// 设置调用的存储过程名及参数情况
CallableStatement proc = connection.prepareCall(“{ call test_proc(?, ?) }”);
// 设置输入参数值1的值
proc.setString(1, poetName);
// 设置输出参数及返回类型
proc.registerOutParameter(2,java.sql.Types.INTEGER);
proc.execute();
// 取出存储过程的返回值
id = proc.getInt(2);
System.out.println(“人员ID为:”+id);
connection.close();
}catch (SQLException e){
e.printStackTrace();
}

// 以下为存储过程的定义
// create proc test_proc
// @username varchar(20),@pid int output
// as
// declare @uid int
// set @uid = 0
// select @uid=userid from users where username=@username
// if @uid<>0
// set @pid = @uid
// else
// set @pid = 0

}
}
当前以上存储过程中调用了users表,此处建表省略.

2:调用返回结果集的存储过程
程序如下：
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
public class TestProcResultSet {

private static Connection connection = null;
public static Connection getConnection(){
try {
Class.forName(“com.microsoft.jdbc.sqlserver.SQLServerDriver”);
connection = DriverManager.getConnection(“jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=mydb”,”sa”,”sa”);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}

public static void main(String[] args) {

Connection connection = TestProc.getConnection();
try{
ResultSet rs = null;
// 设置调用的存储过程名及参数情况,注意的是存储过程不可以有输出参数
CallableStatement proc = connection.prepareCall(“{ call test_proc_resultset(?)}”);
// 设置输入参数
proc.setInt(1, 11);
// 调入存储过程
proc.execute();
// 取出存储过程的结果集
rs = proc.getResultSet();
for(int i=0;rs.next();i++)
System.out.println(“Result的大小为:”+rs.getString(2));
connection.close();
}catch (SQLException e){
e.printStackTrace();
}

// create proc test_proc_resultset
// @id int
// as
// select * from users where userid=@id

}
}

3:调用有默认值的存储过程
程序如下：
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class TestDefaultProc {

private static Connection connection = null;
public static Connection getConnection(){
try {
Class.forName(“com.microsoft.jdbc.sqlserver.SQLServerDriver”);
connection = DriverManager.getConnection(“jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=mydb”,”sa”,”sa”);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}

public static void main(String[] args) {

Connection connection = TestDefaultProc.getConnection();
try{
int id = 0;
// 设置调用的存储过程名及默认参数的情况
CallableStatement proc = connection.prepareCall(“{ call test_default_proc(default, ?) }”);
// 设置输出参数及返回类型
proc.registerOutParameter(1,java.sql.Types.INTEGER);
proc.execute();
// 取出存储过程的返回值
id = proc.getInt(1);
System.out.println(“人员ID为:”+id);
connection.close();
}catch (SQLException e){
e.printStackTrace();
}

// 以下为存储过程的定义
// create proc test_default_proc
// @username varchar(20)=’silas’,@pid int output
// as
// declare @uid int
// set @uid = 0
// select @uid=userid from users where username=@username
// if @uid<>0
// set @pid = @uid
// else
// set @pid = 0

}

4:调用返回两个以上结果集的存储过程（重点）
程序如下;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
public class TestProcMulResultSet {

private static Connection connection = null;
public static Connection getConnection(){
try {
Class.forName(“com.microsoft.jdbc.sqlserver.SQLServerDriver”);
connection = DriverManager.getConnection(“jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=mydb”,”sa”,”sa”);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}

public static void main(String[] args) {

Connection connection = TestProc.getConnection();
try{
ResultSet rs = null;
// 设置调用的存储过程名及参数情况,注意的是存储过程不可以有输出参数
CallableStatement proc = connection.prepareCall(“{ call test_proc_mulresultset(?)}”);
// 设置输入参数
proc.setInt(1, 11);
// 调入存储过程
proc.execute();
// 取出存储过程的结果集
boolean hasResult = true;
while (hasResult) {
rs = proc.getResultSet();
while(rs.next()) {
System.out.println(“第一条记录第二个字段值为:”+rs.getString(2));
break;
}
hasResult = proc.getMoreResults();
}
connection.close();
}catch (SQLException e){
e.printStackTrace();
}

// create proc test_proc_mulresultset
// @id int
// as
// select * from users where userid=@id
// select * from users order by userid desc
}
}

帐号		自动登录	找回密码
密码			加入黑马

总结java中调用存储过程的方法

0 个回复