使用JDBC的存储过程
2016-05-31 23:16
351 查看
使用jdbc调用mysql的存储过程
CallableStatement是使用JDBC调用存储过程的核心接口,使用该接口的步骤:
1. 编写调用存储过程的sql语句,有两种形式:
call procedure_name(arg1,arg2,……)
?= call procedure_name(arg1,arg2,……)
调用存储过程的sql语句的参数可以使用?作为占位符
2. 创建CallableStatement对象
Connection.prepareCall(String sql)
3. 按参数的顺序设置参数的值
1) 如果是IN类型的参数,使用setXxx方法设置参数的值
2) 如果是OUT类型的参数,使用registerOutParameter(int parameterIndex,int sqlType)注册输出参数类型
4. 调用execute()方法执行存储过程
5. 获取存储过程的执行结果
1) OUT类型的参数的值通过getXxx方法获取
2) 如果存储过程返回的是结果集,则使用getResultSet()方法获取结果集对象,并按传统方式获取结果集中的数据
例子:
编写存储过程
delimiter '//';
create procedure proc1(in user_name varchar(20),out user_password varchar(32))
begin
select password into user_password from tb_admin where name=user_name;
end//
delimiter ';'//
java code:
import java.sql.*;
public class CallTest {
public static void main(String[] args) {
// TODO Auto-generated method stub
try {
Class.forName("com.mysql.jdbc.Driver");
String url="jdbc:mysql://localhost:3306/db_spring";
String name="root";
String password="123456";
Connection con=DriverManager.getConnection(url, name, password);
String sql="call proc1(?,?)";
CallableStatement cs=con.prepareCall(sql);
cs.setString(1, "zhangsan");
cs.registerOutParameter(2, Types.VARCHAR);
cs.execute();
System.out.println(cs.getString(2));
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
CallableStatement是使用JDBC调用存储过程的核心接口,使用该接口的步骤:
1. 编写调用存储过程的sql语句,有两种形式:
call procedure_name(arg1,arg2,……)
?= call procedure_name(arg1,arg2,……)
调用存储过程的sql语句的参数可以使用?作为占位符
2. 创建CallableStatement对象
Connection.prepareCall(String sql)
3. 按参数的顺序设置参数的值
1) 如果是IN类型的参数,使用setXxx方法设置参数的值
2) 如果是OUT类型的参数,使用registerOutParameter(int parameterIndex,int sqlType)注册输出参数类型
4. 调用execute()方法执行存储过程
5. 获取存储过程的执行结果
1) OUT类型的参数的值通过getXxx方法获取
2) 如果存储过程返回的是结果集,则使用getResultSet()方法获取结果集对象,并按传统方式获取结果集中的数据
例子:
编写存储过程
delimiter '//';
create procedure proc1(in user_name varchar(20),out user_password varchar(32))
begin
select password into user_password from tb_admin where name=user_name;
end//
delimiter ';'//
java code:
import java.sql.*;
public class CallTest {
public static void main(String[] args) {
// TODO Auto-generated method stub
try {
Class.forName("com.mysql.jdbc.Driver");
String url="jdbc:mysql://localhost:3306/db_spring";
String name="root";
String password="123456";
Connection con=DriverManager.getConnection(url, name, password);
String sql="call proc1(?,?)";
CallableStatement cs=con.prepareCall(sql);
cs.setString(1, "zhangsan");
cs.registerOutParameter(2, Types.VARCHAR);
cs.execute();
System.out.println(cs.getString(2));
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
相关文章推荐
- jdbc中的Statement和PreparedStatement接口对象
- MySQL中的integer 数据类型
- MySQL存储过程
- mysql中int、bigint、smallint 和 tinyint的区别与长度
- mysql load data 导出、导入 csv
- source命令执行SQL脚本文件
- MySQL创建用户及权限控制
- MySQL管理数据表
- linux下mysql添加用户
- mysql procedure
- mysql触发器
- MySQL 备份和恢复策略
- mac下安装mysql(转载)
- mysql 修改编码 Linux/Mac/Unix/通用(杜绝修改后无法启动的情况!)
- MySQL数据的导出、导入(mysql内部命令:mysqldump、mysql)
- mysql数据行转列
- Linux下修改MySQL编码的方法
- MySQL Server 日志
- MySQL 安全事宜