zoukankan      html  css  js  c++  java
  • Elastic Stack:es JavaApi搜索入门

    一.入门API

    @SpringBootTest(classes = SearchApplication.class)
    @RunWith(SpringRunner.class)
    public class TestSearch {
        @Qualifier("restHighLevelClient")
        @Autowired
        RestHighLevelClient client;
    
        @Test
        public void testSearchAll() throws IOException {
            //构建搜索请求
            SearchRequest request = new SearchRequest("book");
            //构建搜索请求体
            SearchSourceBuilder builder = new SearchSourceBuilder();
            builder.query(QueryBuilders.matchAllQuery());
            //第一个参数:包含哪些字段  第二个参数:排除哪些字段
            builder.fetchSource(new String[]{},new String[]{"pic","timestamp"});
            request.source(builder);
            //执行搜索请求
            SearchResponse response = client.search(request, RequestOptions.DEFAULT);
            //获取结果
            SearchHits hits = response.getHits();
            SearchHit[] hits1 = hits.getHits();
            Arrays.asList(hits1).forEach(hit->{
                System.out.println(hit.getId());
                System.out.println(hit.getScore());
                Map<String, Object> map = hit.getSourceAsMap();
                map.forEach((x,y)-> System.out.println(x+":"+y));
                System.out.println("==========");
            });
        }
    }
    

     二.常用方法

    分页:

    builder.from(0);
    builder.size(2);
    

     ids查询:

    builder.query(QueryBuilders.idsQuery().addIds("1","3","5"));

    match搜索:

    builder.query(QueryBuilders.matchQuery("name","java编程"));

    multi_match搜索:

    第一个参数:查询的关键字

    后面的参数:查询的字段

    builder.query(QueryBuilders.multiMatchQuery("java","name","description"));
    

    三.bool query查询  

        @Test
        public void testSearchBool() throws IOException {
            //构建搜索请求
            SearchRequest request = new SearchRequest("book");
            //构建搜索请求体
            SearchSourceBuilder builder = new SearchSourceBuilder();
            //构建bool
            BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
            boolQueryBuilder.must(QueryBuilders.matchQuery("description","java"));
            boolQueryBuilder.should(QueryBuilders.matchQuery("name","开发"));
    
            builder.query(boolQueryBuilder);
            //第一个参数:包含哪些字段  第二个参数:排除哪些字段
            builder.fetchSource(new String[]{},new String[]{"pic","timestamp"});
            request.source(builder);
            //执行搜索请求
            SearchResponse response = client.search(request, RequestOptions.DEFAULT);
            //获取结果
            SearchHits hits = response.getHits();
            SearchHit[] hits1 = hits.getHits();
            Arrays.asList(hits1).forEach(hit->{
                System.out.println(hit.getId());
                System.out.println(hit.getScore());
                Map<String, Object> map = hit.getSourceAsMap();
                map.forEach((x,y)-> System.out.println(x+":"+y));
                System.out.println("==========");
            });
        }
    

     filter:

    boolQueryBuilder.filter(QueryBuilders.rangeQuery("price").gte("50").lte("90"));
    

     四.sort排序

     按照价格降序

        @Test
        public void testSearchSort() throws IOException {
            //构建搜索请求
            SearchRequest request = new SearchRequest("book");
            //构建搜索请求体
            SearchSourceBuilder builder = new SearchSourceBuilder();
            builder.query(QueryBuilders.matchAllQuery());
            //第一个参数:包含哪些字段  第二个参数:排除哪些字段
            builder.fetchSource(new String[]{},new String[]{"pic","timestamp"});
            //排序
            builder.sort("price", SortOrder.DESC);
            request.source(builder);
            //执行搜索请求
            SearchResponse response = client.search(request, RequestOptions.DEFAULT);
            //获取结果
            SearchHits hits = response.getHits();
            SearchHit[] hits1 = hits.getHits();
            Arrays.asList(hits1).forEach(hit->{
                System.out.println(hit.getId());
                System.out.println(hit.getScore());
                Map<String, Object> map = hit.getSourceAsMap();
                map.forEach((x,y)-> System.out.println(x+":"+y));
                System.out.println("==========");
            });
        }
    

      

  • 相关阅读:
    使用hibernate实现树形结构无限级分类
    专家看台:盛大架构师周爱民回顾职业历程,分享十项建议
    开始运行命令大全
    rsvp.exe,AdskScSrv.exe ,avp.exe
    Web2.0 编程思想:16条法则
    李嘉诚:性格才是命运的决定因素
    中兴笔试题目
    管理Websphere的10个有用命令
    我的程序语言实践
    20200514:实现分布式Session的过程是怎样的?
  • 原文地址:https://www.cnblogs.com/wwjj4811/p/13098982.html
Copyright © 2011-2022 走看看