百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 编程网 > 正文

JDBC规范七-JDBC事务 jdbc事务步骤

yuyutoo 2024-10-12 00:49 16 浏览 0 评论

事务用于提供数据完整性、正确的应用程序语义和并发访问的数据一致性。所有遵循JDBC规范的驱动程序都需要提供事务支持。

JDBC API中的事务管理符合SQL:2003规范,主要包含下面几个概念:

自动提交模式

事务隔离级别

保存点

本节只介绍单连接的事务,分布式事务不在本书讨论的范围内,读者可参考相关书籍。

1.事务边界与自动提交

何时开启一个新的事务是由JDBC驱动或数据库隐式决定的。虽然一些数据库实现了通过begin transaction语句显式地开始事务,但是JDBC API中没有对应的方法支持这样做。通常情况下,当SQL语句需要开启事务但是目前还没有事务时会开启一个新的事务。一个特定的SQL语句是否需要事务由SQL:2003规范指定。

Connection对象的autoCommit属性决定什么时候结束一个事务。启用自动提交后,会在每个SQL语句执行完毕后自动提交事务。当Connection对象创建时,默认情况下,事务自动提交是开启的。Connection接口中提供了一个setAutoCommit()方法,可以禁用事务自动提交。此时,需要显式地调用Connection接口提供commit()方法提交事务,或者调用rollback()方法回滚事务。禁用事务自动提交适用于需要将多个SQL语句作为一个事务提交或者事务由应用服务器管理。

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()方法判断是否支持某一事务隔离级别。

3.事务中的保存点

保存点通过在事务中标记一个中间的点来对事务进行更细粒度的控制,一旦设置保存点,事务就可以回滚到保存点,而不影响保存点之前的操作。DatabaseMetaData接口提供了supportsSavepoints()方法,用于判断JDBC驱动是否支持保存点。

Connection接口中提供了setSavepoint()方法用于在当前事务中设置保存点,如果setSavepoint()方法在事务外调用,则调用该方法后会在setSavepoint()方法调用处开启一个新的事务。setSavepoint()方法的返回值是一个Savepoint对象,该对象可作为Connection对象rollback()方法的参数,用于回滚到对应的保存点。下面是将事务回滚到保存点的一个案例,代码如下:

 @Test
public void testSavePoint() {
        try {
            Class.forName("org.hsqldb.jdbcDriver");
            // 获取Connection对象
            Connection conn = DriverManager.getConnection("jdbc:hsqldb:mem:mybatis",
                    "sa", "");
            String sql1 = "insert into user(create_time, name, password, phone, nick_name) " +
                    "values('2010-10-24 10:20:30','User1','test','18700001111','User1')";
            String sql2 = "insert into user(create_time, name, password, phone, nick_name) " +
                    "values('2010-10-24 10:20:30','User2','test','18700001111','User2')";
            conn.setAutoCommit(false);
            Statement stmt = conn.createStatement();
            stmt.executeUpdate(sql1);
            // 创建保存点
            Savepoint savepoint = conn.setSavepoint("SP1");
            stmt.executeUpdate(sql2);
            // 回滚到保存点
            conn.rollback(savepoint);
            conn.commit();
            ResultSet rs  = conn.createStatement().executeQuery("select * from user ");
            DbUtils.dumpRS(rs);
            IOUtils.closeQuietly(stmt);
            IOUtils.closeQuietly(conn);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

如上面的代码所示,我们向表中插入两条数据,在第一条数据插入后创建保存点,在第二条数据插入后回滚到保存点,然后提交事务。最终事务回滚到保存点位置,所以数据库中只存在一条记录。

保存点创建后,可以被手动释放。Connection对象中提供了一个releaseSavepoint()方法,接收一个Savepoint对象作为参数,用于释放当前事务中的保存点。该方法调用后,此保存点之后的保存点都会被释放。一旦保存点被释放,试图回滚到被释放的保存点时就将会抛出SQLException异常。

事务中创建的所有保存点在事务提交或完成回滚之后会自动释放,事务回滚到某一保存点后,该保存点之后创建的保存点会自动释放。

相关推荐

ETCD 故障恢复(etc常见故障)

概述Kubernetes集群外部ETCD节点故障,导致kube-apiserver无法启动。...

在Ubuntu 16.04 LTS服务器上安装FreeRADIUS和Daloradius的方法

FreeRADIUS为AAARadiusLinux下开源解决方案,DaloRadius为图形化web管理工具。...

如何排查服务器被黑客入侵的迹象(黑客 抓取服务器数据)

---排查服务器是否被黑客入侵需要系统性地检查多个关键点,以下是一份详细的排查指南,包含具体命令、工具和应对策略:---###**一、快速初步检查**####1.**检查异常登录记录**...

使用 Fail Ban 日志分析 SSH 攻击行为

通过分析`fail2ban`日志可以识别和应对SSH暴力破解等攻击行为。以下是详细的操作流程和关键分析方法:---###**一、Fail2ban日志位置**Fail2ban的日志路径因系统配置...

《5 个实用技巧,提升你的服务器安全性,避免被黑客盯上!》

服务器的安全性至关重要,特别是在如今网络攻击频繁的情况下。如果你的服务器存在漏洞,黑客可能会利用这些漏洞进行攻击,甚至窃取数据。今天我们就来聊聊5个实用技巧,帮助你提升服务器的安全性,让你的系统更...

聊聊Spring AI Alibaba的YuQueDocumentReader

序本文主要研究一下SpringAIAlibaba的YuQueDocumentReaderYuQueDocumentReader...

Mac Docker环境,利用Canal实现MySQL同步ES

Canal的使用使用docker环境安装mysql、canal、elasticsearch,基于binlog利用canal实现mysql的数据同步到elasticsearch中,并在springboo...

RustDesk:开源远程控制工具的技术架构与全场景部署实战

一、开源远程控制领域的革新者1.1行业痛点与解决方案...

长安汽车一代CS75Plus2020款安装高德地图7.5

不用破解原车机,一代CS75Plus2020款,安装车机版高德地图7.5,有红绿灯读秒!废话不多讲,安装步骤如下:一、在拨号状态输入:在电话拨号界面,输入:*#518200#*(进入安卓设置界面,...

Zookeeper使用详解之常见操作篇(zookeeper ui)

一、Zookeeper的数据结构对于ZooKeeper而言,其存储结构类似于文件系统,也是一个树形目录服务,并通过Key-Value键值对的形式进行数据存储。其中,Key由斜线间隔的路径元素构成。对...

zk源码—4.会话的实现原理一(会话层的基本功能是什么)

大纲1.创建会话...

Zookeeper 可观测性最佳实践(zookeeper能够确保)

Zookeeper介绍ZooKeeper是一个开源的分布式协调服务,用于管理和协调分布式系统中的节点。它提供了一种高效、可靠的方式来解决分布式系统中的常见问题,如数据同步、配置管理、命名服务和集群...

服务器密码错误被锁定怎么解决(服务器密码错几次锁)

#服务器密码错误被锁定解决方案当服务器因多次密码错误导致账户被锁定时,可以按照以下步骤进行排查和解决:##一、确认锁定状态###1.检查账户锁定状态(Linux)```bash#查看账户锁定...

zk基础—4.zk实现分布式功能(分布式zk的使用)

大纲1.zk实现数据发布订阅...

《死神魂魄觉醒》卡死问题终极解决方案:从原理到实战的深度解析

在《死神魂魄觉醒》的斩魄刀交锋中,游戏卡死犹如突现的虚圈屏障,阻断玩家与尸魂界的连接。本文将从技术架构、解决方案、预防策略三个维度,深度剖析卡死问题的成因与应对之策,助力玩家突破次元壁障,畅享灵魂共鸣...

取消回复欢迎 发表评论: