当前位置： 首页 > news >正文

Spring【声明式事务】

news 2025/8/12 17:22:36

事务简介

  • 把一组业务当成一个业务来做；要么都成功，要么都失败！
  • 事务在项目开发中，十分重要，涉及到数据一致性的问题，需要十分注意！
  • 确保完整性和一致性！

事务的ACID原则：

  • 原子性
  • 一致性
  • 隔离性
    • 多个业务在操作临界资源的时候，需要防止数据损坏。
  • 持久性

案例：

先整合spring和mybatis

0、前置用户User类-通过注解帮我们生成有参和无参构造

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;/*** @Data 帮助生成toString、get和set等方法* @AllArgsConstructor 有参构造* @NoArgsConstructor 无参构造*/@Data
@AllArgsConstructor
@NoArgsConstructor
public class User {private int id;private String name;private String pwd;@Overridepublic String toString() {return "User{" +"id=" + id +", name='" + name + '\'' +", pwd='" + pwd + '\'' +'}';}
}

1、我们定义一个接口类 UserMapper，它抽象了我们对数据库的操作。

public interface UserMapper {public List<User> selectUser();public int addUser(User user);public int deleteUserById(int id);
}

2、配置UserMapper.xml，绑定接口中的方法，并实现SQL的实现

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//OTD Config 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.study.mapper.UserMapper"><select id="selectUser" resultType="user">select * from mybatis.user;</select><insert id="addUser" parameterType="user">insert into mybatis.user(id,name,pwd) values(#{id},#{name},#{pwd});</insert><delete id="deleteUserById" parameterType="int">delete from mybatis.user where id = #{id};</delete>
</mapper>

3、写一个接口的实现类UserMapperImpl，对接口的功能进行实现：


import com.study.pojo.User;
import org.mybatis.spring.support.SqlSessionDaoSupport;import java.util.List;public class UserMapperImpl extends SqlSessionDaoSupport implements UserMapper{@Overridepublic List<User> selectUser() {UserMapper mapper = getSqlSession().getMapper(UserMapper.class);return mapper.selectUser();}@Overridepublic int addUser(User user) {return getSqlSession().getMapper(UserMapper.class).addUser(user);}@Overridepublic int deleteUserById(int id) {return getSqlSession().getMapper(UserMapper.class).deleteUserById(id);}
}

4、我们在spring的配置文件applicationContext.xml中注册这个实现类的bean

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsd"><import resource="spring-dao.xml"/><bean id="userMapper" class="com.study.mapper.UserMapperImpl"><property name="sqlSessionFactory" ref="sqlSessionFactory"/></bean>
</beans>

5、测试

import com.study.mapper.UserMapper;
import com.study.pojo.User;
import com.sun.org.apache.bcel.internal.util.ClassPath;
import org.springframework.context.support.ClassPathXmlApplicationContext;import java.util.List;public class MyTest {static ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");static UserMapper mapper = context.getBean("userMapper", UserMapper.class);public static void main(String[] args) {delUser(3);selectAll();System.out.println("============");addUser(new User(4,"李大喜","112233"));selectAll();}public static void selectAll(){List<User> list = mapper.selectUser();for (User user : list) {System.out.println(user);}}public static int delUser(int id){return mapper.deleteUserById(id);}public static int addUser(User user){return mapper.addUser(user);}
}

事务：

        比如我们在selectAll()方法中增加一个用户并将新用户删除，而且我们将删除用户的SQL语句故意写错，这样执行的时候我们就是发现，我们的这个selectAll方法并没有体现出事务的特点，我们说事务应该是统一完成或者统一失败的，但是我们的这个方法结果却是添加了新用户但是并没有删除成功（因为我们的删除SQL是错误的），所以，我们要想一种办法来实现事务：

spring中事务的实现

spring 中事务的实现有两种方式：

  • 声明式事务（通过AOP实现，不需要修改原业务代码）
  • 编程式事务（通过try-catch，需要修改原业务代码）

我们更多的不去直接修改原本的业务代码，而是使用声明式事务

事务的实现

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

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

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

标准配置

要开启 Spring 的事务处理功能，在 Spring 的配置文件中创建一个 DataSourceTransactionManager 对象，也就是注册一个bean。

在我们的spring配置文件（可以在applicationContext.xml中区配置，也可以在我们数据源bean-dataSource所在的配置文件中配置，这里我们直接在spring-dao.xml中操作，因为我们的数据源bean在这个配置文件中，我们将所有与数据库操作相关的代码都放到这个配置文件中去便于后期查找和维护），因此这样我们中注册这样一个bean：

<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><constructor-arg ref="dataSource" />
</bean>

我们可以看到，其中需要指定引用-也就是我的数据源（数据库），这里我们是通过构造器注入的事务管理器对象，我们也可以通过属性来注入：

<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"/></bean>

交由容器管理事务

注册完成事务管理器后，我们需要交由容器来管理事务：

我们在spring含有sqlSessionFactory的配置文件中添加以下配置代码：

1、配置事务通知advice

1.1、导入 tx 约束文件

<?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"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsd">

1.2、设置事务属性

    <tx:advice id="txAdvice" transaction-manager="transactionManager"><tx:attributes><tx:method name="selectUser" propagation="REQUIRED"/><tx:method name="*" propagation="REQUIRED"/></tx:attributes></tx:advice>

2、配置事务切入

 2.1、导入切入约束

<?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:aop="http://www.springframework.org/schema/aop"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop/spring-aop.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsd">

2.2、设置切入点

我们设置切入点的作用范围为com.study.mapper包下所有类的所有方法。

    <tx:advice id="txAdvice" transaction-manager="transactionManager"><tx:attributes><tx:method name="selectUser" propagation="REQUIRED"/><tx:method name="*" propagation="REQUIRED"/></tx:attributes></tx:advice><!--对应tx标签内的id-->
<aop:config><aop:pointcut id="txPointCut" expression="execution(* com.study.mapper.*.*(..))"/><aop:advisor advice-ref="txAdvice" pointcut-ref="txPointCut"/></aop:config>

测试

我们继续测试selectUser方法，我们故意将其中嵌套的delUser方法的SQL雨具写错，观察先执行的addUser方法是否执行，因为它是在delUser方法执行前的，他们是一整个事务，如果配置成功应该是一起成功或失败：

我们发现，配置事务之后，我们的selectUser方法内部的方法也都是一起成功或失败的，事务功能实现！

总结

主要就配置三部分：

  1. 配置事务管理器
  2. 配置事务通知
  3. 配置切入点
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><constructor-arg ref="dataSource" /><property name="dataSource" ref="dataSource"/></bean><tx:advice id="txAdvice" transaction-manager="transactionManager"><tx:attributes><tx:method name="selectUser" propagation="REQUIRED"/><tx:method name="*" propagation="REQUIRED"/></tx:attributes></tx:advice><aop:config><aop:pointcut id="txPointCut" expression="execution(* com.study.mapper.*.*(..))"/><aop:advisor advice-ref="txAdvice" pointcut-ref="txPointCut"/></aop:config>

事务在项目中十分重要！

http://www.lryc.cn/news/101570.html

相关文章：

  • 【雕爷学编程】MicroPython动手做（17）——掌控板之触摸引脚2
  • pytorch 中 view 和reshape的区别
  • 认识数组指针
  • SSM面试题-Spring容器的启动流程
  • Vue 3：玩一下web前端技术（八）
  • AI绘画Stable Diffusion原理之Autoencoder-Latent
  • C++核心知识点总结
  • echart折线图，调节折线点和y轴的间距（亲测可用）
  • Power BI-云端报表定时刷新--ODBC、MySQL、Oracle等其他本地数据源的刷新（二）
  • redis 淘汰策略和持久化
  • Redis学习路线（6）—— Redis的分布式锁
  • 一、创建自己的docker python容器环境；支持新增python包并更新容器；离线打包、加载image
  • 【Git】git企业开发命令整理，以及注意点
  • 使用Django自带的后台管理系统进行数据库管理的实例
  • leetcode解题思路分析（一百四十五）1254 - 1266 题
  • 使用 GORM 连接数据库并实现增删改查操作
  • kafka集群搭建（Linux环境）
  • 树莓派本地快速搭建web服务器，并发布公网访问
  • 集合中的数据结构
  • CentOS 8 错误: Error setting up base repository
  • java外观模式
  • 3秒快速打开 jupyter notebook
  • 数据安全
  • 华为nat64配置
  • 从分片传输到并行传输之大文件传输加速技术
  • mybatisPlus入门篇
  • NineData支持最受欢迎数据库PostgreSQL
  • Redis配置类
  • 【前端知识】React 基础巩固(三十六)——RTK中的异步操作
  • 33. 本地记事本