- MyBatis 3源码深度解析
- 江荣波
- 1846字
- 2021-03-30 18:20:40
2.7 JDBC事务
事务用于提供数据完整性、正确的应用程序语义和并发访问的数据一致性。所有遵循JDBC规范的驱动程序都需要提供事务支持。
JDBC API中的事务管理符合SQL:2003规范,主要包含下面几个概念:
- 自动提交模式
- 事务隔离级别
- 保存点
本节只介绍单连接的事务,分布式事务不在本书讨论的范围内,读者可参考相关书籍。
2.7.1 事务边界与自动提交
何时开启一个新的事务是由JDBC驱动或数据库隐式决定的。虽然一些数据库实现了通过begin transaction语句显式地开始事务,但是JDBC API中没有对应的方法支持这样做。通常情况下,当SQL语句需要开启事务但是目前还没有事务时会开启一个新的事务。一个特定的SQL语句是否需要事务由SQL:2003规范指定。
Connection对象的autoCommit属性决定什么时候结束一个事务。启用自动提交后,会在每个SQL语句执行完毕后自动提交事务。当Connection对象创建时,默认情况下,事务自动提交是开启的。Connection接口中提供了一个setAutoCommit()方法,可以禁用事务自动提交。此时,需要显式地调用Connection接口提供commit()方法提交事务,或者调用rollback()方法回滚事务。禁用事务自动提交适用于需要将多个SQL语句作为一个事务提交或者事务由应用服务器管理。
2.7.2 事务隔离级别
事务隔离级别用于指定事务中对数据的操作对其他事务的“可见性”。不同的事务隔离级别能够解决并发访问数据带来的不同的并发问题,而且会直接影响并发访问效率。数据并发访问可能会出现以下几种问题:
- 脏读 这种情况发生在事务中允许读取未提交的数据。例如,A事务修改了一条数据,但是未提交修改,此时A事务对数据的修改对其他事务是可见的,B事务中能够读取A事务未提交的修改。一旦A事务回滚,B事务中读取的就是不正确的数据。
- 不可重复读 这种情况发生在如下场景:
(1)A事务中读取一行数据。
(2)B事务中修改了该行数据。
(3)A事务中再次读取该行数据将得到不同的结果。 - 幻读 这种情况发生在如下场景:
(1)A事务中通过WHERE条件读取若干行。
(2)B事务中插入了符合条件的若干条数据。
(3)A事务中通过相同的条件再次读取数据时将会读取到B事务中插入的数据。
JDBC遵循SQL:2003规范,定义了4种事务隔离级别,另外增加了一种TRANSACTION_NONE,表示不支持事务。这几种事务隔离级别如下。
- TRANSACTION_NONE:表示驱动不支持事务,这意味着它是不兼容JDBC规范的驱动程序。
- TRANSACTION_READ_UNCOMMITTED:允许事务读取未提交更改的数据,这意味着可能会出现脏读、不可重复读、幻读等现象。
- TRANSACTION_READ_COMMITTED:表示在事务中进行的任何数据更改,在提交之前对其他事务是不可见的。这样可以防止脏读,但是不能解决不可重复读和幻读的问题。
- TRANSACTION_REPEATABLE_READ:该事务隔离级别能够解决脏读和不可重复读问题,但是不能解决幻读问题。
- TRANSACTION_SERIALIZABLE:该事务隔离级别下,所有事务串行执行,能够有效解决脏读、不可重复读和幻读问题,但是并发效率较低。
Connection对象的默认事务级别由JDBC驱动程序指定。通常它是底层数据源支持的默认事务隔离级别。Connection接口中提供了一个setTransactionIsolation()方法,允许JDBC客户端设置Connection对象的事务隔离级别。新设置的事务隔离级别会在之后的会话中生效。在一个事务中调用setTransactionIsolation()方法是否对当前事务有效取决于具体的驱动实现。JDBC规范建议在调用setTransactionIsolation()方法后,下一个新的事务开始生效。另外,JDBC驱动可能不完全支持除TRANSACTION_NONE之外的4个事务级别。
调用Connection对象的setTransactionIsolation()方法时,如果参数是驱动不支持的事务隔离级别,则驱动程序应该使用更高的级别代替该参数指定的级别,如果驱动不支持更高的级别,就会抛出SQLException异常,可以调用DatabaseMetaData对象的supportsTransactionIsolationLevel()方法判断是否支持某一事务隔离级别。
2.7.3 事务中的保存点
保存点通过在事务中标记一个中间的点来对事务进行更细粒度的控制,一旦设置保存点,事务就可以回滚到保存点,而不影响保存点之前的操作。DatabaseMetaData接口提供了supportsSavepoints()方法,用于判断JDBC驱动是否支持保存点。
Connection接口中提供了setSavepoint()方法用于在当前事务中设置保存点,如果setSavepoint()方法在事务外调用,则调用该方法后会在setSavepoint()方法调用处开启一个新的事务。setSavepoint()方法的返回值是一个Savepoint对象,该对象可作为Connection对象rollback()方法的参数,用于回滚到对应的保存点。下面是将事务回滚到保存点的一个案例,代码如下:
如上面的代码所示,我们向表中插入两条数据,在第一条数据插入后创建保存点,在第二条数据插入后回滚到保存点,然后提交事务。最终事务回滚到保存点位置,所以数据库中只存在一条记录。完整代码,读者可参考随书源码mybatis-chapter02项目中的com.blog4java.jdbc.Example09案例。
保存点创建后,可以被手动释放。Connection对象中提供了一个releaseSavepoint()方法,接收一个Savepoint对象作为参数,用于释放当前事务中的保存点。该方法调用后,此保存点之后的保存点都会被释放。一旦保存点被释放,试图回滚到被释放的保存点时就将会抛出SQLException异常。
事务中创建的所有保存点在事务提交或完成回滚之后会自动释放,事务回滚到某一保存点后,该保存点之后创建的保存点会自动释放。