温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

spring框架入门之什么是事务控制

发布时间:2021-10-28 15:36:50 来源:亿速云 阅读:119 作者:iii 栏目:编程语言

本篇内容主要讲解“spring框架入门之什么是事务控制”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“spring框架入门之什么是事务控制”吧!

1. 关于事务控制

事务是一系列的动作,它们综合在一起才是一个完整的工作单元,这些动作必须全部完成,如果有一个失败的话,那么事务就会回滚到最开始的状态,仿佛什么都没发生过一样。

1.1 spring中事务控制API

PlatformTransactionManager 接口提供事务操作的方法,包含三个具体的操作

public interface PlatformTransactionManager extends TransactionManager {
    // 获取事务状态信息
    TransactionStatus getTransaction(@Nullable TransactionDefinition var1) throws TransactionException;

    // 提交事务
    void commit(TransactionStatus var1) throws TransactionException;

    // 回滚事务
    void rollback(TransactionStatus var1) throws TransactionException;
}

开发中常用的实现类:

org.springframework.jdbc.datasource.DataSourceTransactionManager :使用Spring JDBC或iBatis进行持久化数据时使用

spring中事务控制接口的结构

spring框架入门之什么是事务控制

1.1.2 TransactionDefinition

事务的定义信息对象,包含如下方法:

获取事务对象名称:String getName()

获取事务隔离级别:int getIsolationLevel()

获取事务传播行为:int getPropagationBehavior()

获取事务超时时间:int getTimeout()

获取事务是否只读:boolean isReadOnly()

1.1.3 TransactionStatus

描述了某个时间点上事务对象的状态信息,包含6个具体的操作:

刷新事务:void flush()

获取是否存在储存点:boolean hasSavepoint()

获取事务是否完成:boolean isCompleted()

获取事务是否为新的事物:boolean isNewTransaction()

获取事务是否回滚:boolean isRollbackOnly()

设置事务回滚:void set RollbackOnly()

1.2 事务的隔离级别

事务的隔离界别反映事务提交并发访问时的处理态度

1.2.1 事务隔离的级别

ISOLATION_DEFAULT 默认级别,由 DBA 默认的设置来决定隔离级别,归属下列某一种

ISOLATION_READ_UNCOMMITTED 就是一个事务可以读取另一个未提交事务的数据。会出现脏读、不可重复读、幻读(隔离级别最低,但并发性高)

ISOLATION_READ_COMMITTED 就是一个事务要等另一个事务提交后才能读取数据,解决脏读问题。会出现不可重复读、幻读问题(锁定正在读取的行,适用于大多数系统,Oracle默认级别)

ISOLATION_REPEATABLE_READ 就是在开始读取数据(事务开启)时,不再允许修改操作,解决不可重复读问题。会出现幻读问题(锁定所读的所有行,MYSQL默认级别)

ISOLATION_SERALZABLE 是最高的事务隔离级别,在该级别下,事务串行化顺序执行,可以避免脏读、不可重复读与幻读。但是这种事务隔离级别效率低下,比较耗数据库性能,一般不使用。(锁整表)

事务隔离级别由上到下依次提升,隔离级别越高,越能保证数据的完整性和一致性。但对数据库性能的消耗依次增加,并发执行效率依次下降。

大多数的数据库默认隔离级别为 Read Commited,比如 SqlServer、Oracle

少数数据库默认隔离级别为:Repeatable Read 比如:MySQL InnoDB

1.2.2 数据库读取时会出现的三种问题

Dirty reads:读脏数据。

也就是说,比如事务A的未提交(还依然缓存)的数据被事务B读走,如果事务A失败回滚,会导致事务B所读取的的数据是错误的。

non-repeatable reads:数据不可重复读。

比如事务A中两处读取数据price的值。在第一读的时候,price是100,然后事务B就把price的值改成 200;事务A再读一次,结果就发现,price竟然就变成200了,造成事务A数据混乱。

phantom reads:幻象读数据。

这个和non-repeatable reads相似,也是同一个事务中多次读不一致的问题。但是 non-repeatable reads 的不一致是因为他所要取的数据值被改变了(比如price)而 phantom reads 所要读的数据的不一致却是他的条件数据集发生变化了。

比如:执行 Select account.id where account.name="Bruce*",第一次读去了6个符合条件的id;第二次读取的时候,由于事务B把一个帐号的名字由"dd"改成"Bruce1",结果取出来了7个数据。

不可重复读的重点是修改:同样的条件,两次读发现值不一样;

幻读的重点在于新增或者删除:同样的条件,两次读发现得到的记录数不一样

1.2.3 数据隔离级别和出现的问题之间的关联


Dirty readsnon-repeatable readsphantom reads
READ_UNCOMMITTEDYYY
READ_COMMITTEDNYY
REPEATABLE_READNNY
SERALZABLENNN
1.3 事务的传播行为
  • REQUIRED:如果当前没有事务,就新建一个事务,如果已经存在一个事务中,加入到这个事务中。一般的选 择(默认值)

  • SUPPORTS:支持当前事务,如果当前没有事务,就以非事务方式执行(没有事务)

  • MANDATORY:使用当前的事务,如果当前没有事务,就抛出异常。

  • REQUERS_NEW:新建事务,如果当前在事务中,把当前事务挂起。

  • NOT_SUPPORTED:以非事务方式执行操作,如果当前存在事务,就把当前事务挂起。

  • NEVER:以非事务方式运行,如果当前存在事务,抛出异常。

  • NESTED:如果当前存在事务,则在嵌套事务内执行。如果当前没有事务,则执行REQUIRED类似的操作。

1.4 超时时间

指事务提交后最长可以等待的时间,超出时间则会自动失败。默认值是-1,没有时间限制。如果有,则以秒为单位进行设置。

1.5 是否为只读事务

读写型事务:增加、删除、修改时开启事务

只读型事务:执行查询时,也会开启事务

2. 基于xml的事务控制配置

2.1 配置步骤
  1. 配置事务管理器

  2. 配置事务的通知

    此时我们需要导入事务的约束 tx名称空间和约束,同时也需要aop的使用 <tx:advice> 标签配置事务通知

    • id:给事务通知起一个唯一标识

    • transaction-manager:给事务通知提供一个事务管理器引用

  3. 配置AOP中的通用切入点表达式

  4. 建立事务通知和切入点表达式的对应关系

  5. 配置事务的属性是在事务的通知 <tx:advice> 标签的内部

2.2 配置事务的属性
  • isolation:用于指定事务的隔离级别。默认值是 DEFAULT,表示使用数据库的默认隔离级别。

  • propagation:用于指定事务的传播行为。默认值是 REQUIRED,表示一定会有事务,增删改的选择。查询方法可以选择 SUPPORTS

  • read-only:用于指定事务是否只读。只有查询方法才能设置为 true。默认值是false,表示读写。

  • timeout:用于指定事务的超时时间,默认值是-1,表示永不超时。如果指定了数值,以秒为单位。

  • rollback-for:用于指定一个异常,当产生该异常时,事务回滚,产生其他异常时,事务不回滚。没有默认值。表示任何异常都回滚。

  • no-rollback-for:用于指定一个异常,当产生该异常时,事务不回滚,产生其他异常时事务回滚。没有默认值。表示任何异常都回滚。

代码示例:

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

    <!-- 配置数据源 -->
    <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/base_crud"></property>
        <property name="username" value="root"></property>
        <property name="password" value="123456"></property>
    </bean>

    <!-- 1.配置事务管理器 -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"></property>
    </bean>

    <!-- 2.配置事务通知 -->
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <tx:attributes>
            <tx:method name="*" propagation="REQUIRED" read-only="false"></tx:method>
            <tx:method name="get*" propagation="SUPPORTS" read-only="true"></tx:method>
        </tx:attributes>
    </tx:advice>

    <!-- 3.配置AOP -->
    <aop:config>
        <aop:pointcut id="pointcut" expression="execution(* cn.bruce.service.impl.*.*(..))"/>
	<!-- 4.建立事务通知和切入点表达式的对应关系 -->
        <aop:advisor advice-ref="txAdvice" pointcut-ref="pointcut"></aop:advisor>
    </aop:config>

    <!-- 配置dao -->
    <bean id="accountDao" class="cn.bruce.dao.impl.AccountDaoImpl">
        <property name="dataSource" ref="dataSource"></property>
    </bean>

    <!-- 配置service -->
    <bean id="accountService" class="cn.bruce.service.impl.AccountServiceImpl">
        <property name="accountDao" ref="accountDao"></property>
    </bean>

</beans>

3. 基于注解的事务控制配置

3.1 配置步骤

① 书写配置类

② 将对象注入到IoC容器中管理

③ 给业务添加事务注释,并指明事务属性

代码示例:

① 配置spring

@Configuration// 声明为配置类
@ComponentScan("cn.bruce")// 声明需要扫描的包
@Import({JdbcConfig.class, TransactionConfig.class})// 导入其他配置类
@PropertySource("jdbcConfig.properties")// 导入配置文件
@EnableAspectJAutoProxy(proxyTargetClass = true)// 开启注解支持
@EnableTransactionManagement// 开启事务控制
public class SpringConfiguration {
}

② 配置jdbc

public class JdbcConfig {

    @Value("${jdbc.driver}")
    private String driver;

    @Value("${jdbc.url}")
    private String url;

    @Value("${jdbc.username}")
    private String username;

    @Value("${jdbc.password}")
    private String password;

    /**
     * 创建数据源对象
     * @return
     */
    @Bean("dataSource")
    public DataSource creatDataSource() {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName(driver);
        dataSource.setUrl(url);
        dataSource.setUsername(username);
        dataSource.setPassword(password);
        return dataSource;
    }

    /**
     * 创建JdbcTemplate
     * @param dataSource
     * @return
     */
    @Bean(name = "jdbcTemplate")
    public JdbcTemplate creatJdbcTemplate(DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }
}

③ 配置事务控制器

public class TransactionConfig {

    /**
     * 用于创建事务管理器对象
     * @param dataSource
     * @return
     */
    @Bean(name = "transactionManager")
    public PlatformTransactionManager creatTransactionManager(DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }
}

④ 通过 [@Repository](https://my.oschina.net/u/3055569)[@service](https://my.oschina.net/service) 注解将Dao和Service层对象注入IoC容器

⑤ 在业务层使用 [@Transactional](https://my.oschina.net/u/3770144) 注解进行事务配置

// 进行读写型事务配置
@Transactional(propagation = Propagation.REQUIRED, readOnly = false)
@Override
public void transfer(String sourceName, String targetName, Float money) {

    System.out.println("开始进行转账操作。。。");

    Account source = accountDao.getAccountByName(sourceName);

    Account target = accountDao.getAccountByName(targetName);

    source.setMoney(source.getMoney() - money);

    target.setMoney(target.getMoney() + money);

    accountDao.updateAccount(source);

    int i = 1/0;

    accountDao.updateAccount(target);

    System.out.println("转账完成。。。");
}

⑥ 书写测试类进行测试

3.2 涉及到的注解

[@Transactional](https://my.oschina.net/u/3770144) 此注解相当于xml配置中的 <tx:attributes>****</tx:attributes> 用于进行事务的配置,其属性含义和xml中是一致的

此注解可是使用在接口、类和方法上:

  • 出现在接口上,表示此接口所有的实现类都有事务支持

  • 出现在类上,表示类所有的方法都有事务支持

  • 出现在方法上,表示此方法有事务支持

  • 以上三个位置的优先级:方法 > 类 > 接口

到此,相信大家对“spring框架入门之什么是事务控制”有了更深的了解,不妨来实际操作一番吧!这里是亿速云网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI