Oracle/Mysql迁移到Postgresql事务回滚行为差异(开发避坑系列)

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云原生数据库 PolarDB MySQL 版,通用型 2核4GB 50GB
简介: Mysql或Oracle迁移到Postgresql系产品后,经常会发生事务回滚导致的问题,具体问题一般都是类似于: **为什么我没rollback,我的事务就自己回滚了?** 下面我举一个简单的例子,说明下PG和其他两款DB在事务回滚行为上的差异 ## Oracle事务内报错后的行为 (完整代码贴在文章最后) ```java Class.fo

Mysql或Oracle迁移到Postgresql系产品后,经常会发生事务回滚导致的问题,具体问题一般都是类似于:

为什么我没rollback,我的事务就自己回滚了?

下面我举一个简单的例子,说明下PG和其他两款DB在事务回滚行为上的差异

Oracle事务内报错后的行为

(完整代码贴在文章最后)

            Class.forName("oracle.jdbc.driver.OracleDriver");
            conn = DriverManager.getConnection(URL, USER, PASSWORD);
            conn.setAutoCommit(false);
            Statement stmt = conn.createStatement();

            /* 事务启动,写入一些数据 */
            stmt.executeUpdate("INSERT INTO t1 VALUES (1)");

            /* 查询t1全部数据 */
            selectAllFromTable(stmt, "写入后查询");

            /* 制造一些错误,这里查询不存在的列 */
            try {
                stmt.executeQuery("select xxxxxxx from t1 ");
            } catch (Exception e) {
                /* 那么到这里事务是否已经回滚了?*/
                selectAllFromTable(stmt, "异常后查询");
            }
            conn.commit();
            selectAllFromTable(stmt, "提交后查询");

...

private static void selectAllFromTable(Statement stmt, String info) throws SQLException {
        System.out.println("=======" + info + "=======");
        ResultSet rs1 = stmt.executeQuery("SELECT i FROM t1");
        ResultSetMetaData rsMetaData1 = rs1.getMetaData();
        printRs(rs1, rsMetaData1);
    }

...

建表语句

create table t1 (i int);

我们可以猜一下三次selectAllFromTable(函数就是简单的查全表)输出会是什么

用Mysql或Oracle的同学可能直接就可以想到:

=======写入后查询=======
I 1
=======异常后查询=======
I 1
=======提交后查询=======
I 1

这里关键就是 出现查询异常后,不影响事务的正常运行,后面可以继续在事务内操作。但在PG中就不一样了。

Postgresql事务内报错后的行为

public class TestPgsql {

    private static final String URL = "jdbc:postgresql://121.196.26.196:7001/postgres";
    private static final String USER = "postgres";
    private static final String PASSWORD = "333";

    public static void main(String[] args) {
        Connection conn = null;
        try {
            Class.forName("org.postgresql.Driver");
            conn = DriverManager.getConnection(URL, USER, PASSWORD);
            conn.setAutoCommit(false);
            Statement stmt = conn.createStatement();

            /* 事务启动,写入一些数据 */
            stmt.executeUpdate("INSERT INTO t1 VALUES (1)");

            /* 查询t1全部数据 */
            selectAllFromTable(stmt, "写入后查询");

            /* 制造一些错误,这里查询不存在的列 */
            try {
                stmt.executeQuery("select xxxxxxx from t1 ");
            } catch (Exception e) {
                /* 那么到这里事务是否已经回滚了?*/
                selectAllFromTable(stmt, "异常后查询");

            }
            conn.commit();
            selectAllFromTable(stmt, "提交后查询");

...

这里就不再贴报错了,我贴下单步调试的过程更容易理解

第一个差异点:事务内SQL报错后,再执行任何语句都会抛异常

image.png

在报错后的事务内再执行查询,报PG的标准错误:
org.postgresql.util.PSQLException: ERROR: current transaction is aborted, commands ignored until end of transaction block

image.png

第二个差异点:报错后,事务自动回滚,会话状态处于idle in transaction (aborted)

image.png

那么在SQL报错后,为了之前的修改能生效,我在报错后的异常处理时直接提交可以吗?

不可以,在报错时事务已经回滚,虽然提交没有报错,但是写入的数据不会生效

image.png

commit后
image.png

数据没有写入:
image.png

迁移到Postgresql后如何改造?

方案一:PL/pgSQL

使用Postgresql提供的PL/pgSQL语法,将相关逻辑写入PG的函数中,使用PG的EXCEPTION语法封装响应的处理逻辑,在业务代码中调用函数即可保证事务不会中断。

https://www.postgresql.org/docs/9.1/plpgsql-control-structures.html#PLPGSQL-ERROR-TRAPPING

[ <<label>> ]
[ DECLARE
    declarations ]
BEGIN
    statements
EXCEPTION
    WHEN condition [ OR condition ... ] THEN
        handler_statements
    [ WHEN condition [ OR condition ... ] THEN
          handler_statements
      ... ]
END;
If no error occurs, this for

方案二:寻找替代逻辑,避免事务内产生错误

例如这样的业务逻辑(来自云上客户):

On Oracle伪代码

try 
    select xxx from t1
    
    xxx列存在的处理逻辑
catch
    xxx列存不存在的处理逻辑

那么到Postgresql可以采用无异常的处理方式:

On Postgresql伪代码


int n = select count(*) from information_schema.columns WHERE table_schema = 'postgres' and table_name = 't1' and column_name = 'xxx';

if (n == 0) {
    xxx列存不存在的处理逻辑
} else {
    xxx列存在的处理逻辑
}
相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
3月前
|
SQL 运维 Oracle
【迁移秘籍揭晓】ADB如何助你一臂之力,轻松玩转Oracle至ADB的数据大转移?
【8月更文挑战第27天】ADB(Autonomous Database)是由甲骨文公司推出的自动化的数据库服务,它极大简化了数据库的运维工作。在从传统Oracle数据库升级至ADB的过程中,数据迁移至关重要。
67 0
|
9天前
|
存储 关系型数据库 MySQL
MySQL 字段类型深度解析:VARCHAR(50) 与 VARCHAR(500) 的差异
在MySQL数据库中,`VARCHAR`类型是一种非常灵活的字符串存储类型,它允许存储可变长度的字符串。然而,`VARCHAR(50)`和`VARCHAR(500)`之间的差异不仅仅是长度的不同,它们在存储效率、性能和使用场景上也有所不同。本文将深入探讨这两种字段类型的区别及其对数据库设计的影响。
20 2
|
2月前
|
存储 Oracle 关系型数据库
Oracle和MySQL有哪些区别?从基本特性、技术选型、字段类型、事务、语句等角度详细对比Oracle和MySQL
从基本特性、技术选型、字段类型、事务提交方式、SQL语句、分页方法等方面对比Oracle和MySQL的区别。
501 18
Oracle和MySQL有哪些区别?从基本特性、技术选型、字段类型、事务、语句等角度详细对比Oracle和MySQL
|
2月前
|
Oracle NoSQL 关系型数据库
主流数据库对比:MySQL、PostgreSQL、Oracle和Redis的优缺点分析
主流数据库对比:MySQL、PostgreSQL、Oracle和Redis的优缺点分析
395 2
|
3月前
|
消息中间件 关系型数据库 MySQL
实时计算 Flink版产品使用问题之使用CTAS同步MySQL到Hologres时出现的时区差异,该如何解决
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
3月前
|
SQL 关系型数据库 MySQL
SQL Server、MySQL、PostgreSQL:主流数据库SQL语法异同比较——深入探讨数据类型、分页查询、表创建与数据插入、函数和索引等关键语法差异,为跨数据库开发提供实用指导
【8月更文挑战第31天】SQL Server、MySQL和PostgreSQL是当今最流行的关系型数据库管理系统,均使用SQL作为查询语言,但在语法和功能实现上存在差异。本文将比较它们在数据类型、分页查询、创建和插入数据以及函数和索引等方面的异同,帮助开发者更好地理解和使用这些数据库。尽管它们共用SQL语言,但每个系统都有独特的语法规则,了解这些差异有助于提升开发效率和项目成功率。
364 0
|
5月前
|
SQL 关系型数据库 MySQL
mysqldiff - Golang 针对 MySQL 数据库表结构的差异 SQL 工具
Golang 针对 MySQL 数据库表结构的差异 SQL 工具。https://github.com/camry/mysqldiff
92 7
|
6月前
|
SQL Oracle 关系型数据库
【ORACLE】 事务 | 锁 | 约束 | 权限、角色与用户管理
【ORACLE】 事务 | 锁 | 约束 | 权限、角色与用户管理
72 1
|
6月前
|
人工智能 Oracle 关系型数据库
一篇文章弄懂Oracle和PostgreSQL的Database Link
一篇文章弄懂Oracle和PostgreSQL的Database Link
|
6月前
|
存储 Oracle 关系型数据库
oracle 数据库 迁移 mysql数据库
将 Oracle 数据库迁移到 MySQL 是一项复杂的任务,因为这两种数据库管理系统具有不同的架构、语法和功能。
109 0

推荐镜像

更多