使用JDBC调用_存储过程

存储过程

使用JDBC调用存储过程

存储过程：
DELIMITER $$

DROP PROCEDURE IF EXISTS jdbc.addUser $$

CREATE PROCEDURE jdbc.addUser(in pname varchar(45),in birthday date,in money float, out pid int)

BEGIN

insert into user (name,birthday,money) values (pname,birthday,money);

select last_insert_id() into pid;

EnD $$

DELIMITER ;

使用JDBC调用存储过程---------------------------------------------------------------------------------------------------------------------------------

CallableStatement（从PreperedStatement扩展来）
cs = connection.prepareCall(“{call psname(?,?,?)}”);
cs.registerOutParameter(index, Types.INTEGER);
cs.setXXX(i, xxxx);
cs.executeUpdate();
int id=cs.getInt(index);

1：使用CallableStatement（从PreperedStatement扩展来）

2：定义 存储过程调用 语句
cs = connection.prepareCall(“{call psname(?,?,?)}”);

3：注册返回值
cs.registerOutParameter(index, Types.INTEGER);

4：设置 存储过程的参数
cs.setXXX(i, xxxx);

5：执行 存储过程
cs.executeUpdate();

6：接受返回参数
int id=cs.getInt(index);

PsTest.java

package com.dwt1220;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;

public class PsTest {

public static void main(String[] args) throws Exception {
ps();
}

static void ps() throws SQLException {
Connection conn = null;
/*************使用CallableStatement，继承与PreparedStatement*************************/
CallableStatement cs = null;
ResultSet rs = null;

try {
// 2.建立连接
conn = JdbcUtils.getConnection();

/*************调用存储过程的语句*************************/
String sql="{call addUser(?,?,?,?)}";
cs = conn.prepareCall(sql);

/*************注册返回值*************************/
cs.registerOutParameter(4, Types.INTEGER);
cs.setString(1, "ps name");
cs.setDate(2, new java.sql.Date(System.currentTimeMillis()));
cs.setFloat(3, 100f);

cs.executeUpdate();

/*************接受返回值*************************/
int id=cs.getInt(4);

System.out.println("id="+id);

} finally {
JdbcUtils.free(rs, cs, conn);
}
}

}