java pojo使用_在POJO中使用ThreadLocal进行Java嵌套事务

java pojo使用

大多数嵌套事务是使用EJB实现的,现在我们尝试在POJO上实现嵌套事务。 在这里,我们使用了ThreadLocal的功能。

了解嵌套事务

事务可以嵌套在另一个内部。 因此,内部事务或外部事务可以回滚或提交,而不会影响其他事务。

创建新事务后,它将进入外部事务。 一旦内部事务以提交或回滚的方式完成,外部事务就可以执行提交或回滚而与内部事务无关。 首先关闭最内部的事务,然后继续进行外部事务。

图片1

使用简单POJO实施

创建界面如下:

importjava.sql.Connection;publicinterfaceTransactionManager {Connection getConnection();voidbeginTransaction();void commit();void rollback();
}

创建事务管理器类,如下所示:

importjava.sql.Connection;
importjava.sql.DriverManager;
importjava.sql.SQLException;
importjava.util.Stack;publicclassTransactionManagerStackImplimplementsTransactionManager {private Stack<Connection>connections = new Stack<Connection>();@Overridepublic Connection getConnection() {if (connections.isEmpty()) {this.addConn();}returnconnections.peek();}@OverridepublicvoidbeginTransaction() {this.addConn();}@Overridepublicvoid commit() {try {if (connections.peek() != null&& !connections.peek().isClosed()) {System.out.println(connections.peek().toString() +"--Commit---");connections.peek().commit();connections.pop().close();}} catch (SQLException e) {e.printStackTrace();}}@Overridepublicvoid rollback() {try {if (connections.peek() != null&& !connections.peek().isClosed()) {System.out.println(connections.peek().toString() +"--Rollback---");connections.peek().rollback();connections.pop().close();}} catch (SQLException e) {e.printStackTrace();}}privatevoidaddConn() {try {Connection con = this.getMysqlConnection();con.setAutoCommit(false);connections.push(con);System.out.println(con.toString() +"--Conection---");} catch (SQLException e) {e.printStackTrace();}}private Connection getMysqlConnection() {returngetConnection("com.mysql.jdbc.Driver", "jdbc:mysql://localhost:3306/testdb", "test", "test12345");}private Connection getConnection(String driver, String connection,String user, String password) {try {Class.forName(driver);returnDriverManager.getConnection(connection, user, password);} catch (ClassNotFoundException e) {e.printStackTrace();} catch (SQLException e) {e.printStackTrace();}returnnull;}
}

在这里,我们创建了一个堆栈:

private Stack<Connection> connections = new Stack<Connection>();

由于事务创建为LIFO(堆栈),因此我们使用了Java API中的Stack来维护每个事务的连接:

public void beginTransaction()

开始事务以开始新事务并将连接添加到堆栈。 AutoCommit已设置为false:

public Connection getConnection()

获取当前事务的连接。 如果不存在,它将创建并添加到堆栈中:

public void commit()

提交当前事务并关闭连接,该连接也已从堆栈中删除:

public void rollback()

回滚当前事务并关闭连接,该连接也已从堆栈中删除。

上面的TransactionManagerStackImpl类将为单线程创建嵌套事务。

多线程嵌套事务

对于多线程应用程序,每个线程都有独立的事务和嵌套事务。

我们提出使用ThreadLocal来管理连接堆栈。

importjava.sql.Connection;publicclassTransactionManagerThreadLocalimplementsTransactionManager {privatestaticfinalThreadLocal<TransactionManager>tranManager = newThreadLocal<TransactionManager>() {protectedTransactionManagerinitialValue() {System.out.println(this.toString() + "--Thread Local Initialize--");returnnewTransactionManagerStackImpl();}};@OverridepublicvoidbeginTransaction() {tranManager.get().beginTransaction();}@Overridepublicvoid commit() {tranManager.get().commit();}@Overridepublicvoid rollback() {tranManager.get().rollback();}@Overridepublic Connection getConnection() {returntranManager.get().getConnection();}
}

在这里,我们初始化TransactionManagerStackImpl以在线程内部创建嵌套事务。

测试中

为了进行上述测试,请提交内部事务并回滚外部事务。

importjava.sql.Connection;publicclassNestedMainimplements Runnable {privateintv = 0;private String name;NestedMain(int v, String name) {this.v = v;this.name = name;}publicstaticvoid main(String[] args) throws Exception{for (inti = 0; i< 3; i++) {NestedMain main = newNestedMain(i * 10, "Ravi" + i);new Thread(main).start();}}@Overridepublicvoid run() {try {TransactionManagerThreadLocal local = newTransactionManagerThreadLocal();// Transaction 1 ( outer )local.beginTransaction();Connection con = local.getConnection();String sql = "INSERT INTO test_tran (emp_id, name) VALUES ('1"+v+"', '"+ name+v+"')";this.insert(con, sql);// Transaction 2 ( Inner )local.beginTransaction();con = local.getConnection();sql = "INSERT INTO test_tran (emp_id, name) VALUES ('2"+v+"', '"+ name+v+"')";this.insert(con, sql);local.commit(); // Committing 2local.rollback(); // Rollback 1 Outer} catch (Exception e) {e.printStackTrace();}

结果

com.ttit.TransactionManagerThreadLocal$1@1270b73--Thread Local Initialize--
com.ttit.TransactionManagerThreadLocal$1@1270b73--Thread Local Initialize--
com.ttit.TransactionManagerThreadLocal$1@1270b73--Thread Local Initialize--
com.mysql.jdbc.JDBC4Connection@10dd1f7--Conection---
com.mysql.jdbc.JDBC4Connection@1813fac--Conection---
com.mysql.jdbc.JDBC4Connection@136228--Conection---
com.mysql.jdbc.JDBC4Connection@1855af5--Conection---
com.mysql.jdbc.JDBC4Connection@e39a3e--Conection---
com.mysql.jdbc.JDBC4Connection@1855af5--Commit---
com.mysql.jdbc.JDBC4Connection@e39a3e--Commit---
com.mysql.jdbc.JDBC4Connection@9fbe93--Conection---
com.mysql.jdbc.JDBC4Connection@9fbe93--Commit---
com.mysql.jdbc.JDBC4Connection@10dd1f7--Rollback---
com.mysql.jdbc.JDBC4Connection@1813fac--Rollback---
com.mysql.jdbc.JDBC4Connection@136228--Rollback---
名称 emp_id
拉维220 220
拉维00 20
拉维110 210

回滚内部事务并提交外部事务时:

com.ttit.TransactionManagerThreadLocal$1@1270b73--Thread Local Initialize--
com.ttit.TransactionManagerThreadLocal$1@1270b73--Thread Local Initialize--
com.ttit.TransactionManagerThreadLocal$1@1270b73--Thread Local Initialize--
com.mysql.jdbc.JDBC4Connection@9f2a0b--Conection---
com.mysql.jdbc.JDBC4Connection@136228--Conection---
com.mysql.jdbc.JDBC4Connection@1c672d0--Conection---
com.mysql.jdbc.JDBC4Connection@9fbe93--Conection---
com.mysql.jdbc.JDBC4Connection@1858610--Conection---
com.mysql.jdbc.JDBC4Connection@9fbe93--Rollback---
com.mysql.jdbc.JDBC4Connection@1858610--Rollback---
com.mysql.jdbc.JDBC4Connection@1a5ab41--Conection---
com.mysql.jdbc.JDBC4Connection@1a5ab41--Rollback---
com.mysql.jdbc.JDBC4Connection@9f2a0b--Commit---
com.mysql.jdbc.JDBC4Connection@136228--Commit---
com.mysql.jdbc.JDBC4Connection@1c672d0--Commit---
名称 emp_id
拉维00 10
拉维220 120
拉维110 110

资源:

  • 了解ThreadLocal背后的概念

翻译自: https://www.javacodegeeks.com/2013/12/java-nested-transaction-using-threadlocal-in-pojo.html

java pojo使用

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

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

相关文章

Java开发人员应该知道的5大Spring Boot功能

您可能已经听说过Spring Boot&#xff0c;这是用不到140个字符创建一个Spring Web应用程序的神奇力量&#xff0c;可以在一条推文中编写这些字符&#xff0c;但这到底意味着什么&#xff1f; 哪些功能可以使Spring Boot具有如此强大的功能并使Spring应用程序开发如此容易&#…

java 使用本机代理_Java与本机代理–他们所做的强大功能

java 使用本机代理在安装代理之前应了解的内容及其对代码的影响 在构建可伸缩的服务器端应用程序时&#xff0c;我们花费大量时间思考如何在生产中监视&#xff0c;操作和更新代码。 已经开发出一种新的工具来帮助Java和Scala开发人员做到这一点。 它们中的许多都是建立在最强大…

在任何无法理解的情况下,请编写脚本

脚本编写是使您的应用程序在运行时就可以根据客户需求进行调整的最流行的方法之一。 与往常一样&#xff0c;此方法不仅带来好处&#xff0c;例如&#xff0c;在灵活性和可管理性之间存在众所周知的折衷方案。 本文不是从理论上讨论优缺点的文章之一&#xff0c;而是从实践上展…

下载anaconda时出现“Please make sure you are connected to the internet”警告

如题&#xff0c;在anaconda下载过程中下载VScode时出现下图的警告。 百度翻译&#xff1a; 顺着图中指定文件路径&#xff0c;找到vscode_inst.py.log文件&#xff08;注&#xff1a;有些人ProgramData文件夹可能找不到&#xff0c;打开任意文件夹&#xff0c;点击查看&…

多个公证员提高网络吞吐量

您是否需要非常高吞吐量的Corda网络&#xff1f; 网络的吞吐量是否稳定&#xff1f; 您是否已经从其他领域挤出了所有可能的表现&#xff1f; 如果您对这些问题的回答是“是”&#xff0c;那么我可能会为您提供一些有用的信息。 我列出了这些问题&#xff0c;以减少您过早优化C…

初识FPGA(搬运)

原文链接1原文链接2 fpga简介 FPGA&#xff08;Field&#xff0d;Programmable Gate Array&#xff09;&#xff0c; 即现场可编程门阵列&#xff0c;它是在PAL&#xff08;可编程阵列逻辑&#xff09;、GAL&#xff08;通用阵列逻辑器件&#xff09;、CPL&#xff08;复杂可…

蓝桥杯小白系列之汇编点亮led灯

蓝桥杯小白系列之汇编点亮led灯 1、源代码 2、逐条分析 (1)ORG 0000H (2)START: 伪指令,编译器可识别,单片机不可识别,可以随便起。 (3)蜂鸣器设置 蓝桥板插电以后蜂鸣器常会自动响起,故在程序前提前加上如下代码,让蜂鸣器不响: mov P2,#0A0H mov P0,#000H 参照…

带有Oracle Digital Assistant和Fn Project的会话式UI。 第二部分

在上一篇文章中&#xff0c;我使用Oracle Digital Assistant为FlexDeploy实现了一个对话式UI。 今天&#xff0c;我将用Fn Flow丰富它&#xff0c;以便聊天机器人接受发行名称而不是ID来创建快照。 完成后&#xff0c;对话听起来会更加自然&#xff1a; … “您可以建立快照吗…

小白系列之51单片机的入门速成法

51单片机的入门速成法 01-经典51内核资源全览浓缩图 02-重要外设特殊功能寄存器概览 03-程序开发流程与设计要点 04-三大外设的开发与可重用代码 05-应用程序设计入门一例通 01-经典51内核资源全览浓缩图 <1> 四组8位并行I/O端口&#xff1a; P0端口&#xff1a;PC门&a…

蓝桥杯基础模块1:LED跑马灯

一、模块题目 二、原理简述 1、74HC138:三八译码器(3个输入,8个输出) 2、74HC573:锁存器(20个引脚,D1D8是数据输入端,Q1Q8是数据输出端&#

如何使用Hibernate将PostgreSQL枚举映射到JPA实体属性

介绍 开源的hibernate-types项目允许您映射JSON&#xff0c;ARRAY&#xff0c; YearMonth &#xff0c; Month或数据库特定的列&#xff08;例如INET地址&#xff09;。 在本文中&#xff0c;我们将看到使用JPA和Hibernate时如何将PostgreSQL Enum类型映射到Java数组。 Maven…

蓝桥杯基础模块2:蜂鸣器继电器

一、模块题目 二、原理简述 1、74HC138(参见模块1) 2、74HC02(参见模块1) 3、74HC573(参见模块1)

蓝桥杯基础模块3_1:数码管静态显示

一、模块题目 二、原理简述 1、数码管 CT107D单片机综合实训平台上使用的数码管是F3461BH(倒数第二个字母是A则共阴,是B则共阳)。 F3461BH是一个4位8段的数码管,其中a、b、c、d、e、f、g、dp引脚分别对应8个段码,该8个引脚通过74HC573锁存器与单片机的P0端口相连。另外有…

蓝桥杯基础模块3_2:数码管动态显示

一、模块题目 二、原理简述 动态显示的基本原理与实现思路(转载) 动态显示实质上就是轮流点亮单个数码管实现多位数码管整体显示的效果。在轮流显示过程中,每位数码管点亮时间为1~2ms,由于人的视觉暂留现象及发光二极管的余辉效应,尽管实际上各位数码管并非同时点亮,但…

蓝桥杯基础模块4_1:独立按键

一、模块题目 二、原理简述 1、独立按键的处理思路(转载) 一般情况下,独立按键有两个引脚,其中一个通过上拉电阻接到单片机的I/O端口,另外一端接地。也就是说,平时按键没有动作的时候,输出的是高电平,如果有按下动作发生,则输出的是低电平。那么,我们在程序设计的时…

蓝桥杯基础模块4_3:矩阵按键

一、模块题目 二、原理简述 1、矩阵键盘的扫描思想(转载+删减) 与独立按键不同的是,按键的两个引脚都分别连接的单片机的I/O端口,一个作为行信号,另外一个作为列信号。下以4X4的矩阵键盘为例,探讨其工作方式和扫描思路。 要识别出黄色按键的按下状态,逐行扫描,然后读…

蓝桥杯基础模块5:外部中断

一、模块题目 二、原理简述 (转载,删改) 1、什么是中断 你正在追电视剧《神雕侠侣》,正看得入迷的时候,电话响了,你暂停电视剧,去接电话,在接电话的过程中,门铃又响了,你暂时放下电话,去把门打开。如果追电视剧是在执行主程序,那么电话就是中断源,电话铃响了就是中…

蓝桥杯基础模块06_1:定时器计数器

一、模块题目 二、原理简述 &#xff08;转载&#xff0c;删改&#xff09; 1、定时器、计数器定义 在没有钟表的时候&#xff0c;定时的方式通过有一注香的时间&#xff0c;或者一桶水的时间。前者烧香不断减少是减法&#xff0c;后者滴水不断增加是加法。 定时/计数器&#…

structure101_使用structure101分析软件包的依赖关系

structure101稳定应用程序的一个关键是结构良好的代码库。 我们知道我们应该建立尽可能多的黑匣子&#xff0c;因为一旦完成一个黑匣子&#xff0c;我们就不必再考虑其内部了。 您只需要使用您或其他团队成员通过明确定义的界面编写的代码即可。 这使您可以专注于要添加的下一个…