登录
首页 >  数据库 >  MySQL

万字长文,带你从源码认识Spring事务原理,让Spring事务不再是面试噩梦

来源:SegmentFault

时间:2023-01-26 17:51:28 188浏览 收藏

来到golang学习网的大家,相信都是编程学习爱好者,希望在这里学习数据库相关编程知识。下面本篇文章就来带大家聊聊《万字长文,带你从源码认识Spring事务原理,让Spring事务不再是面试噩梦》,介绍一下MySQL、Redis、Java、springboot、后端,希望对大家的知识积累有所帮助,助力实战开发!

gif5新文件(1).gif

create table test.user(
id int auto_increment    
primary key,
name varchar(20) null, age int(3) null)
engine=InnoDB charset=utf8;

2.创建对应数据库表的 PO

public class JdbcUser {

    private Integer id;

    private String name;

    private Integer age;
    
    ...(使用 ctrl + N 进行代码补全 setter 和 getter)
}

3.创建表与实体间的映射

在使用

public class UserRowMapper implements RowMapper {


    @Override
    public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
        JdbcUser user = new JdbcUser();
        user.setId(rs.getInt("id"));
        user.setName(rs.getString("name"));
        user.setAge(rs.getInt("age"));
        return user;
    }
}

4.创建数据操作接口

public interface UserDao {

    /**
     * 插入
     * @param user    用户信息
     */
    void insertUser(JdbcUser user);

    /**
     * 根据 id 进行删除
     * @param id    主键
     */
    void deleteById(Integer id);

    /**
     * 查询
     * @return    全部
     */
    List selectAll();
}

5.创建数据操作接口实现类

跟书中例子不一样,没有在接口上加入事务注解,而是在公共方法上进行添加,可以在每个方法上自定义传播事件、隔离级别。

public class UserJdbcTemplate implements UserDao {

    private DataSource dataSource;

    private JdbcTemplate jdbcTemplate;


    @Override
    @Transactional(propagation = Propagation.REQUIRED)
    public void insertUser(JdbcUser user) {
        String sql = "insert into user (id, name, age) values (?, ?, ?)";
        jdbcTemplate.update(sql, user.getId(), user.getName(), user.getAge());
        System.out.println("Create record : " + user.toString());
    }

    @Override
    @Transactional
    public void deleteById(Integer id) {
        String sql = "delete from user where id = ?";
        jdbcTemplate.update(sql, id);
        System.out.println("Delete record, id = " + id);
        // 事务测试,抛出异常,让上面的插入操作回滚
        throw new RuntimeException("aa");
    }


    @Override
    public List selectAll() {
        String sql = "select * from user";
        List users = jdbcTemplate.query(sql, new UserRowMapper());
        return users;
    }



    public void setDataSource(DataSource dataSource) {
        // 使用 setter 注入参数时,同时初始化 jdbcTemplate
        this.dataSource = dataSource;
        this.jdbcTemplate = new JdbcTemplate(dataSource);
    }

}

6.创建配置文件

Spring编程式和声明式事务实例讲解

  • 在目标方法执行前获取事务并收集事务信息:
    createTransactionIfNecessary(tm, txAttr, joinpointIdentification)
  • 执行目标方法
    invocation.proceed()
  • 出现异常,尝试异常处理
    completeTransactionAfterThrowing(txInfo, ex);
  • 提交事务前的事务信息消除
    cleanupTransactionInfo(txInfo)
  • 提交事务
    commitTransactionAfterReturning(txInfo)
  • 事务回滚 & 提交

    这两步操作,主要调用了底层数据库连接的

    API
    ,所以没有细说。

    总结

    本篇文章简单记录了如何使用

    Spring
    的事务,以及在代码中如何实现。

    在之前的使用场景中,只用到了默认配置的声明式事务

    @Transactional
    ,不了解其它属性设置的含义,也不知道在默认配置下,如果是同一个类中的方法自调用是不支持事务。

    所以,经过这一次学习和总结,在下一次使用时,就能够知道不同属性设置能解决什么问题,例如修改广播特性

    PROPAGATION
    ,让事务支持方法自调用,还有设置事务超时时间
    timeout
    、隔离级别等属性。

    看到这儿了,说明你是个坚持努力的人,求个点赞关注分享,顺便关注下公众号,里面有4000G免费视频资源,等你来拿哦。

    gif5新文件(1).gif

    终于介绍完啦!小伙伴们,这篇关于《万字长文,带你从源码认识Spring事务原理,让Spring事务不再是面试噩梦》的介绍应该让你收获多多了吧!欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布数据库相关知识,快来关注吧!

    声明:本文转载于:SegmentFault 如有侵犯,请联系study_golang@163.com删除
    相关阅读
    更多>
    最新阅读
    更多>
    课程推荐
    更多>