hibernate - MultiTenant Hibernate + Spring boot - 如何防止它在服务器启动期间查找连接

标签 hibernate spring-boot multi-tenant

我们正在使用 Multi-Tenancy hibernate + Spring 引导,如 Multi-Tenancy in Hibernate 中所述.我们在创建实体管理器时提供 MultiTenantConnectionProvider 和 CurrentTenantIdentifierResolver(请参阅下面的示例)。

在我们的 MultiTenantConnectionProvider 中,租户的目标数据库不是静态配置的。相反,它通过调用另一个服务动态确定当前租户的目标数据库详细信息,然后为其创建数据源。

现在,我们面临一个问题,即当 spring boot 服务器启动时,Hibernate 正在调用 MultiTenantConenctionProvider.getAnyConnection() 方法。在服务器启动时,上下文中没有租户,因此我们没有任何数据库可以为其创建连接。此外,我们的设置中没有任何可以在服务器启动时使用的虚拟数据库

  1. 如果我们返回 null,则服务器启动失败并出现 NullPointerException
  2. 如果我们重写 anyConnection() 方法并抛出异常(如下面的代码所示),服务器只会记录异常并继续启动服务器。

对于 2,一切正常,我们能够取得进展。但是,我们真的希望摆脱每次重新启动 spring boot 服务器时记录的这种不必要的异常。

我们正在寻找一种方法来关闭 hibernate 在服务器启动期间尝试连接到数据库的行为,尤其是当设置了 hibernate 的 Multi-Tenancy 策略时。这种行为对于 Multi-Tenancy 软件是不一致的

有什么办法可以防止 hiberate 在服务器启动期间尝试建立连接(即调用 MultiTenantConenctionProvider.getAnyConnection())?

请指教

以下是我们的 Spring 配置示例

@Configuration
@EnableTransactionManagement
public class MultiTenantHibernateJpaConfig {

    @Autowired
    private JpaProperties jpaProperties;

    @Bean
    public MultiTenantConnectionProvider multiTenantConnectionProvider() {
        return new MultiTenantConnectionProviderImpl();
    }

    @Bean
    public CurrentTenantIdentifierResolver currentTenantIdentifierResolver() {
        return new CurrentTenantIdentifierResolverImpl();
    }

    @Value("${jpaconfig.packages-to-scan:#{null}}")
    private String packagesToScan;

    @Bean
    @Primary
    public LocalContainerEntityManagerFactoryBean entityManagerFactory(MultiTenantConnectionProvider multiTenantConnectionProvider,
                                                                       CurrentTenantIdentifierResolver currentTenantIdentifierResolver) {

        Map<String, Object> hibernateProps = new LinkedHashMap<>();
        hibernateProps.put(Environment.MULTI_TENANT, MultiTenancyStrategy.SCHEMA);
        hibernateProps.put(Environment.MULTI_TENANT_CONNECTION_PROVIDER, multiTenantConnectionProvider);
        hibernateProps.put(Environment.MULTI_TENANT_IDENTIFIER_RESOLVER, currentTenantIdentifierResolver);

        hibernateProps.put("javax.persistence.schema-generation.database.action", "none");
        hibernateProps.put("javax.persistence.query.timeout", "5");
        hibernateProps.put(Environment.DIALECT, "org.hibernate.dialect.Oracle10gDialect");
        hibernateProps.putAll(this.jpaProperties.getProperties());

        LocalContainerEntityManagerFactoryBean result = new LocalContainerEntityManagerFactoryBean();
        if(packagesToScan != null) {
            //handle multiple packages separated by comma
            result.setPackagesToScan(packagesToScan.split("\\s*,\\s*"));
        }
        result.setJpaVendorAdapter(new HibernateJpaVendorAdapter());
        result.setJpaPropertyMap(hibernateProps);

        return result;
    }

下面是MultiTenantConnectionProvider的实现

public class MultiTenantConnectionProviderImpl extends AbstractDataSourceBasedMultiTenantConnectionProviderImpl {

    private static final long serialVersionUID = 1L;


    public MultiTenantConnectionProviderImpl()
    {
    }

    @Override
    protected DataSource selectAnyDataSource()
    {
        return null;
    }

    @Override
    protected DataSource selectDataSource(String tenantIdentifier) {
        //This in turn makes a call to a remote service to fetch current tenant 
        //database details and then creates a datasource for it.
        return DataSourceManager.getDataSource(tenantIdentifier);
    }

    @Override
    public Connection getAnyConnection() throws SQLException{
        //Called during server startup. Cannot do any thing  as tenant is not known
        // and there is no default datasource
        throw new SQLException("not implemented in multi-tenant environment");
    }

    @Override
    public void releaseAnyConnection(Connection connection) throws SQLException
    {
        //Called during server startup. Cannot do any thing  as tenant is not known
        // and there is no default datasource
        throw new SQLException("not implemented in multi-tenant environment");
    }
}

最佳答案

这只在启动期间调用,为什么不使用默认的租户标识符来启动呢?

更新:

所以如果这是不可能的。为什么不使用 DummyConnection 类实现 Connection 接口(interface)并在启动时返回该接口(interface)?

关于hibernate - MultiTenant Hibernate + Spring boot - 如何防止它在服务器启动期间查找连接,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60385311/

相关文章:

java - 为什么我们总是将 Hibernate、Spring 和 Strut 放在一个应用程序中?

java - Spring Boot ddl 自动生成器

java - 通过 gradle 为 spring boot 应用构建 docker 镜像时的最佳实践

asp.net - 如何使用现有数据库/模式作为模板从 Asp.Net 应用程序以编程方式部署数据库?

azure - 当用户有权访问 1 个以上租户时,将在 "common"端点中选择哪个 Azure AD 租户?用户可以控制吗?

java - Hibernate 继承查询(条件)

java - Java + Hibernate中对象的匹配算法

java - 我可以否定(!) Spring 配置文件的集合吗?

java - 我正在使用 Java 创建一个博客应用程序。我是手动设置Id还是在Mysql DB中自动生成?

symfony1 - 使用 Doctrine 在 Symfony Multi-Tenancy 应用程序中进行数据分离