Quarkus PanacheRepository persist()无法保存数据至MySQL问题排查

核心问题本质 #

你碰到的是Hibernate Reactive + Panache多租户场景下的典型问题：persist()无报错但数据没落地，手动加@WithSession触发线程错误，根源是反应式会话管理与多租户上下文没正确绑定，导致操作要么没实际执行，要么会话上下文混乱。

分步排查与修复 #

1. 先确认反应式操作有没有被真正执行 #

Hibernate Reactive的所有数据库操作都是Mutiny Uni类型，属于懒执行——如果没正确订阅或链式处理，代码等于白写：

• 你的TenantRepository.add()必须返回Uni类型，REST接口也得返回Uni，交给框架自动订阅：

  // TenantRepository 示例
  public Uni<Void> add(TenantDAO tenantDAO) {
      return persist(tenantDAO); // 直接返回Uni，别用阻塞调用
  }
  
  // REST接口示例
  @POST
  public Uni<Response> createTenant(Tenant tenant) {
      TenantDAO dao = convertToDAO(tenant);
      return tenantRepository.add(dao)
          .onItem().transform(v -> Response.created(URI.create("/tenants/"+dao.id)).build())
          .onFailure().recoverWithItem(e -> Response.status(500).entity(e.getMessage()).build());
  }
  

• 绝对别在反应式方法里用uni.await().indefinitely()这种阻塞操作，这也是加@WithSession触发线程错误的主要原因之一。

2. 检查多租户上下文的绑定逻辑 #

多租户模式下，Hibernate Reactive必须能正确拿到当前租户的上下文，否则会话是无效的，persist()等于空操作：

• 如果是基于请求头/路径的多租户，要确保拦截器在反应式线程里设置租户ID，用Mutiny的上下文传播：

  @ServerRequestFilter
  public Uni<Void> setTenantId(ContainerRequestContext ctx) {
      String tenantId = ctx.getHeaderString("X-Tenant-ID");
      return Uni.createFrom().voidItem()
          .invoke(() -> TenantContext.setCurrentTenantId(tenantId))
          .subscribeOn(Infrastructure.getDefaultWorkerPool());
  }
  

• 核对Hibernate多租户配置（hibernate.multi_tenant）和你的实现匹配，比如DATABASE或SCHEMA模式，且租户对应的数据源已经正确注册。

3. 别手动加@WithSession，依赖Panache自动会话管理 #

Panache Reactive已经自动帮你处理会话生命周期，手动加@WithSession会导致会话冲突——Panache在反应式流里会自动创建/绑定会话，重复绑定直接触发线程错误：

• 删掉自定义的@WithSession注解，PanacheRepository的方法默认会在反应式流里自动获取会话。
• 如果你的抽象SqlRepository有自定义会话逻辑，确保和Panache的逻辑兼容，别重复创建会话。

4. 验证persist()的实际执行状态 #

调试时session.contains(entity)没命中，说明实体根本没被加入会话，可能是这两个原因：

• 实体ID生成策略问题：如果TenantDAO用了@GeneratedValue，但多租户下ID生成没关联租户，会导致会话无法跟踪实体。
• 给persist()加日志验证操作是否真的执行：

  return persist(tenantDAO)
      .invoke(() -> LOGGER.info("实体已持久化: {}", tenantDAO.id))
      .onFailure().invoke(e -> LOGGER.error("持久化失败", e));
  

  如果日志没打印，说明操作没被订阅，检查链式调用是不是断了。

5. 确保操作在事务中执行 #

Hibernate Reactive默认需要显式事务或框架事务管理：

• 在Quarkus这类框架里，给add()方法加反应式版的@Transactional注解，确保操作在事务中执行并自动提交：

  @Transactional
  public Uni<Void> add(TenantDAO tenantDAO) {
      return persist(tenantDAO);
  }
  

  注意：反应式@Transactional需要框架支持（比如Quarkus的quarkus-hibernate-reactive依赖），它会自动处理事务的提交逻辑。

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