在数据库插入万条数据,比普通插入提升百倍速度
JDBC中通过普通方法插入一万条数据
/**
* 普通方法插入10000条数据
* @throws Exception
*/
@Test
public void testInsert() throws Exception {
//注册驱动
Class.forName("com.mysql.cj.jdbc.Driver");
//获取连接
Connection connection = DriverManager.getConnection("jdbc:mysql:///testDb?user=root&password=abc123");
//编写sql语句
String sql = "insert into user(name,,age,sex) values (?,?,?)";
//创建statement
PreparedStatement preparedStatement = connection.prepareStatement(sql);
//计算插入数据开始时间
long startTime = System.currentTimeMillis();
for (int i = 1; i < 10000; i++) {
preparedStatement.setObject(1, "shiSheng" + i);
preparedStatement.setObject(2, "1" + i);
preparedStatement.setObject(3, "男" + i);
//一条一条插入数据
preparedStatement.executeUpdate();
}
//运行完插入数据的结束时间
long endTime = System.currentTimeMillis();
//计算两者的差值,也就是插入1万条数据所用的时间
long time = endTime - startTime;
System.out.println("普通方式执行插入1万个数据消耗的时间:" + time );
//关闭资源
preparedStatement.close();
connection.close();
}
运行结果
普通方式执行插入1万个数据消耗的时间:23391
通过批量插入来提升百倍速度
/**
* 批量插入10000条数据
* @throws Exception
*/
@Test
public void batchInsert() throws Exception {
//注册驱动
Class.forName("com.mysql.cj.jdbc.Driver");
//获取连接
Connection connection = DriverManager.getConnection("jdbc:mysql:///testDb?rewriteBatchedStatements=true","root","abc123");
//编写sql语句
String sql = "insert into user(name,,age,sex) values (?,?,?)";
//创建statement
PreparedStatement preparedStatement = connection.prepareStatement(sql);
//计算插入数据开始时间
long startTime = System.currentTimeMillis();
for (int i = 1; i < 10000; i++) {
preparedStatement.setObject(1, "a" + i);
preparedStatement.setObject(2, "b" + i);
preparedStatement.setObject(3, "c" + i);
//将所有要插入的数据添加到values后面
preparedStatement.addBatch();
}
//批量插入数据
preparedStatement.executeBatch();
//运行完插入数据的结束时间
long endTime = System.currentTimeMillis();
//计算两者的差值,也就是插入1万条数据所用的时间
long time = endTime - startTime;
System.out.println("优化方式执行插入1万个数据消耗的时间:" + time );
//关闭资源
preparedStatement.close();
connection.close();
}
运行结果
优化方式执行插入1万个数据消耗的时间:231
变动
- 改动一
- 改动二
- 改动三
原因