求Hibernate基于Schema的多租户实现参考（JPA环境）

核心配置步骤 #

1. 配置Hibernate多租户策略 #

在persistence.xml中指定多租户策略为SCHEMA，并关联自定义的租户解析器和连接提供者：

<property name="hibernate.multiTenancy" value="SCHEMA"/>
<property name="hibernate.tenant_identifier_resolver" value="com.yourpackage.CustomTenantIdentifierResolver"/>
<property name="hibernate.multi_tenant_connection_provider" value="com.yourpackage.CustomMultiTenantConnectionProvider"/>

2. 实现租户标识符解析器 #

负责在运行时获取当前登录客户端对应的租户Schema名称：

public class CustomTenantIdentifierResolver implements CurrentTenantIdentifierResolver {
    @Override
    public String resolveCurrentTenantIdentifier() {
        // 从JSF会话中获取登录用户的租户信息
        FacesContext context = FacesContext.getCurrentInstance();
        if (context != null) {
            LoggedUser user = (LoggedUser) context.getExternalContext().getSessionMap().get("currentUser");
            return user.getTenantSchema();
        }
        // 无上下文时返回默认Schema
        return "default_tenant";
    }

    @Override
    public boolean validateExistingCurrentSessions() {
        return true;
    }
}

3. 实现多租户连接提供者 #

根据租户ID切换MySQL数据库Schema：

public class CustomMultiTenantConnectionProvider implements MultiTenantConnectionProvider {
    private final ConnectionProvider baseProvider;

    public CustomMultiTenantConnectionProvider() {
        baseProvider = new DriverManagerConnectionProviderImpl();
        // 初始化基础连接配置
        Properties props = new Properties();
        props.put("hibernate.connection.driver_class", "com.mysql.jdbc.Driver");
        props.put("hibernate.connection.url", "jdbc:mysql://localhost:3306/");
        props.put("hibernate.connection.username", "db_username");
        props.put("hibernate.connection.password", "db_password");
        baseProvider.configure(props);
    }

    @Override
    public Connection getConnection(String tenantIdentifier) throws SQLException {
        Connection conn = baseProvider.getConnection();
        // 切换到指定Schema
        conn.createStatement().execute("USE " + tenantIdentifier);
        return conn;
    }

    @Override
    public void releaseConnection(String tenantIdentifier, Connection connection) throws SQLException {
        // 切回默认Schema后释放连接
        connection.createStatement().execute("USE default_tenant");
        baseProvider.releaseConnection(connection);
    }

    // 实现剩余必要接口方法
    @Override
    public boolean isUnwrappableAs(Class<?> clazz) {
        return baseProvider.isUnwrappableAs(clazz);
    }

    @Override
    public <T> T unwrap(Class<T> clazz) {
        return baseProvider.unwrap(clazz);
    }

    @Override
    public boolean supportsAggressiveRelease() {
        return baseProvider.supportsAggressiveRelease();
    }
}

关键注意事项 #

• Schema预准备：提前为每个租户创建对应的MySQL Schema，确保数据库用户拥有所有租户Schema的访问权限。
• 会话同步：JSF登录流程中必须将用户的租户Schema信息存入会话，保证解析器能正确获取标识。
• EJB场景适配：在无JSF上下文的EJB方法中，可通过@Context SessionContext注入上下文，从用户Principal或自定义属性中提取租户ID。
• 版本兼容：你的Hibernate 4.3.5.Final完全支持Schema多租户策略，无需升级核心依赖。

调试技巧 #

• 开启Hibernate SQL日志，验证USE语句是否正确执行：

<property name="hibernate.show_sql" value="true"/>
<property name="hibernate.format_sql" value="true"/>

• 检查连接池：若使用第三方连接池（如C3P0），需确保连接提供者适配池化逻辑，避免连接泄漏。

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