Spring用XML方式使用事务

项目开始前需要新建数据库（数据库使用mysql8.0以上的版本）

#创建数据库
CREATE database userdb;

#创建数据表
CREATE TABLE userdb.t_account  (
  id int  NOT NULL,
  username varchar(50)  NULL DEFAULT NULL,
  money decimal(16,3)  NULL DEFAULT NULL,
  PRIMARY KEY(id)
);

#添加测试数据
INSERT into userdb.t_account(id,username,money)VALUES(1,'lucy',1000);
INSERT into userdb.t_account(id,username,money)VALUES(2,'mary',1000);

项目需要用的的依赖

com.springsource.org.aspectj.weaver-1.6.8.RELEASE.jar
commons-logging-1.2.jar
druid-1.2.14.jar
mysql-connector-java-8.0.19.jar
spring-aop-5.2.6.RELEASE.jar
spring-aspects-5.2.6.RELEASE.jar
spring-beans-5.2.6.RELEASE.jar
spring-context-5.2.6.RELEASE.jar
spring-core-5.2.6.RELEASE.jar
spring-expression-5.2.6.RELEASE.jar
spring-jdbc-5.2.6.RELEASE.jar
spring-tx-5.2.6.RELEASE.jar

项目的结构

数据库配置文件jdbc.properties

shiwujdbc.driverClassName=com.mysql.cj.jdbc.Driver
shiwujdbc.url=jdbc:mysql://localhost:3306/userdb?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8&useSSL=false
shiwujdbc.username=root
shiwujdbc.password=sa1234

XML配置文件 beans.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"
xmlns:aop="http://www.springframework.org/schema/aop"
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
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
<!--开启组件扫描-->
<context:component-scan base-package="com.mt.spring.shiwu"></context:component-scan>

<!-- 加载数据库配置文件-->
<context:property-placeholder  location="jdbc.properties"></context:property-placeholder>

<!--数据库连接池配置-->
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close">
<property name="driverClassName" value="${shiwujdbc.driverClassName}"></property>
<property name="url" value="${shiwujdbc.url}"></property>
<property name="username" value="${shiwujdbc.username}"></property>
<property name="password" value="${shiwujdbc.password}"></property>
</bean>

<!--  创建JdbcTemplate对象  -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<!--注入数据源-->
<property name="dataSource" ref="dataSource"></property>
</bean>


<!--    创建事务管理类-->
<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"></property>
</bean>

<!--配置通知-->
<tx:advice id="txadvice" transaction-manager="dataSourceTransactionManager">
<!--配置事务参数-->
<tx:attributes>
<!--指定那种规则的方法上面添加事务-->
<tx:method name="accountMoney" propagation="REQUIRED"/>
</tx:attributes>
</tx:advice>

<!--配置切入点和切面-->
<aop:config>
<!--配置切入点-->
<aop:pointcut id="pt" expression="execution(* com.mt.spring.shiwu.service.UserService.*(..))"/>
<!--配置切面-->
<aop:advisor advice-ref="txadvice" pointcut-ref="pt"/>
</aop:config>
</beans>

数据操作接口UserDao

package com.mt.spring.shiwu.dao;

public interface UserDao {
public void addMoney();//多钱
public void reduceMoney();//少钱
}

数据操作实现类UserDaoImpl

package com.mt.spring.shiwu.dao;

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

@Repository
public class UserDaoImpl implements UserDao{
//注入数据库连接池
@Autowired
private JdbcTemplate jdbcTemplate;

//少钱 lucy转账给mary lucy先减少100
@Override
public void reduceMoney() {
String sql = "update t_account set money=money-? where username=?";
jdbcTemplate.update(sql,100,"lucy");
    }

//多钱钱 lucy转账给mary mary加100
@Override
public void addMoney() {
String sql = "update t_account set money=money+? where username=?";
jdbcTemplate.update(sql,100,"mary");
    }

}

业务层UserService

package com.mt.spring.shiwu.service;

import com.mt.spring.shiwu.dao.UserDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class UserService {
//注入Dao
@Autowired
private UserDao userDao;
public void accountMoney(){
//lucy少100
userDao.reduceMoney();
//模拟异常
int i = 10/0; //出现异常之后已经操作的会回滚
//mary加100
userDao.addMoney();

    }
}

测试类

package com.mt.spring;

import com.mt.spring.shiwu.service.UserService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Main {
public static void main(String[] args) {
ApplicationContext context = new ClassPathXmlApplicationContext("beans.xml");
UserService userService = context.getBean("userService", UserService.class);
userService.accountMoney();
    }

}