Spring 學習（二十四）——事務的傳播行為
阿新 • • 發佈：2018-12-25
事務傳播屬性
•當事務方法被另一個事務方法呼叫時, 必須指定事務應該如何傳播. 例如: 方法可能繼續在現有事務中執行, 也可能開啟一個新事務, 並在自己的事務中執行.
•事務的傳播行為可以由傳播屬性指定. Spring 定義了 7 種類傳播行為.
Spring 支援的事務傳播行為
需求：
•新定義 Cashier 介面: 表示客戶的結賬操作
•修改資料表資訊如下, 目的是使用者 Tom 在結賬時, 餘額只能支付第一本書, 不夠支付第二本書：
REQUIRED
•當 bookService 的 purchase() 方法被另一個事務方法 checkout() 呼叫時, 它預設會在現有的事務內執行. 這個預設的傳播行為就是 REQUIRED. 因此在 checkout() 方法的開始和終止邊界內只有一個事務. 這個事務只在 checkout() 方法結束的時候被提交, 結果使用者一本書都買不了
•事務傳播屬性可以在 @Transactional 註解的 propagation 屬性中定義
REQUIRES_NEW 傳播行為
•另一種常見的傳播行為是 REQUIRES_NEW. 它表示該方法必須啟動一個新事務
在 Spring 2.x 事務通知中配置傳播屬性
•在 Spring 2.x 事務通知中, 可以像下面這樣在 <tx:method> 元素中設定傳播事務屬性
程式碼示例：
1、資料庫表的建立如下：
employee表
department表
2、目錄結構
Spring
|——src
|——|——com.hzyc.spring.jdbc
|——|——|——employee.java
|——|——|——JdbcTest.java
|——|——application-context.xml
|——|——db.properties
2、db.properties
jdbc.driverClass=com.mysql.jdbc.Driver
jdbc.jdbcUrl=jdbc:mysql:///spring
jdbc.user=root
jdbc.password=root
jdbc.initPoolSize=5
jdbc.maxPoolSize=10
3、application-context.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd">
<context:component-scan base-package="com.hzyc.spring"/>
<!--匯入資原始檔-->
<context:property-placeholder location="classpath:db.properties"/>
<!--配置 c3p0 資料來源-->
<bean id="dataSource"
class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="driverClass" value="${jdbc.driverClass}"/>
<property name="jdbcUrl" value="${jdbc.jdbcUrl}"/>
<property name="user" value="${jdbc.user}"/>
<property name="password" value="${jdbc.password}"/>
<property name="initialPoolSize" value="${jdbc.initPoolSize}"/>
<property name="maxPoolSize" value="${jdbc.maxPoolSize}"/>
</bean>
<!--配置 Spring 的 Jdbc Template-->
<bean id="jdbcTemplate"
class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"/>
</bean>
<!--
配置 NamedParameterJdbcTemplate, 該物件可以使用具名引數（具有名字）
其沒有無參的構造器，必須為其構造器指定引數
-->
<bean id="namedParameterJdbcTemplate"
class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate">
<constructor-arg ref="dataSource"/>
</bean>
<!--配置事務管理器-->
<bean id="transactionManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
<!--事務註解-->
<tx:annotation-driven transaction-manager="transactionManager"/>
</beans>BookShopDao.javapackage com.hzyc.spring.jdbc.transaction;
/**
* @author xuehj2016
* @Title: BookShopDao
* @ProjectName Spring
* @Description: TODO
* @date 2018/12/21 20:32
*/
public interface BookShopDao {
/**
* 根據書號獲取書的單價
*/
public int getBookPriceById(String id);
/**
* 更新書的庫存，使書號對應的庫存 - 1
*/
public void updateBookStock(String id);
/**
* 更新使用者的賬戶餘額 : 使 username 的 balance - price
*/
public void updateUserAccount(String username, int price);
}package com.hzyc.spring.jdbc.transaction;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
/**
* @author xuehj2016
* @Title: BookShopDaoImpl
* @ProjectName Spring
* @Description: TODO
* @date 2018/12/21 20:39
*/
@Repository("bookShopDao")
public class BookShopDaoImpl implements BookShopDao {
@Autowired
private JdbcTemplate jdbcTemplate;
/**
* 根據書號獲取書的單價
*
* @param id
*/
@Override
public int getBookPriceById(String id) {
String sql = "select price from book where id = ?";
return jdbcTemplate.queryForObject(sql, Integer.class, id);
}
/**
* 更新書的庫存，使書號對應的庫存 - 1
*
* @param id
*/
@Override
public void updateBookStock(String id) {
//檢查書的庫存是否足夠，若不夠，則丟擲異常
String stockSql = "select stock from book_stock where id =?";
int stock = jdbcTemplate.queryForObject(stockSql, Integer.class, id);
if (stock == 0) {
throw new BookStockException("庫存不足！");
}
String sql = "update book_stock set stock = stock - 1 where id =?";
jdbcTemplate.update(sql, id);
}
/**
* 更新使用者的賬戶餘額 : 使 username 的 balance - price
*
* @param username
* @param price
*/
@Override
public void updateUserAccount(String username, int price) {
//因為 MySQL 不支援檢查約束
//驗證使用者的餘額是否足夠，若不夠，則丟擲異常
String balanceSql = "select balance from account where username =?";
int balance = jdbcTemplate.queryForObject(balanceSql, Integer.class, username);
if (balance < price) {
throw new UserAccountException("餘額不足！");
}
String sql = "update account set balance = balance - ? where username =?";
jdbcTemplate.update(sql, price, username);
}
}package com.hzyc.spring.jdbc.transaction;
/**
* @author xuehj2016
* @Title: BookShopService
* @ProjectName Spring
* @Description: TODO
* @date 2018/12/21 21:22
*/
public interface BookShopService {
public void purchase(String username, String id);
}package com.hzyc.spring.jdbc.transaction;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
/**
* @author xuehj2016
* @Title: BookShopServiceImpl
* @ProjectName Spring-3
* @Description: TODO
* @date 2018/12/21 21:24
*/
@Service("bookShopService")
public class BookShopServiceImpl implements BookShopService {
@Autowired
private BookShopDao bookShopDao;
/**
* 新增事務註解
* 1.使用 propagation 指定事務的傳播行為, 即當前的事務方法被另外一個事務方法呼叫時
* 如何使用事務, 預設取值為 REQUIRED, 即使用呼叫方法的事務
* REQUIRES_NEW: 事務自己的事務, 呼叫的事務方法的事務被掛起.
*
* @param username
* @param id
*/
@Transactional(propagation = Propagation.REQUIRES_NEW)
@Override
public void purchase(String username, String id) {
//1.獲取書的單價
int price = bookShopDao.getBookPriceById(id);
//2.更新書的庫存
bookShopDao.updateBookStock(id);
//3.更新使用者餘額
bookShopDao.updateUserAccount(username, price);
}
}package com.hzyc.spring.jdbc.transaction;
/**
* @author xuehj2016
* @Title: BookStockException
* @ProjectName Spring
* @Description: TODO
* @date 2018/12/21 21:10
*/
public class BookStockException extends RuntimeException {
public BookStockException() {
}
public BookStockException(String message) {
super(message);
}
public BookStockException(String message, Throwable cause) {
super(message, cause);
}
public BookStockException(Throwable cause) {
super(cause);
}
public BookStockException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
super(message, cause, enableSuppression, writableStackTrace);
}
}package com.hzyc.spring.jdbc.transaction;
import java.util.List;
/**
* @author xuehj2016
* @Title: Cashier
* @ProjectName Spring-3
* @Description: TODO
* @date 2018/12/21 23:23
*/
public interface Cashier {
public void checkout(String username, List<String> ids);
}package com.hzyc.spring.jdbc.transaction;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
/**
* @author xuehj2016
* @Title: CashierImpl
* @ProjectName Spring-3
* @Description: TODO
* @date 2018/12/21 23:24
*/
@Service("cashier")
public class CashierImpl implements Cashier {
@Autowired
private BookShopService bookShopService;
/**
*
* @param username
* @param ids
*/
@Transactional
@Override
public void checkout(String username, List<String> ids) {
for (String id : ids) {
bookShopService.purchase(username, id);
}
}
}package com.hzyc.spring.jdbc.transaction;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.util.Arrays;
/**
* @author xuehj2016
* @Title: SpringTransactionTest
* @ProjectName Spring
* @Description: TODO
* @date 2018/12/21 20:52
*/
public class SpringTransactionTest {
private BookShopDao bookShopDao;
private BookShopService bookShopService;
private Cashier cashier;
{
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("application-context.xml");
bookShopDao = (BookShopDao) applicationContext.getBean("bookShopDao");
bookShopService = (BookShopService) applicationContext.getBean("bookShopService");
cashier = (Cashier) applicationContext.getBean("cashier");
}
@Test
public void testBookShopGetBookPriceById() {
System.out.println(bookShopDao.getBookPriceById("1001"));
}
@Test
public void testBookShopUpdateBookStock() {
bookShopDao.updateBookStock("1001");
}
@Test
public void testBookShopUpdateUserAccount() {
bookShopDao.updateUserAccount("xuehj", 50);
}
@Test
public void testBookShopService() {
bookShopService.purchase("xuehj", "1001");
}
@Test
public void testTransactionalPropagation() {
cashier.checkout("xuehj", Arrays.asList("1001", "1002"));
}
}package com.hzyc.spring.jdbc.transaction;
/**
* @author xuehj2016
* @Title: UserAccountException
* @ProjectName Spring
* @Description: TODO
* @date 2018/12/21 21:16
*/
public class UserAccountException extends RuntimeException {
public UserAccountException() {
}
public UserAccountException(String message) {
super(message);
}
public UserAccountException(String message, Throwable cause) {
super(message, cause);
}
public UserAccountException(Throwable cause) {
super(cause);
}
public UserAccountException(String message, Throwable cause, boolean enableSuppression, boolean
writableStackTrace) {
super(message, cause, enableSuppression, writableStackTrace);
}
}