Spring异常处理 bug的问题记录(同一份代码,结果却不一样)

更新时间：2025年05月26日 08:58:47 作者：程序员博博

这篇文章主要介绍了Spring异常处理 bug的问题记录(同一份代码,结果却不一样)的相关资料,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧

1. 背景

在上周遇到一个spring bug的问题，将其记录一下。简化的代码如下：

public void insert() {
    try {
        Person person = new Person();
        person.setId(3581L);// 这个是主键，拥有唯一索引**
        personDao.insert(person);
    } catch (DuplicateKeyException e) {
        log.error("DuplicateKeyException e = {}", e.getMessage(), e);
        // DuplicateKeyException 其他逻辑处理
    } catch (DataIntegrityViolationException e) {
        log.error("DataIntegrityViolationException e = {}", e.getMessage(), e);
        // DataIntegrityViolationException 其他逻辑处理
    } catch (Exception e) {
        log.error("Exception e = {}", e.getMessage(), e);
    }
}

然而同一份代码，部署在不同机器（数据库只有一个, 不存在分库分表情况），遇到的情况不一样。

A机器：如果主键冲突，则抛出DuplicateKeyException异常，进入第7行的逻辑

B机器：如果主键冲突，则抛出DataIntegrityViolationException异常，进入第11行的逻辑

甚至我将B机器重启，如果主键冲突，则抛出DuplicateKeyException异常，进入第7行的逻辑

非常的奇怪，我们一一细说

2. 数据库异常分析

2.1 spring对java标准异常的包装

异常类型/属性	所属框架或技术栈	触发场景
SQLIntegrityConstraintViolationException	属于 JDBC 标准异常体系，是 `java.sql.SQLException` 的子类。	当数据库操作违反了完整性约束（如主键冲突、外键约束、唯一性约束等）时，JDBC 驱动会抛出此异常。
DuplicateKeyException	是 Spring 框架中定义的异常，属于 Spring Data 或 Spring JDBC 的封装异常。	通常在插入或更新数据时，违反了数据库表的主键或唯一索引约束（即尝试插入重复的主键或唯一键值）。
DataIntegrityViolationException	是 Spring 框架中的异常，属于 Spring 数据访问层的通用异常体系	是一个更通用的异常，表示任何违反数据完整性的操作，包括但不限于主键冲突、外键约束、非空约束等。

从表格中我们可以明显看出，SQLIntegrityConstraintViolationException是属于Java体系的标准异常，当主键冲突，外键约束，非空等情况正常都会抛出这个异常

然后spring框架对这个异常进行了一个封装，比如违反唯一索引会抛出DuplicateKeyException异常，其他的情况会抛出DataIntegrityViolationException异常。

2.2 spring代码包装

在spring中会有一个SQLErrorCodesFactory类，会加载下面路径下的资源。也就是说，每个数据库厂商对于不同异常返回的错误码不同，spring进行了一个包装

public static final String SQL_ERROR_CODE_DEFAULT_PATH 
    =  "org/springframework/jdbc/support/sql-error-codes.xml";

2.3 问题产生的原因

在spring异常处理中，有一个非常核心的类 SQLErrorCodeSQLExceptionTranslator，但遇到主键冲突，非空约束等异常的时候，spring会使用这个类进行转化。

if (Arrays.binarySearch(this.sqlErrorCodes.getBadSqlGrammarCodes(), errorCode) >= 0) {
    logTranslation(task, sql, sqlEx, false);
    return new BadSqlGrammarException(task, (sql != null ? sql : ""), sqlEx);
}
else if (Arrays.binarySearch(this.sqlErrorCodes.getInvalidResultSetAccessCodes(), errorCode) >= 0) {
    logTranslation(task, sql, sqlEx, false);
    return new InvalidResultSetAccessException(task, (sql != null ? sql : ""), sqlEx);
}
else if (Arrays.binarySearch( this .sqlErrorCodes.getDuplicateKeyCodes(), errorCode) >= 0) {
    logTranslation(task, sql, sqlEx, false);
    return new DuplicateKeyException(buildMessage(task, sql, sqlEx), sqlEx);
}
else if (Arrays.binarySearch(this.sqlErrorCodes.getDataIntegrityViolationCodes(), errorCode) >= 0) {
    logTranslation(task, sql, sqlEx, false);
    return new DataIntegrityViolationException(buildMessage(task, sql, sqlEx), sqlEx);
}
else if // xxx 省略

我们可以从上面代码中可以看到，他其中是从sqlErrorCodes中，进行二分查找，是否存在相应的code码，然后返回给上游不同的错误，那么sqlErrorCodes是从哪里获取的呢。

try {
    String name = JdbcUtils.extractDatabaseMetaData(dataSource, "getDatabaseProductName");
    if (StringUtils.hasLength(name)) {
       return registerDatabase(dataSource, name);
    }
}
catch (MetaDataAccessException ex) {
    logger.warn("Error while extracting database name - falling back to empty error codes", ex);
}
// Fallback is to return an empty SQLErrorCodes instance.
return new SQLErrorCodes();

从上面代码我们可以看出，会通过JdbcUtils.extractDatabaseMetaData方法来获取sqlErrorCodes，是哪个厂商，并且获取到Connection进行连接，然后返回相应的sqlErrorCodes码

但是在第7行，如果此时Connection数据库链接有异常，则会报错，然后返回11行一个空的sqlErrorCodes，那么问题就出在这里了！！！

也就是说，如果在第一次获取sqlErrorCodes，如果出了问题，那么这个字段就会为空，上面代码的转化异常逻辑就会判断错误。就会走到else兜底退避的策略。

具体退避的策略在SQLExceptionSubclassTranslator类中，所以当走到了退避策略，所有SQLIntegrityConstraintViolationException异常都会返回DataIntegrityViolationException异常

if (ex instanceof SQLNonTransientConnectionException) {
    return new DataAccessResourceFailureException(buildMessage(task, sql, ex), ex);
}
else if (ex instanceof SQLDataException) {
    return new DataIntegrityViolationException(buildMessage(task, sql, ex), ex);
}
else if (ex instanceof SQLIntegrityConstraintViolationException) {
    return new DataIntegrityViolationException(buildMessage(task, sql, ex), ex);
}
else if // 省略

3. 问题复现

3.1 错误复现

我们从2.3分析中，可以清楚的知道，根因是SQLErrorCodeSQLExceptionTranslator类中sqlErrorCodes字段为空导致主键冲突退避返回了DataIntegrityViolationException异常。

那么我们就可以模拟链接异常，比如连接被关闭了，导致首次初始化的时候导致sqlErrorCodes失败，代码如下 (注意这块代码必须在项目启动首先第一次执行)

@Transactional
public void testConnect() {
    try {
        Connection connection = DataSourceUtils.getConnection(dataSource);
        connection.close(); // 强制关闭连接，破坏事务一致性
        personDao.selectById(1L);
    } catch (DuplicateKeyException e) {
        log.error("DuplicateKeyException e = {}", e.getMessage(), e);
    } catch (DataIntegrityViolationException e) {
        log.error("DataIntegrityViolationException e = {}", e.getMessage(), e);
    } catch (Exception e) {
        log.error("Exception e = {}", e.getMessage(), e);
    }
}

在上面代码中，我们获取了链接，并且强制关闭了，那么就会导致初始化的时候走2.3那块代码就会报错，此时sqlErrorCodes就会为空。

如果后面sql遇到了唯一索引，返回如下：

3.2 正确复现

将上面代码connection.close()去掉，那么第一次缓存就正常了。再次执行，如果遇到了唯一索引，返回如下：

4. 解决办法

在github上面已经有人提出此问题，并且标记为了bug，链接如下：https://github.com/spring-projects/spring-framework/issues/25681

并且修复pull request如下（此代码已合并到v5.2.9.RELEASE分支）

https://github.com/spring-projects/spring-framework/commit/670b9fd60b3b5ada69b060424d697270eeee01c2#diff-e2f38c7b7d44c3679cd585e5c81e76b3ca32313bf870caa6435cd36bfe4d9600

4.1 办法1

升级spring版本到5.2.9.release+，可以彻底解决此问题

4.2 办法2

第一步在项目启动的时候，获取SQLErrorCodes，如果为空，则打印error日志并且告警。让开发同学知道有这么一个问题 (可重启也可不重启)

public class DatabaseMetadataPreloader  {
    @PostConstruct
    public void init() {
       try {
          SQLErrorCodes errorCodes = errorCodesFactory.getErrorCodes(dataSource);
          log.info("Database metadata preloaded successfully errorCodes = {}", GsonUtils.toJson(errorCodes));
          String[] duplicateKeyCodes = errorCodes.getDuplicateKeyCodes();
          if (ArrayUtils.isEmpty(duplicateKeyCodes)) {
             log.error("No duplicate key codes found in database metadata 请重启服务");
          }
       } catch (Exception e) {
          log.error("Failed to preload database metadata", e);
       }
    }
}

第二步重新查询一遍数据库

如果有数据则表明是索引冲突，如果没有数据，则可能是其他异常引起的，走原有的老逻辑

catch (DuplicateKeyException e) {
    log.error("DuplicateKeyException e = {}", e.getMessage(), e);
}
catch (DataIntegrityViolationException e) {
    log.error("DataIntegrityViolationException e = {}", e.getMessage(), e);
    // 重新查一遍数据库，如果有数据，说明是唯一索引冲突
    Person p = select(xxxx)
    if (p != null) {
        // 唯一索引冲突
    } else {
        // 其他异常引起的
    }
}

您可能感兴趣的文章:

Python import与from import使用及区别介绍
Python程序可以调用一组基本的函数（即内建函数），比如print()、input()和len()等函数。接下来通过本文给大家介绍Python import与from import使用及区别介绍，感兴趣的朋友一起看看吧
2018-09-09
python跳出双层for循环的解决方法
今天小编就为大家分享一篇python跳出双层for循环的解决方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2019-06-06
Python使用PyCrypto实现AES加密功能示例
这篇文章主要介绍了Python使用PyCrypto实现AES加密功能,结合具体实例形式分析了PyCrypto实现AES加密的操作步骤与相关实现技巧,需要的朋友可以参考下
2017-05-05
如何利用Python监控别人的网站
这篇文章主要为大家详细介绍了如何利用Python实现监控别人的网站，这样还可以详细了解你的竞争对手网站，感兴趣的小伙伴可以跟随小编一起学习一下
2023-05-05
Django中的Signal代码详解
这篇文章主要介绍了Django中的Signal代码详解，分享了相关代码示例，小编觉得还是挺不错的，具有一定借鉴价值，需要的朋友可以参考下
2018-02-02
django使用LDAP验证的方法示例
这篇文章主要介绍了django使用LDAP验证的方法示例，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2018-12-12
Django-xadmin+rule对象级权限的实现方式
今天小编就为大家分享一篇Django-xadmin+rule对象级权限的实现方式，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-03-03
Python中动态获取对象的属性和方法的教程
本文主要介绍了如何在Python中动态获取对象的属性和方法,并运行使用它们,需要的朋友可以参考一下
2015-04-04
python主动抛出异常raise的方法实现
本文主要介绍了python主动抛出异常raise的方法实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
2023-12-12
Python文本预处理学习指南
文本预处理是指在进行自然语言处理（NLP）任务之前，对原始文本数据进行清洗、转换和标准化的过程，本文主要为大家介绍了文本预处理的使用，需要的可以参考下
2023-07-07