网站做优化按点击收费,wordpress登陆框,全屋定制十大名牌衣柜,专业网站建设公司郑州一、前言
注#xff1a;本文实现了Java对Elasticseach的分页检索/不分页检索的封装
ES就不用过多介绍了#xff0c;直接上代码#xff1a;
二、实现步骤#xff1a;
创建Store类#xff08;与ES字段对应#xff0c;用于接收ES数据#xff09;
import com.alibaba.f…一、前言
注本文实现了Java对Elasticseach的分页检索/不分页检索的封装
ES就不用过多介绍了直接上代码
二、实现步骤
创建Store类与ES字段对应用于接收ES数据
import com.alibaba.fastjson2.annotation.JSONField;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;/*** indexName 索引名称 理解为数据库名 限定小写* type 理解为数据库的表名称* shards 默认分区数* replicas 每个分区默认的备份数* refreshInterval 刷新间隔* indexStoreType 索引文件存储类型**/
Data
Builder
NoArgsConstructor
AllArgsConstructor
Document(indexName yourIndex, shards n, replicas n, refreshInterval n)
public class Store implements Serializable {/*** 属性与ES字段对应* 注Field注解* 若Java属性名与ES字段名不同则根据Field的name属性匹配ES字段* 若Java属性名与ES字段名完全相同则不用加该注解或name属性*/Field(name yourESfield)private String yourAttribute;
}Elasticsearch全文检索接口不分页检索
import com.alibaba.fastjson2.JSON;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.sort.SortOrder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;Slf4j
Component
public class Elasticsearch{Autowiredprivate RestHighLevelClient restHighLevelClient;/*** 不分页检索** param yourIndex 索引* param builder 搜索条件* param sortField 排序属性* param sortOrder 排序方式* param clazz 返回类* param T 泛型* return 分页表格*/SuppressWarnings(checkstyle:ParameterNumber)public T ListT searchListByCond(String yourIndex, BoolQueryBuilder builder, String sortField, SortOrder sortOrder, ClassT clazz) {SearchSourceBuilder sourceBuilder new SearchSourceBuilder();sourceBuilder.query(builder);if (StringUtils.isNotBlank(sortField)) {sourceBuilder.sort(sortField, sortOrder);}SearchRequest request new SearchRequest(yourIndex);request.source(sourceBuilder);SearchResponse response null;try {response restHighLevelClient.search(request, RequestOptions.DEFAULT);} catch (Exception e) {log.error(Search Elasticsearch Error!, e);}if (response null) {return Collections.emptyList();}return Arrays.stream(response.getHits().getHits()).map(v - JSON.parseObject(v.getSourceAsString(), clazz)).collect(Collectors.toList());}
}Elasticsearch全文检索接口分页检索
/*** 分页检索** param yourIndex 索引* param builder 搜索条件* param page 分页参数自己封装一个分页类网上很多easy* param sortField 排序属性* param sortOrder 排序方式* param clazz 返回类* param T 泛型* return 分页表格*/SuppressWarnings(checkstyle:ParameterNumber)public T PageT searchPageByCond(String yourIndex, BoolQueryBuilder builder, PageT page, String sortField, SortOrder sortOrder, ClassT clazz) {SearchSourceBuilder sourceBuilder new SearchSourceBuilder();sourceBuilder.query(builder);sourceBuilder.from(Math.max(page.getOffset(), 0));sourceBuilder.size(page.getLimit());if (StringUtils.isNotBlank(sortField)) {sourceBuilder.sort(sortField, sortOrder);}SearchRequest request new SearchRequest(yourIndex);request.source(sourceBuilder);SearchResponse response null;try {response restHighLevelClient.search(request, RequestOptions.DEFAULT);} catch (Exception e) {log.error(Search Elasticsearch Error!, e);}if (response null) {page.setRows(Collections.emptyList());page.setTotal(0);return page;}page.setRows(Arrays.stream(response.getHits().getHits()).map(v - JSON.parseObject(v.getSourceAsString(), clazz)).collect(Collectors.toList()));page.setTotal((int) response.getHits().getTotalHits().value);return page;}三、总结 本文实现了Java对Elasticsearch搜索引擎全文检索的封装 传入索引、BoolQueryBuilder查询条件选传、排序方式选传、Store数据接收类 即可完成对Elasticsearch的全文分页检索、不分页检索
