什么叫事务?Java如何处理事务呢?
什么叫事務?這些就是數據庫特有的術語了。懶蟲在這里口頭解釋:就是把多件事情當做一件事情來處理。也就是大家同在一條船上,要活一起活,要over一起over !
我為什么要使用事務? 俺這里再舉個很俗很俗的例子:
俺到銀行存錢,于是有這么幾個步驟:
1、把錢交給工作人員;2、工作人員填單;3、將單子給我簽字;4、工作人員確認并輸入電腦。
要是,要是我把錢交給工作人員之后,進行到3我簽字了。那哥們突然心臟病發作,over掉了,那,我的錢還沒有輸入電腦,但我卻交了錢又簽字確認了,而并沒有其他任何記錄。我豈不是要虧死了???我的血汗錢啊!趕緊退給我!!
于是,在數據庫里產生了這么一個術語:事務(Transaction),也就是要么成功,要么失敗,并恢復原狀。
還是寫程序把:
Create Proc sp我去存款(@M Money , @iOperator Int)
As
Begin
Declare @i int
Begin Tran --激活事務
Exec @i=sp交錢 @m,@iOperator
if @i<>0 --這里一般用系統錯誤號 @@Error。我這里為了舉例子沒有用到。需要根據實際情況。
begin
Rollback Tran --回滾事務
RaisError ('銀行的窗口太少了,我懶得排隊,不交了!:( ', 16, 1) with Log --記錄日志
Return -1 --返回錯誤號
end
Exec @i=sp填單 @m,@iOperator
if @i<>0
begin
Rollback Tran --回滾事務
RaisError ('銀行的哥們打印機出了點毛病,打印不出單子來,把錢退回來給我吧??', 16, 1) with Log
Return -2
end
Exec @i=sp簽字 @m
if @i<>0
begin
Rollback Tran --回滾事務
RaisError ('我靠?什么爛銀行,換了3支筆都寫不出水來!!老子不存了!!不簽!', 16, 1) with Log
Return -3
end
Exec @i=sp輸入電腦 @m,@iOperator
if @i<>0
begin
Rollback Tran --回滾事務
RaisError ('什么意思?磁盤空間已滿?好了好了,把錢給我,我到旁邊的這家銀行!', 16, 1) with Log
Return -4
end
Commit Tran --提交事務
Return 0
End
----------------------------------------------------------------------
以上是偽代碼,模擬我去存款的過程。
例如我們有一個訂單庫存管理系統,每一次生成訂單的同時我們都要消減庫存。通常來說訂單和庫存在數據庫里是分兩張表來保存的:訂單表,庫存表。每一次我們追加一個訂單實際上需要兩步操作:在訂單表中插入一條數據,同時修改庫存的數據。
這樣問題來了,例如我們需要一個單位為10的訂單,庫存中有30件,理想的操作是我們在訂單表中插入了一條單位為10的訂單,之后將庫存表中的數據修改為20。但是有些時候事情并不是總是按照你的想法發生,例如:在你修改庫存的時候,數據庫突然由于莫名其妙的原因無法連接上了。也就是說庫存更新失敗了。但是訂單已經產生了,那么怎么辦呢?沒辦法,只有手動的修改。所以最好的方式是將訂單插入的操作和庫存修改的操作綁定在一起,必須同時成功或者什么都不做。這就是事務。
Java如何處理事務呢?
我們從java.sql.Connection說起,Connection表示了一個和數據庫的鏈接,可以通過Connection來對數據庫操作。在通常情況是Connection的屬性是自動提交的,也就是說每次的操作真的更新了數據庫,真的無法回退了。針對上述的例子,一旦庫存更新失敗了,訂單無法回退,因為訂單真的插入到了數據庫中。這并不是我們希望的。
我們希望的是:看起來成功了,但是沒有真的操作數據庫,知道我想讓他真的發生。可以通過Connection的setAutoCommit(false)讓Connection不自動提交你的數據,除非你真的想提交。那么如何讓操作真的發生呢?可以使用Connection的commit方法。如何讓操作回退呢?使用rollback方法。
例如:
try{
Connection conn = getConnection(); // 不管如何我們得到了鏈接
conn.setAutoCommit(false);
// 插入訂單
// 修改庫存
conn.commit(); // 成功的情況下,提交更新。
} catch(SQLException ex) {
conn.rollback(); // 失敗的情況下,回滾所有的操作
} finally {
conn.close();
}
這里有一點非常重要,事務是基于數據庫鏈接的。所以在但數據庫的情況下,事務操作很簡單。
那么如果表分布在兩個不同的數據庫中呢?
例如訂單表在訂單庫中,庫存表在庫存庫中,那么我們如何處理這樣的事務呢?
需要注意,提交也可以遇到錯誤呀!
try{
Connection conn1 = getConnection1();
Connection conn2 = getConnection2();
// 基于conn1做插入操作
// 基于conn2做更新操作
try{
conn1.commit()
} catch(SQLExcetion ) {
conn1.rollback();
}
try {
conn2.commit();
} catch(SQLException ) {
conn2.rollbakc();
// 保證肯定刪除剛才插入的訂單。
}
} catch(SQLException ex) {
// 如果插入失敗,conn1.rollback
// 如果更新失敗,conn1.rollback && conn2.rollback
} finally {
conn1.close();
conn2.close();
}
看看上述的代碼就知道,其實操作非常的復雜,甚至:保證肯定刪除剛才插入的訂單根本無法保證。
在上述情況下的事務可以稱之為分布式事務,通過上述的代碼中事務同時提交處理的部分我們可以得出,要想處理分布式事務,必須有獨立于數據庫的第三方的事務處理組件。
幸運的是通常情況下,JavaEE兼容的應用服務器,例如:Weblogic,Websphere,JBoss,Glassfish等都有這種分布式事務處理的組件。
如何使用應用服務器的分布式事務管理器處理分布式事務?
以galssfish為例
1 建立對應兩個數據庫的XA(javax.sql.XADataSource)類型的數據源。
2 使用UserTransaction來保證分布式事務。
try{
Connection conn1 = datasource1.getConnection();
Connection conn2 = datasource2.getConnection();
UserTransaction ut = getUserTransaction();
ut.begin();
// 插入訂單
// 修改庫存
ut.commit(); // 成功的情況下,提交更新。
} catch(SQLException ex) {
ut.rollback(); // 失敗的情況下,回滾所有的操作
} finally {
conn.close();
}
如何獲取UserTransaction呢?可以使用如下方法
UserTransaction tx = (UserTransaction)
ctx.lookup("jndi/UserTransaction");
總結
以上是生活随笔為你收集整理的什么叫事务?Java如何处理事务呢?的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: ORACLE 等待事件
- 下一篇: BGP策略路由的实现