什么是批處理

之前進(jìn)行JDBC的操作的時(shí)候，都是一條SQL語(yǔ)句執(zhí)行。現(xiàn)在如果使用批處理，可以將一批SQL一起執(zhí)行。

批處理基本使用

@Test/*** 批處理基本操作*/public void demo1(){Connection conn = null;Statement stmt = null;try{// 獲得連接:conn = JDBCUtils.getConnection();// 創(chuàng)建執(zhí)行批處理對(duì)象:stmt = conn.createStatement();// 編寫(xiě)一批SQL語(yǔ)句：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);// 執(zhí)行批處理:stmt.executeBatch();}catch(Exception e){e.printStackTrace();}finally{JDBCUtils.release(stmt, conn);}}

批量插入（使用PreparedStatement）

@Test/*** 批量插入記錄:* * 默認(rèn)情況下MySQL批處理沒(méi)有開(kāi)啟的，需要在url后面拼接一個(gè)參數(shù)即可。*/public void demo2(){// 記錄開(kāi)始時(shí)間:long begin = System.currentTimeMillis();Connection conn = null;PreparedStatement pstmt = null;try{// 獲得連接:conn = JDBCUtils.getConnection();// 編寫(xiě)SQL語(yǔ)句：String sql = "insert into user values (null,?)";// 預(yù)編譯SQL:pstmt = conn.prepareStatement(sql);for(int i=1;i<=10000;i++){pstmt.setString(1, "name"+i);// 添加到批處理pstmt.addBatch();// 注意問(wèn)題：// 執(zhí)行批處理if(i % 1000 == 0){// 執(zhí)行批處理:pstmt.executeBatch();// 清空批處理:pstmt.clearBatch();}}}catch(Exception e){e.printStackTrace();}finally{JDBCUtils.release(pstmt, conn);}long end = System.currentTimeMillis();System.out.println((end-begin));}

?

總結(jié)

以上是生活随笔為你收集整理的JDBC的批处理操作的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。