重要概念
自動提交模式
對於mysql資料庫,預設情況下,資料庫處於自動提交模式。每一語句處於單獨的事務中,在這條語句執行完畢時,如果執行成功則隱式的提交事務,如果執行失敗則隱式的回滾事務。對於正常的事務管理,是一組相關的操作處於一個事務之中,因此必須關閉資料庫的自動提交模式,以下是查看方式:
查看是否自動提交命令(ON表示開啟自動提交,值為1,OFF表示關閉自動提交,值為0):
show variables like 'autocommit';
關閉自動提交後,則使用者將一直處於某個事務中,直到執行一條commit提交或rollback語句才會結束目前事務重新開始一個新的事務。
DataSource connection = masterDataSource.getConnection(); connection.setAutoCommit(false);
交易隔離等級
隔離等級是指若干個並發的交易之間的隔離程度。 TransactionDefinition 介面中定義了五個表示隔離等級的常數:
1、TransactionDefinition.ISOLATION_DEFAULT
:這是預設值,表示使用底層資料庫的預設隔離等級。對大部分資料庫而言,通常這值就是TransactionDefinition.ISOLATION_READ_COMMITTED
。
2、TransactionDefinition.ISOLATION_READ_UNCOMMITTED
:此隔離等級表示一個交易可以讀取另一個交易修改但尚未提交的資料。此等級無法防止髒讀,不可重複讀取和幻讀,因此很少使用該隔離等級。例如PostgreSQL其實並沒有此等級。
3、TransactionDefinition.ISOLATION_READ_COMMITTED
:此隔離等級表示一個交易只能讀取另一個交易已經提交的資料。此等級可防止髒讀,這也是大多數情況下的建議值。
4、TransactionDefinition.ISOLATION_REPEATABLE_READ
:此隔離等級表示一個交易在整個過程中可以重複執行某個查詢,並且每次回傳的記錄都相同。此等級可防止髒讀和不可重複讀。
5、TransactionDefinition.ISOLATION_SERIALIZABLE
:所有的交易依序逐一執行,這樣事務之間就完全不可能產生幹擾,也就是說,該層級可以防止髒讀、不可重複讀以及幻讀。但是這將嚴重影響程式的效能。通常情況下也不會用到該等級。
事務傳播行為
所謂事務的傳播行為是指,如果在開始當前事務之前,一個事務上下文已經存在,此時有若干選項可以指定一個事務性方法的執行行為。在TransactionDefinition定義中包含瞭如下幾個表示傳播行為的常數:
1、TransactionDefinition.PROPAGATION_REQUIRED
:如果目前存在事務,則加入該事務;如果目前沒有事務,則建立一個新的事務。這是預設值。
2、TransactionDefinition.PROPAGATION_REQUIRES_NEW
:建立一個新的事務,如果目前有事務,則把目前交易掛起。
3、TransactionDefinition.PROPAGATION_SUPPORTS
:如果目前存在事務,則加入該交易;如果目前沒有事務,則以非交易的方式繼續運作。
4、TransactionDefinition.PROPAGATION_NOT_SUPPORTED
:以非交易方式運作,如果目前有事務,則把目前交易掛起。
5、TransactionDefinition.PROPAGATION_NEVER
:以非交易方式運行,如果目前存在事務,則拋出例外。
6、TransactionDefinition.PROPAGATION_MANDATORY
#:如果目前存在事務,則加入該交易;如果目前沒有事務,則拋出例外。
7、TransactionDefinition.PROPAGATION_NESTED
:如果目前存在事務,則建立一個事務作為目前交易的巢狀事務來運作;如果目前沒有事務,則該取值等價於TransactionDefinition.PROPAGATION_REQUIRED
。
保護點(Savepoints
)
#首先要知道savepoint就是為回退做的,savepoint的個數沒有限制,savepoint和虛擬機中快照類似. savepoint是事務中的一點。用於取消部分事務,當結束事務時,會自動的刪除該事務中所定義的所有保存點。
當執行rollback時,透過指定保存點可以回退到指定的點。
回退交易的幾個重要操作
1、設定保存點savepoint a
2、取消儲存點a之後交易rollback to a
# 3.取消全部事務rollback
注意:這個回退事務,必須是沒有commit前使用的;
public class UserRepository { private DataSource masterDataSource; private Connection connection = null; @Autowired public void setMasterDataSource(DataSource masterDataSource) { this.masterDataSource = masterDataSource; } @Transactional public boolean save(User user) { try { connection = masterDataSource.getConnection(); connection.setAutoCommit(false); //设置保护点 Savepoint saveUser = connection.setSavepoint("saveUser"); PreparedStatement prepareStatement = connection.prepareStatement("insert into user(id,name,age) values(?,?,?)"); prepareStatement.setLong(1, user.getId()); prepareStatement.setString(2, user.getName()); prepareStatement.setInt(3, user.getAge()); prepareStatement.execute(); try { update(user); } catch (Exception e) { System.out.println("出错了。。"+e); //回滚至保护点 connection.rollback(saveUser); } connection.commit(); } catch (SQLException e) { e.printStackTrace(); } finally { try { connection.close(); } catch (SQLException e) { e.printStackTrace(); } } return true; } public boolean update(User user) { System.out.println("save user:"+user); try { PreparedStatement prepareStatement = connection.prepareStatement("update user set name = ? ,age = ? where id = ?)"); prepareStatement.setLong(3, user.getId()); prepareStatement.setString(1, "王大拿"); prepareStatement.setInt(2, 100/0); prepareStatement.execute(); connection.commit(); } catch (SQLException e) { e.printStackTrace(); } return true; } }
以上內容整理若有錯誤請指正,謝謝!
更多Mysql相關問題請造訪PHP中文網:Mysql影片教學
以上是SpringBoot事務詳細簡介的詳細內容。更多資訊請關注PHP中文網其他相關文章!