一逼侦、實(shí)驗(yàn)?zāi)康模?/h1>
熟練掌握聲明式事務(wù)管理宇弛。
二鸡典、實(shí)驗(yàn)內(nèi)容：
編寫一個(gè)模擬銀行轉(zhuǎn)賬的程序，要求在轉(zhuǎn)賬時(shí)通過Spring對(duì)事務(wù)進(jìn)行控制枪芒。
三彻况、實(shí)驗(yàn)要求：
分別使用基于XML和基于注解的聲明式事務(wù)管理方式來(lái)實(shí)現(xiàn)。
四舅踪、設(shè)計(jì)
1.數(shù)據(jù)表設(shè)計(jì)：id money name
2.Dao數(shù)據(jù)庫(kù)層：
根據(jù)用戶的id查詢用戶的余額信息
根據(jù)用戶的id查詢的姓名
根據(jù)id存錢
根據(jù)id取錢
3.service層：
根據(jù)用戶的id查詢用戶的余額信息
A給B轉(zhuǎn)賬（調(diào)用 根據(jù)id存錢纽甘、根據(jù)id取錢）
其內(nèi)調(diào)用（根據(jù)用戶的id查詢的姓名）來(lái)展示用戶轉(zhuǎn)賬過程
4.controller層：
控制層（調(diào)用服務(wù)層方法，并在控制層完成事務(wù)操作的異常處理）
5.測(cè)試層：
XMLTest.java:
調(diào)用托管在Spring里的控制層方法抽碌，獲取到控制層返回的結(jié)果信息
XML方式：在XML里面利用AOP的操作悍赢，切點(diǎn)是Service，通知就是其事務(wù)的操作
AnnotationTest.java:
調(diào)用托管在Spring里的控制層方法，獲取到控制層返回的結(jié)果信息
基于注釋：利用@Transactional在service方法處進(jìn)行事務(wù)管理左权，在xml內(nèi)掃描標(biāo)簽
五皮胡、代碼
BankDao.java
package com.dao;
public interface BankDao {
public double getMoneyById(String id);
public String getNameById(String id);
public void cashIn(String id, double money);
public void cashOut(String id, double money);
}
BankDaoImpl.java
package com.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
import com.util.MyException;
//@Repository用于標(biāo)注數(shù)據(jù)訪問組件，即DAO組件
@Repository("BankDao")
/*
* 數(shù)據(jù)訪問層
*/
public class BankDaoImpl implements BankDao {
@Autowired
private JdbcTemplate jdbcTemplate;
@Override
//根據(jù)用戶的id查詢用戶的余額信息
public double getMoneyById(String id) {
String sql="select money from bank where id=?";
return jdbcTemplate.queryForObject(sql, new Object[] {id}, double.class);
}
@Override
//根據(jù)用戶的id查詢的姓名
public String getNameById(String id) {
String sql="select name from bank where id=?";
return jdbcTemplate.queryForObject(sql, new Object[] {id}, String.class);
}
@Override
//根據(jù)id存錢
public void cashIn(String id, double money) {
String sql="update bank set money=money+? where id=?";
jdbcTemplate.update(sql, money,id);
}
@Override
//根據(jù)id取錢
public void cashOut(String id, double money) {
double num=getMoneyById(id);//查詢余額
if(num>=money) {
//余額充足涮总，可以取錢
String sql="update bank set money=money-? where id=?";
jdbcTemplate.update(sql, money,id);
}else {
//余額不足胸囱，向外拋出異常
System.out.println("余額不足");
throw new MyException("余額不足");
}
}
}
BankService.java
package com.service;
public interface BankService {
public void transferMoney(String inId,String outId, double money);
}
BankServiceImpl.java
package com.service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.dao.BankDao;
import com.util.MyException;
@Service("BankService")
/*
* 服務(wù)層（對(duì)數(shù)據(jù)訪問層封裝，綁定事務(wù)操作）
*/
public class BankServiceImpl implements BankService{
@Autowired
private BankDao bankdao;
//基于注釋的事務(wù)管理
@Transactional(rollbackFor = (MyException.class))
// 這里調(diào)用Dao層的save和delete方法瀑梗，參數(shù)為sql和param烹笔，等控制層在傳入sql語(yǔ)句
public void transferMoney(String inId,String outId, double money) {
String name1 = bankdao.getNameById(inId);
String name2 = bankdao.getNameById(outId);
double money1 = bankdao.getMoneyById(inId);
double money2 = bankdao.getMoneyById(outId);
System.out.println("轉(zhuǎn)賬前:"+name2+"的余額:"+ money2 +" "+ name1+"余額:"+ money1);
//轉(zhuǎn)賬的具體操作
bankdao.cashIn(inId, money);
bankdao.cashOut(outId, money);
double money3 = bankdao.getMoneyById(inId);
double money4 = bankdao.getMoneyById(outId);
System.out.println("用戶1:"+name2+" >>>==轉(zhuǎn)賬==>>> "+ "用戶2:"+ name1);
System.out.println("支付寶到賬:"+ money + "元");
System.out.println("轉(zhuǎn)賬后:"+name2+"的余額:"+ money4 +" "+ name1+"余額:"+ money3);
}
}
BankController.java
package com.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import com.service.BankService;
@Controller("BankController")
/*
* 控制層（調(diào)用服務(wù)層方法，并在控制層完成事務(wù)操作的異常處理）
*/
public class BankController {
@Autowired
private BankService bankService;
public String test() {
String message = "";
try{
bankService.transferMoney("002","001", 5);
message = "事務(wù)正常";
}catch(Exception e){
message = "事務(wù)異常,回滾";
e.printStackTrace();
}
return message;
}
}
（一）基于XML的聲明式事務(wù)管理方式
XMLTest.java
package com.test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.controller.BankController;
/*
* 測(cè)試類（調(diào)用托管在Spring里的控制層方法抛丽，獲取到控制層返回的結(jié)果信息）
*
* XML方式：在XML里面利用AOP的操作谤职，切點(diǎn)是Service，通知就是其事務(wù)的操作
*/
public class XMLTest {
public static void main(String[] args) {
@SuppressWarnings("resource")
ApplicationContext appCon = new ClassPathXmlApplicationContext("/com/xml/XMLstatementapplicationContext.xml");
BankController ct = (BankController)appCon.getBean("BankController");
String result = ct.test();
System.out.println(result);
}
}
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:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:context="http://www.springframework.org/schema/context"
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.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd">
<!-- 指定需要掃描的包（包括子包）亿鲜，使注解生效 -->
<context:component-scan base-package="com"/>
<!-- 配置數(shù)據(jù)源 -->
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<!-- MySQL數(shù)據(jù)庫(kù)驅(qū)動(dòng) -->
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<!-- 連接數(shù)據(jù)庫(kù)的URL -->
<property name="url" value="jdbc:mysql://localhost:3306/bank?characterEncoding=utf8"/>
<!-- 連接數(shù)據(jù)庫(kù)的用戶名 -->
<property name="username" value="root"/>
<!-- 連接數(shù)據(jù)庫(kù)的密碼 -->
<property name="password" value="363316495"/>
</bean>
<!-- 配置JDBC模板 -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"/>
</bean>
<!-- 為數(shù)據(jù)源添加事務(wù)管理器 -->
<bean id="txManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean>
<!-- 編寫通知：聲明事務(wù) -->
<tx:advice id="myAdvice" transaction-manager="txManager">
<tx:attributes>
<!--事務(wù)的傳播行為 -->
<tx:method name="*" propagation="REQUIRED"/>
</tx:attributes>
</tx:advice>
<!-- 編寫AOP允蜈，讓Spring自動(dòng)對(duì)目標(biāo)對(duì)象生成代理，需要使用AspectJ的表達(dá)式 -->
<aop:config>
<!-- 定義切入點(diǎn)蒿柳，織入的對(duì)象是testService -->
<aop:pointcut expression="execution(* com.service.*.*(..))" id="txPointCut"/>
<!-- 切面：將切入點(diǎn)與通知關(guān)聯(lián) -->
<aop:advisor advice-ref="myAdvice" pointcut-ref="txPointCut"/>
</aop:config>
</beans>
（二）基于注解的聲明式事務(wù)管理方式
AnnotationTest.java
package com.test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.transaction.annotation.Transactional;
import com.controller.BankController;
/*
* 測(cè)試類（調(diào)用托管在Spring里的控制層方法饶套，獲取到控制層返回的結(jié)果信息）
*
* 基于注釋：利用@Transactional在service方法處進(jìn)行事務(wù)管理，在xml內(nèi)掃描標(biāo)簽
*/
public class AnnotationTest {
public static void main(String[] args) {
@SuppressWarnings("resource")
ApplicationContext appCon = new ClassPathXmlApplicationContext("/com/xml/annotationstatementapplicationContext.xml");
BankController ct = (BankController)appCon.getBean("BankController");
String result = ct.test();
System.out.println(result);
}
}
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:tx="http://www.springframework.org/schema/tx"
xmlns:context="http://www.springframework.org/schema/context"
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.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd">
<!-- 指定需要掃描的包（包括子包）垒探，使注解生效 -->
<context:component-scan base-package="com"/>
<!-- 配置數(shù)據(jù)源 -->
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<!-- MySQL數(shù)據(jù)庫(kù)驅(qū)動(dòng) -->
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<!-- 連接數(shù)據(jù)庫(kù)的URL -->
<property name="url" value="jdbc:mysql://localhost:3306/bank?characterEncoding=utf8"/>
<!-- 連接數(shù)據(jù)庫(kù)的用戶名 -->
<property name="username" value="root"/>
<!-- 連接數(shù)據(jù)庫(kù)的密碼 -->
<property name="password" value="363316495"/>
</bean>
<!-- 配置JDBC模板 -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"/>
</bean>
<!-- 為數(shù)據(jù)源添加事務(wù)管理器 -->
<bean id="txManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean>
<!-- 為事務(wù)管理器注冊(cè)注解驅(qū)動(dòng) -->
<tx:annotation-driven transaction-manager="txManager" />
</beans>
六妓蛮、結(jié)果
正常轉(zhuǎn)賬.png
數(shù)據(jù)庫(kù)1.png
轉(zhuǎn)賬至0元.png
數(shù)據(jù)庫(kù)2.png
余額不足拋出異常.png
數(shù)據(jù)庫(kù)3.png
