数据库程序接口——JDBC——功能第五篇—

综述

批量处理一般指批量插入，批量更新，删除通过可以指定where条件实现。批量插入的实现方式有三种类型。statement，preparedStatement，callableStatement。

Java代码

/*** 演示批量插入的三种方式* @throws SQLException*/
public static void batchInsert() throws SQLException
{// 使用Statement对象进行批量插入,可以执行不同的sql语句
  insertByStatement();// 使用PreStatement对象进行批量插入,一条sql语句,多行参数
  insertByPreparedStatement();// 使用CallableStatement对象进行批量插入,一条存储过程，多行参数,当表结构修改时,只需要修改存储过程。
  insertByCallableStatement();
}

Statement方式

Statement方式批量执行SQL的优点在于可以执行多条SQL语句，缺点也很明显，需要改变SQL语句时需要修改程序，每次执行都需要重新编译SQL。下面通过举例说明。

示例演示往数据库student表，book表中批量插入数据。

student表有四个字段，stu_name（学号，INTEGER类型），stu_name（名称，varchar2(200)），stu_age（年龄，INTEGER类型），stu_class（班级，varchar2（200））。

  CREATE TABLE "STUDENT" (    "STU_NUM" NUMBER(*,0), "STU_NAME" VARCHAR2(200), "STU_AGE" NUMBER(*,0), "STU_CLASS" VARCHAR2(200))

book表中有四个字段，num（编号，INTEGER类型），name（名称，varchar2（200）），type（类型，varchar2（200））。

CREATE TABLE "SYSTEM"."BOOK"
( "NUM" NUMBER(*,0), "NAME" VARCHAR2(200), "TYPE" VARCHAR2(200)
)

Java代码

 /*** 通过Statement对象进行批量插入* @throws SQLException*/private static void insertByStatement() throws SQLException{// 获取连接对象Connection conn = ConnectionUtil.getConn();// 获取Statement对象Statement state = conn.createStatement();// 不同的sql语句，不同的表, studentSql为插入student表,bookSql为插入book表// stu_num(学号),stu_name(名称),stu_age(年龄),stu_class("班级")String studentSql = "insert into student values(1,'test1',25,'333班')";// num(图书编号),name(名称),type(类型)String bookSql = "insert into book values(1,'book1','杂志')";// 添加sql语句,
    state.addBatch(studentSql);state.addBatch(bookSql);// 执行sql
    state.executeBatch();// 清空批量
    state.clearBatch();// 关闭statement对象
    state.close();}

PreparedStatement方式

PreparedStatement优点是SQL语句结构不变，并且经过预编译，所以一般适用于一条SQL语句，多行参数。对于插入场景很适用。但是需要知道表中拥有哪些字段，如何设置这些值，如果表结构修改，需要修改代码。

Java代码

/*** 通过PreparedStatement对象进行批量插入* @throws SQLException*/
private static void insertByPreparedStatement() throws SQLException
{// 获取连接对象Connection conn = ConnectionUtil.getConn();// 插入Sql语句String insertSql = "insert into student values(?,?,?,?)";// 获取PreparedStatement对象PreparedStatement preStatement = conn.prepareStatement(insertSql);// 设置参数for(int i=2;i<100;i++){// 添加批量执行批量，相比于Statement的方式,一条sql语句，多行参数,适用于单表插入setPreparedStatementParam(preStatement, i, "test"+i, 23, "333班");preStatement.addBatch();}preStatement.executeBatch();// 清空批量，关闭对象
  preStatement.clearBatch();preStatement.close();
}/*** 为PreparedStatement对象设置参数* @param preStatement PreParedStament对象* @param stuNum 学号* @param name 姓名* @param age 年龄* @param stuClass 班级* @throws SQLException */
private static void setPreparedStatementParam(PreparedStatement preStatement, int stuNum, String name, int age,String stuClass) throws SQLException
{preStatement.setInt(1, stuNum);preStatement.setString(2, name);preStatement.setInt(3, age);preStatement.setString(4, stuClass);
}

CallableStatement方式

CallableStatement的方式优点在于只需要了解存储过程中的使用，不需要了解表结构，当表结构改变时，不用修改程序.

存储过程

create or replace procedure insertStudentProc
(stu_num in INTEGER,name in varchar2)
as
begininsert into student values(stu_num,name,25,'存储过程');commit;
end;

Java代码

/*** 通过CallableStatement对象进行批量插入* @throws SQLException */
private static void insertByCallableStatement() throws SQLException
{// 获取连接对象Connection conn = ConnectionUtil.getConn();// 第一个参数为学号,第二个参数为名称String callSql = "{call insertStudentProc(?,?)}";// 创建CallableStatement对象CallableStatement callStatement = conn.prepareCall(callSql);// 设置参数for(int i=100;i<200;i++){setCallableStatementParam(callStatement, i, "test"+i);callStatement.addBatch();}// 执行批量操作
  callStatement.executeBatch();// 清空批量,关闭对象
  callStatement.clearBatch();callStatement.close();
}/*** 为CallableStatement对象设置参数* @param callStatement CallableStatement对象* @param stuNum 学号* @param name 姓名* @throws SQLException */
private static void setCallableStatementParam(CallableStatement callStatement,int stuNum,String name) throws SQLException
{callStatement.setInt(1, stuNum);callStatement.setString(2, name);
}

至此本篇内容结束

转载于:https://www.cnblogs.com/rain144576/p/6971656.html