主页 / coding / 问题 / 79092759
Accepted
Amith Sai
Asked: 2024-10-16 14:44:18 +0800 CST

Quarkus Hibernate Reactive 未在 onFailure() 块中捕获 ConstraintViolationException

  • 772

我正在使用 Hibernate Reactive 和 PostgreSQL 开发一个 Quarkus 项目。我有一个将新用户保留在数据库中的方法，并且我想处理由于电子邮件字段的唯一约束而导致重复用户（相同电子邮件）导致 ConstraintViolationException 的情况。

我使用 .onFailure() 设置了一个错误处理块来捕获此异常并抛出自定义 UserAlreadyExistsException。但是，该异常并未在故障块中被捕获，相反，我在日志中看到了未捕获的 ConstraintViolationException。

@POST
    @Path("/register")
    @WithTransaction
    @Consumes(MediaType.APPLICATION_JSON)
    @Produces(MediaType.APPLICATION_JSON)
    public Uni<Response> registerUser(@Valid Auth authRequest) {
        return authService.createUser(authRequest)
                .onItem().transform(success -> Response.status(Response.Status.CREATED)
                        .entity(success).build())
                .onFailure()
                .recoverWithItem(ex -> {
                    log.error("Unable to create User, email: {}, Exception: {}", authRequest.getEmail(), ex.getMessage(), ex);
                    ErrorResponse errorResponse = new ErrorResponse(ex.getMessage(), Response.Status.INTERNAL_SERVER_ERROR);
                    return Response.status(Response.Status.INTERNAL_SERVER_ERROR).entity(errorResponse).build();
                });
    }


public Uni<Auth> createUser(Auth authRequest) {
        User user = new User(authRequest);
        String passwordHash = Password.hash(authRequest.getPassword()).withArgon2().getResult();
        user.setPasswordHash(passwordHash);
        return PanacheEntityBase.persist(user).onItem().transform(success -> {
            log.info("Successfully created user, email: {}", authRequest.getEmail());
            return authRequest;
        })
        .onFailure().invoke(ex -> {
            log.error("Unable to create User, email: {}, Exception: {}",
                    authRequest.getEmail(), ex.getMessage(), ex);
            throw new RegistrationFailedException(Errors.UNABLE_TO_REGISTER_USER + ex.getMessage());
        });
    }

我的期望：

当尝试插入具有现有电子邮件（重复键）的用户时，onFailure（）块应捕获 ConstraintViolationException，并抛出自定义 UserAlreadyExistsException。

会发生什么：

错误没有被 onFailure() 块捕获，而是返回了以下错误：

org.hibernate.exception.ConstraintViolationException: error executing SQL statement
[ERROR: duplicate key value violates unique constraint "user_email_key" (23505)]

看起来失败处理程序没有捕获异常，并且我得到了未捕获的异常响应。

quarkus

1 个回答

  1. Best Answer

    调用.persist告诉 Hibernate 该对象需要保存在数据库中，但它并没有告诉插入查询实际上应该何时发生。

    在您的用例中，查询是在事务提交时执行的。由于您已@WithTransaction在 REST 端点上添加，因此它发生在.recoverWithFailure范围之外。

    您有以下几种选择：

    1. 刷新操作：而不是.persist，你可以调用.persistAndFlush
    2. 提交事务然后捕获失败。例如： 
      public Uni<Auth> createUser(Auth authRequest) {
    User user = new User(authRequest);
    String passwordHash = Password.hash(authRequest.getPassword()).withArgon2().getResult();
    user.setPasswordHash(passwordHash);
    return Panache
             .withTransaction( () -> PanacheEntityBase.persist( user ) )
             .onItem().transform( success -> {
                 log.info( "Successfully created user, email: {}", authRequest.getEmail() );
                 return authRequest;
             } )
             .onFailure().invoke( ex -> {
                 log.error( "Unable to create User, email: {}, Exception: {}", authRequest.getEmail(), ex.getMessage(), ex );
                 throw new RegistrationFailedException( Errors.UNABLE_TO_REGISTER_USER + ex.getMessage() );
             } );
}

    第二种方法通常是推荐的方法，因为您应该让 Hibernate 决定运行查询的最佳时间。

    顺便说一句，我还没有测试过，但您也可以使用以下方法重新映射异常@ServerExceptionMapper：https://quarkus.io/guides/rest#exception-mapping

    • 3

相关问题