JDBC批处理

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

1、第一种方式

package com.demo;

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

import org.junit.Test;

import com.utils.DButils;

//jdbc批处理
public class Demo3 {
    //批处理第一种方式
    @Test
    public void test1() throws SQLException{
        Connection con = null;
        Statement st = null;
        ResultSet result = null;
        
        try{
            con = DButils.getConnection();
            String sql1 = "insert into testbatch(id,name) values('1','aaaa')";
            String sql2 = "update testbatch set name='bbbb' where id=1";
            st = con.createStatement();
            st.addBatch(sql1);//Statement维护了一个list集合
            st.addBatch(sql2);
            
            //返回一个int[1,1]数组代表每条sql语句影响几行数组
            st.executeBatch();
            st.clearBatch();
            
        }finally{
            DButils.release(con, st, result);
        }
    }

 

2、第二种方式

//实现批处理的第二种方式  适用于批量更新和插入
    @Test
    public void test2() throws SQLException{
        Connection con = null;
        PreparedStatement st = null;
        ResultSet result = null;
        long startTime = System.currentTimeMillis();
        try{
            con = DButils.getConnection();
            String sql = "insert into testbatch(id,name) values(?,?)";
            st = con.prepareStatement(sql);
            for(int i=1;i<10000;i++){
                st.setString(1,i+"");
                st.setString(2,"aa"+i);
                st.addBatch();
            }
            st.executeBatch();
            st.clearBatch();    
            
        }finally{
            DButils.release(con, st, result);
        }
        long endTime = System.currentTimeMillis();
        System.out.println("花费时间："+(endTime-startTime)/1000+"秒");
    }
}