手动事务的使用

news2025/6/6 6:25:40

使用原因:

        公司需要写一个定时任务,涉及增改查操作,

        定时将前端页面配置的字典数据(标签数据)同步到数据库特定的表(标签表)

                查询字典表数据

                字典有,数据库表没有=新增

                都有,判断名称,名称不同修改

        【观察其他定时任务,采用return Result写法,异常-1,正常1,所以排除@Transactional,因为异常时return,无法回滚(抛异常会跟相同功能的写法背离),所以采用手动事务处理】

备注:

        范围要小,在增删改的地方,创建手动事务,异常里做回滚

        原因:上来就手动事务,或者手动事务开启过早,容易出现长事务问题

写法如下:

=====================正常情况下用这一坨=============================
=====================扩展作为全面了解使用===========================
=====================注解写法看第二段===============================
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;
 
 @Resource
 private PlatformTransactionManager transactionManager;
            
            // 1:定义事务属性
            DefaultTransactionDefinition def = new DefaultTransactionDefinition();
            def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
            TransactionStatus status = transactionManager.getTransaction(def);


 try {
            //2:数据库操作
            //新增
            //更新
            //删除
            ........
 } catch (Exception e) {
            // 【出现问题】3:手动回滚事务
            transactionManager.rollback(status);
            log.info("数据批量插入及更新异常,异常消息:{},完整异常:{}", e.getMessage(), e);
        }

        // 【没问题】4:手动提交事务
        transactionManager.commit(status);



==============================@Transactional写法====================
==============================@Transactional写法====================
==============================@Transactional写法====================
@Transactional(
    propagation = Propagation.REQUIRED,  //传播行为
    isolation = Isolation.READ_COMMITTED,	//隔离级别
    timeout = 30, //超时时间,超时自动回滚
    readOnly = false //是否只读,ture不可写,false可写
)



===============================扩展=================================
===============================扩展=================================
===============================扩展=================================
// 创建一个默认事务定义对象
DefaultTransactionDefinition def = new DefaultTransactionDefinition();

// 设置传播行为为 PROPAGATION_REQUIRED:
// - 如果当前没有事务,就新建一个;
// - 如果已经存在事务,就加入该事务(这是默认值)
def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);

// 可选的其他传播行为如下(取消注释即可使用):
// def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW); // 总是新建事务,并挂起已有事务
// def.setPropagationBehavior(TransactionDefinition.PROPAGATION_SUPPORTS);     // 有事务就用,没事务就不用
// def.setPropagationBehavior(TransactionDefinition.PROPAGATION_NOT_SUPPORTED);// 不用事务,挂起已有事务
// def.setPropagationBehavior(TransactionDefinition.PROPAGATION_NEVER);        // 不能有事务,否则抛异常
// def.setPropagationBehavior(TransactionDefinition.PROPAGATION_MANDATORY);    // 必须有事务,否则抛异常
// def.setPropagationBehavior(TransactionDefinition.PROPAGATION_NESTED);       // 嵌套事务,可独立提交或回滚

// 设置隔离级别为 ISOLATION_READ_COMMITTED:
// - 只能读取已提交的数据,避免脏读(读已提交)
def.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);

// 可选的其他隔离级别如下(取消注释即可使用):
// def.setIsolationLevel(TransactionDefinition.ISOLATION_DEFAULT);            // 使用数据库默认级别(如 MySQL 是 REPEATABLE_READ) 【读已提交】
// def.setIsolationLevel(TransactionDefinition.ISOLATION_READ_UNCOMMITTED);   // 允许脏读(最低隔离) 【读未提交】
// def.setIsolationLevel(TransactionDefinition.ISOLATION_REPEATABLE_READ);    // 避免脏读和不可重复读   【可重复读】
// def.setIsolationLevel(TransactionDefinition.ISOLATION_SERIALIZABLE);       // 最高隔离,完全串行化执行   【串行化】

// 设置事务最大持续时间为30秒,超时自动回滚
def.setTimeout(30);

// 设置事务是否为只读:
// - true:表示事务中不会修改数据,有助于性能优化(如查询操作)
// - false:允许读写操作(默认值)
def.setReadOnly(false);

// 设置事务名称,用于日志、调试或监控识别
def.setName("MyCustomTx");

// 开始事务,并获取事务状态对象
TransactionStatus status = transactionManager.getTransaction(def);

try {
    // 【在这里编写你的业务逻辑】
    // 比如执行多个数据库操作 jdbcTemplate.update(...) 等

    // 提交事务:如果没有异常,提交所有更改
    transactionManager.commit(status);
} catch (Exception e) {
    // 出现异常:回滚事务,撤销之前的操作
    transactionManager.rollback(status);
    throw e; // 可选择重新抛出异常以便上层处理
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2398708.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

Vue 树状结构控件

1、效果图如下所示&#xff1a; 2、网络请求的数据结构如下&#xff1a; 3、新建插件文件&#xff1a;menu-tree.vue&#xff0c;插件代码如下&#xff1a; <template><div class"root"><div class"parent" click"onParentClick(pare…

【LUT技术专题】图像自适应3DLUT代码讲解

本文是对图像自适应3DLUT技术的代码解读&#xff0c;原文解读请看图像自适应3DLUT文章讲解 1、原文概要 结合3D LUT和CNN&#xff0c;使用成对和非成对的数据集进行训练&#xff0c;训练后能够完成自动的图像增强&#xff0c;同时还可以做到极低的资源消耗。下图为整个模型的…

vscode使用“EIDE”和“Cortex-Debug”插件利用st-link插件实现程序烧写以及调试工作

第一步&#xff1a;安装vscode插件“EIDE”EIDE和“Cortex-Debug”。 第二步&#xff1a;配置EIDE 2.1安装“实用工具”&#xff1a; 2.2 EIDE插件配置&#xff1a;根据安装的keil C51 keil MDK IAR的相关路径设置 第三步&#xff1a;配置Cortex-Debug插件 点击settings.jso…

Spring @Value注解的依赖注入实现原理

Spring Value注解的依赖注入实现原理 一&#xff0c;什么是Value注解的依赖注入二&#xff0c;实现原理三&#xff0c;代码实现1. 定义 Value 注解2. 实现 InstantiationAwareBeanPostProcessor3. 实现 AutowiredAnnotationBeanPostProcessor4. 占位符解析逻辑5. 定义 StringVa…

三、kafka消费的全流程

五、多线程安全问题 1、多线程安全的定义 使用多线程访问一个资源&#xff0c;这个资源始终都能表现出正确的行为。 不被运行的环境影响、多线程可以交替访问、不需要任何额外的同步和协同。 2、Java实现多线程安全生产者 这里只是模拟多线程环境下使用生产者发送消息&…

Axure形状类组件图标库(共8套)

点击下载《月下倚楼图标库(形状组件)》 原型效果&#xff1a;https://axhub.im/ax9/02043f78e1b4386f/#g1 摘要 本图标库集锦精心汇集了8套专为Axure设计的形状类图标资源&#xff0c;旨在为产品经理、UI/UX设计师以及开发人员提供丰富多样的设计素材&#xff0c;提升原型设计…

20250530-C#知识:String与StringBuilder

String与StringBuilder string字符串在开发中经常被用到&#xff0c;不过在需要频繁对字符串进行增加和删除时&#xff0c;使用StringBuilder有利于提升效率。 1、String string是一种引用类型而非值类型&#xff08;某些方面像值类型&#xff09;使用“”进行两个string对象的…

从 Docker 到 Containerd:Kubernetes 容器运行时迁移实战指南

一、背景 Kubernetes 自 v1.24 起移除了 dockershim&#xff0c;不再原生支持 Docker Engine&#xff0c;用户需迁移至受支持的 CRI 兼容运行时&#xff0c;如&#xff1a; Containerd&#xff08;推荐&#xff0c;高性能、轻量级&#xff09; CRI-O&#xff08;专为 Kuberne…

uniapp中view标签使用范围

不止用于微信小程序。兼容型号&#xff0c;是uniapp内置组件之一&#xff0c;在uniapp中进行了跨平台适配。支持所有uniapp的平台。如微信小程序、h5、app、支付宝小程序

欢乐熊大话蓝牙知识14:用 STM32 或 EFR32 实现 BLE 通信模块:从0到蓝牙,你也能搞!

&#x1f680; 用 STM32 或 EFR32 实现 BLE 通信模块&#xff1a;从0到蓝牙&#xff0c;你也能搞&#xff01; “我能不能自己用 STM32 或 EFR32 实现一个 BLE 模块&#xff1f;” 答案当然是&#xff1a;能&#xff01;还能很帅&#xff01; &#x1f468;‍&#x1f3ed; 前…

IDEA 在公司内网配置gitlab

赋值项目链接 HTTPS 将HTTP的链接 ip地址换成 内网地址 例如&#xff1a;https:172.16.100.18/...... 如果出现需要需要Token验证的情况&#xff1a; 参考&#xff1a;Idea2024中拉取代码时GitLab提示输入token的问题_gitlab token-CSDN博客

黑马Java面试笔记之 微服务篇(业务)

一. 限流 你们项目中有没有做过限流?怎么做的? 为什么要限流呢? 一是并发的确大(突发流量) 二是防止用户恶意刷接口 限流的实现方式: Tomcat:可以设置最大连接数 可以通过maxThreads设置最大Tomcat连接数,实现限流,但是适用于单体架构 Nginx:漏桶算法网关,令牌桶算法自定…

通过WiFi无线连接小米手机摄像头到电脑的方法

通过WiFi无线连接小米手机摄像头到电脑的方法 以下是基于Scrcpy和DroidCam两种工具的无线连接方案&#xff0c;需提前完成开发者模式与USB调试的开启&#xff08;参考原教程步骤&#xff09;&#xff1a; 方法一&#xff1a;Scrcpy无线投屏&#xff08;无需手机端安装&#xf…

长短期记忆(LSTM)网络模型

一、概述 长短期记忆&#xff08;Long Short-Term Memory&#xff0c;LSTM&#xff09;网络是一种特殊的循环神经网络&#xff08;RNN&#xff09;&#xff0c;专门设计用于解决传统 RNN 在处理长序列数据时面临的梯度消失 / 爆炸问题&#xff0c;能够有效捕捉长距离依赖关系。…

CSS3美化页面元素

1. 字体 <span>标签 字体样式⭐ 字体类型&#xff08;font-family&#xff09; 字体大小&#xff08;font-size&#xff09; 字体风格&#xff08;font-style&#xff09; 字体粗细&#xff08;font-weight&#xff09; 字体属性&#xff08;font&#xff09; 2. 文本 文…

WPS 利用 宏 脚本拆分 Excel 多行文本到多行

文章目录 WPS 利用 宏 脚本拆分 Excel 多行文本到多行效果需求背景&#x1f6e0; 操作步骤代码实现代码详解使用场景注意事项总结 WPS 利用 宏 脚本拆分 Excel 多行文本到多行 在 Excel 工作表中&#xff0c;我们经常遇到一列中包含多行文本&#xff08;用换行符分隔&#xff…

AI“实体化”革命:具身智能如何重构体育、工业与未来生活

近年来&#xff0c;人工智能&#xff08;AI&#xff09;技术的飞速发展正在重塑各行各业&#xff0c;而具身智能&#xff08;Embodied AI&#xff09;作为AI领域的重要分支&#xff0c;正逐渐从实验室走向现实应用。具身智能的核心在于让AI系统具备物理实体&#xff0c;能够与环…

R语言基础| 创建数据集

在R语言中&#xff0c;有多种数据类型&#xff0c;用以存储和处理数据。每种数据类型都有其特定的用途和操作函数&#xff0c;使得R语言在处理各种数据分析任务时非常灵活和强大&#xff1a; 向量&#xff08;Vector&#xff09;: 向量是R语言中最基本的数据类型&#xff0c;它…

Centos7搭建zabbix6.0

此方法适用于zabbix6以上版本zabbix6.0前期环境准备&#xff1a;Lamp&#xff08;linux httpd mysql8.0 php&#xff09;mysql官网下载位置&#xff1a;https://dev.mysql.com/downloads/mysql/Zabbix源码包地址&#xff1a;https://www.zabbix.com/cn/download_sourcesZabbix6…

Docker 部署前后端分离项目

1.Docker 1.1 什么是 Docker &#xff1f; Docker 是一种开源的 容器化平台&#xff0c;用于开发、部署和运行应用程序。它通过 容器&#xff08;Container&#xff09; 技术&#xff0c;将应用程序及其依赖项打包在一个轻量级、可移植的环境中&#xff0c;确保应用在不同计算…