Spring中的事務管理實例詳解
本文實例講述了Spring中的事務管理。分享給大家供大家參考。具體分析如下：
事務簡介：
事務管理是企業(yè)級應用程序開發(fā)中必不可少的技術，用來確保數(shù)據(jù)的完整性和一致性
事務就是一系列的動作，它們被當作一個單獨的工作單元。這些動作要么全部完成，要么全部不起作用
事務的四個關鍵屬性(ACID)
① 原子性(atomicity):事務室一個原子操作，有一系列動作組成。事務的原子性確保動作要么全部完成，要么完全不起作用
② 一致性(consistency):一旦所有事務動作完成，事務就被提交。數(shù)據(jù)和資源就處于一種滿足業(yè)務規(guī)則的一致性狀態(tài)中
③ 隔離性(isolation):可能有許多事務會同時處理相同的數(shù)據(jù)，因此每個事物都應該與其他事務隔離開來，防止數(shù)據(jù)損壞
④ 持久性(durability):一旦事務完成，無論發(fā)生什么系統(tǒng)錯誤，它的結果都不應該受到影響。通常情況下，事務的結果被寫到持久化存儲器中
Spring中的事務管理
作為企業(yè)級應用程序框架，Spring在不同的事務管理API之上定義了一個抽象層。而應用程序開發(fā)人員不必了解底層的事務管理API，就可以使用Spring的事務管理機制。
Spring既支持編程式事務管理，也支持聲明式的事務管理
編程式事務管理：將事務管理代碼嵌入到業(yè)務方法中來控制事務的提交和回滾，在編程式事務中，必須在每個業(yè)務操作中包含額外的事務管理代碼
聲明式事務管理：大多數(shù)情況下比編程式事務管理更好用。它將事務管理代碼從業(yè)務方法中分離出來，以聲明的方式來實現(xiàn)事務管理。事務管理作為一種橫切關注點，可以通過AOP方法模塊化。Spring通過Spring AOP框架支持聲明式事務管理。
Spring事務的傳播屬性：
當事務方法被另一個事務方法調(diào)用時，必須指定事務應該如何傳播。例如：方法可能繼續(xù)在現(xiàn)有事務中運行，也可能開啟一個新事務，并在自己的事務中運行。
事務的傳播行為可以由傳播屬性指定。Spring定義了7種傳播行為：
| 傳播行為 | 含義 |
| PROPAGATION_MANDATORY | 表示該方法必須在事務中運行，如果當前事務不存在，則會拋出一個異常 |
| PROPAGATION_NESTED | 表示如果當前已經(jīng)存在一個事務，那么該方法將會在嵌套事務中運行。嵌套的事務可以獨立于當前事務進行單獨地提交或回滾。如果當前事務不存在，那么其行為與PROPAGATION_REQUIRED一樣。注意各廠商對這種傳播行為的支持是有所差異的?？梢詤⒖假Y源管理器的文檔來確認它們是否支持嵌套事務 |
| PROPAGATION_NEVER | 表示當前方法不應該運行在事務上下文中。如果當前正有一個事務在運行，則會拋出異常 |
| PROPAGATION_NOT_SUPPORTED | 表示該方法不應該運行在事務中。如果存在當前事務，在該方法運行期間，當前事務將被掛起。如果使用JTATransactionManager的話，則需要訪問TransactionManager |
| PROPAGATION_REQUIRED | 表示當前方法必須運行在事務中。如果當前事務存在，方法將會在該事務中運行。否則，會啟動一個新的事務 |
| PROPAGATION_REQUIRED_NEW | 表示當前方法必須運行在它自己的事務中。一個新的事務將被啟動。如果存在當前事務，在該方法執(zhí)行期間，當前事務會被掛起。如果使用JTATransactionManager的話，則需要訪問TransactionManager |
| PROPAGATION_SUPPORTS | 表示當前方法不需要事務上下文，但是如果存在當前事務的話，那么該方法會在這個事務中運行 |
其中PROPAGATION_REQUIRED為默認的傳播屬性
并發(fā)事務所導致的問題
在同一個應用程序或者不同應用程序中的多個事務在同一個數(shù)據(jù)集上并發(fā)執(zhí)行時，可能會出現(xiàn)許多意外的問題。
并發(fā)事務所導致的問題可以分為以下三類：
① 臟讀：臟讀發(fā)生在一個事務讀取了另一個事務改寫但尚未提交的數(shù)據(jù)時。如果改寫在稍后被回滾了，那么第一個事務獲取的數(shù)據(jù)就是無效的。
② 不可重復讀：不可重復讀發(fā)生在一個事務執(zhí)行相同的查詢兩次或兩次以上，但是每次都得到不同的數(shù)據(jù)時。這通常是因為另一個并發(fā)事務在兩次查詢期間更新了數(shù)據(jù)
③ 幻讀：幻讀與不可重復讀類似。它發(fā)生在一個事務(T1)讀取了幾行數(shù)據(jù)，接著另一個并發(fā)事務(T2)插入了一些數(shù)據(jù)時。在隨后的查詢中，第一個事務(T1)就會發(fā)現(xiàn)多了一些原本不存在的記錄
代碼示例
首先是數(shù)據(jù)庫表：
包括book(isbn, book_name, price)，account(username, balance)，book_stock(isbn, stock)
然后是使用的類：
BookShopDao
package com.yl.spring.tx;
public interface BookShopDao {
//根據(jù)書號獲取書的單價
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
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 指定事務的傳播行為，即當前的事務方法被另外一個事務方法調(diào)用時如何使用事務。
* 默認取值為REQUIRED，即使用調(diào)用方法的事務
* REQUIRES_NEW：使用自己的事務，調(diào)用的事務方法的事務被掛起。
*
* 2.使用isolation 指定事務的隔離級別，最常用的取值為READ_COMMITTED
* 3.默認情況下 Spring 的聲明式事務對所有的運行時異常進行回滾，也可以通過對應的屬性進行設置。通常情況下，默認值即可。
* 4.使用readOnly 指定事務是否為只讀。 表示這個事務只讀取數(shù)據(jù)但不更新數(shù)據(jù)，這樣可以幫助數(shù)據(jù)庫引擎優(yōu)化事務。若真的是一個只讀取數(shù)據(jù)庫值得方法，應設置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聯(lián)合測試了事務的傳播行為
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程序設計有所幫助。
相關文章
這篇文章主要介紹了idea2019配置Tomcat9全過程,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-11-11
在java編寫代碼中經(jīng)常會遇到某些重復判定或者去重的操作,本文主要為大家介紹了幾個常用方法,感興趣的小伙伴可以跟隨不想一起學習一下2024-12-12
這篇文章主要介紹了使用Java對Hbase進行操作總結,本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-07-07
SpringBoot Logback日志記錄到數(shù)據(jù)庫的實現(xiàn)方法
這篇文章主要介紹了SpringBoot Logback日志記錄到數(shù)據(jù)庫的實現(xiàn)方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-11-11
Java 使用IO流實現(xiàn)大文件的分割與合并實例詳解
這篇文章主要介紹了Java 使用IO流實現(xiàn)大文件的分割與合并實例詳解的相關資料,需要的朋友可以參考下2016-12-12
這篇文章主要為大家介紹了JDK8 HashMap擴容機制分析詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-07-07
由于IDEA項目路徑中有中文、空格等特殊符號,影響正常使用,想要修改路徑名稱,怎么正確修改IDEA項目名稱,使其正常運行呢？所以本文小編講給大家詳細的介紹了更改IDEA已有項目的路徑/名稱解決方案,需要的朋友可以參考下2023-11-11
String字符串在我們?nèi)粘ｉ_發(fā)中最常用的，當然還有他的兩個兄弟StringBuilder和StringBuilder，接下來通過本文給大家介紹JDK8中String的intern()方法詳細解讀,需要的朋友可以參考下2022-09-09
本文給大家介紹的是java使用動態(tài)代理類實現(xiàn)動態(tài)代理的方法和示例，這里推薦給大家，有需要的小伙伴參考下吧2015-02-02
IDEA JavaWeb項目啟動運行后出現(xiàn)404錯誤的解決方法
這篇文章主要介紹了IDEA JavaWeb項目啟動運行后出現(xiàn)404錯誤的解決方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-12-12