分布式事务之数据库事务与JDBC事务实现(一)

简介: 分布式事务之数据库事务与JDBC事务实现

著作权归作者所有,任何形式的转载都请联系作者获得授权并注明出处。

介绍事务的四大原则,并通过实例介绍数据库实现事务的方法,以及使用JDBC实现事务的方法。

微服务系统最大的挑战:

  • 数据的并发访问、修改;
  • 不同请求之间的数据隔离,一个业务请求修改多个数据,保证都完成或失败;
  • 发生异常时的数据回滚。

事务是以一种可靠、一致的方式,访问和操作数据库中的数据的程序单元。

16522e70215594b0_tplv-t2oaga2asx-zoom-in-crop-mark_4536_0_0_0.png

以sql的方式演示数据库事务:

BEGIN TRANSACTION; --开启事务
UPDATE t_user SET amount = amount-100 WHERE username='BatMan';
UPDATE t_user SET amount = amount+100 WHERE username='SuperMan';
COMMIT; --提交事务
ROLLBACK; --回滚事务

16522e73f56dab5f_tplv-t2oaga2asx-zoom-in-crop-mark_4536_0_0_0.png

  • ResourceManager:为事务管理器
  • JDBC Driver:事务的具体实现,使用不同的驱动包则代表不同的事务实现方式。
  • DB Connection:数据库连接
  • Resource:资源(这里指数据库)

以java 程序为例子介绍JDBC事务管理

Connection conn = getConnection();  // 创建数据库连接
conn.setAutoCommit(false);        // 设置不自动提交
Statement stmt1 = conn.prepareStatement(updateUser1Sql);
stmt1.executeUpdate();
Statement stmt2 = conn.prepareStatement(updateUser2Sql);
stmt2.executeUpdate();
conn.commit(); // or conn.rollback();  提交事务或回滚事务

这里演示一个事务的例子: 以转帐为例,SuperMan给BatMan转账100元,则SuperMan账户-100,BatMan账户+100。

第一段sql

-- 查看全局事务隔离级别,Session事务隔离级别
SELECT @@GLOBAL.tx_isolation, @@SESSION.tx_isolation;  
BEGIN TRANSACTION; --开启事务
UPDATE t_user SET amount = amount-100 WHERE username='BatMan';
UPDATE t_user SET amount = amount+100 WHERE username='SuperMan';
COMMIT; --提交事务

第二段sql

-- 设置事务隔离级别(不commit也可以读取最新内容,类似于脏读)
1: SET SESSION TRANSACTION ISOLATION LEVEL READ UNCOMMITTED; 
2: BEGIN TRANSACTION; --开启事务
3: SELECT * FROM t_user;
4: SELECT * FROM t_user WHERE username='BatMan';
5: COMMIT; --提交事务
  • 以navicat for mysql 工具为例,开启一个查询,执行第一段sql ,但最后一行COMMIT还未执行。这时再开一个查询窗口执行第二段sql,但第2行sql先不执行,从第3行开始执行,此时可以看到结果还是和最初的数据一致,没有增加也没有减少,这就是事务的隔离性:一个事务的执行过程中不能影响到其他事务的执行,即一个事务内部的操作及使用的数据对其他事务是隔离的,并发执行各个事务之间无不干扰。
  • 此时全部执行第二段sql,因为设置了事务的隔离级别,所以此时可以看到数据有加有减少,虽然第一段sql没有执行COMMIT操作。但任然看到了修改后的数据。

为了解决类似这种数据脏读问题可以在SELECT 语句后加 FOR UPDATEFOR UPDATE 是一个排它锁,也就是说,其他的事务是可以读取的。但是不能写入或者更新。效果等同于mysql事务级别中的Serializable。  mysql 默认的事务处理级别是REPEATABLE-READ,也就是可重复读。



目录
相关文章
|
3月前
|
存储 监控 分布式数据库
ClickHouse分布式数据库动态伸缩(弹性扩缩容)的实现
实现ClickHouse数据库的动态伸缩需要持续的维护和精细的操作。从集群配置到数据迁移,再到监控和自动化,每一步都要仔细管理以确保服务的可靠性和性能。这些活动可以显著提高应用的响应性和成本效率,帮助业务根据实际需求灵活调整资源分配。
228 10
|
4月前
|
存储 关系型数据库 分布式数据库
【赵渝强老师】基于PostgreSQL的分布式数据库:Citus
Citus 是基于 PostgreSQL 的开源分布式数据库,采用 shared nothing 架构,具备良好的扩展性。它以插件形式集成,部署简单,适用于处理大规模数据和高并发场景。本文介绍了 Citus 的基础概念、安装配置步骤及其在单机环境下的集群搭建方法。
345 2
|
4月前
|
中间件 关系型数据库 Go
Go语言数据库编程:数据迁移与事务控制
本文介绍了《Go语言实战指南》中关于数据库编程的核心内容,涵盖使用 GORM 进行数据迁移与事务控制。主要内容包括:AutoMigrate 方法自动创建或更新表结构;事务控制的自动与手动实现方式;事务隔离级别的设置;以及在 Gin 框架中统一管理事务的实践建议。适合开发阶段的数据库结构管理和事务性操作需求。
|
6月前
|
SQL 存储 分布式数据库
分布式存储数据恢复—hbase和hive数据库数据恢复案例
分布式存储数据恢复环境: 16台某品牌R730xd服务器节点,每台服务器节点上有数台虚拟机。 虚拟机上部署Hbase和Hive数据库。 分布式存储故障: 数据库底层文件被误删除,数据库不能使用。要求恢复hbase和hive数据库。
225 12
|
8月前
|
SQL 数据建模 BI
【YashanDB 知识库】用 yasldr 配置 Bulkload 模式作单线程迁移 300G 的业务数据到分布式数据库,迁移任务频繁出错
问题描述 详细版本:YashanDB Server Enterprise Edition Release 23.2.4.100 x86_64 6db1237 影响范围: 离线数据迁移场景,影响业务数据入库。 外场将部分 NewCIS 的报表业务放到分布式数据库,验证 SQL 性能水平。 操作系统环境配置: 125G 内存 32C CPU 2T 的 HDD 磁盘 问题出现的步骤/操作: 1、部署崖山分布式数据库 1mm 1cn 3dn 单线启动 yasldr 数据迁移任务,设置 32 线程的 bulk load 模式 2、观察 yasldr.log 是否出现如下错
|
8月前
|
SQL 运维 关系型数据库
体验用分布式数据库突破资源瓶颈,完成任务领智能台灯!
体验用分布式数据库突破资源瓶颈,完成任务领智能台灯!
|
7月前
|
SQL Java 数据库连接
【YashanDB数据库】由于网络带宽不足导致的jdbc向yashandb插入数据慢
由于网络带宽不足导致的jdbc向yashandb插入数据慢
|
7月前
|
SQL 数据库 索引
【YashanDB数据库】大事务回滚导致其他操作无法执行,报错YAS-02016 no free undo blocks
大事务回滚导致其他操作无法执行,报错YAS-02016 no free undo blocks
|
9月前
|
容灾 关系型数据库 分布式数据库
PolarDB分布式版:与云融合的分布式数据库发展新阶段
PolarDB分布式版标志着分布式数据库与云融合的新阶段。它经历了三个发展阶段:从简单的分布式中间件,到一体化分布式架构,再到云原生分布式数据库。PolarDB充分利用云资源的弹性、高性价比、高可用性和隔离能力,解决了大规模数据扩展性问题,并支持多租户场景和复杂事务处理。零售中台的建设背景包括国家数字化转型战略及解决信息孤岛问题,采用分布式数据库提升高可用性和性能,满足海量订单处理需求。展望未来,零售中台将重点提升容灾能力、优化资源利用并引入AI技术,以实现更智能的服务和更高的业务连续性。
299 9

热门文章

最新文章