問題

今天項目測試一個方法的時候，發(fā)現(xiàn)日志報錯

日志報錯大致如下：Connection is read-only. Queries leading to data modification are not allowed

org.springframework.dao.TransientDataAccessResourceException:
### Error updating database.  Cause: java.sql.SQLException: Connection is read-only. Queries leading to data modification are not allowed
### The error may involve com.o2o.app.repository.AccountOrderMybatisDao.updateOrder-Inline
### The error occurred while setting parameters
### SQL: UPDATE t_account_order SET ORDER_STATUS=?, STATUS_DESCRIPTION=?, IS_DELETE = ?           WHERE  TRADE_CODE = ? and TRADE_TYPE=?
### Cause: java.sql.SQLException: Connection is read-only. Queries leading to data modification are not allowed; SQL []; Connection is 
read-only. Queries leading to data modification are not allowed; nested exception is java.sql.SQLException: 
Connectionis read-only. Queries leading to data modification are not allowed

第一眼看上去，這不是Spring事務配置了只讀事務屬性，當執(zhí)行sql寫操作當然會失敗了，為了更好解決這個bug，讓我們先溫習一下事務以及Spring在事務傳播做了那些事？

• 事務介紹
• 事務(Transaction)：指的是要做的事情，在計算機術語指的是訪問并能更新數(shù)據(jù)庫數(shù)據(jù)的一個程序執(zhí)行單元
• 由于我們日常開發(fā)，需要經(jīng)常對關系型數(shù)據(jù)庫打交道，這里簡單介紹一下關系型數(shù)據(jù)庫的事務四大屬性

• Spring事務核心類和接口
• 如下圖所示：在spring-tx包下有三個spring事務管理非常重要的接口 : PlatformTransactionManager,TransactionDefinition,TransactionStatus

spring并不實現(xiàn)各個數(shù)據(jù)庫持久層的事務實現(xiàn)，而是提供對應的事務管理器，如下圖所示：

我們首先查看PlatformTransactionManager接口的源代碼：

TransactionStatus getTransaction(TransactionDefinition definition)

官方的解釋是： Return a currently active transaction or create a new one, according to the specified propagation behavior

這句話的意思是根據(jù)指定的事務行為，返回當前的事務或者新建一個事務。

void commit(TransactionStatus status)

官方解釋是：Commit the given transaction, with regard to its status. If the transaction has been marked rollback-only programmatically, perform a rollback.

這句話的意思是根據(jù)事務的狀態(tài)提交事務，如果事務標記了rollback-only，請執(zhí)行會滾。

void rollback(TransactionStatus status)

官方的解釋是： Perform a rollback of the given transaction，即對事務進行回滾。

看到這里，我們需要明確三個接口中入?yún)⒌腡ransactionDefinition是個什么東西呢？

讓我們先大致查看一下TransactionDefinition接口的方法和成員變量，以下將會對此接口的方法做個簡單的介紹，如下圖所示：

• 事務的傳播行為
• 當事務方法被調用時候，必須指定事務如何傳播，下面是事務傳播行為的介紹：

• 事務的隔離級別
• 典型的事務隔離不同所造成問題如下：

1.臟讀：臟讀發(fā)送在A事務讀取B事務已經(jīng)改寫但是還未提交的數(shù)據(jù),若此時B事務回滾了，那么A事務獲取就是臟數(shù)據(jù)

2.不可重復讀：不可重復讀發(fā)送在當A事務執(zhí)行2次查詢，每一次獲取的數(shù)據(jù)結果都不相同，這是由于B事務在A事務2次查詢期間進行了更新

3.幻讀： 幻讀發(fā)送在當A事務讀取了幾行數(shù)據(jù)，緊接著B事務進行輸入的插入，在隨后的查詢中A事務就會讀了原本不存在的記錄

不可重復讀特指修改的記錄，而幻讀指的是新增或刪除的記錄

• 只讀屬性
• 如果設置了只讀事務，只讀事務常常用于做查詢使用，此時的增刪改，將會報Connection is read-only. Queries leading to data modification are not allowed的異常。
• 事務的超時
• 一個正常和良好的程序，事務的行為時間并不會很長，較長的事務運行時間，會占用數(shù)據(jù)庫資源，所以這里就設置超時時間，若指定時間內沒有執(zhí)行完事務，將會自動進行回滾
• 事務的名稱
• 在一個事務行為中配置獲取事務的名稱，如我們常見的save，add，del 等等…

以上溫習過Spring事務管理器和傳播行為后，所以既然報錯Connection is read-only. Queries leading to data modification are not allowed所以我們在接口方法的實現(xiàn)，加了以下的注解: @Transactional(propagation = Propagation.REQUIRED, readOnly = false),but！當我再次請求接口的時候，發(fā)現(xiàn)依然還是報同樣的錯誤，百度一下，發(fā)現(xiàn)有相關問題博客的收集：Spring下默認事務機制中@Transactional 無效的原因

Method visibility and @Transactional When using proxies, you should apply the @Transactional annotation 
only to methods with public visibility. If you do annotate protected, private or package-visible methods with the
@Transactional annotation, no error is raised, but the annotated method does not exhibit the configured transactional settings. 
Consider the use of AspectJ (see below) if you need to annotate non-public methods.

大概意思是：如果你是使用默認的Spring Aop代理方式將@Transaction注解應該用于公共可見即public的，如果對protected，或者private的方法加入@Transaction注解，則會無效。如果想在私有方法是使事務有效，可以用AspectJ進行實現(xiàn)。

but,我們的注解沒有加在protected和private方法上，但是依然無效，why？

此次注解失效原因像下面簡單的例子一樣：在電商系統(tǒng)中，存在待支付的訂單，假設有一個訂單編號為201904191102的訂單要進行支付，首先我需要刷新支付頁面，就需要調用收銀臺接口，由于一直使用的scala開發(fā)，所以下面的代碼使用scala做演示：

  /**
    * 刷新收銀臺的接口：refreshCashier
    */
  def refreshCashier(orderId: String): OrderInfo
  
    /**
    * 更新錢包的方法
    */
  def updateWallet(order:orderInfo):PayDto
  
  override def refreshCashier(orderId: String): OrderInfo = {
    // 偽代碼，在這個方法里面調用 updateWallet方法
  }
 @Transactional(propagation = Propagation.REQUIRED, readOnly = false)
  override def updateWallet(order:orderInfo): PayDto = {
   // 這里發(fā)送了異常
   throw new AppException()
  }

在上面的代碼中，refreshCashier方法調用了updateWallet方法的時候，當updateWallet方法出錯報異常，事務并沒有回滾，這是因為Spring Aop動態(tài)代理會為每個class對象生成代理對象，只有在代理對象之間進行調用的時候，將會觸發(fā)切面相關的邏輯處理。

所以要保證整個方法調用鏈的事務性，在refreshCashier方法加上@Transaction注解，此時才能保證，updateWallet方法出錯時候，整個方法能進行事務的回滾。這樣完美，問題解決了.

總結

以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。

最新評論