是的。春天是可能的。但是您应该使用 ElasticsearchTemplate 而不是 .Repository
例如。我有两个产品。它们存储在不同的索引中。
@Document(indexName = "product-a", type = "product")
public class ProductA {
@Id
private String id;
private String name;
private int value;
//Getters and setters
}
@Document(indexName = "product-b", type = "product")
public class ProductB {
@Id
private String id;
private String name;
//Getters and setters
}
假设它们具有相同的类型,因此它们具有相同的字段。但这不是必需的。两种产品可以有完全不同的领域。
我有两个存储库:
public interface ProductARepository extends ElasticsearchRepository<ProductA, String> {
}
public interface ProductBRepository
extends ElasticsearchRepository<ProductB, String> {
}
这也没有必要。仅用于测试。存储在“产品-a”索引中并存储在“产品-b”索引中的事实。ProductA
ProductB
如何查询相同类型的两个(十个,十几个)索引?
只需构建这样的自定义存储库
@Repository
public class CustomProductRepositoryImpl {
@Autowired
private ElasticsearchTemplate elasticsearchTemplate;
public List<ProductA> findProductByName(String name) {
MatchQueryBuilder queryBuilder = QueryBuilders.matchPhrasePrefixQuery("name", name);
//You can query as many indices as you want
IndicesQueryBuilder builder = QueryBuilders.indicesQuery(queryBuilder, "product-a", "product-b");
SearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(builder).build();
return elasticsearchTemplate.query(searchQuery, response -> {
SearchHits hits = response.getHits();
List<ProductA> result = new ArrayList<>();
Arrays.stream(hits.getHits()).forEach(h -> {
Map<String, Object> source = h.getSource();
//get only id just for test
ProductA productA = new ProductA()
.setId(String.valueOf(source.getOrDefault("id", null)));
result.add(productA);
});
return result;
});
}
}
您可以根据需要搜索任意数量的索引,并且可以透明地将此行为注入到将自定义行为添加到单个存储库中ProductARepository
第二种解决方案是使用索引别名,但您还必须创建自定义模型或自定义存储库。