Spring Boot/Spring Data如何动态映射PostgreSQL中按月生成的同结构业务表

以下方案均适配你提到的PostgreSQL按月分表（表名规则movprodXXZZ，结构完全一致）的业务场景：

方案1：Spring Data JPA 环境下使用Hibernate表名拦截器 #

适用于已经用JPA做实体映射的项目，无需改造原有Repository接口：

• 第一步：先给实体类设置占位表名，后续通过拦截器替换为实际表名

@Data
@Entity
@Table(name = "movprod_placeholder")
public class MvProdEntity {
    // 所有字段和分表字段完全对应即可
    @Id
    private Long id;
    // 其他业务字段省略
}

• 第二步：自定义表名持有者，用ThreadLocal存储当前查询的年月，避免多线程参数冲突

public class MvProdTableNameHolder {
    private static final ThreadLocal<YearMonth> HOLDER = new ThreadLocal<>();

    public static void set(YearMonth ym) {
        HOLDER.set(ym);
    }

    public static YearMonth get() {
        return HOLDER.get();
    }

    public static void clear() {
        HOLDER.remove();
    }
}

• 第三步：自定义Hibernate语句拦截器，替换SQL中的占位表名

public class MvProdTableNameInterceptor extends EmptyInterceptor {
    @Override
    public String onPrepareStatement(String sql) {
        YearMonth queryYm = MvProdTableNameHolder.get();
        if (queryYm != null) {
            // 按规则生成真实表名：movprodXXZZ，XX是月份，ZZ是年份后两位
            String realTableName = String.format("movprod%02d%02d", 
                queryYm.getMonthValue(), 
                queryYm.getYear() % 100
            );
            sql = sql.replaceAll("movprod_placeholder", realTableName);
        }
        return super.onPrepareStatement(sql);
    }
}

• 第四步：Spring Boot下注册拦截器到JPA配置，在application.yml添加配置：

spring:
  jpa:
    properties:
      hibernate:
        session_factory:
          statement_inspector: 你的项目包路径.MvProdTableNameInterceptor

• 调用示例：

// 查询2021年1月的数据
try {
    MvProdTableNameHolder.set(YearMonth.of(2021, 1));
    List<MvProdEntity> result = mvProdRepository.findAll(你的查询条件);
} finally {
    // 必须清除ThreadLocal，避免线程复用导致表名错误
    MvProdTableNameHolder.clear();
}

方案2：Spring Data JDBC 环境下自定义动态SQL #

适用于轻量查询场景，不需要依赖JPA的实体管理能力，更灵活：
直接用NamedParameterJdbcTemplate拼接表名，注意表名不能作为预编译参数，需要提前生成好再拼接，同时做好参数合法性校验避免SQL注入：

@Repository
public class MvProdCustomRepository {
    @Resource
    private NamedParameterJdbcTemplate jdbcTemplate;

    public List<MvProdEntity> queryByMonth(YearMonth queryYm, String bizParam) {
        // 先校验年月合法性，避免SQL注入
        if (queryYm.getYear() < 2020 || queryYm.getYear() > LocalDate.now().getYear()) {
            throw new IllegalArgumentException("不支持的查询年份");
        }
        // 生成真实表名
        String realTableName = String.format("movprod%02d%02d", 
            queryYm.getMonthValue(), 
            queryYm.getYear() % 100
        );
        // 拼接SQL，业务参数用预编译占位符
        String sql = "select * from " + realTableName + " where biz_column = :bizParam";
        MapSqlParameterSource params = new MapSqlParameterSource().addValue("bizParam", bizParam);
        // 执行查询映射结果
        return jdbcTemplate.query(sql, params, new BeanPropertyRowMapper<>(MvProdEntity.class));
    }
}

注意事项 #

• 所有传入的年月参数必须做范围校验，禁止直接拼接外部传入的字符串作为表名，避免SQL注入风险
• 跨月查询场景可以自行在拦截器或者SQL拼接层实现多表UNION ALL逻辑
• 如果你的项目用的是MyBatis/MyBatis-Plus，也可以直接用内置的动态表名插件实现，逻辑和上述方案类似

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