Spring事务JDBC方式下的事务使用示例

Posted 2020-12-29 写出高级BUG

摘要: 本文结合《Spring源码深度解析》来分析Spring 5.0.6版本的源代码。若有描述错误之处，欢迎指正。

 

目录

一、创建数据表结构

二、创建对应数据表的PO

三、创建表与实体间的映射

四、创建数据操作接口

五、创建数据操作接口实现类

六 、创建Spring配置文件

七、测试

 

Spring声明式事务让我们从复杂的事务处理中得到解脱，使我们再也不需要去处理获得连接、关闭连接、事务提交和回滚等操作，再也不需要在与事务相关的方法中处理大置的 try...catch...finally代码。Spring中事务的使用虽然已经相对简单得多，但是，还是有很多的使用及配置规则，有兴趣的读者可以自己查阅相关资料进行深入研究，这里只列举出最常用的使用方法。

同样，我们还是以最简单的示例来进行直观地介绍。

一、创建数据表结构

CREATE TABLE `user` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `username` varchar(20) DEFAULT NULL COMMENT ‘用户名‘,
  `password` varchar(50) DEFAULT NULL COMMENT ‘密码‘,
  `sex` tinyint(1) DEFAULT NULL COMMENT ‘用户性别, 1: 男; 2: 女‘,
  `age` int(2) DEFAULT NULL COMMENT ‘用户年龄‘,
  `status` int(1) DEFAULT NULL COMMENT ‘用户状态, 1: 有效; 0: 无效‘,
  `create_tm` timestamp NULL DEFAULT NULL COMMENT ‘创建时间‘,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=33 DEFAULT CHARSET=utf8;

二、创建对应数据表的PO

public class User {
 
    private Long id;

    private String username;

    private String password;

    private Integer sex;

    private Integer age;

    private Integer status;

    private Date createTm;
    
    // 省略set/get方法
}

三、创建表与实体间的映射

public interface UserMapper {

    int insert(User record);
    
    User selectByPrimaryKey(Long id);
}

四、创建数据操作接口

public interface UserService {

    boolean register(UserDTO userDTO);
}

五、创建数据操作接口实现类

@Service("userService")
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapper userMapper;

    @Override
    @Transactional(propagation = Propagation.REQUIRED)
    public boolean register(UserDTO userDTO) {
        if (!ObjectUtils.allNotNull(userDTO)) {
            return false;
        }

        User user = new User();
        try {
            BeanUtils.copyProperties(userDTO, user);
            user.setStatus(1);
            user.setCreateTm(new Date());
        }catch (BeansException e) {
            return false;
        }

        boolean ret = userMapper.insert(user) == 1;
        // 事务测试，加上这句代码则数据不会保存到数据库中
        throw new RuntimeException("insert error");

        return ret;
    }
}

六 、创建Spring配置文件

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

    <!-- 配置数据源 -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"
          lazy-init="true">
        <property name="driverClassName" value="${jdbc.driverClassName}"/>
        <property name="url" value="${jdbc.url}"/>
        <property name="username" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>

        <!-- 配置连接池初始化大小、最小、最大 -->
        <property name="initialSize" value="${jdbc.initialSize}"/>
        <property name="minIdle" value="${jdbc.minIdle}"/>
        <property name="maxActive" value="${jdbc.maxActive}"/>
        <!-- 配置获取连接等待超时的时间，单位是毫秒 -->
        <property name="maxWait" value="${jdbc.maxWait}"/>
        <!-- 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 -->
        <property name="timeBetweenEvictionRunsMillis" value="${jdbc.timeBetweenEvictionRunsMillis}"/>
        <!-- 配置一个连接在池中最小生存的时间，单位是毫秒 -->
        <property name="minEvictableIdleTimeMillis" value="${jdbc.minEvictableIdleTimeMillis}"/>
        <property name="validationQuery" value="select 1"/>
        <property name="testWhileIdle" value="${jdbc.testWhileIdle}"/>
        <property name="testOnBorrow" value="${jdbc.testOnBorrow}"/>
        <property name="testOnReturn" value="${jdbc.testOnReturn}"/>
        <!-- 打开PSCache，并且指定每个连接上PSCache的大小 -->
        <property name="poolPreparedStatements" value="${jdbc.poolPreparedStatements}"/>
        <property name="maxPoolPreparedStatementPerConnectionSize"
                  value="${jdbc.maxPoolPreparedStatementPerConnectionSize}"/>
        <!-- 统计sql filter -->
        <property name="proxyFilters">
            <list>
                <bean class="com.alibaba.druid.filter.stat.StatFilter">
                    <property name="mergeSql" value="true"/>
                    <property name="slowSqlMillis" value="${jdbc.slowSqlMillis}"/>
                    <property name="logSlowSql" value="true"/>
                </bean>
            </list>
        </property>
    </bean>

    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
    </bean>
    <tx:annotation-driven/>

</beans>

 七、测试

public static void main(String[] args) {
    ApplicationContext context = new ClassPathXmlApplicationContext("spring/application.xml");
    UserService userService = (UserService) context.getBean("userService");
    UserDTO userDTO = new UserDTO();
    userDTO.setUsername("张三");
    userDTO.setAge(20);
    userDTO.setSex(1);
    // 保存一条记录
     userService.register(userDTO);
}

上面的测试示例中，UserServicelmpl类对接口UserService中的register函数的实现最后加入了一句抛出异常的代码：throw new RuntimeException("insert error")。当注掉这段代码执行测试类，那 么会看到数据被成功的保存到了数据库中，但是如果加入这段代码时再次运行测试类，发现此处的操作并不会将数据保存到数据库中。

注意：默认情况下Spring中的事务处理只对RuntimeException方法进行回滚，所以，如果此处将RuntimeException替换成普通的Exception不会产生回滚效果。