Spring学习笔记（五）：JDBCTemplate+事务管理

2020-09-27 536

1 概述

Spring为开发者提供了JDBCTemplate，可以简化很多数据库操作相关的代码，本文主要介绍JDBCTemplate的使用以及事务管理功能。

2 `JDBC Template`

2.1 配置

配置的话主要配置以下几项：

数据源：org.springframework.jdbc.datasource.DriverManager.DataSource
数据库驱动：com.cj.mysql.jdbc.Driver，这里采用的是MySQL 8，注意MySQL 5.7以下的驱动名字不同，另外若是其他数据库请对应修改
数据库URL：jdbc:mysql://localhost:3306/test，MySQL默认的3306端口，数据库test
数据库用户名
数据库密码
JDBC模板：org.springframework.jdbc.core.jdbcTemplate

参考配置如下：

<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
    <property name="url" value="jdbc:mysql://localhost:3306/test"/>
    <property name="username" value="test"/> 
    <property name="password" value="test"/>
</bean>
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    <property name="dataSource" ref="dataSource"/>
</bean>
<context:component-scan base-package="pers.dao"/>

2.2 常用方法

int update(String sql,Object args[])：增/删/改操作，使用args设置其中的参数，返回更新的行数
List<T> query(String sql,RowMapper<T> rowMapper,Object []args)：查询操作，rowMapper将结果集映射到用户自定义的类中

2.3 示例

2.3.1 依赖

首先导入依赖：

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-jdbc</artifactId>
    <version>5.2.9.RELEASE</version>
</dependency>

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.21</version>
</dependency>

MySQL的版本请根据个人需要更改，或使用其他数据库的驱动。

2.3.2 配置文件

完整配置文件如下：

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

    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/test"/>
        <property name="username" value="test"/>
        <property name="password" value="test"/>
    </bean>
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"/>
    </bean>
    <context:component-scan base-package="pers.dao"/>
</beans>

2.3.3 实体类

public class MyUser {
    private Integer id;
    private String uname;
    private String usex;
}

2.3.4 数据访问层

添加@Repository以及@RequiredArgsConstructor：

@Repository
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class TestDao {
    private final JdbcTemplate template;

    public int update(String sql,Object[] args)
    {
        return template.update(sql,args);
    }

    public List<MyUser> query(String sql, Object[] args)
    {
        RowMapper<MyUser> mapper = new BeanPropertyRowMapper<>(MyUser.class);
        return template.query(sql,mapper,args);
    }
}

因为直接使用@Autowired的话会提示不推荐：

所以利用了Lombok的注解@RequiredArgsConstructor，效果相当如下构造方法，只不过是简化了一点：

@Autowired
public TestDao(JdbcTemplate template)
{
    this.template = template;
}

2.3.5 测试

测试之前先建表：

create table MyUser(
    id INT AUTO_INCREMENT PRIMARY KEY ,
    uname varchar(20),
    usex varchar(20)
)

测试类：

public class Main {
    public static void main(String[] args) {
        ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
        TestDao dao = (TestDao)context.getBean("testDao");
        String insertSql = "insert into MyUser(uname,usex) values(?,?)";
        String[] param1 = {"chenhengfa1","男"};
        String[] param2 = {"chenhengfa2","男"};
        String[] param3 = {"chenhengfa3","男"};
        String[] param4 = {"chenhengfa4","男"};

        dao.update(insertSql,param1);
        dao.update(insertSql,param2);
        dao.update(insertSql,param3);
        dao.update(insertSql,param4);

        String selectSql = "select * from MyUser";
        List<MyUser> list = dao.query(selectSql,null);
        for(MyUser mu:list)
        {
            System.out.println(mu);
        }
    }
}

输出：

如果出现异常或插入不成功等其他情况，请检查SQL语句是否编写正确，包括表名以及字段名。

3 事务管理

Spring中的事务管理有两种方法：

编程式事务管理：代码中显式调用beginTransaction、commit、rollback等就是编程式事务管理
声明式事务管理：通过AOP实现，不需要通过编程方式管理事务，因此不需要再业务逻辑代码中掺杂事务处理的代码，开发更加简单，便于后期维护

下面先来看一下编程式事务管理的实现。

3.1 编程式事务管理

编程式事务管理的配置又有两种方法：

基于底层API
基于TransactionTemplate

需要的依赖如下：

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-tx</artifactId>
    <version>5.2.9.RELEASE</version>
</dependency>

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-expression</artifactId>
    <version>5.2.9.RELEASE</version>
</dependency>

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-aop</artifactId>
    <version>5.2.9.RELEASE</version>
</dependency>

<dependency>
    <groupId>org.aspectj</groupId>
    <artifactId>aspectjweaver</artifactId>
    <version>1.9.6</version>
    <scope>runtime</scope>
</dependency>

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-aspects</artifactId>
    <version>5.2.9.RELEASE</version>
</dependency>

3.1.1 底层`API`实现

根据PlatformTransactionManager、TransactionDefinition、TransactionStatus几个核心接口，通过编程方式进行事务管理，首先配置事务管理器：

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

接着修改数据库访问类：

@Repository
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class TestDao {
    private final JdbcTemplate template;
    private final DataSourceTransactionManager manager;

    public int update(String sql,Object[] args)
    {
        return template.update(sql,args);
    }

    public List<MyUser> query(String sql,Object[] args)
    {
        RowMapper<MyUser> mapper = new BeanPropertyRowMapper<>(MyUser.class);
        return template.query(sql,mapper,args);
    }

    public void testTransaction()
    {
        TransactionDefinition definition = new DefaultTransactionDefinition();
        TransactionStatus status = manager.getTransaction(definition);
        String message = "执行成功，没有事务回滚";

        try
        {
            String sql1 = "delete from MyUser";
            String sql2 = "insert into MyUser(id,uname,usex) values(?,?,?)";
            Object [] param2 = {1,"张三","男"};
            template.update(sql1);
            template.update(sql2,param2);
            template.update(sql2,param2);
            manager.commit(status);
        }
        catch (Exception e)
        {
            e.printStackTrace();
            manager.rollback(status);
            message = "主键重复，事务回滚";
        }
        System.out.println(message);
    }
}

3.1.1.1 事务定义

TransactionDefinition是事务定义，是一个接口：

主要定义了：

事务隔离级别
事务传播行为
事务超时时间
是否为只读事务

而DefaultTransactionDefinition就是上面属性的一些默认配置，比如：

也就是定义了：

传播行为为0：也就是常量PROPAGATION_REQUIREDE，表示如果当前存在一个事务，则加入当前事务，如果不存在任何事务，就创建一个新事务
隔离级别为-1：这个也是TransactionDefinition的默认参数，表示使用数据库的默认隔离级别，通常情况下为Read Committed
超时为-1：默认设置不超时，如需要设置超时请调用setTimeout方法，比如如果设置为了60，那么相当于如果操作时间超过了60s，而且后面还涉及到CRUD操作，那么会抛出超时异常并回滚，如果超时操作的后面没有涉及到CRUD操作，那么不会回滚
只读事务为false：默认为false，但是该变量不是表明“不能”进行修改等操作，而是一种暗示，如果不包含修改操作，那么JDBC驱动和数据库就有可能针对该事务进行一些特定的优化

3.1.1.2 具体执行流程

具体执行流程如下：

定义事务：实例类为DefaultTransactionDefinition
开启事务：通过getTransaction(TransactionDefinition)开启
执行业务方法
根据业务方法是否出现异常手动调用DataSourceTransaction的commit(TransactionStatus)进行提交
出现异常调用rollback(TransactionStatus)进行回滚

测试如下：

3.1.2 基于`TransactionTemplate`

步骤：

通过调用TransactionTemplate的execute实现
execute接受一个TransactionCallback接口参数
TransactionCallback定义了一个doInTransaction方法
通常以匿名内部类的方式实现TransactionCallback接口，在其中的doInTransaction编写业务逻辑代码
doInTransaction有一个TransactionStatus的参数，可以调用setRollbackOnly进行回滚

默认的回滚规则如下：

如果抛出未检查异常或者手动调用setRollbackOnly，则回滚
如果执行完成或抛出检查异常，则提交事务

示例如下，首先编写配置文件对Bean进行注入：

<!--事务管理器-->
<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
</bean>
<!--事务模板-->
<bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">
    <property name="transactionManager" ref="txManager"/>
</bean>

其次修改数据访问类，添加一个测试方法：

public void testTransactionTemplate()
{
    System.out.println(transactionTemplate.execute((TransactionCallback<Object>) transactionStatus -> {
        String deleteSql = "delete from MyUser";
        String insertSql = "insert into MyUser(id,uname,usex) values(?,?,?)";
        Object[] parm = {1, "张三", "男"};
        try {
            template.update(deleteSql);
            template.update(insertSql, parm);
            template.update(insertSql, parm);
        } catch (Exception e) {
            message = "主键重复，事务回滚";
            e.printStackTrace();
        }
        return message;
    }));
}

大部分代码与第一个例子类似就不解释了，结果也是因为主键重复出现异常，造成事务回滚：

3.2 声明式事务管理

Spring声明式事务管理通过AOP实现，本质是在方法前后进行拦截，在目标方法开始之前创建或加入一个事务，执行目标方法完成之后根据执行情况提交或回滚事务。相比起编程式事务管理，声明式最大的优点就是不需要通过编程的方式管理事务，业务逻辑代码无需混杂事务代码，但是唯一不足的地方就是最细粒度只能作用到方法上，而不能做到代码块级别。

实现方式有如下两种：

基于XML实现
基于@Transactional实现

3.2.1 基于`XML`

Spring提供了tx命令空间来配置事务：

<tx:advice>：配置事务通知，一般需要指定id以及transaction-manager
<tx:attributes>：配置多个<tx:method>指定执行事务的细节

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

    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/test"/>
        <property name="username" value="test"/>
        <property name="password" value="test"/>
    </bean>
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"/>
    </bean>
    <context:component-scan base-package="pers.dao"/>
    <!--事务管理器-->
    <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
    </bean>

    <bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">
        <property name="transactionManager" ref="txManager"/>
    </bean>

	<!--声明式事务-->
    <tx:advice id="myAdvice" transaction-manager="txManager">
        <tx:attributes>
        	<!--任意方法-->
            <tx:method name="*" />
        </tx:attributes>
    </tx:advice>
    <!--aop配置，具体可以看笔者之前的文章-->
    <aop:config>
    	<!--定义切点，执行testXMLTranscation()时进行增强-->
        <aop:pointcut id="txPointCut" expression="execution(* pers.dao.TestDao.testXMLTransaction())"/>
        <!--切面-->
        <aop:advisor advice-ref="myAdvice" pointcut-ref="txPointCut"/>
    </aop:config>
</beans>

3.2.1.2 测试

测试方法如下：

public void testXMLTransaction()
{
    String deleteSql = "delete from MyUser";
    String saveSql = "insert into MyUser(id,uname,usex) values(?,?,?)";
    Object [] parm = {1,"张三","男"};
    template.update(deleteSql);
    template.update(saveSql,parm);
    template.update(saveSql,parm);
}

运行结果：

可以看到提示主键重复了。

3.2.2 基于`@Transactional`

@Transactional一般作用于类上，使得该类所有public方法都具有该类型的事务属性。下面创建一个示例。

3.2.2.1 配置文件

将上一个例子中的<aop:config>以及<tx:advice>注释掉，同时添加：

<!--事务管理的注解驱动器-->
<tx:annotation-driven transaction-manager="txManager"/>

3.2.2.2 测试

测试方法与上一个例子一致，结果也是如此：

4 参考源码

Java版：

Kotlin版：

微信关注我们

原文链接：https://my.oschina.net/u/4231975/blog/4652281

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

Redis:05-应用：分布式锁

分布式应用进行逻辑处理时经常会遇到并发问题。比如一个操作要修改用户的状态，修改状态需要先读出用户的状态，在内存里进行修改，改完了再存回去。如果这样的操作同时进行了，就会出现并发问题，因为读取和保存状态这两个操作不是原子的。（Wiki 解释：所谓原子操作是指不会被线程调度机制打断的操作；这种操作一旦开始，就一直运行到结束，中间不会有任何 context switch 线程切换。）这个时候就要使用到分布式锁来限制程序的并发执行。Redis 分布式锁使用非常广泛，它是面试的重要考点之一。分布式锁分布式锁本质上要实现的目标就是在 Redis 里面占一个位置，当别的进程也要来占时，发现已经有人在那里了，就只好放弃或者稍后再试。占位置一般是使用 setnx(set if not exists) 指令，只允许被一个客户端占坑。先来先占，用完了，再调用 del 指令释放。 // 这里的冒号:就是一个普通的字符，没特别含义，它可以是任意其它字符，不要误解 > setnx lock:codehole true OK ... do something critical ... > d...

2020-09-27

516

鸿蒙内核源码注释中文版【 Gitee仓|CSDN仓|Github仓|Coding仓】给 HarmonyOS 源码逐行加上中文注解,详细阐述设计细节, 助你快速精读 HarmonyOS 内核源码, 掌握整个鸿蒙内核运行机制,四大码仓和wiki每日同步更新. 鸿蒙源码分析系列篇【 CSDN| OSCHINA| WIKI 】从 HarmonyOS 架构层视角整理成文, 并首创用生活场景讲故事的方式试图去解构内核，一窥究竟。本文分析虚拟内存模块源码详见:../kernel/base/vm 本篇源码超级多，很烧脑，但笔者关键处都加了注释。废话不多说，开始吧。目录初始化整个内存鸿蒙虚拟内存全景图内核空间是怎么初始化的？ Page是如何初始化的？进程是如何申请内存的？ task是如何申请内存的？初始化整个内存从main()跟踪可看内存部分初始化是在OsSysMemInit()中完成的。 UINT32 OsSysMemInit(VOID) { STATUS_T ret; OsKSpaceInit();//内核空间初始化 ret = OsKHeapInit(OS_KHE...

2020-09-27

676

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Spring学习笔记（五）：JDBCTemplate+事务管理

1 概述

2 `JDBC Template`

2.1 配置

2.2 常用方法

2.3 示例

2.3.1 依赖

2.3.2 配置文件

2.3.3 实体类

2.3.4 数据访问层

2.3.5 测试

3 事务管理

3.1 编程式事务管理

3.1.1 底层`API`实现

3.1.1.1 事务定义

3.1.1.2 具体执行流程

3.1.2 基于`TransactionTemplate`

3.2 声明式事务管理

3.2.1 基于`XML`

3.2.1.1 配置文件

3.2.1.2 测试

3.2.2 基于`@Transactional`

3.2.2.1 配置文件

3.2.2.2 测试

4 参考源码

Redis:05-应用：分布式锁

鸿蒙内核源码分析(内存管理篇) | 鸿蒙虚拟内存全景图是怎样的 | 给HarmonyOS源码逐行加上中文注释 | v10.03

相关文章

发表评论

资源下载

优质分享App

Mario

Nacos

Rocky Linux

欢迎您来访！

Spring学习笔记（五）：JDBCTemplate+事务管理

1 概述

2 JDBC Template

2.1 配置

2.2 常用方法

2.3 示例

2.3.1 依赖

2.3.2 配置文件

2.3.3 实体类

2.3.4 数据访问层

2.3.5 测试

3 事务管理

3.1 编程式事务管理

3.1.1 底层API实现

3.1.1.1 事务定义

3.1.1.2 具体执行流程

3.1.2 基于TransactionTemplate

3.2 声明式事务管理

3.2.1 基于XML

3.2.1.1 配置文件

3.2.1.2 测试

3.2.2 基于@Transactional

3.2.2.1 配置文件

3.2.2.2 测试

4 参考源码

Redis:05-应用：分布式锁

鸿蒙内核源码分析(内存管理篇) | 鸿蒙虚拟内存全景图是怎样的 | 给HarmonyOS源码逐行加上中文注释 | v10.03

相关文章

发表评论

资源下载

优质分享App

Mario

Nacos

Rocky Linux

欢迎您来访！

2 `JDBC Template`

3.1.1 底层`API`实现

3.1.2 基于`TransactionTemplate`

3.2.1 基于`XML`

3.2.2 基于`@Transactional`