6.AOP之转账案例

news2024/11/21 2:39:09

数据准备

CREATE TABLE `account` (
	`id` int(11) NOT NULL,
	`name` varchar(100) NOT NULL,
	`money` decimal(7,2) NOT NULL,
	`create_time` datetime(6) NOT NULL,
  	PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

insert into account values(1,"steven",10000,"2022-12-07 00:00:00");
insert into account values(2,"sherry",10000,"2022-12-07 00:00:00");

搭建工程

1.引入项目使用的依赖

<dependency>
	<groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.47</version>
</dependency>
<dependency>
    <groupId>com.mchange</groupId>
    <artifactId>c3p0</artifactId>
    <version>0.9.5.2</version>
</dependency>
<dependency>
    <groupId>commons-dbutils</groupId>
    <artifactId>commons-dbutils</artifactId>
    <version>1.6</version>
</dependency>
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-context</artifactId>
    <version>5.1.5.RELEASE</version>
</dependency>

2.编写db配置文件db.properties
在项目目录“/src/main/resources”下新建db.properties文件，具体代码如下。

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/study?useSSL=false
username=root
password=admin123

3.编写Spring框架核心配置文件applicationContext.xml
在项目目录“/src/main/resources”下新建applicationContext.xml文件，具体代码如下。

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

    <!-- 1.开启注解扫描 -->
    <context:component-scan base-package="com.steven.*"/>

    <!-- 2.引入properties -->
    <context:property-placeholder location="classpath:db.properties"/>

    <!-- 3.配置DataSource -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="jdbcUrl" value="${url}"/>
        <property name="driverClass" value="${driver}"/>
        <property name="user" value="${username}"/>
        <property name="password" value="${password}"/>
    </bean>

    <!-- 4.配置queryRunner -->
    <bean id="queryRunner" class="org.apache.commons.dbutils.QueryRunner">
        <constructor-arg name="ds" ref="dataSource"/>
    </bean>
</beans>

4.编写工具类
在项目目录“/src/main/java/com/steven”下新建utils目录，并在utils目录下新建获取数据库连接工具类ConnectionUtils和事务管理工具类TransactionManager类，具体代码如下。
(1).ConnectionUtils

@Component
public class ConnectionUtils {
    @Autowired
    private DataSource dataSource;

    private ThreadLocal<Connection> threadLocal = new ThreadLocal<Connection>();


    /**
     * 获取当前线程上绑定连接
     * 如果获取到的连接为空，就要从数据源中获取连接，并放到ThreadLocal中(绑定到当前线程)
     */
    public Connection getThreadConnection() {
        //1.先从ThreadLocal上获取连接
        Connection connection = threadLocal.get();

        //2.判断当前线程中是否有Connection
        if (connection == null) {
            //3.从数据源中获取一个连接，并且存入ThreadLocal中
            try {
                connection = dataSource.getConnection();

                threadLocal.set(connection);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return connection;
    }


    /**
     * 解除当前线程的连接绑定
     */
    public void removeThreadConnection() {
        threadLocal.remove();
    }
}

(2).TransactionManager

@Component
public class TransactionManager {
    @Autowired
    private ConnectionUtils connectionUtils;

    /**
     * 开启事务
     */
    public void beginTransaction() {
        try {
            //开启了一个手动事务
            connectionUtils.getThreadConnection().setAutoCommit(false);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }


    /**
     * 提交事务
     */
    public void commit() {
        try {
            connectionUtils.getThreadConnection().commit();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }


    /**
     * 回滚事务
     */
    public void rollback() {
        try {
            connectionUtils.getThreadConnection().rollback();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }


    /**
     * 释放资源
     */
    public void release() {
        try {
            //将手动事务改成自动提交事务
            connectionUtils.getThreadConnection().setAutoCommit(true);
            //将连接归还到连接池
            connectionUtils.getThreadConnection().close();
            //解除线程绑定
            connectionUtils.removeThreadConnection();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

5.dao层
在项目目录“/src/main/java/com/steven”下新建dao目录，并在dao目录下新建IAccountDao接口和AccountDaoImpl实现类，具体代码如下。

public interface IAccountDao {
    //转出操作
    void out(String outUser, Double money);

    //转入操作
    void in(String inUser, Double money);
}

@Repository("accountDao")
public class AccountDaoImpl implements IAccountDao {
    @Autowired
    private QueryRunner queryRunner;

    @Autowired
    private ConnectionUtils connectionUtils;

    public void out(String outUser, Double money) {
        String sql = "update account set money = money - ? where name = ?";
        try {
            queryRunner.update(connectionUtils.getThreadConnection(), sql, money, outUser);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public void in(String inUser, Double money) {
        String sql = "update account set money = money + ? where name = ?";
        try {
            queryRunner.update(connectionUtils.getThreadConnection(), sql, money, inUser);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

6.service层
在项目目录“/src/main/java/com/steven”下新建service目录，并在service目录下新建IAccountService接口和AccountServiceImpl实现类，具体代码如下。

public interface IAccountService {
    void transfer(String outUser,String inUser,Double money);
}

@Service
public class AccountServiceImpl implements IAccountService {
    @Autowired
    private IAccountDao accountDao;

    @Autowired
    private TransactionManager transactionManager;

    public void transfer(String outUser, String inUser, Double money) {
        try {
            //1.开启事务
            transactionManager.beginTransaction();

            //2.业务操作
            accountDao.out(outUser, money);

            int i = 1 / 0;

            accountDao.in(inUser, money);

            //3.提交事务
            transactionManager.commit();
        } catch (Exception e) {
            e.printStackTrace();
            //4.回滚事务
            transactionManager.rollback();
        } finally {
            //5.释放资源
            transactionManager.release();
        }
    }
}

7.编写测试类
在项目目录“/src/main/java/com/steven”下新建Test类，具体代码如下。

public class Test {

    public static void main(String[] args) {
        ApplicationContext context = new ClassPathXmlApplicationContext("classpath:applicationContext.xml");
        IAccountService accountService = (IAccountService) context.getBean("accountServiceImpl");
        accountService.transfer("steven", "sherry", 100d);
    }
}

程序执行成功，查看数据库数据，steven和sherry的10000元数额未发生变化。
上面代码，虽然可以实现事务控制，但是业务层方法和事务控制方法耦合在一起，违背了面向对象的开发思想。
将业务代码和事务代码进行拆分，通过动态代理的方式，对业务方法进行事务的增强。这样
就不会对业务层产生影响，解决耦合性的问题。

8.工程目录
在这里插入图片描述

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

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

相关文章

循环程序设计 乘法口诀表

循环程序设计 乘法口诀表

凡是写循环程序 必须满足两个条件 一是存在相同的操作 二是有规律 对于乘法口诀表 我们都很熟悉 如下图是左下角的 探求一下 规律&#xff1a; 1 多个乘法 2 规律性 第一1行 1个乘法运算 1*1 第二2行 2个乘法运算 1*2 2*2 第三3行 3个乘法运算 1*3 2*3 3*3 第四4行 4个…
阅读更多...
关于Linux的基础总结

关于Linux的基础总结

关于Linux的基础总结 文章目录关于Linux的基础总结前言一、为什么Linux如此流行&#xff1f;1.原因2.Linux系统的版本二、Linux的基础命令1.目录结构2.文件命令1.ls2.pwd3.cd4.touch、mkdir5.cat、tail、head、tail、od、tee、more、less6.rm、cp、mv7.find、grep、xargs8.tar、…
阅读更多...
voc To yolov5-6.1数据集格式转换

voc To yolov5-6.1数据集格式转换

voc To yolov5-6.1数据集格式转换 已有的数据集操作第一步：划分训练集、验证集、测试集通过脚本文件（createImageSet.py）生成训练集和验证集本代码需要修改的地方：结果：第二步：vocToyolo1、Head_classes.json文件：Head_classes.json文件对应的代码：3、操作技巧：2、第二…
阅读更多...
用Python画一个足球

用Python画一个足球

文章目录前情提要先画六边形再画五边形前情提要 如果想优雅地绘制一个足球&#xff0c;那首先需要绘制正二十面体&#xff1a;用Python绘制正二十面体 其核心代码为 import numpy as np from itertools import product G (np.sqrt(5)-1)/2 def getVertex():pt2 [(a,b) fo…
阅读更多...
【Flask框架】——07 request请求和 get请求 post请求

【Flask框架】——07 request请求和 get请求 post请求

request参数 指定请求方式 在Flask中&#xff0c;可以定义路由默认的请求方式&#xff1a; 利用 methods 参数可以自己指定一个接口的请求方式 get方式&#xff1a;把请求参数放到为url的&#xff1f;后面&#xff0c;每个请求参数格式为&#xff1a;参数名参数值。参数之间…
阅读更多...
全梯度下降算法、随机梯度下降算法、小批量梯度下降算法、随机平均梯度下降算法、梯度下降算法总结

全梯度下降算法、随机梯度下降算法、小批量梯度下降算法、随机平均梯度下降算法、梯度下降算法总结

一、常见梯度下降算法 全梯度下降算法(Full gradient descent&#xff0c;FGD&#xff09;随机梯度下降算法&#xff08;Stochastic gradient descent&#xff0c;SGD&#xff09;随机平均梯度下降算法&#xff08;Stochastic average gradient descent&#xff0c;SAGD&#…
阅读更多...
12.9工作学习记录 课程统计 Echarts表格插件 Stream.map

12.9工作学习记录 课程统计 Echarts表格插件 Stream.map

课程统计接口要做的是 统计各个日期的用户观看人数 生成报表 sql就是根据日期分组 查出开始时间到结束时间这个区间范围内 每天有多少人观看 SELECT DATE(join_time) AS joinTime, COUNT(*) AS userCount FROM video_visitor <…
阅读更多...
基于ServiceStage的微服务开发与部署（二）

基于ServiceStage的微服务开发与部署（二）

目录 2.微服务开发与部署 2.1. 组织管理 2.2. 仓库授权 2.3. 微服务接入CSE 2.4. 基于源码构建软件包 2.5. 创建环境 2.6. 应用部署 2.7. 外网访问 2.微服务开发与部署 2.1. 组织管理 步骤 1 打开应用管理与运维平台控制台&#xff0c;在"软件中心"-"组织管理&q…
阅读更多...
【QT开发笔记-基础篇】| 第五章 绘图QPainter | 5.4 点、线

【QT开发笔记-基础篇】| 第五章 绘图QPainter | 5.4 点、线

本节对应的视频讲解&#xff1a;B_站_视_频 https://www.bilibili.com/video/BV1x14y1J7rn 完成了界面布局&#xff0c;以及添加了初始化数据&#xff0c;就可以开始真正绘制图形了 本节讲解如何绘制点、线 1. 基本点线的绘制 1.1 为 cboShape 关联信号槽 首先&#xff0c;…
阅读更多...
NR 多天线传输过程 2- Scrambling -1

NR 多天线传输过程 2- Scrambling -1

参考 《5G 无线系统设计与国际标准》 于威廉斯托林斯的《数据与计算机通信》 《south western university--Scrambling》 《Prof. Hitesh Dholakiya-- Scrambling》 前言 最近一次答辩&#xff0c;有同事问了LDPC 和 线性分组码有什么区别&#xff0c;当时只说出了应用场景…
阅读更多...
Presto（OpenLookeng）之BloomFilter索引优化代码走读

Presto（OpenLookeng）之BloomFilter索引优化代码走读

一. 前言 本文计划通过走读代码来理解Presto&#xff08;其实是OpenLookeng&#xff09;中BloomFilter索引的建立以及Presto中利用BloomFilter索引对查询进行优化的执行流程。OpenLookeng BloomFilter索引的基本资料可以参考官网介绍&#xff1a;openLooKeng documentation。 二…
阅读更多...
MacOS安装PyAudio

MacOS安装PyAudio

brew install portaudio pip install pyaudio docs&#xff1a;https://people.csail.mit.edu/hubert/pyaudio/docs/ pyaudio对象的open()方法&#xff1a; rate&#xff1a;取样频率channels&#xff1a;声道数format&#xff1a;取样值的量化格式 (paFloat32, paInt32, pa…
阅读更多...
Node.js Event Loop 的三大常见理解误区和正确概念辨析

Node.js Event Loop 的三大常见理解误区和正确概念辨析

Node.js Event loop 监控器。高的 frequency 和低的持续时间是最理想的 event loop 状态。 上图显示三点半到五点半之间&#xff0c;event loop 的 frequency 骤降&#xff0c;然后 duration 居高不下。 Node.js 是一个基于事件的平台。 这意味着在 Node 中发生的一切都是对…
阅读更多...
Windows无法读取驱动器中的光盘

Windows无法读取驱动器中的光盘

一. 问题 在网上搜索了很多方法来解决下图的问题&#xff0c;一直失败。浪费了很多时间。后来发现&#xff0c;网上的方案可能恰恰是相反的思路。所以&#xff0c;留下个笔记吧。 二. 方法 1.打开本地服务管理器。按键盘的”WinR"组合键 打开“运行”窗口。输入“Serv…
阅读更多...
汽车美容店会员管理系统开发步骤_分享会员系统小程序的优势

汽车美容店会员管理系统开发步骤_分享会员系统小程序的优势

洗车店/汽车维修保养带店如何打开线上市场&#xff0c;获得更多目标用户呢&#xff1f; 除了服务的内容足够专业、优质以外&#xff0c;引入会员系统小程序就是关键一步。 汽修店为什么要做会员系统小程序&#xff1f;来看看行业现状&#xff1a; 1.竞争激烈&#xff1a;到处都…
阅读更多...
Spring Boot与Web开发

Spring Boot与Web开发

Spring Boot与Web开发 SpringMVC快速使用 1.基于restful http接口 的CURD 2.调用rest http接口 通过RestTemplate调用 3.通过postman调用 通过MockMvc测试 4.通过swagger调用 添加依赖 添加swagger配置类 注意&#xff1a;访问的地址是&#xff1a;http://localhost:80…
阅读更多...
【Java基础篇】基础知识易错集锦

【Java基础篇】基础知识易错集锦

在学习的路上&#xff0c;我们只记得学习新的知识&#xff0c;却忽略了一切新知识都是在旧知识的基础上&#xff1b;努力奔跑的过程中&#xff0c;也要记得常回头看看&#xff1b; 题目展示&#xff1a; 解析&#xff1a; abstract是抽象的意思&#xff0c;在java中&#xff0…
阅读更多...
Python爬虫实战，requests+pyecharts模块，Python实现新冠疫情数据可视化（附源码）

Python爬虫实战，requests+pyecharts模块，Python实现新冠疫情数据可视化（附源码）

前言 今天给大家介绍的是Python爬取新冠疫情数据并实现数据可视化&#xff0c;在这里给需要的小伙伴们代码&#xff0c;并且给出一点小心得。 首先是爬取之前应该尽可能伪装成浏览器而不被识别出来是爬虫&#xff0c;基本的是加请求头&#xff0c;但是这样的纯文本数据爬取的…
阅读更多...
牛客网Mysql题目-SQL进阶篇 SQL 126-155

牛客网Mysql题目-SQL进阶篇 SQL 126-155

前言 这篇是进阶sql题目的记录&#xff0c;由于上一篇文章已经写将近一万字&#xff0c;有点长&#xff0c;就把剩下的再开一篇&#xff0c;免得总是重新发布 SQL126 平均活跃天数和月活人数 本题目要求统计&#xff0c;并且是多行&#xff0c;就需要使用group by查询 首先需…
阅读更多...
kafka可靠性保证

kafka可靠性保证

1、概念 创建Topic的时候可以指定--replication-factor 3 &#xff0c;表示分区的副本数&#xff0c;不要超过broker的数量。Leader是负责读写的节点&#xff0c;而其他副本则是Follower。Producer只把消息发送到Leader&#xff0c;Follower定期地到Leader上Pull数据。ISR是Le…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023