@Transactional方法隔离级偶现serializable而非read_committed问题排查

问题现象 #

生产环境CosmosDB PostgreSQL API出现如下报错：

PSQLException: ERROR: could not serialize access due to read/write dependencies among transactions
  Detail: Reason code: Canceled on identification as a pivot, during conflict in checking.
  Hint: The transaction might succeed if retried

涉事方法标注了@Transactional，预期使用默认的read_committed隔离级，但生产环境调试日志显示，同一方法的事务隔离级时而为serializable，时而为read_committed。本地PostgreSQL测试无此异常，隔离级始终保持read_committed。

排查背景 #

• 系统部分逻辑确实会使用serializable隔离级，怀疑是连接池复用了未重置隔离级的连接。
• 此前使用org.springframework.jdbc.datasource.DriverManagerDataSource搭配PgBouncer（无HikariCP），切换回HikariCP后，serializable隔离级的出现次数大幅减少，但仍偶发。
• 高频方法中记录隔离级的代码：

@Async
@Transactional
fun updateLastUsedAsync(apiKey: ApiKey) {
    logTransactionIsolation()
    updateLastUsed(apiKey)
}

private fun logTransactionIsolation() {
  if (logger.isDebugEnabled) {
    val isolationLevel = entityManager.createNativeQuery("show transaction_isolation")
      .singleResult as String
    logger.debug("Transaction isolation level: $isolationLevel")
  }
}

• 日志输出示例：

Transaction isolation level: serializable
Transaction isolation level: serializable
Transaction isolation level: serializable
Transaction isolation level: read_committed
Transaction isolation level: read_committed
Transaction isolation level: serializable

原因分析 #

1. 连接池连接未重置隔离级
   这是核心问题：当某个事务显式设置为serializable隔离级后，连接归还连接池时如果没有重置回默认的read_committed，后续获取该连接的事务会直接继承这个隔离级。

   • 使用DriverManagerDataSource+PgBouncer时，若PgBouncer的server_reset_query未配置重置隔离级的语句，就会导致隔离级残留。
   • HikariCP默认会做连接重置，但如果自定义了connectionInitSql或存在特殊场景，仍可能出现重置不彻底的情况。

2. @Async事务的连接获取逻辑
   @Async方法会开启独立的事务上下文，从连接池获取连接时，若拿到了被污染的连接，就会使用错误的隔离级执行事务，进而触发序列化冲突报错。

3. CosmosDB兼容层的细微差异
   本地PostgreSQL测试正常，但CosmosDB的PostgreSQL兼容层在连接复用或事务处理上可能存在细微特性，但核心问题仍源于连接池的隔离级未正确重置。

解决方案 #

1. 配置连接池的连接重置语句

   • HikariCP：设置connectionInitSql=SET transaction_isolation TO 'read_committed'，确保每个连接被获取时都重置到默认隔离级。
   • PgBouncer：修改server_reset_query为SET transaction_isolation TO 'read_committed'; RESET ALL;，覆盖默认重置逻辑，确保隔离级被重置。

2. 显式指定事务隔离级
   在@Transactional注解中明确指定隔离级，避免依赖连接的默认值：

   @Async
   @Transactional(isolation = Isolation.READ_COMMITTED)
   fun updateLastUsedAsync(apiKey: ApiKey) {
       // ...
   }
   

3. 显式重置隔离级
   在使用serializable隔离级的事务方法末尾，执行重置语句，确保归还连接前隔离级恢复默认：

   @Transactional(isolation = Isolation.SERIALIZABLE)
   fun serializableOperation() {
       // 业务逻辑
       entityManager.createNativeQuery("SET transaction_isolation TO 'read_committed'").executeUpdate()
   }
   

内容的提问来源于stack exchange，提问作者Jan Cizmar