Java教程

Mysql事务开启方式(客户端+java手动+Spring Boot)

本文主要是介绍Mysql事务开启方式(客户端+java手动+Spring Boot),对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

一:概念

      作为单个逻辑单元执行一系列操作,要么完全执行,要么完全不执行。举例 我们需要向数据库插入3条数据(我们希望这三条数据要么全部插入成功,要么全部失败), 比如第一条数据插入成功,插入第二条数据失败(显然这已经不是一个完整的业务数据),那么第三条数据也无需执行。那么我们就可以用到事务了。

二:事务的特性和隔离级别

      为了避免在事务期间发生冲突,DBMS使用锁定机制来阻止其他人访问事务正在访问的数据。(请注意,在自动提交模式下,每个语句都是一个事务,只保留一个语句的锁定。)设置锁定后,它将一直有效,直到提交或回滚事务为止。例如,DBMS可以锁定表的一行,直到对其进行更新为止。此锁定的作用是防止用户获取脏读,即在永久化之前读取值。(访问尚未提交的更新值被视为脏读因为该值可以回滚到其先前的值。如果您读取稍后回滚的值,则会读取无效值。)

隔离级别 事务 脏读 不可重复读 幻读  描述
TRANSACTION_NONE 不支持 不适用 不适用 不适用  
TRANSACTION_SERIALIZABLE 支持 防止 防止 防止  
TRANSACTION_READ_COMMITTED 支持 防止 允许 允许 在同一个事务中查询,不能确保每次查询的数据相同,即可以查询到另一个事务更新后的数据(与repeatable_read形成鲜明对比)。
TRANSACTION_REPEATABLE_READ(默认) 支持 防止 防止 允许 在同一个事务中的查询,可以确保每次读取的数据相同。即使另一个事务提交了更新也读不到更新后的数据。
TRANSACTION_READ_UNCOMMITTED 支持 允许 允许 允许 在同一个事务中的查询,可以查询到另一个事务没有提交的数据

 

 

 

 

 

 

 

 

 

 

 

 

 

脏读   :   读取了另一个事务没有提交的数据,默认隔离级别,即防止了别人读取到我们没有提交(commit)的数据

重复读:对一个开启了事务连接,在第一次查询一行数据(此次另一个开启的事务更新了这一条数据),与第二次查询的数据不一样。即两次查询同一条数据不一样

幻读   :对一个开启了事务连接,第一次查询的数据行数(此次另一个开启的事务的连接新增了一条),与第二次查询的行数不一样(好像产生了幻觉)。即两次查询的数量不一样

备注:事务隔离级别

备注:因在官方文档中没有找到相关的名词解释(幻读,不可重复读),故在此废弃。

备注:个人理解脏读,幻读,重复读可以上我们看到数据的整个变化过程,而不是只注重结果,故我认为这并不算是一种bug。打个比方说我种了了一亩地的西瓜,在我准备第二天收获之前我先去数了一下共有200个大西瓜。等到第二天我去收获的时候我只收获了198个,还有两个去哪里了呢?我猜测可能是被那个口渴的路人偷吃了吧,我不会纠结这两个西瓜到哪里去了。当然这也要根据业务场景分析了,如果说你第一天数的200个西瓜并兴高采烈的告诉了你的老婆大人(多线程查询同一条数据),然而收获回去只有198个,那你就要和她解释了。如果她是个通情达理的人这就不是bug,如果不是你就把它认为bug吧。

备注1:客户端设置隔离级别

mysql>  SET TRANSACTION ISOLATION LEVEL SERIALIZABLE;
Query OK, 0 rows affected (0.00 sec)

备注2: Java设置隔离级别

Connection.getTransactionIsolation//获取当前隔离级别
Connection.setTransactionIsolation)//设置当前隔离级别

注意:一次事务只能设置一次隔离即便

mysql> START TRANSACTION;
Query OK, 0 rows affected (0.00 sec)

mysql> SET TRANSACTION ISOLATION LEVEL SERIALIZABLE;
ERROR 1568 (25001): Transaction characteristics can't be changed while a transaction is in progress

三:客户端操作方法

  备注:默认数据库事务是关闭的,即执行更新(修改)表的语句,MySQL就会将更新存储在磁盘上以使其永久化。无法回滚更改。

                  我们可以通过执行  SET autocommit=0; 命令设置事务开启状态,即每条更新语句都需要手动commit提交事务(只对当前session有效,即其他客户端更新操作是没有事务)

  • START TRANSACTION或 BEGIN开始新的交易。

  • COMMIT 提交当前事务,使其更改永久化。

  • ROLLBACK 回滚当前事务,取消其更改。

  • SET autocommit 禁用或启用当前会话的默认自动提交模式。

四:java手动控制

 即:手动控制事务的开启和关闭

public class RawTransactions {
    
    private final JdbcTemplate jdbcTemplate;

    public RawTransactions(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    } 
    public void book(String... persons) {
        //开启事务
        jdbcTemplate.execute("START TRANSACTION");
        for (String person : persons) {
            try {
                 jdbcTemplate.update("insert into BOOKINGS(FIRST_NAME) values (?)", person);
            } catch (RuntimeException e) {
                System.out.println("----发生异常数据回滚 -----");
                jdbcTemplate.execute("ROLLBACK");
                break;
            }  
        }
        //提交事务
        jdbcTemplate.execute("COMMIT");
    }
    public List<String> findAllBookings() {
        return jdbcTemplate.query("select FIRST_NAME from BOOKINGS",
                (rs, rowNum) -> rs.getString("FIRST_NAME"));
    }

}

项目地址:https://github.com/374003909/JdbcTransactions/blob/master/src/main/java/hello/RawTransactions.java

五:spring boot开启事务

即:在spring boot框架中通过注解@Transactional 实现

@Component
public class BookingService {

    private final static Logger logger = LoggerFactory.getLogger(BookingService.class);

    private final JdbcTemplate jdbcTemplate;

    public BookingService(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    @Transactional
    public void book(String... persons) {
        for (String person : persons) {
            logger.info("Booking " + person + " in a seat...");
            jdbcTemplate.update("insert into BOOKINGS(FIRST_NAME) values (?)", person);
        }
    }

    public List<String> findAllBookings() {
        return jdbcTemplate.query("select FIRST_NAME from BOOKINGS",
                (rs, rowNum) -> rs.getString("FIRST_NAME"));
    }

}
这篇关于Mysql事务开启方式(客户端+java手动+Spring Boot)的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!