基于Spring Boot+Hibernate+CockroachDB的Kotlin CRUD应用抛出TransactionException

我来帮你拆解这个问题——你遇到的org.springframework.orm.jpa.JpaSystemException/org.hibernate.TransactionException异常，在搭配CockroachDB的分布式场景里，大概率和CockroachDB的事务特性、主键策略或者Hibernate与CockroachDB的适配配置有关。结合你给出的极简CRUD场景，我整理了具体的排查和修复方案：

先明确核心代码（你提供的实体类） #

@Entity
data class Thing(
    @Id var id: Long,
    var value: String
)

异常原因分析 #

1. 主键冲突风险：手动指定Long类型主键，在CockroachDB分布式环境下，多节点并发写入极易出现主键重复，触发事务回滚。
2. 事务隔离级别不兼容：CockroachDB默认使用SERIALIZABLE隔离级别（比MySQL的默认级别严格得多），Hibernate默认配置没有针对这种高隔离级别做重试适配，并发场景下容易出现事务冲突。
3. JDBC驱动未配置重试：CockroachDB在分布式冲突时会返回序列化失败错误，默认JDBC驱动不会自动重试这类错误。

具体修复方案 #

1. 调整主键生成策略（优先推荐） #

CockroachDB天生适合用UUID或分布式序列作为主键，避免手动指定带来的冲突：

方案A：使用UUID主键

import java.util.UUID
import jakarta.persistence.GeneratedValue
import jakarta.persistence.GenerationType
import jakarta.persistence.Id
import jakarta.persistence.Entity

@Entity
data class Thing(
    @Id
    @GeneratedValue(strategy = GenerationType.UUID)
    var id: UUID = UUID.randomUUID(), // 提供默认值避免Kotlin构造器问题
    var value: String
)

方案B：使用分布式序列主键

如果你坚持用Long类型，可借助CockroachDB的序列生成器：

import jakarta.persistence.GeneratedValue
import jakarta.persistence.GenerationType
import jakarta.persistence.Id
import jakarta.persistence.Entity
import jakarta.persistence.SequenceGenerator

@Entity
data class Thing(
    @Id
    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "thing_seq")
    @SequenceGenerator(
        name = "thing_seq",
        sequenceName = "thing_id_seq",
        allocationSize = 1000 // 适配CockroachDB的序列预取优化
    )
    var id: Long = 0, // 默认值
    var value: String
)

注意：需要在application.properties中设置spring.jpa.hibernate.ddl-auto=update，让Hibernate自动创建序列，或者手动在CockroachDB中执行CREATE SEQUENCE thing_id_seq;。

2. 优化事务与Hibernate配置 #

在application.properties中添加针对CockroachDB的适配配置：

# 数据库连接（关键：开启序列化失败自动重试）
spring.datasource.url=jdbc:cockroachdb://localhost:26257/your_db?sslmode=disable&retryOnSerializationFailure=true
spring.datasource.username=root
spring.datasource.password=

# JPA/Hibernate配置
spring.jpa.hibernate.ddl-auto=update
spring.jpa.show-sql=true
spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.CockroachDB201Dialect
# 适配CockroachDB的SERIALIZABLE隔离级别
spring.jpa.properties.hibernate.connection.isolation=8
# 配置事务超时与重试
spring.jpa.properties.hibernate.jdbc.timeout=30

3. 给服务层添加事务重试 #

引入Spring Retry依赖，让服务层在遇到事务冲突时自动重试：

更新build.gradle.kts

dependencies {
    implementation("org.springframework.boot:spring-boot-starter-data-jpa")
    implementation("org.springframework.boot:spring-boot-starter-web")
    implementation("org.jetbrains.kotlin:kotlin-reflect")
    // 添加Spring Retry依赖
    implementation("org.springframework.retry:spring-retry")
    implementation("org.springframework.boot:spring-boot-starter-aop")
    runtimeOnly("org.cockroachdb:cockroachdb-jdbc:23.2.0")
    testImplementation("org.springframework.boot:spring-boot-starter-test")
}

在ThingService中添加重试注解

import org.springframework.retry.annotation.Retryable
import org.springframework.stereotype.Service
import org.springframework.transaction.annotation.Transactional
import org.hibernate.TransactionException

@Service
class ThingService(private val thingRepository: ThingRepository) {

    @Retryable(value = [TransactionException::class])
    @Transactional
    fun createThing(value: String): Thing {
        val thing = Thing(value = value)
        return thingRepository.save(thing)
    }

    // 其他CRUD方法同理添加@Transactional和@Retryable
}

4. 优化压力测试脚本 #

如果你的stress_test.py是并发调用接口，需要在客户端层面处理409冲突（CockroachDB返回的冲突错误），添加重试逻辑：

import requests
import time
from concurrent.futures import ThreadPoolExecutor

BASE_URL = "http://localhost:8080/things"

def create_thing():
    try:
        response = requests.post(BASE_URL, json={"value": "test_value"})
        response.raise_for_status()
        print(f"Created thing: {response.json()}")
    except requests.exceptions.HTTPError as e:
        if e.response.status_code == 409:
            # 遇到冲突时短暂等待后重试
            time.sleep(0.1)
            create_thing()
        else:
            print(f"Request failed: {e}")

if __name__ == "__main__":
    with ThreadPoolExecutor(max_workers=10) as executor:
        for _ in range(100):
            executor.submit(create_thing)

总结 #

这些异常本质是CockroachDB的分布式特性和Hibernate默认配置的不匹配导致的。通过调整主键策略、开启事务重试、适配CockroachDB的JDBC配置，再加上客户端层面的冲突处理，就能解决绝大多数事务异常问题。

内容的提问来源于stack exchange，提问作者Tobias Hermann