事务Transaction/* * 事务Transaction * JDBC默认开启自动提交事务，需要关闭，才能手动控制事务 * * 默认MySQL存储引擎为My…，其不支持事务处理，修改为InnoDB引擎 * create table 表名( ) engine=InnoDB default charset=utf8; * * InnoDB引擎默认关闭自动事务提交，修改MySQL为自动提交事务 * set autocommit=1; //1表示自动提交，，0表示关闭自动提交 * show variables like ‘autocommit’; */public class Test01 {(String[] args) {Connection conn = null;PreparedStatement pstmt = null;ResultSet rs = null;conn = DBUtil.getConnection();try {conn.setAutoCommit(false);//关闭自动提交事务，手动控制事务String sql = “insert into user values (null,’eee’,’123′)”;pstmt = conn.prepareStatement(sql);pstmt.executeUpdate(); //插入第一个用户String sql2=”insert into user values (‘fff’,’123′)”;pstmt=conn.prepareStatement(sql2);pstmt.executeUpdate();//插入第二个用户conn.commit();//提交事务System.out.println(“插入用户成功！”);} catch (SQLException e) {System.out.println(“出现异常，回滚事务”);try {conn.rollback();//回滚事务} catch (SQLException e1) {e1.printStackTrace();}} finally {DBUtil.closeAll(rs, pstmt, conn);}}}批处理/* * 批处理 */public class Test02 {Connection conn = null;Statement stmt = null;PreparedStatement pstmt=null;ResultSet rs = null;() {try {conn = DBUtil.getConnection();stmt = conn.createStatement();// 添加批处理语句stmt.addBatch(“insert into user values (null,’s001′,’123′)”);stmt.addBatch(“insert into user values (null,’s002′,’123′)”);stmt.addBatch(“insert into user values (null,’s003′,’123′)”);// 执行批处理int[] nums = stmt.executeBatch();System.out.println(Arrays.toString(nums));} catch (SQLException e) {e.printStackTrace();} finally {DBUtil.closeAll(rs, stmt, conn);}}() {try {conn = DBUtil.getConnection();conn.setAutoCommit(false);pstmt=conn.prepareStatement(“insert into user values (null,?,?)”);// 添加批处理语句pstmt.setObject(1, “t001”);pstmt.setObject(2, “123”);pstmt.addBatch();pstmt.setObject(1, “t002”);pstmt.setObject(2, “123”);pstmt.addBatch();pstmt.setObject(1, “t003”);pstmt.setObject(2, “123”);pstmt.addBatch();// 执行批处理int[] nums=pstmt.executeBatch();System.out.println(Arrays.toString(nums));conn.commit();} catch (SQLException e) {try {conn.rollback();} catch (SQLException e1) {e1.printStackTrace();}e.printStackTrace();} finally {DBUtil.closeAll(rs, stmt, conn);}}(String[] args) {Test02 test = new Test02();test.test02();}}
如果心在远方，只需勇敢前行，梦想自会引路，
