package com.yqy.t; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; public class TestTransaction { public static void main(String[] args) { Connection conn = null; PreparedStatement pstmt = null; try { Class.forName("oracle.jdbc.driver.OracleDriver"); String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl"; conn = DriverManager.getConnection(url,"scott","tiger"); conn.setAutoCommit(false);//设置jdbs的提交方式为手动,默认为自动提交 String sql = "insert into dept values(?,?,?)";//用prepare的方式 pstmt = conn.prepareStatement(sql); pstmt.setInt(1, 91); pstmt.setString(2, "duke"); pstmt.setString(3, "NH"); pstmt.addBatch();//加入批量处理 pstmt.setInt(1, 92); pstmt.setString(2, "Silin"); pstmt.setString(3, "US"); pstmt.addBatch();//加入批量处理 /* statement写法: stmt = conn.createStatement(); stmt.addBatch("insert into dept values(51,'nn','hs'); stmt.addBatch("insert into dept values(52,'aa','as'); stmt.executeBatch(); */ pstmt.executeBatch();//提交批量处理executeBatch conn.commit();//提交之前的处理 conn.setAutoCommit(true);//记着要把提交方式再改成默认的方式。 } catch(ClassNotFoundException e) { e.printStackTrace(); } catch(SQLException e) {//有sql异常时,要回滚 e.printStackTrace(); try{ if(conn != null) {//如果检测到有异常,那么对操作进行回滚 conn.rollback();//回滚 conn.setAutoCommit(true);//因为异常原因,对提交方式再改成默认的,保险 } } catch(SQLException e2) {//e变量名已经被用了 e2.printStackTrace(); } } finally {//最后再关闭连接 try{ if(pstmt != null){ pstmt.close(); pstmt = null; } if(conn != null){ conn.close(); conn = null; } } catch(SQLException e){ e.printStackTrace(); } } } }
java-jdbc-transaction & Batch例子
猜你喜欢
转载自nineking.iteye.com/blog/2212481
今日推荐
周排行