java中处理mysql sqlexception应采用策略模式加自定义注解解耦异常类型与处理逻辑，通过@sqlerrortype注解标记sqlstate和vendorcode，实现锁超时、主键冲突等场景的独立恢复策略。

Java 中处理 MySQL 的 SQLException，关键不是捕获后硬编码判断 SQLState 或错误码，而是把“异常类型→处理策略”的映射关系解耦出来。用策略模式 + 自定义注解，能让锁超时、主键冲突、语法错误等场景各自有独立的恢复逻辑（比如重试、降级、告警），且新增异常类型不改原有代码。

定义异常分类注解 @SqlErrorType

先声明一个运行时注解，用于标记每种策略类对应哪类 MySQL 异常：

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
public @interface SqlErrorType {
    String sqlState() default "";        // SQLState 五位码，如 "40001"
    int vendorCode() default 0;          // MySQL 错误号，如 1205（死锁）
    Class extends Throwable> type() default SQLException.class;
}

这个注解不绑定具体语义，只提供匹配维度：可按 SQLState、MySQL 原生错误码、或异常子类三选一或组合使用。

编写策略接口与具体实现

定义统一策略接口，每个实现类专注一种异常的业务应对逻辑：

public interface SqlExceptionStrategy {
    void handle(SQLException e, Object context);
}

例如针对死锁重试：

Java Development Manual

Java开发手册规约集合，基于阿里巴巴Java开发手册（嵩山版）。 涵盖7大维度：编程规约、异常日志、单元测试、安全规约、MySQL数据库、工程结构、设计规约。 当用户需要：(1) 编写或审查Java代码 (2) 检查命名/代码规范 (3) 处理异常和日志 (4) 编写单元测试 (5) 安全编码 (6) 数据库设...

下载

@SqlErrorType(vendorCode = 1205) // MySQL Deadlock
public class DeadlockRetryStrategy implements SqlExceptionStrategy {
    @Override
    public void handle(SQLException e, Object context) {
        // 可结合 context（如原 DAO 方法名、参数）做有限次重试
        if (context instanceof Map) {
            Integer retryCount = (Integer) ((Map) context).get("retry");
            if (retryCount == null || retryCount 

再如主键冲突转更新：

@SqlErrorType(sqlState = "23000") // SQLState 通用约束违例
public class DuplicateKeyUpsertStrategy implements SqlExceptionStrategy {
    @Override
    public void handle(SQLException e, Object context) {
        // 解析原始 SQL 或上下文，生成对应的 INSERT ... ON DUPLICATE KEY UPDATE
        // 或调用预定义的 upsert 方法
    }
}

语法错误则直接记录并抛出业务异常：

@SqlErrorType(sqlState = "42000") // 语法/访问规则错误
public class SqlSyntaxAlertStrategy implements SqlExceptionStrategy {
    @Override
    public void handle(SQLException e, Object context) {
        log.error("SQL syntax error in {}: {}", context, e.getMessage());
        throw new BusinessException("SQL 编写有误，请检查", e);
    }
}

构建策略查找与分发器

启动时扫描所有带 @SqlErrorType 的策略类，缓存为 Map，按异常特征快速匹配：

public class SqlExceptionStrategyRegistry {
    private final Map<string sqlexceptionstrategy> bySqlState = new HashMap();
    private final Map<integer sqlexceptionstrategy> byVendorCode = new HashMap();

    public SqlExceptionStrategyRegistry(List<class>> strategyClasses) {
        for (Class> clazz : strategyClasses) {
            SqlErrorType ann = clazz.getAnnotation(SqlErrorType.class);
            if (ann != null) {
                try {
                    SqlExceptionStrategy instance = (SqlExceptionStrategy) clazz.getDeclaredConstructor().newInstance();
                    if (!ann.sqlState().isEmpty()) {
                        bySqlState.put(ann.sqlState(), instance);
                    }
                    if (ann.vendorCode() != 0) {
                        byVendorCode.put(ann.vendorCode(), instance);
                    }
                } catch (Exception ignored) {}
            }
        }
    }

    public SqlExceptionStrategy findStrategy(SQLException e) {
        // 优先匹配 vendorCode（MySQL 错误号最精准）
        SqlExceptionStrategy s = byVendorCode.get(e.getErrorCode());
        if (s != null) return s;
        // 其次匹配 SQLState
        s = bySqlState.get(e.getSQLState());
        if (s != null) return s;
        // 最后 fallback 到通用策略（可选）
        return new DefaultSqlStrategy();
    }
}</class></integer></string>

在 DAO 层或拦截器中统一应用

不在每个 dao 方法里写 try-catch，而是集中拦截 SQLException：

public class SqlExceptionHandlingInterceptor {
    private final SqlExceptionStrategyRegistry registry;

    public Object invoke(MethodInvocation invocation) throws Throwable {
        try {
            return invocation.proceed();
        } catch (SQLException e) {
            SqlExceptionStrategy strategy = registry.findStrategy(e);
            strategy.handle(e, buildContext(invocation)); // 传入方法、参数等上下文
            return null; // 或抛出包装后的业务异常
        }
    }

    private Map<string object> buildContext(MethodInvocation mi) {
        return Map.of(
            "method", mi.getMethod().getName(),
            "args", mi.getArguments(),
            "target", mi.getThis()
        );
    }
}</string>

这样，当 insert 报错 1062（Duplicate entry），自动走 DuplicateKeyUpsertStrategy；update 报 1205，触发 DeadlockRetryStrategy —— 无需修改 DAO 代码，只需加注解和实现类。

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南