Spring中的事務管理實例詳解

本文實例講述了Spring中的事務管理。分享給大家供大家參考。具體分析如下：

事務簡介：

事務管理是企業級應用程式開發中不可或缺的技術，用來確保資料的完整性和一致性

事務就是一系列的動作，它們被當作一個單獨的工作單位。這些動作要么全部完成，要么全部不起作用

事務的四個關鍵屬性(ACID)

① 原子性(atomicity):事務室一個原子操作，有一系列動作組成。事務的原子性確保動作要麼全部完成，要麼完全不起作用② 一致性(consistency):一旦所有事務動作完成，事務就被提交。數據和資源就處於滿足業務規則的一致性狀態中③ 隔離性(isolation):可能有許多事務會同時處理相同的數據，因此每個事物都應該與其他事務隔離開來，防止數據損壞④持久性(durability):一旦事務完成，無論發生什麼系統錯誤，它的結果都不應該受到影響。通常情況下，事務的結果會被寫入持久化記憶體中

Spring中的事務管理

作為企業級應用程式框架，Spring在不同的事務管理API之上定義了一個抽象層。而應用程式開發人員不必了解底層的事務管理API，就可以使用Spring的事務管理機制。

Spring既支援編程序事務管理，也支援聲明式的事務管理

編程序事務管理：將事務管理程式碼嵌入到業務方法中來控制事務的提交和回滾，在編程序事務中，必須在每個業務操作中包含額外的事務管理程式碼

聲明式事務管理：大多數情況下比編程式事務管理更好用。它將事務管理程式碼從業務方法中分離出來，以聲明的方式來實現事務管理。事務管理作為一種橫切關注點，可以透過AOP方法模組化。 Spring透過Spring AOP框架支援聲明式事務管理。

Spring事務的傳播屬性：

當事務方法被另一個事務方法呼叫時，必須指定事務應該如何傳播。例如：方法可能繼續在現有事務中運行，也可能開啟一個新事務，並在自己的事務中運行。

事務的傳播行為可以由傳播屬性指定。 Spring定義了7種傳播行為：

其中PROPAGATION_REQUIRED為預設的傳播屬性

並發事務所導致的問題

在同一個應用程式或不同應用程式中的多個交易在同一個資料集上並發執行時，可能會出現許多意外的問題。

並發事務所導致的問題可分為以下三類：

① 髒讀：髒讀發生在一個事務讀取了另一個事務改寫但尚未提交的資料時。如果改寫在稍後被回滾了，那麼第一個交易取得的資料就是無效的。

② 不可重複讀取：不可重複讀取發生在一個事務執行相同的查詢兩次或兩次以上，但是每次都得到不同的資料時。這通常是因為另一個並發事務在兩次查詢期間更新了數據

③ 幻讀：幻讀與不可重複讀類似。它發生在一個事務(T1)讀取了幾行數據，接著另一個並發事務(T2)插入了一些數據時。在隨後的查詢中，第一個事務(T1)就會發現多了一些原本不存在的記錄

程式碼範例

首先是資料庫表：

包括book(isbn, book_name, price)，account(username, balance)，book_stock(isbn, stock)

然後是使用的類別：

BookShopDao

複製代碼代碼如下:
package com.yl.spring.tx;

public interface BookShopDao {
//根據書號取得書的單價
public int findBookPriceByIsbn(String isbn);
//更新書的庫存，使書號對應的庫存-1
public void updateBookStock(String isbn);
//更新使用者的帳號餘額：讓username的balcance-price
public void updateUserAccount(String username, int price);

}

BookShopDaoImpl

複製代碼代碼如下:
package com.yl.spring.tx;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

@Repository("bookShopDao")
public class BookShopDaoImpl implements BookShopDao {

@Autowired
private JdbcTemplate JdbcTemplate;

@Override
public int findBookPriceByIsbn(String isbn) {
String sql = "SELECT price FROM book WHERE isbn = ?";

return JdbcTemplate.queryForObject(sql, Integer.class, isbn);
}

@Override
public void updateBookStock(String isbn) {
//檢查書的庫存是否足夠，若不夠，則拋出異常
String sql2 = "SELECT stock FROM book_stock WHERE isbn = ?";
int stock = JdbcTemplate.queryForObject(sql2, Integer.class, isbn);
if (stock == 0) {
throw new BookStockException("庫存不足！");
}
String sql = "UPDATE book_stock SET stock = stock - 1 WHERE isbn = ?";
JdbcTemplate.update(sql, isbn);
}

@Override
public void updateUserAccount(String username, int price) {
//檢查餘額是否不足，若不足，則拋出異常
String sql2 = "SELECT balance FROM account WHERE username = ?";
int balance = JdbcTemplate.queryForObject(sql2, Integer.class, username);
if (balance < price) {
throw new UserAccountException("餘額不足！");
}
String sql = "UPDATE account SET balance = balance - ? WHERE username = ?";
JdbcTemplate.update(sql, price, username);
}

}

BookShopService
複製程式碼代碼如下:package com.yl.spring.tx;
public interface BookShopService {
public void purchase(String username, String isbn);
}

BookShopServiceImpl

複製代碼代碼如下:
package com.yl.spring.tx;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

@Service("bookShopService")
public class BookShopServiceImpl implements BookShopService {

@Autowired
private BookShopDao bookShopDao;

/**
* 1.新增事務註解
* 使用propagation 指定事務的傳播行為，即當前的事務方法被另一個事務方法呼叫時如何使用事務。
* 預設取值為REQUIRED，即使用呼叫方法的事務
* REQUIRES_NEW：使用自己的事務，呼叫的事務方法的事務被掛起。
*
* 2.使用isolation 指定交易的隔離級別，最常用的取值為READ_COMMITTED
* 3.預設情況下Spring 的聲明式交易對所有的運行時異常進行回滾，也可以透過對應的屬性進行設定。通常情況下，預設值即可。
* 4.使用readOnly 指定事務是否為唯讀。 表示這個事務只讀取數據但不更新數據，這樣可以幫助資料庫引擎優化事務。若真的是只讀取資料庫值得方法，應設定readOnly=true
* 5.使用timeOut 指定強制回滾之前事務可以佔用的時間。
*/
@Transactional(propagation=Propagation.REQUIRES_NEW,
isolation=Isolation.READ_COMMITTED,
noRollbackFor={UserAccountException.class},
readOnly=true, timeout=3)
@Override
public void purchase(String username, String isbn) {
//1.取得書的單價
int price = bookShopDao.findBookPriceByIsbn(isbn);
//2.更新書的庫存
bookShopDao.updateBookStock(isbn);
//3.更新使用者餘額
bookShopDao.updateUserAccount(username, price);;
}
}

BookStockException

複製代碼代碼如下:
package com.yl.spring.tx;
public class BookStockException extends RuntimeException {

/**
*
*/
private static final long serialVersionUID = 1L;

public BookStockException() {
super();
// TODO Auto-generated constructor stub
}

public BookStockException(String arg0, Throwable arg1, boolean arg2,
boolean arg3) {
super(arg0, arg1, arg2, arg3);
// TODO Auto-generated constructor stub
}

public BookStockException(String arg0, Throwable arg1) {
super(arg0, arg1);
// TODO Auto-generated constructor stub
}

public BookStockException(String arg0) {
super(arg0);
// TODO Auto-generated constructor stub
}

public BookStockException(Throwable arg0) {
super(arg0);
// TODO Auto-generated constructor stub
}
}

UserAccountException

複製代碼代碼如下:
package com.yl.spring.tx;
public class UserAccountException extends RuntimeException {

/**
*
*/
private static final long serialVersionUID = 1L;

public UserAccountException() {
super();
// TODO Auto-generated constructor stub
}

public UserAccountException(String arg0, Throwable arg1, boolean arg2,
boolean arg3) {
super(arg0, arg1, arg2, arg3);
// TODO Auto-generated constructor stub
}

public UserAccountException(String arg0, Throwable arg1) {
super(arg0, arg1);
// TODO Auto-generated constructor stub
}

public UserAccountException(String arg0) {
super(arg0);
// TODO Auto-generated constructor stub
}

public UserAccountException(Throwable arg0) {
super(arg0);
// TODO Auto-generated constructor stub
}
}

Cashier

複製代碼代碼如下:
package com.yl.spring.tx;
import java.util.List;
public interface Cashier {
public void checkout(String username, List<String>isbns);
}

CashierImpl。 CashierImpl.checkout和bookShopService.purchase共同測試了事務的傳播行為

複製代碼代碼如下:
package com.yl.spring.tx;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service("cashier")
public class CashierImpl implements Cashier {
@Autowired
private BookShopService bookShopService;

@Transactional
@Override
public void checkout(String username, List<String> isbns) {
for(String isbn : isbns) {
bookShopService.purchase(username, isbn);
}
}
}

測試類別：

複製代碼代碼如下:
package com.yl.spring.tx;

import java.util.Arrays;

import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class SpringTransitionTest {

private ApplicationContext ctx = null;
private BookShopDao bookShopDao = null;
private BookShopService bookShopService = null;
private Cashier cashier = null;
{
ctx = new ClassPathXmlApplicationContext("applicationContext.xml");
bookShopDao = ctx.getBean(BookShopDao.class);
bookShopService = ctx.getBean(BookShopService.class);
cashier = ctx.getBean(Cashier.class);
}

@Test
public void testBookShopDaoFindPriceByIsbn() {
System.out.println(bookShopDao.findBookPriceByIsbn("1001"));
}

@Test
public void testBookShopDaoUpdateBookStock(){
bookShopDao.updateBookStock("1001");
}

@Test
public void testBookShopDaoUpdateUserAccount(){
bookShopDao.updateUserAccount("AA", 100);
}
@Test
public void testBookShopService(){
bookShopService.purchase("AA", "1001");
}

@Test
public void testTransactionPropagation(){
cashier.checkout("AA", Arrays.asList("1001", "1002"));
}
}

希望本文所述對大家的Spring程式設計有幫助。