基于Reactive/Mutiny持久化实体后创建关联实体的优化方案

刚接触Quarkus，对Reactive Java/Mutiny完全陌生，现在需要在持久化数据库实体后创建其关联实体——比如保存User对象后，创建和User一对一关联的UserProfile对象。

在其他框架里，我会在REST API调用里这么做：

• 用API请求体创建User实例user1；
• 保存user1后，创建UserProfile实例并设置profile.user_id = user1.id；
• 把整个操作包在一个事务里。

我写了下面的UserResource代码，目前HTTP响应和数据库数据都符合预期，但想知道有没有更优的实现方式？能不能用单个事务完成操作？

@ApplicationScoped
@Path("/api/user")
@Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON)
public class UserResource {

  @Inject
  UserRepository userRepository;

  @Inject
  UserProfileRepository userProfileRepository;

  @GET
  public Uni<List<UserEntity>> list() {
    return userRepository.listAll();
  }

  @GET
  @Path("/{id}")
  public Uni<UserEntity> get(Long id) {
    return userRepository.findById(id);
  }

  @POST
  @Path("/")
  public Uni<Response> create(UserEntity user) {
    return Panache
        .withTransaction(() -> userRepository.persist(user))
        .onItem()
        .transformToUni(item -> {
          System.out.println(item);
          var userProfile = new UserProfileEntity();
          userProfile.setUser(item);
          userProfile.setDisplayName("My Name");
          return Panache.withTransaction(() -> userProfileRepository.persist(userProfile));
        })
        .invoke(item -> System.out.println(item))
        .replaceWith(Response.ok(user).status(Status.CREATED)::build);
  }
}

1. 合并为单个事务 #

你当前代码用了两次Panache.withTransaction()，会开启两个独立事务。要合并成单个事务，只需把两个持久化操作放在同一个事务块内，利用Mutiny的Uni链式调用完成流程：

@POST
@Path("/")
public Uni<Response> create(UserEntity user) {
    return Panache.withTransaction(() -> {
        // 先持久化User
        return userRepository.persist(user)
                .onItem().transformToUni(savedUser -> {
                    // 创建并关联UserProfile
                    var userProfile = new UserProfileEntity();
                    userProfile.setUser(savedUser);
                    userProfile.setDisplayName("My Name");
                    // 持久化UserProfile
                    return userProfileRepository.persist(userProfile);
                })
                // 最后返回保存后的User用于构建响应
                .replaceWith(user);
    })
    .onItem().transform(savedUser -> Response.ok(savedUser).status(Status.CREATED).build());
}

这样整个流程在单个事务中执行，要么全部成功，要么全部回滚，完全匹配你原有的事务需求。

2. 利用实体关联特性简化代码 #

如果UserEntity和UserProfileEntity已正确配置一对一关联，可通过级联持久化进一步简化代码：

示例实体配置：

@Entity
public class UserEntity extends PanacheEntity {
    // 其他字段
    @OneToOne(mappedBy = "user", cascade = CascadeType.PERSIST)
    public UserProfileEntity profile;
}

@Entity
public class UserProfileEntity extends PanacheEntity {
    // 其他字段
    @OneToOne
    @JoinColumn(name = "user_id")
    public UserEntity user;
    public String displayName;
}

简化后的Resource代码：

@POST
@Path("/")
public Uni<Response> create(UserEntity user) {
    // 创建并关联UserProfile到User
    var userProfile = new UserProfileEntity();
    userProfile.setUser(user);
    userProfile.setDisplayName("My Name");
    user.profile = userProfile;

    return Panache.withTransaction(() -> userRepository.persist(user))
            .onItem().transform(savedUser -> Response.ok(savedUser).status(Status.CREATED).build());
}

这种方式减少了代码量，同时确保关联操作的原子性，全程在单个事务中完成。

3. 清理冗余代码 #

代码中的System.out.println()属于临时调试代码，生产环境建议替换为Quarkus日志API（如@Inject Logger log;）或直接删除，避免冗余输出。

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