时间:2021-07-01 10:21:17 帮助过:18人阅读
void addBatch()
- 将要执行的SQL先保存起来,先不执行
- 这个方法在设置完所有的占位符之后调用
int[] executeBatch()
- 这个方法用来执行SQL语句,这个方法会将批处理中所有SQL语句执行
- mysql默认批处理是关闭的,所以我们还需要去打开mysql的批处理:
rewriteBatchedStatements=true
我们需要将以上的参数添加到mysql的url地址中
- 注意:低版本的mysql-jdbc驱动也不支持批处理,一般都是在修改的时候使用批处理,查询的时候不使用!
CREATE TABLE t_emp( id INT PRIMARY KEY AUTO_INCREMENT, NAME VARCHAR(50) )
package com.tyd.batch.dao; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; public class UserDao { public void testBatch(){ //向t_emp表中插入10000条数据 //准备两个变量 Connection connection = null; PreparedStatement ps = null; try { //获取数据库连接 connection=JDBCUtil.getConnection(); //准备SQL模板 String sql = "INSERT INTO t_emp(NAME) VALUES(?)"; //获取PrepareStatement ps = connection.prepareStatement(sql); //创建一个for循环,来设置占位符 for(int i = 0; i < 10000 ;i++){ //填充占位符 ps.setString(1,"emp"+i); //添加到批处理方法中,调用无参的,有参的是Statement来调用的! ps.addBatch(); } //获取一个时间戳 long start = System.currentTimeMillis(); //执行批处理 ps.executeBatch(); //获取一个时间戳 long end = System.currentTimeMillis(); System.out.println("共花费了:"+(end-start)); } catch (SQLException e) { e.printStackTrace(); }finally{ JDBCUtil.close(connection, ps,null); } } }
public static void main(String[] args) { System.out.println("开始执行"); UserDao ud=new UserDao(); System.out.println("执行结束"); }
SELECT * FROM t_emp;
批处理——数据库
标签:循环 ext 效率 margin jdbcutil 默认 str color sql