JDBC学习笔记(12)：使用JDBC调用存储过程与批处理

浏览数：20 / 时间：2015年06月12日

存储过程：是一组为了完成特定功能的SQL语句集合，经编译后存储在数据库中，用户通过指定存储过程的名称并给出参数来执行。存储过程中可以包含逻辑控制语句和数据操纵语句，它可以接受参数、输出参数、返回单个或多个结果集以及返回值。

由于存储过程在创建时即在数据库服务器上进行了编译并存储在数据库中，所以存储过程运行要比单个的SQL语句块要快。同时由于在调用时只需用提供存储过程名和必要的参数信息，所以在一定程度上也可以减少网络流量、简单网络负担。

创建存储过程：

DELIMITER $$
DROP PROCEDURE IF EXISTS ‘jdbc‘.‘addUser‘ $$
CREATE PROCEDURE ‘jdbc‘.‘addUser‘ (IN pname VARCHAR(45), IN birthday DATE, INT money FLOAT, OUT pid INT)
BEGIN
    INSERT INTO USER(NAME,birthday,money) VALUES(pname,birthday,money);
    SELECT LAST_INSERT_ID() INTO pid;
END $$
DELIMITER;

通过调用存储过程插入一条记录：

 1 package com.xxyh.jdbc;
 2 import java.sql.CallableStatement;
 3 import java.sql.Connection;
 4 import java.sql.ResultSet;
 5 import java.sql.SQLException;
 6 import java.sql.Types;
 7 public class PsTest {
 8     
 9     public static void main(String[] args) throws SQLException {
10         
11         Connection conn = null;
12         CallableStatement cs = null;
13         ResultSet rs = null;
14         try {
15             conn = JdbcUtils.getConnection();
16             String sql = "{ call addUser(?,?,?,?) }";
17             cs = conn.prepareCall(sql);
18             
19             cs.registerOutParameter(4, Types.INTEGER);    
20             cs.setString(1, "ps1");
21             cs.setDate(2, new java.sql.Date(System.currentTimeMillis()));
22             cs.setFloat(3, 100f);
23             
24             cs.executeUpdate();
25             
26             int id = cs.getInt(4);
27             System.out.println("id = " + id);
28         } finally {
29             JdbcUtils.close(rs, cs, conn);
30         }
31     }
32 }

由于存储过程中的LAST_INSERT_ID()方法与MySQL数据库相关，当改变数据来源(如来自oracle、MS SQL server数据库)时，程序将会出现错误，为了提高代码的通用性，使用其他API来实现主键的获取：

 1 package com.xxyh.jdbc;
 2 import java.sql.Connection;
 3 import java.sql.PreparedStatement;
 4 import java.sql.ResultSet;
 5 import java.sql.SQLException;
 6 import java.sql.Statement;
 7 public class OtherApi {
 8     public static void main(String[] args) throws SQLException {
 9         Connection conn = null;
10         PreparedStatement ps = null;
11         ResultSet rs = null;
12         
13         try {
14             conn = JdbcUtils.getConnection();
15             String sql = "insert into user(name,birthday,money) values(‘ps3‘,‘2015-01-02‘,400)";
16             
17             // 返回主键
18             ps = conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);
19             ps.executeUpdate();
20             
21             //return a ResultSet object containing the auto-generated key(s) 
22             rs = ps.getGeneratedKeys();
23             int id = 0;
24             if (rs.next()) 
25                 id = rs.getInt(1);
26             System.out.println("id = " + id);
27         } finally {
28             JdbcUtils.close(rs, ps, conn);
29         }
30     }
31 }

批处理

当向数据库中发送一批SQL语句时，应避免向数据库一条条的发送执行，而应采用JDBC的批处理机制以提高效率。

 1 package com.xxyh.jdbc;
 2 import java.sql.Connection;
 3 import java.sql.Date;
 4 import java.sql.PreparedStatement;
 5 import java.sql.ResultSet;
 6 import java.sql.SQLException;
 7 import java.sql.Statement;
 8 public class BatchTest {
 9     public static void main(String[] args) throws SQLException {
10         
11         createBatch();
12     }
13     
14     static void createBatch() throws SQLException {
15         Connection conn = null;
16         PreparedStatement ps = null;
17         ResultSet rs = null;
18         try {
19             conn = JdbcUtils.getConnection();
20             String sql = "insert into user(name,birthday,money) values(?,?,?)";
21             ps = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);
22             for (int i = 0; i < 5; i++) {
23                 ps.setString(1, "batch"+i);
24                 ps.setDate(2, new Date(System.currentTimeMillis()));
25                 ps.setFloat(3, 100f+i);
26                 
27                 ps.addBatch();
28             }
29             ps.executeBatch();
30         } finally {
31             JdbcUtils.close(rs, ps, conn);
32         }
33     }
34 }