多租户 Spring Boot 应用程序中的 Hibernate Search 初始化索引

Question

我有一个使用 Hibernate 的 Spring Boot 应用程序，我正在向它添加 Hibernate Search。该应用程序使用带有 Hibernate 的模式分离的多租户，实现 MultiTenantConnectionProvider 和 CurrentTenantIdentifierResolver

我想在应用程序启动时创建初始搜索索引（或重新索引），以便能够搜索现有数据。

这是执行索引的服务：

@Service
public class SearchService {

    @PersistenceContext
    private EntityManager entityManager;

    @Transactional
    public void initializeSearchIndex() {

        try {
            FullTextEntityManager fullTextEntityManager = Search.getFullTextEntityManager(entityManager);
            fullTextEntityManager.createIndexer().startAndWait();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

但问题是我不知道在哪里调用此服务。因为它使用EntityManager 而不是DataSource，所以它似乎与单个租户（数据库模式）相关联。有没有办法为整个数据库创建索引？如果是这样，在哪里调用它？

Answer 1

基本上，您需要为每个租户打开不同的会话（实体管理器）。您不能使用单一的跨租户质量索引器，因为这违背了多租户的概念：严格分离对每个租户数据的访问。

我不知道使用 Spring boot 正确执行此操作的确切方法，但您的代码将如下所示：

@Service
public class SearchService {

    @PersistenceUnit
    private EntityManagerFactory entityManagerFactory;

    public void initializeSearchIndex() {
        SessionFactory sessionFactory = entityManagerFactory.unwrap(SessionFactory.class);
        for (String tenantId : getAllTenantIds()) {
            try (Session session = sessionFactory.withOptions().tenantIdentifier(tenantId).openSession()) {
                FullTextEntityManager fullTextEntityManager = Search.getFullTextEntityManager(session);
                fullTextEntityManager.createIndexer().startAndWait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    List<String> getAllTenantIds() {
         // return all tenant Ids
    }
}