目录

批量处理语句

实现方式

方式1

方式2

---

批量处理语句

JDBC的批量处理语句包括下面三个方法：

• addBatch(String)：添加需要批量处理的SQL语句或是参数；
• executeBatch()：执行批量处理语句；

• clearBatch():清空缓存的数据

实现方式

方式1

/*

* 修改1： 使用 addBatch() / executeBatch() / clearBatch()

* 修改2：mysql服务器默认是关闭批处理的，我们需要通过一个参数，让mysql开启批处理的支持。

* &rewriteBatchedStatements=true 写在配置文件的url后面

*

*

*/

@Test

public void testInsert1() throws Exception{

long start = System.currentTimeMillis();



Connection conn = JDBCUtils.getConnection();



String sql = "insert into goods(name)values(?)";

PreparedStatement ps = conn.prepareStatement(sql);



for(int i = 1;i <= 1000000;i++){

ps.setString(1, "name_" + i);



//1.“攒”sql

ps.addBatch();

if(i % 500 == 0){

//2.执行

ps.executeBatch();

//3.清空

ps.clearBatch();

}

}



long end = System.currentTimeMillis();

System.out.println("花费的时间为：" + (end - start));//20000条：625 //1000000条:14733



JDBCUtils.closeResource(conn, ps);

}

方式2

/*

* 层次四：在层次三的基础上操作

* 使用Connection 的 setAutoCommit(false) / commit()

*/

@Test

public void testInsert2() throws Exception{

long start = System.currentTimeMillis();



Connection conn = JDBCUtils.getConnection();



//1.设置为不自动提交数据

conn.setAutoCommit(false);



String sql = "insert into goods(name)values(?)";

PreparedStatement ps = conn.prepareStatement(sql);



for(int i = 1;i <= 1000000;i++){

ps.setString(1, "name_" + i);



//1.“攒”sql

ps.addBatch();



if(i % 500 == 0){

//2.执行

ps.executeBatch();

//3.清空

ps.clearBatch();

}

}



//2.提交数据

conn.commit();



long end = System.currentTimeMillis();

System.out.println("花费的时间为：" + (end - start));//1000000条:4978



JDBCUtils.closeResource(conn, ps);

}