如何从JDBC的Connection获取表名实现通用实体deleteById方法

关于从Connection获取表名的可行性结论 #

这个思路不可行。Connection是JDBC中数据库连接的抽象对象，仅存储连接层面的元数据（比如默认schema、数据库版本、连接账号等），完全不感知业务层面的实体和表的映射关系。你调用getSchema()返回的public是当前连接的默认schema名，和你要操作的业务表没有任何关系，不可能通过Connection拿到你要删除的实体对应的表名。

通用deleteById方法实现方案 #

要实现通用删除，核心是建立实体类和表、主键的映射关系，推荐用注解+反射的方式实现，步骤如下：

1. 定义映射注解 #

首先定义两个注解用来标记实体对应的表和主键：

// 标记实体对应的表名
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
public @interface Table {
    String value();
}

// 标记实体的主键字段
@Target(ElementType.FIELD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Id {
}

2. 改造实体类 #

让你的实体类继承Entity基类，加上对应的注解，以Student类为例：

@Table("students")
public class Student extends Entity {
    @Id
    private Integer studentId;
    // 其他字段、getter、setter省略
}

3. 实现通用deleteById方法 #

通过反射读取实体的注解信息，动态拼接删除SQL：

@Override
public void deleteById(Entity entity, Connection connection) {
    // 1. 读取实体的@Table注解获取表名
    Table tableAnno = entity.getClass().getAnnotation(Table.class);
    if (tableAnno == null || tableAnno.value().isBlank()) {
        throw new IncorrectSqlQueryException("实体类未配置@Table注解，无法获取对应表名");
    }
    String tableName = tableAnno.value();

    // 2. 读取标记了@Id的字段作为主键
    Field idField = null;
    for (Field field : entity.getClass().getDeclaredFields()) {
        if (field.isAnnotationPresent(Id.class)) {
            idField = field;
            break;
        }
    }
    if (idField == null) {
        throw new IncorrectSqlQueryException("实体类未配置@Id主键注解，无法确定删除条件");
    }
    idField.setAccessible(true);
    Object idValue;
    try {
        idValue = idField.get(entity);
    } catch (IllegalAccessException e) {
        throw new IncorrectSqlQueryException("读取实体主键值失败", e);
    }
    if (idValue == null) {
        throw new IncorrectSqlQueryException("实体主键值为空，无法执行删除");
    }

    // 3. 拼接SQL执行删除
    String deleteSql = String.format("DELETE FROM %s WHERE %s = ?", tableName, idField.getName());
    try (PreparedStatement st = connection.prepareStatement(deleteSql)) {
        st.setObject(1, idValue);
        st.executeUpdate();
    } catch (SQLException ex) {
        throw new IncorrectSqlQueryException("按ID删除实体失败，表名：" + tableName, ex);
    }
}

优化建议 #

• 如果对性能要求较高，可以提前缓存所有实体类的表名、主键信息，避免每次删除都反射扫描字段
• 如果你的主键字段名和数据库列名不一致，可以给@Id或@Table注解增加列名映射的属性
• 可以额外加事务控制的逻辑，避免异常导致数据不一致

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