使用ThreadLocal绑定连接资源（事务）

dao层代码如下：

package beyond.transfer.dao;import java.sql.Connection;
import java.sql.SQLException;import org.apache.commons.dbutils.QueryRunner;import beyond.utils.DataSourceUtils;
import beyond.utils.MyDataSourceUtils;public class TransferDao {public void out( String out, double money) throws SQLException {QueryRunner runner = new QueryRunner();//不用穿参数Connection conn = MyDataSourceUtils.getCurrentConnection();String sql = "update account set money= money-? where name=?";runner.update(conn, sql, money,out);}public void in(String in, double money) throws SQLException {QueryRunner runner = new QueryRunner();//不用穿参数Connection conn = MyDataSourceUtils.getCurrentConnection();String sql = "update account set money= money+? where name=?";runner.update(conn, sql, money,in);}}

service层代码如下：

package beyond.transfer.service;import java.sql.Connection;
import java.sql.SQLException;import beyond.transfer.dao.TransferDao;
import beyond.utils.DataSourceUtils;
import beyond.utils.MyDataSourceUtils;public class TransferService {public boolean transfer(String out, String in, double money) {//创建dao层对象TransferDao dao = new TransferDao();boolean isTransferSuccess = true;Connection conn = null;try {//进行事务控制，开启事务//conn = DataSourceUtils.getConnection();//不自动开启事务，也就是手动开启事务//conn.setAutoCommit(false);//开启事务MyDataSourceUtils.startTransaction();//调用dao层的转出钱的方法,只需要知道 转钱的人是谁 跟 钱数 就行dao.out(out,money);//调用dao层的转入钱的方法,只需要知道 转给谁 跟 钱数 就行dao.in(in,money);} catch (SQLException e) {isTransferSuccess = false;try {//当出现事务错误，进行事务的回滚；回滚本身内部不包含提交的功能MyDataSourceUtils.rollback();} catch (SQLException e1) {e1.printStackTrace();}e.printStackTrace();}finally{try {MyDataSourceUtils.commit();} catch (SQLException e) {e.printStackTrace();}}return isTransferSuccess;}}

web层代码如下：

package beyond.transfer.web;import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;import beyond.transfer.service.TransferService;public class TransferServlet extends HttpServlet {public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {//接收转账的参数String out = request.getParameter("out");String in = request.getParameter("in");String moneyStr = request.getParameter("money");double money=Double.parseDouble(moneyStr);//进行将转账金额强转//调用业务层的转账方法TransferService service = new TransferService();boolean isTransferSuccess = service.transfer(out,in,money);//解决乱码问题response.setContentType("text/html;charset=UTF-8");if(isTransferSuccess){response.getWriter().write("转账成功！！！");}else{response.getWriter().write("转账失败！！！");}}public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {doGet(request, response);}
}

使用ThreadLocal绑定连接资源（事务）相关推荐

jdbc事务 jta事务_将非事务性资源绑定到JTA事务中的几种模式
jdbc事务 jta事务我最近发表了一篇有关如何将非事务性资源(如Web服务/微服务)绑定到全局分布式事务中的文章,以便自动处理恢复. 多年来,我经常不得不将"非事务性"系统集成 ...
将非事务性资源绑定到JTA事务中的几种模式
我最近发表了一篇有关如何将非事务性资源(如Web服务/微服务)绑定到全局分布式事务中的文章,以便自动处理恢复. 多年来,我经常不得不将"非事务性"系统集成到Java EE应用程序服 ...
jta atomikos_带有Atomikos示例的Tomcat中的Spring JTA多个资源事务
jta atomikos 在本教程中,我们将向您展示如何使用Atomikos Transaction Manager在Tomcat服务器中实现JTA多个资源事务. Atomicos事务管理器为分布式事 ...
带有Atomikos示例的Tomcat中的Spring JTA多个资源事务
在本教程中,我们将向您展示如何使用Atomikos Transaction Manager在Tomcat服务器中实现JTA多个资源事务. Atomicos事务管理器为分布式事务提供支持. 这些是多阶段 ...
threadlocal存连接对象的目的_面试官：知道ThreadLocal嘛？谈谈你对它的理解？
在java的多线程模块中,ThreadLocal是经常被提问到的一个知识点,提问的方式有很多种,可能是循序渐进也可能是就像我的题目那样,因此只有理解透彻了,不管怎么问,都能游刃有余. 这篇文章主要从以 ...
mysql 不同连接的事务会嵌套_MySQL——事务
事务(Transaction)是数据库区别于文件系统的重要特性之一,事务会把数据库从一种一致状态转换为另一种一致状态. 关键词事务四大特性ACID MySql事务隔离级别 MVCC多版本并发控制实 ...
如何释放mysql连接资源_CI框架出现mysql数据库连接资源无法释放的解决方法
本文实例分析了CI框架出现mysql数据库连接资源无法释放的解决方法.分享给大家供大家参考,具体如下: 使用ci框架提供的类查询数据: $this->load->database(); $ ...
threadlocal存连接对象的目的_终于懂了ThreadLocal，不再害怕面试官问了
ThreadLocal解析 synchronized和ThreadLocal的区别: synchronized:以时间换空间,只提供一份变量,让不同的线程排队访问,失去了并发性,降低了程序效率,着重对 ...
threadlocal存连接对象的目的_ThreadLocal 介绍
概述 ThreadLocal 是 java 提供的一个方便对象在本线程内不同方法中传递和获取的类.用它定义的变量,仅在本线程中可见和维护,不受其他线程的影响,与其他线程相互隔离. 虽然在本线程不同方法 ...

使用ThreadLocal绑定连接资源（事务）

dao层代码如下：

service层代码如下：

web层代码如下：

使用ThreadLocal绑定连接资源（事务）相关推荐

最新文章

热门文章