JDBC的批处理操作【黑马大数据培训】

【郑州校区】JDBC的批处理操作

之前进行JDBC的操作的时候，都是一条SQL语句执行。现在如果使用批处理，可以将一批SQL一起执行。

@Test /** * 批处理基本操作 */ public void demo1(){ Connection conn = null; Statement stmt = null; try{ // 获得连接: conn = JDBCUtils.getConnection(); // 创建执行批处理对象: stmt = conn.createStatement(); // 编写一批SQL语句： String sql1 = "create database test1"; String sql2 = "use test1"; String sql3 = "create table user(id int primary key auto_increment,name varchar(20))"; String sql4 = "insert into user values (null,'aaa')"; String sql5 = "insert into user values (null,'bbb')"; String sql6 = "insert into user values (null,'ccc')"; String sql7 = "update user set name = 'mmm' where id = 2"; String sql8 = "delete from user where id = 1"; // 添加到批处理 stmt.addBatch(sql1); stmt.addBatch(sql2); stmt.addBatch(sql3); stmt.addBatch(sql4); stmt.addBatch(sql5); stmt.addBatch(sql6); stmt.addBatch(sql7); stmt.addBatch(sql8); // 执行批处理: stmt.executeBatch(); }catch(Exception e){ e.printStackTrace(); }finally{ JDBCUtils.release(stmt, conn); } }

@Test /** * 批量插入记录: * * 默认情况下MySQL批处理没有开启的，需要在url后面拼接一个参数即可。 */ public void demo2(){ // 记录开始时间: long begin = System.currentTimeMillis(); Connection conn = null; PreparedStatement pstmt = null; try{ // 获得连接: conn = JDBCUtils.getConnection(); // 编写SQL语句： String sql = "insert into user values (null,?)"; // 预编译SQL: pstmt = conn.prepareStatement(sql); for(int i=1;i<=10000;i++){ pstmt.setString(1, "name"+i); // 添加到批处理 pstmt.addBatch(); // 注意问题： // 执行批处理 if(i % 1000 == 0){ // 执行批处理: pstmt.executeBatch(); // 清空批处理: pstmt.clearBatch(); } } }catch(Exception e){ e.printStackTrace(); }finally{ JDBCUtils.release(pstmt, conn); } long end = System.currentTimeMillis(); System.out.println((end-begin)); }

传智播客·黑马程序员郑州校区地址