PostgreSQL - 事务的提交、回滚与保存点操作

Ne0inhk

— 14 min read
PostgreSQL - 事务的提交、回滚与保存点操作
在这里插入图片描述
👋 大家好，欢迎来到我的技术博客！
📚 在这里，我会分享学习笔记、实战经验与技术思考，力求用简单的方式讲清楚复杂的问题。
🎯 本文将围绕PostgreSQL这个话题展开，希望能为你带来一些启发或实用的参考。
🌱 无论你是刚入门的新手，还是正在进阶的开发者，希望你都能有所收获！

文章目录

PostgreSQL - 事务的提交、回滚与保存点操作

在现代数据库系统中，事务（Transaction） 是确保数据一致性和完整性的核心机制。PostgreSQL 作为一款功能强大、开源且高度可靠的对象关系型数据库管理系统（ORDBMS），对事务的支持尤为完善。本文将深入探讨 PostgreSQL 中事务的三大关键操作：提交（COMMIT）、回滚（ROLLBACK） 和 保存点（SAVEPOINT），并通过 Java 代码示例、原理剖析和实际应用场景，帮助开发者全面掌握事务控制的艺术。

什么是数据库事务？

在深入技术细节之前，我们先明确“事务”的定义。根据经典的 ACID 原则，一个事务必须具备以下四个特性：

  • 原子性（Atomicity）：事务中的所有操作要么全部成功，要么全部失败。不存在“部分完成”的状态。
  • 一致性（Consistency）：事务执行前后，数据库必须从一个一致状态转移到另一个一致状态。
  • 隔离性（Isolation）：多个并发事务之间互不干扰，每个事务都像是在独立环境中运行。
  • 持久性（Durability）：一旦事务提交，其结果将永久保存，即使系统崩溃也不会丢失。
💡 小知识：PostgreSQL 默认使用 READ COMMITTED 隔离级别，但支持从 READ UNCOMMITTED（实际等同于 READ COMMITTED）到 SERIALIZABLE 的完整隔离级别谱系。

在 PostgreSQL 中，事务通过 BEGIN（或 START TRANSACTION）显式开启，通过 COMMIT 提交更改，或通过 ROLLBACK 撤销所有操作。此外，PostgreSQL 还支持 保存点（SAVEPOINT），允许在事务内部设置“检查点”，实现更细粒度的回滚控制。

PostgreSQL 事务的基本语法

1. 开启事务

BEGIN;-- 或STARTTRANSACTION;
📌 注意：在 PostgreSQL 中，即使不显式使用 BEGIN，每条单独的 SQL 语句也会被自动包装在一个事务中（即“自动提交”模式）。但当我们需要多条语句作为一个整体执行时，就必须显式开启事务。

2. 提交事务（COMMIT）

COMMIT;

执行 COMMIT 后，事务中所有更改将被永久写入数据库，并释放所有锁。

3. 回滚事务（ROLLBACK）

ROLLBACK;

执行 ROLLBACK 后，事务中所有未提交的更改将被丢弃，数据库恢复到事务开始前的状态。

4. 保存点（SAVEPOINT）

SAVEPOINT my_savepoint;-- ... 执行一些操作 ...ROLLBACKTOSAVEPOINT my_savepoint;-- 回滚到保存点RELEASESAVEPOINT my_savepoint;-- 释放保存点（可选）

保存点允许我们在一个大事务中设置多个“回滚锚点”，从而避免因局部错误导致整个事务失败。

事务生命周期图解

为了更直观地理解事务的流程，我们使用 Mermaid 绘制一个典型的事务生命周期图：

BEGIN / START TRANSACTION

COMMIT

ROLLBACK

SAVEPOINT sp1

RELEASE SAVEPOINT sp1

ROLLBACK TO SAVEPOINT sp1

COMMIT

ROLLBACK

Idle

TransactionActive

Committed

RolledBack

SavepointSet

从图中可以看出，事务从空闲状态开始，通过 BEGIN 进入活跃状态。在此期间，可以设置多个保存点。最终，事务要么通过 COMMIT 成功结束，要么通过 ROLLBACK 完全撤销。保存点的存在使得回滚可以是局部的，而非全有或全无。

Java 中如何操作 PostgreSQL 事务？

在 Java 应用中，我们通常通过 JDBC（Java Database Connectivity）与 PostgreSQL 交互。JDBC 提供了对事务的精细控制能力。

准备工作

首先，确保你的项目中包含 PostgreSQL 的 JDBC 驱动依赖。以 Maven 为例：

<dependency><groupId>org.postgresql</groupId><artifactId>postgresql</artifactId><version>42.7.3</version></dependency>
🔗 你可以从 PostgreSQL JDBC 官方页面 获取最新驱动信息。

关闭自动提交模式

默认情况下，JDBC 处于 自动提交（auto-commit） 模式，即每条 SQL 语句都会立即提交。要手动控制事务，必须先关闭自动提交：

Connection conn =DriverManager.getConnection(url, user, password); conn.setAutoCommit(false);// 关闭自动提交

基本事务操作示例

假设我们有一个银行转账场景：从账户 A 转账 100 元到账户 B。

publicvoidtransferMoney(String fromAccount,String toAccount,double amount){String url ="jdbc:postgresql://localhost:5432/mydb";String user ="postgres";String password ="your_password";try(Connection conn =DriverManager.getConnection(url, user, password)){// 关闭自动提交 conn.setAutoCommit(false);try{// 扣款String debitSql ="UPDATE accounts SET balance = balance - ? WHERE account_id = ?";try(PreparedStatement ps1 = conn.prepareStatement(debitSql)){ ps1.setDouble(1, amount); ps1.setString(2, fromAccount);int rowsAffected1 = ps1.executeUpdate();if(rowsAffected1 ==0){thrownewSQLException("Account "+ fromAccount +" not found or insufficient funds.");}}// 入账String creditSql ="UPDATE accounts SET balance = balance + ? WHERE account_id = ?";try(PreparedStatement ps2 = conn.prepareStatement(creditSql)){ ps2.setDouble(1, amount); ps2.setString(2, toAccount);int rowsAffected2 = ps2.executeUpdate();if(rowsAffected2 ==0){thrownewSQLException("Account "+ toAccount +" not found.");}}// 提交事务 conn.commit();System.out.println("Transfer successful!");}catch(SQLException e){// 发生异常，回滚整个事务 conn.rollback();System.err.println("Transaction failed, rolled back: "+ e.getMessage());throw e;}}catch(SQLException e){ e.printStackTrace();}}

在这个例子中：

  • 如果扣款成功但入账失败（例如目标账户不存在），rollback() 会确保 A 账户的资金不会被扣除。
  • 只有当两条 UPDATE 都成功执行后，才会调用 commit()，保证原子性。
⚠️ 重要提示：务必在 finally 块或 try-with-resources 中恢复 autoCommit 状态（如果后续代码依赖它），但上述代码使用 try-with-resources 自动关闭连接，因此无需显式恢复。

保存点（SAVEPOINT）的 Java 实现

保存点在处理复杂业务逻辑时非常有用。例如，在一个订单创建过程中，可能需要先插入订单头，再插入多个订单项。如果某个订单项插入失败，我们可能只想回滚该项，而不是整个订单。

场景：批量插入订单项

publicvoidcreateOrderWithItems(String orderId,List<OrderItem> items){String url ="jdbc:postgresql://localhost:5432/mydb";String user ="postgres";String password ="your_password";try(Connection conn =DriverManager.getConnection(url, user, password)){ conn.setAutoCommit(false);try{// 插入订单头String insertOrderSql ="INSERT INTO orders (order_id, customer_id, total) VALUES (?, ?, ?)";try(PreparedStatement ps = conn.prepareStatement(insertOrderSql)){ ps.setString(1, orderId); ps.setString(2,"CUST123"); ps.setDouble(3,calculateTotal(items)); ps.executeUpdate();}// 为每个订单项设置保存点for(OrderItem item : items){Savepoint savepoint = conn.setSavepoint("item_"+ item.getItemId());try{String insertItemSql ="INSERT INTO order_items (order_id, product_id, quantity, price) VALUES (?, ?, ?, ?)";try(PreparedStatement ps = conn.prepareStatement(insertItemSql)){ ps.setString(1, orderId); ps.setString(2, item.getProductId()); ps.setInt(3, item.getQuantity()); ps.setDouble(4, item.getPrice()); ps.executeUpdate();}}catch(SQLException e){// 单个商品插入失败，回滚到该保存点，继续处理下一个 conn.rollback(savepoint);System.err.println("Failed to insert item "+ item.getItemId()+", skipped: "+ e.getMessage());}finally{// 可选：释放保存点（PostgreSQL 会在事务结束时自动清理）// conn.releaseSavepoint(savepoint);}} conn.commit();System.out.println("Order created with partial success.");}catch(SQLException e){ conn.rollback();throw e;}}catch(SQLException e){ e.printStackTrace();}}

在这个例子中：

  • 每个订单项的插入都被包裹在一个保存点中。
  • 如果某一项因主键冲突或外键约束失败，只会回滚该项的操作，不影响其他项。
  • 最终，只要订单头插入成功，即使部分商品失败，订单仍可提交（业务上可能标记为“部分完成”）。
✅ 优势：提高了系统的容错能力，避免“全有或全无”的极端情况。

事务隔离级别详解

PostgreSQL 支持四种标准 SQL 隔离级别，可通过以下方式设置：

SETTRANSACTIONISOLATIONLEVELREADCOMMITTED;-- 或在 Java 中： conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
隔离级别脏读不可重复读幻读PostgreSQL 实现
READ UNCOMMITTED❌❌❌实际等同于 READ COMMITTED
READ COMMITTED✅❌❌默认级别
REPEATABLE READ✅✅❌使用快照隔离（Snapshot Isolation）
SERIALIZABLE✅✅✅使用 SSI（Serializable Snapshot Isolation）
🔗 更多关于隔离级别的细节，可参考 PostgreSQL 官方文档 - 事务隔离。

Java 设置隔离级别示例

Connection conn =DriverManager.getConnection(url, user, password); conn.setTransactionIsolation(Connection.TRANSACTION_SERIALIZABLE); conn.setAutoCommit(false);// ... 执行事务 ...
⚠️ 注意：更高的隔离级别会带来更大的性能开销和潜在的序列化失败（SerializationFailure 异常），需谨慎使用。

事务与锁机制

PostgreSQL 使用 多版本并发控制（MVCC） 来实现高并发下的事务隔离，但在某些操作（如 UPDATE、DELETE）中仍会加锁。

常见锁类型

  • 行级锁（Row-Level Locks）：如 FOR UPDATE、FOR SHARE
  • 表级锁（Table-Level Locks）：如 LOCK TABLE

例如，在转账场景中，为防止并发修改，可以显式加锁：

BEGIN;SELECT balance FROM accounts WHERE account_id ='A'FORUPDATE;-- 此时其他事务无法修改账户 A，直到当前事务结束UPDATE accounts SET balance = balance -100WHERE account_id ='A';COMMIT;

在 Java 中：

String selectForUpdate ="SELECT balance FROM accounts WHERE account_id = ? FOR UPDATE";try(PreparedStatement ps = conn.prepareStatement(selectForUpdate)){ ps.setString(1, accountId);ResultSet rs = ps.executeQuery();if(rs.next()){double balance = rs.getDouble("balance");// ... 业务逻辑 ...}}
🔒 使用 FOR UPDATE 可有效防止“写偏斜（Write Skew）”问题，但需注意死锁风险。

事务中的异常处理策略

在 Java 中处理事务异常时，应遵循以下最佳实践：

  1. 捕获 SQLException：这是所有数据库操作异常的基类。
  2. 区分可重试异常：如死锁（SQLState = "40P01"）或序列化失败（"40001"），可考虑重试。
  3. 确保资源释放：使用 try-with-resources 或 finally 块。
  4. 记录日志：便于排查问题。

重试机制示例

publicvoidexecuteWithRetry(RunnableWithSQLException task,int maxRetries)throwsSQLException{SQLException lastException =null;for(int i =0; i <= maxRetries; i++){try{ task.run();return;// 成功则退出}catch(SQLException e){String sqlState = e.getSQLState();if("40P01".equals(sqlState)||"40001".equals(sqlState)){ lastException = e;if(i < maxRetries){try{Thread.sleep(100*(i +1));// 指数退避}catch(InterruptedException ie){Thread.currentThread().interrupt();thrownewSQLException("Interrupted during retry", ie);}}}else{throw e;// 非重试异常，直接抛出}}}throw lastException;// 超过重试次数，抛出最后一次异常}@FunctionalInterfaceinterfaceRunnableWithSQLException{voidrun()throwsSQLException;}

使用方式：

executeWithRetry(()->{// 你的事务代码transferMoney("A","B",100);},3);

保存点的限制与注意事项

尽管保存点功能强大，但也有其局限性：

  1. 命名唯一性：在同一事务中，保存点名称必须唯一。重复命名会覆盖之前的保存点。
  2. 嵌套限制：PostgreSQL 支持保存点嵌套，但回滚到外层保存点会自动释放内层保存点。
  3. 性能开销：频繁创建/回滚保存点会增加 WAL（Write-Ahead Logging）负担。
  4. 不支持跨事务：保存点仅在当前事务内有效，事务结束后自动消失。

保存点嵌套示例

BEGIN;SAVEPOINT sp1;INSERTINTO logs VALUES('step1');SAVEPOINT sp2;INSERTINTO logs VALUES('step2');ROLLBACKTO sp2;-- 仅撤销 'step2'RELEASESAVEPOINT sp2;INSERTINTO logs VALUES('step3');ROLLBACKTO sp1;-- 撤销 'step1' 和 'step3'COMMIT;-- logs 表为空

在 Java 中，保存点对象（java.sql.Savepoint）由 Connection.setSavepoint(String name) 返回，可用于精确回滚。

事务与 Spring 框架集成

在企业级 Java 应用中，Spring Framework 提供了声明式事务管理，极大简化了事务控制。

使用 @Transactional 注解

@ServicepublicclassBankService{@AutowiredprivateJdbcTemplate jdbcTemplate;@Transactionalpublicvoidtransfer(String from,Stringto,double amount){ jdbcTemplate.update("UPDATE accounts SET balance = balance - ? WHERE account_id = ?", amount, from); jdbcTemplate.update("UPDATE accounts SET balance = balance + ? WHERE account_id = ?", amount,to);}}

Spring 会自动处理：

  • 开启事务
  • 提交（无异常时）
  • 回滚（抛出 RuntimeException 时）

配置数据源与事务管理器

@Configuration@EnableTransactionManagementpublicclassDatabaseConfig{@BeanpublicDataSourcedataSource(){HikariConfig config =newHikariConfig(); config.setJdbcUrl("jdbc:postgresql://localhost:5432/mydb"); config.setUsername("postgres"); config.setPassword("your_password");returnnewHikariDataSource(config);}@BeanpublicPlatformTransactionManagertransactionManager(){returnnewDataSourceTransactionManager(dataSource());}}
🔗 Spring 官方文档提供了详细的 事务管理指南。

事务监控与性能调优

长时间运行的事务可能导致：

  • 表膨胀（Bloat）：由于 MVCC 保留旧版本行
  • WAL 日志堆积
  • 锁争用

监控长事务

-- 查看当前运行的事务SELECT pid,now()- xact_start AS duration, query FROM pg_stat_activity WHERE state ='active'AND xact_start ISNOTNULLORDERBY duration DESC;

设置事务超时

-- 会话级设置SET idle_in_transaction_session_timeout ='5min';-- 或在 Java 连接字符串中 String url ="jdbc:postgresql://localhost:5432/mydb?options=-c%20idle_in_transaction_session_timeout=300000";

这可以自动终止空闲超过 5 分钟的事务，防止资源泄漏。

事务与分布式系统

在微服务架构中，单数据库事务无法满足跨服务一致性需求。此时需考虑：

  • Saga 模式：通过补偿事务实现最终一致性
  • 两阶段提交（2PC）：但 PostgreSQL 对 XA 事务支持有限
  • 事件驱动架构：通过消息队列解耦
🔗 Martin Fowler 在其博客中详细讨论了 微服务中的事务管理。

虽然本文聚焦于单机 PostgreSQL 事务，但在分布式场景下，理解本地事务是构建可靠分布式事务的基础。

总结：事务控制的最佳实践

  1. 显式控制事务边界：避免依赖自动提交，尤其在多语句操作中。
  2. 保持事务短小：减少锁持有时间和 MVCC 版本链长度。
  3. 合理使用保存点：用于局部回滚，提高容错性。
  4. 选择合适的隔离级别：默认 READ COMMITTED 通常足够，高并发场景慎用 SERIALIZABLE。
  5. 处理异常并重试：对死锁和序列化失败实现重试逻辑。
  6. 监控长事务：防止数据库性能下降。
  7. 利用框架能力：如 Spring 的声明式事务，减少样板代码。

PostgreSQL 的事务机制成熟、稳定且功能丰富。掌握 COMMIT、ROLLBACK 和 SAVEPOINT 的使用，不仅能写出健壮的数据操作代码，还能在复杂业务场景中游刃有余。

🌟 最后提醒：事务是保障数据一致性的利器，但不是万能药。设计良好的数据模型和业务逻辑，才是系统可靠性的根本。

希望本文能帮助你深入理解 PostgreSQL 事务的核心操作。如果你有任何问题或实践经验，欢迎在评论区分享！

🙌 感谢你读到这里！
🔍 技术之路没有捷径，但每一次阅读、思考和实践，都在悄悄拉近你与目标的距离。
💡 如果本文对你有帮助，不妨 👍 点赞、📌 收藏、📤 分享 给更多需要的朋友！
💬 欢迎在评论区留下你的想法、疑问或建议，我会一一回复，我们一起交流、共同成长 🌿
🔔 关注我，不错过下一篇干货！我们下期再见！✨

Read more

从0到1彻底掌握Trae：手把手带你实战开发AI Chatbot，提升开发效率的必备指南！

从0到1彻底掌握Trae：手把手带你实战开发AI Chatbot，提升开发效率的必备指南！

我正在参加Trae「超级体验官」创意实践征文，本文所使用的 Trae 免费下载链接：www.trae.ai/?utm_source… 暴富技巧 比特鹰作为国内领先的 AI+Web3 领域企业，团队充满年轻活力 ——95% 成员为 00 后，不仅技术氛围浓厚，还会为每位成员量身定制成长规划；在职业发展层面，公司前景广阔，提供餐饮补贴、租房补贴、年底奖金、股票期权及额外假期等多重福利，助力员工在 35 岁前实现财富自由 目前公司正招聘海外运营、前端、后端、智能合约、AI 开发、HR 等岗位，有意向者可加微信联系: ai_lianqq 前言 大家好，我是小Q，字节跳动近期推出了一款 AI IDE—— Trae，

By Ne0inhk
DooTask：AI赋能的开源项目协作神器——从部署到精通的全链路指南

DooTask：AI赋能的开源项目协作神器——从部署到精通的全链路指南

DooTask：AI赋能的开源项目协作神器——从部署到精通的全链路指南 DooTask 是一款基于 Laravel 框架 开发的 开源在线项目任务管理工具，专为中小团队和敏捷开发场景设计。它以“轻量化、高集成、易部署”为核心优势，整合任务管理、文档协作、即时通讯、日历视图等功能于一体，支持多平台访问（PC/移动端），帮助团队高效规划项目、跟踪进度、沉淀知识，实现协作效率的指数级提升。 一、DooTask的核心价值：一站式协作中枢 DooTask突破传统任务管理工具的单一功能边界，构建了覆盖项目全生命周期的协作生态： 跨平台无缝衔接 提供PC端、平板和手机端响应式界面，支持任务快速处理、文件在线预览和进度跟踪。例如，移动端可实时接收任务提醒，外出时也能通过手机端更新任务状态。 安全即时通讯 内置IM系统采用非对称加密技术，任务详情页直接关联讨论区，团队成员可针对具体任务展开针对性沟通，避免信息碎片化。 智能文档协作 集成在线思维导图、流程图工具和富文本编辑器，支持多人实时协作编辑。例如，技术团队可同步绘制系统架构图，

By Ne0inhk
零基础学AI大模型之LLM存储优化：大量QA与长对话问题实战

零基础学AI大模型之LLM存储优化：大量QA与长对话问题实战

大家好，我是工藤学编程 🦉一个正在努力学习的小博主，期待你的关注实战代码系列最新文章😉C++实现图书管理系统（Qt C++ GUI界面版）SpringBoot实战系列🐷【SpringBoot实战系列】SpringBoot3.X 整合 MinIO 存储原生方案分库分表分库分表之实战-sharding-JDBC分库分表执行流程原理剖析消息队列深入浅出 RabbitMQ-RabbitMQ消息确认机制（ACK）AI大模型零基础学AI大模型之LLM存储记忆功能之BaseChatMemory实战 前情摘要 1、零基础学AI大模型之读懂AI大模型 2、零基础学AI大模型之从0到1调用大模型API 3、零基础学AI大模型之SpringAI 4、零基础学AI大模型之AI大模型常见概念 5、零基础学AI大模型之大模型私有化部署全指南 6、零基础学AI大模型之AI大模型可视化界面 7、零基础学AI大模型之LangChain 8、零基础学AI大模型之LangChain六大核心模块与大模型IO交互链路 9、零基础学AI大模型之Prompt提示词工程 10、零基础学AI大模型之LangCh

By Ne0inhk
AI看不懂图片？我把Transformer塞进“九宫格”，CV/NLP从此一家亲！

AI看不懂图片？我把Transformer塞进“九宫格”，CV/NLP从此一家亲！

Transformer 模型深度解读：从零手撕到霸榜 AI 界的“变形金刚” 文章目录 * Transformer 模型深度解读：从零手撕到霸榜 AI 界的“变形金刚” * 一、 引言：AI 界的“工业革命”与旧时代的落幕 * 1.1 从蒸汽机到核聚变 * 1.2 为什么 RNN 必须死？ * 二、 宏观视角：先把黑盒看穿 * 2.1 那个神奇的黑盒子 * 2.2 堆叠的艺术：千层饼结构 * 三、 拆解编码器：机器是如何“理解”语言的？ * 3.1 Encoder 的两大护法 * 3.2 数据流动的细节 * 四、

By Ne0inhk