如何将方法从命令式更改为反应式

Question

我构建了一个小型Rest API，以了解更多关于Quarkus框架的信息。现在我想开始使用带有反应式API的框架，但我很难理解一些概念。目前，该项目正在使用RESTEasy Responsive与Jackson、Hibernate Responsive与Panache以及Postgresql Responsive客户端。

这是我的课

@Table(name = "cat_role")
@Entity
public class Role extends PanacheEntityBase {
    private static final long serialVersionUID = -2246110460374253942L;

    @Id
    @Column(name = "id", nullable = false, updatable = false)
    @GeneratedValue
    public UUID id;
    
    @Enumerated(EnumType.STRING)
    @Column(name = "name", nullable = false, length = 18)
    public UserRole name;

    public enum UserRole {
        Administrador, Asesor_Empresarial, Asesor_Academico, Alumno
    }
    
}

现在，在我的服务（强制方式）中，我做以下工作：

角色类

    public static Boolean existsRoleSeed(){
        return Role.count() > 0;
    }

角色服务类

    @Transactional
    public void seedRoles() {
        if (!Role.existsRoleSeed()) {
            for(Role.UserRole userRole: Role.UserRole.values()){
                Role role = Role.builder()
                        .name(userRole)
                        .build();
                
                role.persist();
            }
        }
    }

这显然将在数据库中注册UserRole枚举中的所有角色，并且它工作正常。我试图实现的是复制这种方法，但使用反应形式。这些是我在代码中所做的更改

角色类

    public static Uni<Boolean> existsRoleSeed() {
        return Role.count().map(x -> x > 0);
    }

角色服务类

    @ReactiveTransactional
    public void seedRoles() {
        Role.existsRoleSeed()
                .map(exists -> {
                    if (!exists) {
                        Multi.createFrom()
                                .iterable(Arrays
                                        .stream(Role.UserRole.values())
                                        .map(userRole -> Role.builder()
                                                .name(userRole)
                                                .build())
                                        .collect(Collectors.toList()))
                                .map(role -> role.persistAndFlush())
                                .subscribe().with(item -> LOGGER.info("Something happened"), failure -> LOGGER.info("Something bad happened"));
                    }
                    return null;
                }).subscribe().with(o -> {
                });
    }

当我运行应用程序时，它没有给出任何错误，日志显示发生了什么，数据库创建了表，但是它没有插入任何内容。我尝试过不同的方法，但是，我没有成功地使它像我希望的那样工作。

Answer 1

根据@Haroon的回答和@Clement的评论，我做了以下工作

• 删除了@ReactiveTransactional，因为我的方法返回空并且不在REST边界上
• 当我删除注释时，我需要使用Panache.with事务方法
• 最后在方法中我订阅了多

需要注意的是，我将TransformTounianedMerge从@Haroon答案更改为transformToUniAndConcatenate，以维护角色的顺序。

public void seedRoles() {
        Role.existsRoleSeed()
                .onItem().transformToMulti(exists -> {
                    if (!exists) {
                        return Multi.createFrom().items(Role.UserRole.values());
                    } else {
                        return Multi.createFrom().nothing();
                    }
                })
                .map(userRole -> Role.builder().name(userRole).build())
                .onItem().transformToUniAndConcatenate(role -> Panache.withTransaction(role::persist))
                .subscribe().with(subscription -> LOGGER.infov("Persisting: {0}", subscription));
    }