实现搜索分页功能

川长思鸟来 2021-12-05 05:51 681阅读 0赞

# 1.1 需求分析 #

实现搜索分页功能，每页显示30条记录。实现商品列表下方分页栏。

# 1.2 实现思路 #

前端向后端传递参数 pageNo （页码）

# 1.3 代码实现 #

修改SearchServiceImpl的search方法，在第1段代码中添加代码

package com.changgou.service;
    
    
    import org.apache.commons.lang.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.common.text.Text;
    import org.elasticsearch.index.query.BoolQueryBuilder;
    import org.elasticsearch.index.query.MatchQueryBuilder;
    
    import org.elasticsearch.index.query.QueryBuilders;
    import org.elasticsearch.search.SearchHit;
    import org.elasticsearch.search.SearchHits;
    import org.elasticsearch.search.builder.SearchSourceBuilder;
    import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
    import org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    
    /**
     * @author ：lijunxuan
     * @date ：Created in 2019/7/17  19:00
     * @description ：
     * @version: 1.0
     */
    @Service
    public class SearchServiceImpl implements SearchService {
        @Autowired
        private RestHighLevelClient restHighLevelClient;
        //设置每页查询条数据
        public final static Integer PAGE_SIZE = 4;
        @Override
        public Map search(Map<String, String> paramMap) throws Exception {
            Map<String,Object> resultMap=new HashMap<>();
            /**
             * 1.获取查询参数
             */
            //查询关键字
            String keywords = paramMap.get("keywords");
            //当前页数
            String pageNo = paramMap.get("pageNo");
            /**
             * 2.获取查询需要的对象
             */
            //创建查询对象，指定索引库名称，_index
            SearchRequest searchRequest = new SearchRequest("sku");
            //指定查询索引库中的类型
            searchRequest.types("doc");
            //创建查询构造对象
            SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
            //创建布尔查询（组合查询对象）
            BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
    
            /**
             * 3.设置根据关键字查询（关键字需要中文分词）
             */
            MatchQueryBuilder nameQueryBuilder = QueryBuilders.matchQuery("name", keywords);
            //根据名称查询条件放入组合查询对象中
            boolQueryBuilder.must(nameQueryBuilder);
            /**
             * 4. 设置高亮查询
             */
            HighlightBuilder highlightBuilder = new HighlightBuilder();
            //设置在哪个域中高亮显示
            highlightBuilder.field("name");
            //设置高亮前缀
            highlightBuilder.preTags("<em style=\"color:red\">");
            //设置高亮后缀
            highlightBuilder.postTags("</em>");
            searchSourceBuilder.highlighter(highlightBuilder);
            /**
             * 5. 设置分页查询
             */
            if (StringUtils.isEmpty(pageNo)) {
                paramMap.put("pageNo", "1");
                resultMap.put("pageNo", "1");
            }
            Integer pageNoTemp = Integer.parseInt(pageNo);
            if (pageNoTemp < 1) {
                paramMap.put("pageNo", "1");
                resultMap.put("pageNo", "1");
                pageNoTemp = 1;
            }
            //从第几条开始查询
            Integer start = (pageNoTemp - 1) * PAGE_SIZE;
            //从第几条开始查询
            searchSourceBuilder.from(start);
            //每页查询多少条数据
            searchSourceBuilder.size(PAGE_SIZE);
    
            /**
             * 12.查询并返回的结果
             */
            //将组合查询条件放入查询构造对象中
            searchSourceBuilder.query(boolQueryBuilder);
            //将组合查询条件放入查询请求中
            searchRequest.source(searchSourceBuilder);
            SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
            /**
             * 13. 获取查询到的结果集, 封装后返回
             */
            SearchHits searchHits = searchResponse.getHits();
            //获取查询到的总条数
            long totalHits = searchHits.getTotalHits();
            resultMap.put("total",totalHits);
            //获取查询结果集
            SearchHit[] hits = searchHits.getHits();
            List rows = new ArrayList<>();
            if (hits!=null){
                for (SearchHit hit : hits) {
                    //获取普通的查询出来的一条数据(不带高亮名称)
                    Map<String, Object> sourceAsMap = hit.getSourceAsMap();
                    //获取高亮结果
                    Map<String, HighlightField> highlightFields = hit.getHighlightFields();
                    if (highlightFields != null) {
                        HighlightField highlightField = highlightFields.get("name");
                        Text[] fragments = highlightField.fragments();
                        if (fragments != null && fragments.length > 0) {
                            //将高亮名称放入查询出来的数据中, 覆盖原来不带高亮的名称
                            sourceAsMap.put("name", fragments[0].toString());
                        }
                }
                    rows.add(sourceAsMap);
                }
        }
            resultMap.put("rows",rows);
            return resultMap;
        }
    }

# 1.4 测试结果 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70]: /images/20211205/cebbdc845ce245ab97985fe89d6f3cdc.png