Quarkus Panache ORM数据库错误/异常捕获方法咨询

Hibernate with Panache的persist()/persistAndFlush()方法会将底层数据库异常包装在javax.persistence.PersistenceException中，无法直接捕获JDBC层的特定异常（如唯一约束冲突），需要逐层拆解异常链定位问题：

1. 直接捕获并拆解异常链 #

通过getCause()遍历异常链，定位到JDBC标准的SQLIntegrityConstraintViolationException（对应唯一约束、主键冲突等完整性约束异常）：

import javax.persistence.PersistenceException;
import java.sql.SQLIntegrityConstraintViolationException;
import javax.ws.rs.WebApplicationException;
import javax.ws.rs.core.Response;

// 业务代码示例
public void saveMember(Member member) {
    try {
        member.persist(); // Panache持久化方法
    } catch (PersistenceException e) {
        // 逐层获取根源异常
        Throwable rootCause = e.getCause();
        while (rootCause != null && !(rootCause instanceof SQLIntegrityConstraintViolationException)) {
            rootCause = rootCause.getCause();
        }

        if (rootCause instanceof SQLIntegrityConstraintViolationException) {
            // 处理唯一约束冲突：返回友好提示给前端
            throw new WebApplicationException("该会员账号已存在", Response.Status.CONFLICT);
        }

        // 处理其他持久化异常
        throw new WebApplicationException("数据保存失败，请稍后重试", Response.Status.INTERNAL_SERVER_ERROR);
    }
}

2. 按数据库错误码精准判断 #

不同数据库的完整性约束有特定SQL状态码，可进一步精准区分异常类型：

• MySQL唯一约束冲突：SQL状态码23000，错误码1062
• PostgreSQL唯一约束冲突：SQL状态码23505
• Oracle唯一约束冲突：SQL状态码23000，错误码1

示例代码：

if (rootCause instanceof SQLIntegrityConstraintViolationException) {
    SQLIntegrityConstraintViolationException sqlEx = (SQLIntegrityConstraintViolationException) rootCause;
    // 针对PostgreSQL唯一约束做处理
    if ("23505".equals(sqlEx.getSQLState())) {
        throw new WebApplicationException("该会员账号已存在", Response.Status.CONFLICT);
    }
}

3. 全局异常映射（推荐） #

通过Quarkus的ExceptionMapper实现全局异常处理，避免重复编写捕获逻辑：

import javax.persistence.PersistenceException;
import java.sql.SQLIntegrityConstraintViolationException;
import javax.ws.rs.core.Response;
import javax.ws.rs.ext.ExceptionMapper;
import javax.ws.rs.ext.Provider;

@Provider
public class PersistenceExceptionMapper implements ExceptionMapper<PersistenceException> {

    @Override
    public Response toResponse(PersistenceException e) {
        Throwable rootCause = e.getCause();
        while (rootCause != null && !(rootCause instanceof SQLIntegrityConstraintViolationException)) {
            rootCause = rootCause.getCause();
        }

        if (rootCause instanceof SQLIntegrityConstraintViolationException) {
            return Response.status(Response.Status.CONFLICT)
                    .entity("数据已存在，请勿重复提交")
                    .build();
        }

        return Response.status(Response.Status.INTERNAL_SERVER_ERROR)
                .entity("数据操作失败，请稍后重试")
                .build();
    }
}

内容的提问来源于stack exchange，提问作者Daniel W.