文档建议反馈控制台
首页
学习
活动
专区
圈层
工具
MCP广场
文章/答案/技术大牛
发布
社区首页 >专栏 >【Spring】011-Spring声明式事务

【Spring】011-Spring声明式事务

作者头像
訾博ZiBo
发布于 2025-01-06 15:48:14
发布于 2025-01-06 15:48:14
2640
举报
文章被收录于专栏：全栈开发工程师全栈开发工程师

一、事务回顾

1、概述

①一组业务：要么都成功，要么都失败；

②事务在项目开发中，十分重要，涉及数据的一致性，不可马虎；

2、事务的ACID原则

A：原子性；

C：一致性；

I：隔离性：多个业务操作数据，相互隔离，不能相互影响；

D：持久性：事务一旦提交，无论系统发生什么问题，结果都不会被影响，都被被持久化地写到了存储器中；

3、环境搭建（类似Spring整合Mybatis案例）

第一步：创建新Moudle，并往pom.xml导入所依赖的Maven坐标
代码语言：javascript
复制
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>StudySpring</artifactId>
        <groupId>org.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>spring_011_transcation</artifactId>
    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.13</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.21</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.5.5</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>5.2.8.RELEASE</version>
        </dependency>
        <!--Spring操作数据库的话，好需要Spring JDBC-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>5.2.8.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.9.6</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis-spring</artifactId>
            <version>2.0.5</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.12</version>
        </dependency>
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.17</version>
        </dependency>
    </dependencies>

</project>
第二步：创建实体类Account
代码语言：javascript
复制
package com.zibo.pojo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Account {
    private int id;
    private String name;
    private double money;
}
第三步：创建AccountMapper接口
代码语言：javascript
复制
package com.zibo.mapper;

import com.zibo.pojo.Account;

import java.util.List;

public interface AccountMapper {
    List<Account> findAll();
}
第四步：编写AccountMapper.xml
代码语言：javascript
复制
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.zibo.mapper.AccountMapper">
    <!--    配置查询所有-->
    <select id="findAll" resultType="com.zibo.pojo.Account">
        select * from account;
    </select>
</mapper>
第五步：编写Spring整合Mybatis的配置文件applicationContext.xml
代码语言：javascript
复制
<?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"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd">
    <!--DataSource：使用Spring的数据源替换MyBatis的配置，c3p0 dbcp druid，
    我们这里使用Spring的JDBC:org.springframework.jdbc.datasource-->
    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/zibo?serverTimezone=UTC"/>
        <property name="username" value="root"/>
        <property name="password" value="zibo15239417242"/>
    </bean>
    <!--sqlSessionFactory-->
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <!--绑定Mybatis配置文件-->
        <!--spring可以整合mybatis的配置，也可以将mybatis的配置文件引入-->
<!--        这个引入导致错误，暂时就不引入了，所有的配置也可由spring完成-->
<!--        <property name="configuration" value="classpath:mybatis-config.xml"/>-->
        <property name="mapperLocations" value="classpath:mapper/AccountMapper.xml"/>
<!--        设置别名-->
        <property name="typeAliasesPackage" value="com.zibo.pojo"/>
    </bean>
    <!--SqlSessionTemplate：就是我们使用的SqlSession-->
    <bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">
        <!--这里只能通过构造器注入，因为SqlSessionTemplate没有setter方法-->
        <constructor-arg name="sqlSessionFactory" ref="sqlSessionFactory"/>
    </bean>

    <!--注入AccountMapperImpl-->
    <bean id="accountMapper" class="com.zibo.mapper.AccountMapperImpl">
        <property name="sqlSessionFactory" ref="sqlSessionFactory"/>
    </bean>
</beans>
第六步：编写Log4j配置文件
代码语言：javascript
复制
# Set root category priority to INFO and its only appender to CONSOLE.
#log4j.rootCategory=INFO, CONSOLE            debug   info   warn error fatal
log4j.rootCategory=debug, CONSOLE, LOGFILE

# Set the enterprise logger category to FATAL and its only appender to CONSOLE.
log4j.logger.org.apache.axis.enterprise=FATAL, CONSOLE

# CONSOLE is set to be a ConsoleAppender using a PatternLayout.
log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern=%d{ISO8601} %-6r [%15.15t] %-5p %30.30c %x - %m\n

# LOGFILE is set to be a File appender using a PatternLayout.
log4j.appender.LOGFILE=org.apache.log4j.FileAppender
log4j.appender.LOGFILE.File=d:\axis.log
log4j.appender.LOGFILE.Append=true
log4j.appender.LOGFILE.layout=org.apache.log4j.PatternLayout
log4j.appender.LOGFILE.layout.ConversionPattern=%d{ISO8601} %-6r [%15.15t] %-5p %30.30c %x - %m\n
第七步：创建AccountMapper接口的实现类
代码语言：javascript
复制
package com.zibo.mapper;

import com.zibo.pojo.Account;
import org.mybatis.spring.support.SqlSessionDaoSupport;

import java.util.List;

public class AccountMapperImpl extends SqlSessionDaoSupport implements AccountMapper {
    @Override
    public List<Account> findAll() {
        return getSqlSession().getMapper(AccountMapper.class).findAll();
    }
}
第八步：创建测试类
代码语言：javascript
复制
package zibo;

import com.zibo.mapper.AccountMapper;
import com.zibo.pojo.Account;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.util.List;

public class MyTest {
    @Test
    public void testFindAll(){
        ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
        AccountMapper mapper = context.getBean("accountMapper", AccountMapper.class);
        List<Account> all = mapper.findAll();
        for (Account account : all) {
            System.out.println(account);
        }
    }
}
测试结果：
代码语言：javascript
复制
Account(id=1, name=大哥, money=100.0)
Account(id=2, name=二哥, money=200.0)
Account(id=6, name=訾博, money=88.0)

4、开始模拟事务

第一步：修改AccountMapper接口
代码语言：javascript
复制
package com.zibo.mapper;

import com.zibo.pojo.Account;

import java.util.List;

public interface AccountMapper {
    List<Account> findAll();
    
    //添加账户
    int saveAccount(Account account);

    //删除账户
    int deleteAccount(int id);
}
第二步：修改AccountMapper.xml
代码语言：javascript
复制
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.zibo.mapper.AccountMapper">
    <!--配置查询所有-->
    <select id="findAll" resultType="com.zibo.pojo.Account">
        select * from account;
    </select>
    <!--配置添加用户-->
    <insert id="saveAccount" parameterType="account">
        insert into account (id,name,money) values (#{id},#{name},#{money});
    </insert>
    <!--配置删除用户，为了程序出错，故意将delete多写个s-->
    <delete id="deleteAccount" parameterType="int">
        deletes from account where id = #{id};
    </delete>
</mapper>
第三步：在接口实现类中补全新增的方法
代码语言：javascript
复制
package com.zibo.mapper;

import com.zibo.pojo.Account;
import org.mybatis.spring.support.SqlSessionDaoSupport;

import java.util.List;

public class AccountMapperImpl extends SqlSessionDaoSupport implements AccountMapper {
    @Override
    public List<Account> findAll() {
        //在这里多做一些事情，制造一些错误
        Account account = new Account(10, "三哥", 100);
        saveAccount(account);
        deleteAccount(10);
        return getSqlSession().getMapper(AccountMapper.class).findAll();
    }

    @Override
    public int saveAccount(Account account) {
        return getSqlSession().getMapper(AccountMapper.class).saveAccount(account);
    }

    @Override
    public int deleteAccount(int id) {
        return getSqlSession().getMapper(AccountMapper.class).deleteAccount(id);
    }
}
测试结果（报错）：
看看数据库：

这就很尴尬了吧，我就想犯贱插入再删除，结果插入了没删除成功！

那咋办，这个时候我们就需要用到事务了，使其要成功都成功，要失败都失败！

5、mybatis-spring的事务管理概述

一个使用 MyBatis-Spring 的其中一个主要原因是它允许 MyBatis 参与到 Spring 的事务管理中。而不是给 MyBatis 创建一个新的专用事务管理器，MyBatis-Spring 借助了 Spring 中的 DataSourceTransactionManager 来实现事务管理；

一旦配置好了 Spring 的事务管理器，你就可以在 Spring 中按你平时的方式来配置事务。并且支持 @Transactional 注解和 AOP 风格的配置。在事务处理期间，一个单独的 SqlSession 对象将会被创建和使用。当事务完成时，这个 session 会以合适的方式提交或回滚；

事务配置好了以后，MyBatis-Spring 将会透明地管理事务。这样在你的 DAO 类中就不需要额外的代码了；

二、Spring声明式事务

1、Spring中的事务管理分为两种

声明式事务（常用）：AOP；

编程式事务：需要在代码中进行事务管理；

2、代码演示

第一步：在applicationContext.xml中配置声明式事务
代码语言：javascript
复制
<?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"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.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">
    <!--DataSource：使用Spring的数据源替换MyBatis的配置，c3p0 dbcp druid，
    我们这里使用Spring的JDBC:org.springframework.jdbc.datasource-->
    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/zibo?serverTimezone=UTC"/>
        <property name="username" value="root"/>
        <property name="password" value="zibo15239417242"/>
    </bean>
    <!--sqlSessionFactory-->
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <!--绑定Mybatis配置文件-->
        <!--spring可以整合mybatis的配置，也可以将mybatis的配置文件引入-->
<!--        这个引入导致错误，暂时就不引入了，所有的配置也可由spring完成-->
<!--        <property name="configuration" value="classpath:mybatis-config.xml"/>-->
        <property name="mapperLocations" value="classpath:mapper/AccountMapper.xml"/>
<!--        设置别名-->
        <property name="typeAliasesPackage" value="com.zibo.pojo"/>
    </bean>
    <!--SqlSessionTemplate：就是我们使用的SqlSession-->
    <bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">
        <!--这里只能通过构造器注入，因为SqlSessionTemplate没有setter方法-->
        <constructor-arg name="sqlSessionFactory" ref="sqlSessionFactory"/>
    </bean>

    <!--注入AccountMapperImpl-->
    <bean id="accountMapper" class="com.zibo.mapper.AccountMapperImpl">
        <property name="sqlSessionFactory" ref="sqlSessionFactory"/>
    </bean>
    <!--开启 Spring 的事务处理功能-->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <constructor-arg ref="dataSource" />
    </bean>
    <!--结合AOP，实现事务的织入-->
    <!--配置事务通知-->
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <!--给那些方法配置事务-->
        <!--配置事务的传播特性（新）,propagation默认就是REQUIRED-->
        <tx:attributes>
            <tx:method name="save" propagation="REQUIRED"/>
            <tx:method name="delete" propagation="REQUIRED"/>
            <tx:method name="update" propagation="REQUIRED"/>
            <tx:method name="query" read-only="true"/>
            <tx:method name="*" propagation="REQUIRED"/>
        </tx:attributes>
    </tx:advice>
    <!--配置事务切入-->
    <aop:config>
        <aop:pointcut id="txPointCut" expression="execution(* com.zibo.mapper.*.*(..))"/>
        <aop:advisor advice-ref="txAdvice" pointcut-ref="txPointCut"/>
    </aop:config>
</beans>
测试结果：

依旧报错，但没有插入成功；

我们没有修改原来的代码，只是通过AOP配置了事务管理，就成功达到了事务管理的目的，这就是Spring AOP的伟大！

3、注意

为什么需要事务：

如果不配置事务，可能无法保证数据提交的一致性；

如果我们不配置Spring声明式事务，我们需要在代码中手动配置事务；

事务在项目开发中，十分重要，涉及数据的一致性，不可马虎！

三、Spring学习整个项目的源码

链接：https://pan.baidu.com/s/1Jy3Q4MPtBxrlor7jybHl3g  提取码：zibo

本文参与 腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。
原始发表：2025-01-06，如有侵权请联系 cloudcommunity@tencent.com 删除
spring
测试
接口
配置
事务

本文分享自 作者个人站点/博客 前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ，欢迎热爱写作的你一起参与！

spring
测试
接口
配置
事务
评论
登录后参与评论
0 条评论
热度
最新
登录 后参与评论
推荐阅读
目录
  • 一、事务回顾
    • 1、概述
    • 2、事务的ACID原则
    • 3、环境搭建（类似Spring整合Mybatis案例）
      • 第一步：创建新Moudle，并往pom.xml导入所依赖的Maven坐标
      • 第二步：创建实体类Account
      • 第三步：创建AccountMapper接口
      • 第四步：编写AccountMapper.xml
      • 第五步：编写Spring整合Mybatis的配置文件applicationContext.xml
      • 第六步：编写Log4j配置文件
      • 第七步：创建AccountMapper接口的实现类
      • 第八步：创建测试类
      • 测试结果：
    • 4、开始模拟事务
      • 第一步：修改AccountMapper接口
      • 第二步：修改AccountMapper.xml
      • 第三步：在接口实现类中补全新增的方法
      • 测试结果（报错）：
      • 看看数据库：
    • 5、mybatis-spring的事务管理概述
  • 二、Spring声明式事务
    • 1、Spring中的事务管理分为两种
    • 2、代码演示
      • 第一步：在applicationContext.xml中配置声明式事务
      • 测试结果：
    • 3、注意
      • 为什么需要事务：
  • 三、Spring学习整个项目的源码
领券

腾讯云开发者

扫码关注腾讯云开发者

扫码关注腾讯云开发者

领取腾讯云代金券

热门产品

热门推荐

更多推荐

Copyright © 2013 - 2025 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有 

深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 粤公网安备44030502008569号

腾讯云计算（北京）有限责任公司 京ICP证150476号 |  京ICP备11018762号

问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档

Copyright © 2013 - 2025 Tencent Cloud.

All Rights Reserved. 腾讯云 版权所有

登录 后参与评论