Jakarta EE+Hibernate 6级联保存：如何复用已存在玩家实体？

要实现你需要的功能，仅靠Hibernate的默认级联无法直接完成——因为级联操作不会自动查询数据库中是否存在同名玩家，也无法处理唯一约束冲突。你需要通过预查询+替换实例或数据库原子MERGE操作来实现，以下是两种不依赖Spring的可行方案：

方案一：预查询判断（直观易实现） #

核心思路是在保存游戏前，先根据玩家名称查询数据库：若存在则复用已有实例，不存在则生成ID后保留新实例，最后关联到游戏并保存。

步骤与代码示例 #

1. 修复实体拼写错误：Gamer类的columnDefiniton应为columnDefinition，避免映射异常。
2. 给Game类添加ID生成逻辑（否则保存时会因ID为空报错）：

public void generateID() {
    id = UUID.randomUUID();
}

3. 编写游戏创建与保存逻辑（需在事务中执行）：

Session session = // 从EntityManagerFactory获取Session，或通过Jakarta EE的@PersistenceContext获取EntityManager后转换
Transaction tx = session.beginTransaction();

try {
    // 处理玩家Jon
    Gamer one = new Gamer();
    one.setName("Jon");
    Gamer existingJon = session.createQuery("SELECT g FROM Gamer g WHERE g.name = :name", Gamer.class)
            .setParameter("name", one.getName())
            .uniqueResult();
    if (existingJon != null) {
        one = existingJon; // 复用数据库中已有的玩家实例
    } else {
        one.generateID(); // 新玩家生成ID
    }

    // 处理玩家Bob
    Gamer two = new Gamer();
    two.setName("Bob");
    Gamer existingBob = session.createQuery("SELECT g FROM Gamer g WHERE g.name = :name", Gamer.class)
            .setParameter("name", two.getName())
            .uniqueResult();
    if (existingBob != null) {
        two = existingBob;
    } else {
        two.generateID();
    }

    // 创建并配置游戏
    Game game = new Game();
    game.generateID();
    game.setGamerOne(one);
    game.setGamerTwo(two);
    game.setWinner(one);

    // 保存游戏，级联保存新玩家（若有）
    session.persist(game);
    tx.commit();
} catch (Exception e) {
    tx.rollback();
    throw new RuntimeException("保存游戏失败", e);
} finally {
    if (session.isOpen()) {
        session.close();
    }
}

注意事项 #

• 该方案存在并发风险：若两个线程同时查询同一名称的玩家（此时均返回null），随后同时插入会触发唯一约束异常。若要避免此问题，可在查询时添加行级锁：

Gamer existingJon = session.createQuery("SELECT g FROM Gamer g WHERE g.name = :name FOR UPDATE", Gamer.class)
        .setParameter("name", one.getName())
        .uniqueResult();

方案二：使用JPQL MERGE语句（原子操作，无并发风险） #

利用Hibernate 6支持的JPQL MERGE语句，直接通过数据库原子操作实现“存在则返回、不存在则插入”，彻底避免并发问题。

代码示例 #

Session session = // 获取Session
Transaction tx = session.beginTransaction();

try {
    // 处理玩家Jon
    Gamer one = new Gamer();
    one.setName("Jon");
    one.generateID();
    // 执行MERGE：存在则返回已有实例，不存在则插入新实例
    Gamer mergedJon = session.createQuery("MERGE INTO Gamer g USING :newGamer ng ON g.name = ng.name " +
                    "WHEN NOT MATCHED THEN INSERT (id, name) VALUES (ng.id, ng.name) " +
                    "RETURNING g", Gamer.class)
            .setParameter("newGamer", one)
            .uniqueResult();

    // 处理玩家Bob
    Gamer two = new Gamer();
    two.setName("Bob");
    two.generateID();
    Gamer mergedBob = session.createQuery("MERGE INTO Gamer g USING :newGamer ng ON g.name = ng.name " +
                    "WHEN NOT MATCHED THEN INSERT (id, name) VALUES (ng.id, ng.name) " +
                    "RETURNING g", Gamer.class)
            .setParameter("newGamer", two)
            .uniqueResult();

    // 创建并保存游戏
    Game game = new Game();
    game.generateID();
    game.setGamerOne(mergedJon);
    game.setGamerTwo(mergedBob);
    game.setWinner(mergedJon);

    session.persist(game);
    tx.commit();
} catch (Exception e) {
    tx.rollback();
    throw new RuntimeException("保存游戏失败", e);
} finally {
    if (session.isOpen()) {
        session.close();
    }
}

优势 #

• 数据库层面的原子操作，完全避免并发插入导致的唯一约束异常。
• 无需手动判断实例是否存在，代码更简洁。

关于级联的说明 #

你的Game类中已配置CascadeType.PERSIST和CascadeType.MERGE，当关联的玩家是临时状态（新创建未保存）时，会自动级联保存；若关联的是持久化状态（从数据库查询/merge返回的实例），Hibernate会自动处理关联关系，无需额外操作。

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