首页 > 数据库 > MySQL

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

来源：SegmentFault

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

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

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

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

1
2
3
4
5
6
7
8
9
10
public class JdbcUser {

    private Integer id;

    private String name;

    private Integer age;

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

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

在使用
1
2
3
4
5
6
7
8
9
10
11
12
<strong>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;
    }
}</strong>

4.创建数据操作接口

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
public interface UserDao {

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

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

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

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

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
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<jdbcuser> selectAll() {
        String sql = "select * from user";
        List<jdbcuser> users = jdbcTemplate.query(sql, new UserRowMapper());
        return users;
    }

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

}</jdbcuser></jdbcuser>

6.创建配置文件

<strong><strong><!--?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"><!-- 数据源 MySQL --><bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"><property name="driverClassName" value="com.mysql.jdbc.Driver"></property><property name="url" value="jdbc:mysql://localhost:3306/test?characterEncoding=utf8"></property><property name="username" value="root"></property><property name="password" value="12345678"></property></bean><bean id="userJdbcTemplate" class="transaction.UserJdbcTemplate"><property name="dataSource" ref="dataSource"></property></bean><!-- 开启事务，如果将这行去掉，将不会创建事务  --><a target="_blank" href="https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXuytMyerpZ5o9rFrWaamarQqJy5ZZrEZGCqtWyKmJOmnaTJp5enmHqJ3Metht6JtpyvmdSGnMOfnKmxpqSkfGx7rsiWt66CiYDcsYhz0YXNx2qFupdkr5yFZLKjkWF9s6WhvrezbH2rhM-trX_Pkre1bYWqgpyxhoKfsqN9Y4mmhrG0t81tg3mM37Jmft6FlblqkeCKmrGDbXE">Spring编程式和声明式事务实例讲解</a>
 
<li>
<strong>在目标方法执行前获取事务并收集事务信</strong>息：<pre class="brush:go;">createTransactionIfNecessary(tm, txAttr, joinpointIdentification)</pre>
</li>
<li>
<strong>执行目标方法</strong>：<pre class="brush:go;">invocation.proceed()</pre>
</li>
<li>
<strong>出现异常，尝试异常处理</strong>：<pre class="brush:go;">completeTransactionAfterThrowing(txInfo, ex);</pre>
</li>
<li>
<strong>提交事务前的事务信息消除</strong>：<pre class="brush:go;">cleanupTransactionInfo(txInfo)</pre>
</li>
<li>
<strong>提交事务</strong>：<pre class="brush:go;">commitTransactionAfterReturning(txInfo)</pre>
</li>
<h3>事务回滚 & 提交</h3>
<p>这两步操作，主要调用了底层数据库连接的 </p><pre class="brush:go;">API</pre>，所以没有细说。</beans></strong><p></p>
<h2>总结</h2>
<p>本篇文章简单记录了如何使用 </p><pre class="brush:go;">Spring</pre> 的事务，以及在代码中如何实现。</strong><p></p>
<p><strong>在之前的使用场景中，只用到了默认配置的声明式事务</strong> <strong></strong></p><pre class="brush:go;"><strong>@Transactional</strong></pre><strong>，不了解其它属性设置的含义，也不知道在默认配置下，如果是同一个类中的方法自调用是不支持事务。</strong><p></p>
<p><strong>所以，经过这一次学习和总结，在下一次使用时，就能够知道不同属性设置能解决什么问题，例如修改广播特性</strong> <strong></strong></p><pre class="brush:go;"><strong>PROPAGATION</strong></pre><strong>，让事务支持方法自调用，还有设置事务超时时间</strong><strong><pre class="brush:go;">timeout</pre>、隔离级别等属性。</strong><p></p>
<blockquote><strong>看到这儿了，说明你是个坚持努力的人，求个点赞关注分享，顺便关注下公众号，里面有4000G免费视频资源，等你来拿哦。</strong></blockquote>
<p></p><center><img referrerpolicy="no-referrer" src="/uploads/20230126/167472720563d24f254b498.gif" alt="gif5新文件(1).gif" title="gif5新文件(1).gif" loading="lazy"></center><p></p>
<p></p><center><img referrerpolicy="no-referrer" src="/uploads/20230126/167472720563d24f2500528.jpg" alt="" title="" loading="lazy"></center><p></p><p>终于介绍完啦！小伙伴们，这篇关于《万字长文，带你从源码认识Spring事务原理，让Spring事务不再是面试噩梦》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布数据库相关知识，快来关注吧！</p><p></p><p></p><p></p><p></p><p></p><p></p>

mysql MySQL Redis Java springboot 后端

声明：本文转载于：SegmentFault 如有侵犯，请联系study_golang@163.com删除