jdbc实现批量更新

朴灿烈づ我的快乐病毒、 2022-03-28 09:30 1694阅读 0赞

批量更新  
1.批量更新优点  
批处理：将一组更新语句作为一个单元，同时发送到数据库执行。  
批处理有效的降低了应用程序和数据库之间的网络调用，相比单个SQL语句的处理，批处理效率更高。

2.批量更新API  
addBatch(String sql)  
Statement类的方法, 可以将多条sql语句添加Statement对象的SQL语句列表中  
addBatch()  
PreparedStatement类的方法, 可以将多条预编译的sql语句添加到PreparedStatement对象的SQL语句列表中  
executeBatch()  
把Statement对象或PreparedStatement对象语句列表中的所有SQL语句发送给数据库进行处理  
clearBatch()  
清空当前SQL语句列表

3.防止OutOfMemory错误  
如果PreparedStatement对象中的SQL列表包含过多的待处理SQL语句, 可能会产生OutOfMemory错误。所以需要及时处理SQL语句列表  
for (int i = 0; i < 1000; i++) \{  
sql = “insert into student(id, name) values(student\_seq.nextval, ‘name" + i + "’)";  
//将SQL语句加入到Batch中  
stmt.addBatch(sql);  
//根据需要设置及时处理的条件  
if (i % 500 == 0) \{  
stmt.executeBatch(); //及时处理  
stmt.clearBatch(); //清空列表  
\}  
\}  
// 如果最后一次列表不足500条，要处理  
stmt.executeBatch();

案例：

问题  
批量插入student\_1表数据  
student\_1表结构:

向student\_1表中批量插入1000条数据，需要插入数据的列为id、name。这两个字段对应的数据分别为id列的数据通过序列stu\_seq自动生成,stu\_seq从2000开始每次递增1、name列的数据为字符串“name”+循环次数i组成。

方案  
每循环一次，向数据库插入一条数据，频繁的访问数据库，效率很低。  
在Java中专门提供的批处理的API。在对数据库频繁操作时，可以使用JDBC批处理方式提高程序的效率。批处理的主要特点如下：  
使用同一Connection资源，一次发送多条SQL语句执行。  
提高应用程序与DB之间的吞吐量，缩短DB的响应时间。  
与逐条执行SQL的方式相比，需要处理的数据量越大，批处理的优势越明显。

步骤  
步骤一：  
在Oracle数据库中创建student\_1表，语句如下:  
create table student\_1(  
id number(7),  
name varchar2(30)  
);  
在Oracle数据库中创建序列stu\_seq，该序列的起始值为2000、步进为1，SQL语句如下所示：  
create sequence stu\_seq start with 2000 increment by 1;

步骤二： 准备JDBC操作数据库的基本代码  
首先，新建类Batch，在该类中新建addBath方法；然后，准备数据库连接Connection对象、操作SQL语句的PreparedStatement对象以及设置事务管理；最后进行异常的处理

步骤三：批量向student\_1表中插入数据  
使用PreparedStatement的addBatch方法和executeBatch方法，批量向student\_1表中插入数据

步骤四：测试是否批量插入数据成功  
新建测试类TestBatch类,并新建测试方法testBatch，调用Batch的addBath方法  
运行测试方法，然后去查看Oracle数据库中的student\_1表，会发现批量向该表中插入了99999  
条记录。

源码：  
package cn.lyc.dao;

import java.sql.Connection;  
import java.sql.PreparedStatement;  
import java.sql.SQLException;

import cn.lyc.util.DBUtils;

/\*\*  
\*

*  批处理
 *  @author JLB
 *

\*/  
public class BatchStudent \{

public void insert(){
    	Connection conn = null;
    	PreparedStatement ps = null;
    	String sql = "insert into student_a values(stu_seq_key.nextval,?)";
    	conn = DBUtils.getConnection();
    	//防止OutOfMemory错误
    	try {
    		ps = conn.prepareStatement(sql);
    		for (int i = 0; i < 1000; i++) {
    			ps.setString(1, "student_"+i);
    			ps.addBatch();
    			if(i%200==0){//再分批插入
    				ps.executeBatch();
    				ps.clearBatch();
    			}
    		}
    		// 如果最后一次列表不足200条，要处理
    		ps.executeBatch();
    		System.out.println("执行成功。。。");
    	} catch (SQLException e) {
    		e.printStackTrace();
    	}finally{
    		DBUtils.close(conn,ps,null);
    	}
    }
    
    public static void main(String[] args) {
    	BatchStudent bs = new BatchStudent();
    	bs.insert();
    }

希望对大家有帮助哦！