Java事务管理[通俗易懂]

public void JdbcTransfer() { 

java.sql.Connection conn = null;
Statement stmt = null;
try { 

conn = conn = DriverManager.getConnection(
"jdbc:oracle:thin:@host:1521:SID", "username", "userpwd");
// 将自动提交设置为 false，
// 若设置为 true 则数据库将会把每一次数据更新认定为一个事务并自动提交
conn.setAutoCommit(false);
stmt = conn.createStatement();
// 将 A 账户中的金额减少 500
stmt.execute("update t_account set amount = amount - 500 where account_id = 'A'");
// 将 B 账户中的金额增加 500
stmt.execute("update t_account set amount = amount + 500 where account_id = 'B'");
// 提交事务
conn.commit();
// 事务提交：转账的两步操作同时成功
} catch (SQLException e) { 

try { 

// 发生异常，回滚在本事务中的操做
conn.rollback();
// 事务回滚：转账的两步操作完全撤销
stmt.close();
conn.close();
} catch (Exception ignore) { 

}
e.printStackTrace();
}
}

public void JtaTransfer() { 

javax.transaction.UserTransaction tx = null;
java.sql.Connection conn = null;
Statement stmt = null;
try { 

tx = (javax.transaction.UserTransaction) context
.lookup("java:comp/UserTransaction"); // 取得JTA事务，本例中是由Jboss容器管理
javax.sql.DataSource ds = (javax.sql.DataSource) context
.lookup("java:/XAOracleDS"); // 取得数据库连接池，必须有支持XA的数据库、驱动程序
tx.begin();
conn = ds.getConnection();
// 将自动提交设置为 false，
// 若设置为 true 则数据库将会把每一次数据更新认定为一个事务并自动提交
conn.setAutoCommit(false);
stmt = conn.createStatement();
// 将 A 账户中的金额减少 500
stmt.execute("update t_account set amount = amount - 500 where account_id = 'A'");
// 将 B 账户中的金额增加 500
stmt.execute("update t_account set amount = amount + 500 where account_id = 'B'");
// 提交事务
tx.commit();
// 事务提交：转账的两步操作同时成功
} catch (SQLException sqle) { 

try { 

// 发生异常，回滚在本事务中的操做
tx.rollback();
// 事务回滚：转账的两步操作完全撤销
stmt.close();
conn.close();
} catch (Exception ignore) { 

}
sqle.printStackTrace();
}
}

// JDBC事务 
Connection conn = getConnection(); 
conn.setAutoCommit(false);
... // 业务实现 ... 
if 正常 
conn.commit(); 
if 失败 
conn.rollback();

// Hibernate事务 
Session s = getSession(); 
Transaction tx = s.beginTransaction(); 
... // 业务实现 ... 
if 正常 
tx.commit(); 
if 失败 
tx.rollback();