为了让多个 SQL 语句作为一个事务执行：
- 调用 Connection 对象的 setAutoCommit(false); 以取消自动提交事务
- 在所有的 SQL 语句都成功执行后，调用 commit(); 方法提交事务
- 在出现异常时，调用 rollback(); 方法回滚事务
- 若此时 Connection 没有被关闭, 则需要恢复其自动提交状态
// AA 用户转给 BB 用户 100元。 1.AA 用户 扣除 100
2.BB用户增加 100
@Test
public void testUpdate2 () {
Connection conn = null ;
try {
conn = JDBCUtils .getConnection ();
// 1. 开启事务
conn .setAutoCommit ( false);
String sql1 = "update
user_table set balance = balance - ? where user = ?";
updateWithTx (conn , sql1 , 100 , "AA");
// 模拟网络异常
// System.out.println(10 / 0);
String sql2 = "update
user_table set balance = balance + ? where user = ?";
updateWithTx (conn , sql2 , 100 , "BB");
// 2. 提交事务
conn .commit ();
} catch (Exception
e ) {
e .printStackTrace ();
if (conn != null ) {
try {
// 3. 回滚事务
conn .rollback (); //出现异常则直接会执行 catch 中的内容，然后使之前对数据库的操作回滚
} catch (SQLException
e1 ) {
e1 .printStackTrace ();
}
}
} finally {
JDBCUtils .close ( null, null, conn);
}
}
// 通用的增删改方法（ version
3.0 ）: 考虑上数据库事务
public void updateWithTx (Connection
conn , String sql , Object... args) {
// 1. 返回一个PreparedStatement 的对象，涉及预编译 sql 语句
PreparedStatement ps = null ;
try {
ps = conn .prepareStatement (sql );
// 2. 填充占位符
for ( int i = 0; i < args .length ; i ++) {
ps .setObject (i + 1 , args [i ]);// 设置占位符
}
// 3. 执行
ps .executeUpdate ();
} catch (Exception
e ) {
e .printStackTrace ();
} finally {
// 4. 关闭操作
JDBCUtils .close ( null, ps , null); // 注意连接不能关，否则会有语句执行不到
}
}
