SpringBoot整合ElasticSearch-v6.8.1的使用 - 6.索引的数据(查询)

---

SpringBoot整合ElasticSearch-v6.8.1的封装 - 1.配置类
SpringBoot整合ElasticSearch-v6.8.1的封装 - 2.接口类
SpringBoot整合ElasticSearch-v6.8.1的封装 - 3.支持类
SpringBoot整合ElasticSearch-v6.8.1的使用 - 4.索引的创建与删除
SpringBoot整合ElasticSearch-v6.8.1的使用 - 5.索引的数据(增删改)

在 ES 当中提供了 bool 查询，一个 bool 查询可以包含一个或多个查询字句，支持以下四种查询：

• must：必须匹配，贡献算分
• should：选择性匹配，贡献算分
• must_not：查询字句，必须不能匹配
• filter：必须匹配，不贡献算分

查询ES索引数据_全部

@Test
void 查询ES索引数据_全部() {
    String index = "my_index";
    try {
        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
        // 根据_id查询 
        boolQueryBuilder.must(QueryBuilders.termQuery("_id", "33"));
        
        // 精确条件(单值查询)
        boolQueryBuilder.must(QueryBuilders.termQuery("account", "admin"));
        // 精确条件(多值查询)
        boolQueryBuilder.must(QueryBuilders.termsQuery("keyId", Arrays.asList("22", "33")));
        
        // 模糊查询(查询全部)
        boolQueryBuilder.must(QueryBuilders.matchAllQuery());
        // 模糊查询(会将搜索词分词，再与目标查询字段进行匹配，若分词中的任意一个词与目标字段匹配上，则可查询到)
        boolQueryBuilder.must(QueryBuilders.matchQuery("username", "临管"));
        // 模糊查询(不会将搜索词分词，会精确匹配查询的短语，需要全部单词和顺序要完全一样)
        boolQueryBuilder.must(QueryBuilders.matchPhraseQuery("username", "时管理员"));
        // 模糊查询(不会将搜索词分词，会精确匹配查询的短语，需要全部单词和顺序要完全一样同时需要前缀匹配，中英有出入)
        boolQueryBuilder.must(QueryBuilders.matchPhrasePrefixQuery("username", "临时管理"));
        // 模糊查询(匹配搜索多个字段,minimumShouldMatch:设置匹配度，  field:提升字段的得分权限,每个结果搜索出来后都会有一个得分)
        boolQueryBuilder.must(QueryBuilders.multiMatchQuery("用户", Arrays.asList("username", "address.region").toArray(new String[0])).minimumShouldMatch("50%"));
        boolQueryBuilder.must(QueryBuilders.multiMatchQuery("浦东新区", Arrays.asList("username", "address.location.city").toArray(new String[0])).minimumShouldMatch("50%"));

        // 范围值查询 lt小于value的值，小于等于是lte、大于是gt、大于等于是gte
        boolQueryBuilder.must(QueryBuilders.rangeQuery("age").lt(30));
        // 范围时间查询 lt小于value的值，小于等于是lte、大于是gt、大于等于是gte
        boolQueryBuilder.must(QueryBuilders.rangeQuery("createdTime").lt("2122-12-22 12:33:33"));

        // 过滤器查询(不分词查询,必须匹配，不贡献算分)
        boolQueryBuilder.filter(QueryBuilders.termQuery("account", "admin"));
                    
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().query(boolQueryBuilder);
        
        // 设置源字段过虑,第一个参数结果集包括哪些字段，第二个参数表示结果集不包括哪些字段
        String[] includes = {"keyId", "username", "account", "createdTime", "role","birthday","address","age"};
        String[] excludes = {"keyId"};
        searchSourceBuilder.fetchSource(includes, excludes);
        
        // 排序(对查询后结果进行排序,DESC:倒序-从大到小,ASC:顺序-从小到大,含有优先序列)
        searchSourceBuilder.sort("age", SortOrder.ASC).sort("birthday",SortOrder.DESC);
        
        // 设置高亮(requireFieldMatch:多次段高亮需要设置为false)
        HighlightBuilder highlightBuilder = new HighlightBuilder();
        highlightBuilder.preTags("<tag>").postTags("</tag>");
        highlightBuilder.field("account").field("username");
        searchSourceBuilder.highlighter(highlightBuilder.requireFieldMatch(false));
        
        ElasticSearchDTO elasticSearchDTO = new ElasticSearchDTO().setEsIndex(index).setSearchRequest(new SearchRequest().source(searchSourceBuilder));
        List<Map<String, Object>> mapList = elasticSearchService.searchDataList(elasticSearchDTO);
        System.out.println(JSON.toJSONString(mapList));
    } catch (Exception e) {
        e.printStackTrace();
    }
}

查询ES索引数据_分页

@Test
void 查询ES索引数据_分页() {
    String index = "my_index";
    try {
        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
        // 模糊查询
        boolQueryBuilder.must(QueryBuilders.matchPhraseQuery("username", "管理员"));
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().query(boolQueryBuilder);

        ElasticSearchDTO elasticSearchDTO = new ElasticSearchDTO(1, 10).setEsIndex(index).setSearchRequest(new SearchRequest().source(searchSourceBuilder));
        ElasticSearchPage elasticSearchPage = elasticSearchService.searchDataListPage(elasticSearchDTO);
        System.out.println(JSON.toJSONString(ElasticSearchListUtil.getData(elasticSearchPage)));
    } catch (Exception e) {
        e.printStackTrace();
    }
}

查询ES索引数据_统计

@Test
void 查询ES索引数据_统计() {
    String index = "my_index";
    try {
        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
        boolQueryBuilder.must(QueryBuilders.matchPhraseQuery("username", "管理员"));

        ElasticSearchDTO elasticSearchDTO = new ElasticSearchDTO().setEsIndex(index);
        elasticSearchDTO.getCountRequest().source(new SearchSourceBuilder().query(boolQueryBuilder));
        System.out.println(elasticSearchService.getIndexCount(elasticSearchDTO));
    } catch (Exception e) {
        e.printStackTrace();
    }
}