JPA编程，去重查询ES索引中的字段，对已有数据的去重过滤，而非全部字典数据

一、配景

课程管理界面，查询前，必要把查询元数据给出。
学科列表、学段列表和分类列表，我们把它界说为查询元数据。

一样平常的业务需求是：
体系维护许多多少个字典，比如学科、学段等等，相当于属性库。
但是，这有一个不友爱的地方，字典列表数据过多，比如学段字典包罗了幼儿园和大学等，而现实上，课程只有初中或高中，连小学学段也没有。
如许展示的学段列表，就显得数据冗余，增长选择的干扰。
修改后的需求：
基于已有课程的属性，举行去重查询出学科列表等数据，也即上文提到的查询元数据。（已非原始字典）
比如说，我创建了一个课程，它是数学科目，初中学段，那么查询列表中的学科列表就只有数学一个值，学段列表只有初中一个值。
后期创建了一个化学科目标高中课程，此时学科列表就有数学和化学两个学科，学段包罗初中和高中。
二、es索引

1. @Data
2. @Document(indexName = "#{commonConfig.courseIdx}", type = "_doc", shards = 1, refreshInterval = "-1")
3. public class CourseIndex implements Serializable {
5.     @Id
6.     private String id;
8.     /**
9.      * 课程编号
10.      */
11.     @Field(type = FieldType.Keyword)
12.     private String courseNo;
14.     /**
15.      * 创建者ID
16.      */
17.     @Field(type = FieldType.Long)
18.     private long creatorId;
20.     /**
21.      * 课程名称
22.      */
23.     @Field(type = FieldType.Text)
24.     private String name;
25.    
26.     /**
27.      * 科目
28.      */
29.     @Field(type = FieldType.Integer)
30.     private int subject;
32.     /**
33.      * 学段
34.      */
35.     @Field(type = FieldType.Integer)
36.     private int stage;
37. }

复制代码

三、es聚合查询

2. import lombok.RequiredArgsConstructor;
3. import org.elasticsearch.index.query.BoolQueryBuilder;
4. import org.elasticsearch.index.query.QueryBuilders;
5. import org.elasticsearch.search.aggregations.Aggregation;
6. import org.elasticsearch.search.aggregations.AggregationBuilders;
7. import org.elasticsearch.search.aggregations.bucket.terms.ParsedLongTerms;
8. import org.elasticsearch.search.aggregations.bucket.terms.Terms;
9. import org.elasticsearch.search.aggregations.bucket.terms.TermsAggregationBuilder;
10. import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
11. import org.springframework.data.elasticsearch.core.aggregation.AggregatedPage;
12. import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
13. import org.springframework.stereotype.Component;
15. import java.util.ArrayList;
16. import java.util.List;
18. @Component
19. @RequiredArgsConstructor
20. public class CourseIndexAggrService {
21.     private final ElasticsearchRestTemplate elasticsearchRestTemplate;
22.     private static final String UNIQUE_FIELD = "unique_field";
24.     public static final String SUBJECT = "subject";
25.     public static final String STAGE = "stage";
27.     public List<String> findUniqueField(String uniqueField) {
28.         NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();
29.         BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
30.         boolQueryBuilder.filter(QueryBuilders.termQuery("deleted", LogicDeleteEnum.OK.ordinal()));
31.         queryBuilder.withQuery(boolQueryBuilder);
33.         TermsAggregationBuilder termsAgg = AggregationBuilders.terms(UNIQUE_FIELD).field(uniqueField);
35.         queryBuilder.addAggregation(termsAgg);
37.         queryBuilder.withIndices("course_index");
39.         AggregatedPage<CourseIndex> resultPage = elasticsearchRestTemplate.queryForPage(queryBuilder.build(), CourseIndex.class);
41.         Aggregation aggregation = resultPage.getAggregation(UNIQUE_FIELD);
43.         ParsedLongTerms terms = (ParsedLongTerms) aggregation;
45.         // 获取桶
46.         final List<? extends Terms.Bucket> buckets = terms.getBuckets();
48.         // 提取唯一值
49.         List<String> uniqueUserIds = new ArrayList<>();
50.         for (Terms.Bucket bucket : buckets) {
51.             uniqueUserIds.add(bucket.getKeyAsString());
52.         }
54.         return uniqueUserIds;
55.     }
56. }

复制代码

四、调用示例

1. // 科目列表
2. final List<Integer> subjects = courseIndexAggrService.findUniqueField(SUBJECT).stream().map(v -> Integer.parseInt(v)).collect(Collectors.toList());
4. // 学段列表
5. final List<Integer> stages = courseIndexAggrService.findUniqueField(STAGE).stream().map(v -> Integer.parseInt(v)).collect(Collectors.toList());

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。