Hibernate：基于Schema多租户叠加按列实现数据版本化可行吗？

核心思路 #

既然已经基于Hibernate实现了Schema级多租户，我们可以把数据版本作为次级隔离维度，通过Hibernate全局过滤器自动注入版本过滤条件，全程避免修改现有实体类和业务查询代码，同时保证查询性能。

具体实现步骤 #

1. 统一添加版本鉴别列 #

不用逐个修改实体，通过@MappedSuperclass定义基类，让所有业务实体继承即可：

@MappedSuperclass
@FilterDef(
    name = "dataVersionFilter",
    parameters = @ParamDef(name = "version", type = "int")
)
@Filter(
    name = "dataVersionFilter",
    condition = "data_version = :version"
)
public class VersionedEntity {
    @Column(name = "data_version", nullable = false)
    private Integer dataVersion;

    @PrePersist
    public void prePersist() {
        // 默认写入当前上下文版本，无上下文时用版本1
        if (this.dataVersion == null) {
            this.dataVersion = TenantVersionContext.getCurrentVersion() != null 
                ? TenantVersionContext.getCurrentVersion() 
                : 1;
        }
    }

    // getter/setter
}

现有实体只需修改继承关系，比如public class User extends VersionedEntity {}，批量修改可借助代码生成工具或IDE重构功能完成。

2. 整合租户与版本上下文 #

扩展现有租户上下文，同时存储当前操作的版本号，保证线程安全：

public class TenantVersionContext {
    private static final ThreadLocal<String> TENANT_ID = new ThreadLocal<>();
    private static final ThreadLocal<Integer> DATA_VERSION = new ThreadLocal<>();

    public static void setContext(String tenantId, Integer version) {
        TENANT_ID.set(tenantId);
        DATA_VERSION.set(version);
    }

    public static String getCurrentTenant() {
        return TENANT_ID.get();
    }

    public static Integer getCurrentVersion() {
        return DATA_VERSION.get();
    }

    public static void clear() {
        TENANT_ID.remove();
        DATA_VERSION.remove();
    }
}

3. 自动激活版本过滤器 #

在请求拦截器或切面中，针对业务服务方法自动激活过滤器，无需修改业务代码：

@Aspect
public class VersionFilterActivator {
    @Autowired
    private EntityManagerFactory entityManagerFactory;

    @Before("execution(* com.yourcompany.service..*(..))")
    public void activateFilter() {
        Integer version = TenantVersionContext.getCurrentVersion();
        if (version != null) {
            Session session = entityManagerFactory.createEntityManager().unwrap(Session.class);
            session.enableFilter("dataVersionFilter").setParameter("version", version);
        }
    }
}

如果是基于Spring Boot，也可以在OpenEntityManagerInViewFilter中扩展逻辑，保证过滤器在整个请求周期生效。

4. 版本切换与数据初始化 #

• 初始化阶段：默认将TenantVersionContext的版本设为1，所有新写入数据自动带上data_version=1。
• 版本切换：只需调用TenantVersionContext.setContext("tenant1", 2)，后续所有查询会自动过滤版本2的数据，写入新数据也会默认用版本2。
• 批量版本升级：若需要将版本1的数据复制为版本2，直接用原生SQL批量执行，避免ORM开销：

INSERT INTO user (id, name, data_version) 
SELECT id, name, 2 FROM user WHERE data_version=1 AND tenant_schema = 'tenant1';

性能优化要点 #

• 给data_version字段单独或与业务主键创建联合索引，避免全表扫描：

CREATE INDEX idx_data_version ON user(data_version);

• 跨版本查询场景：临时调用session.disableFilter("dataVersionFilter")即可，用完记得重新激活。
• 禁用过滤器缓存：确保版本切换后过滤器参数即时生效，避免旧版本数据被缓存。

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