elasticsearchtemplate 工具类实现不同的type关联查询
时间: 2023-11-21 07:06:13 浏览: 80
Elasticsearch使用工具类
ElasticsearchTemplate 是 Spring Data Elasticsearch 提供的 Elasticsearch 操作模板类,可以方便地进行 Elasticsearch 的操作。关于 ElasticsearchTemplate 的使用,可以参考官方文档。
关于不同 type 关联查询的实现,需要先了解 Elasticsearch 中的 mapping 和 routing。
mapping:定义了索引中的字段类型、分词方式、存储方式等信息。在创建索引时可以指定 mapping,也可以自动创建。
routing:用于将文档路由到对应的 shard 上。在创建索引时可以指定 routing,也可以自动路由。
在 Elasticsearch 中,一个索引可以有多个 type,每个 type 可以有不同的 mapping 和 routing。因此,不同 type 之间可以进行关联查询。
下面是一个简单的示例,假设索引名为 my_index,有两个 type:user 和 role。
User:
```
{
"user_id": 1,
"username": "john",
"role_id": 1
}
```
Role:
```
{
"role_id": 1,
"name": "admin"
}
```
我们想要查询 username 为 john 的用户所属的角色信息,可以使用 ElasticsearchTemplate 的 queryForList 方法进行查询:
```
QueryBuilder userQuery = QueryBuilders.termQuery("username", "john");
SearchQuery searchQuery = new NativeSearchQueryBuilder()
.withQuery(userQuery)
.withTypes("user")
.build();
List<User> users = elasticsearchTemplate.queryForList(searchQuery, User.class);
if (!users.isEmpty()) {
User user = users.get(0);
QueryBuilder roleQuery = QueryBuilders.termQuery("role_id", user.getRoleId());
searchQuery = new NativeSearchQueryBuilder()
.withQuery(roleQuery)
.withTypes("role")
.build();
List<Role> roles = elasticsearchTemplate.queryForList(searchQuery, Role.class);
}
```
在这个例子中,我们先通过 username 查询到了对应的 user,然后再根据 user 的 role_id 查询对应的 role。需要注意的是,查询时需要指定 type,以便 Elasticsearch 能够正确路由查询请求。
阅读全文