11、使用Java High Level REST Client操作elasticsearch

看山远兮

 关注

阅读 102

2023-05-30


阅读文本大概需要3分钟。

Elasticsearch查到多种多样

1、matchAllQuery查询所有索引

public static void matchAllQueryTest(RestHighLevelClient client) throws Exception{

    // 1、创建search请求

    SearchRequest searchRequest = new SearchRequest();

    searchRequest.indices("it"); //索引名称

    searchRequest.types("_doc");//类型名称

    // 2、用SearchSourceBuilder来构造查询请求体 ,请仔细查看它的方法，构造各种查询的方法都在这。

    SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();

    //搜索全部文档

    sourceBuilder.query(QueryBuilders.matchAllQuery());



    //将请求体加入到请求中

    searchRequest.source(sourceBuilder);

    //3、发送请求

    SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

    SearchHits hits = searchResponse.getHits();

    SearchHit[] searchHits = hits.getHits();

    for (SearchHit searchHit : searchHits) {

        String source = searchHit.getSourceAsString();

        System.out.println(source);

    }

}

测试结果：

{"bookName":"C++","publishDate":"2019-06-30T11:45:00.985Z","sales":"100.00"}
{"bookName":"java","publishDate":"2013-01-30","sales":"100.00"}
{"bookName":"python","publishDate":"2019-06-30T11:45:00.735Z","sales":"100.00","reason":"dailyupdate","updated":"2019-07-13T02:51:27.915Z"}

2、matchQuery(filedName,value)匹配单个字段，匹配字段名为filedName，值为value的文档

public static void matchQueryTest(RestHighLevelClient client) throws Exception{

    // 1、创建search请求

    SearchRequest searchRequest = new SearchRequest();

    searchRequest.indices("it"); //索引名称

    searchRequest.types("_doc");//类型名称

    // 2、用SearchSourceBuilder来构造查询请求体 ,请仔细查看它的方法，构造各种查询的方法都在这。

    SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();

    //搜索全部文档

    sourceBuilder.query(QueryBuilders.matchQuery("bookName", "java"));



    //将请求体加入到请求中

    searchRequest.source(sourceBuilder);

    //3、发送请求

    SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

    SearchHits hits = searchResponse.getHits();

    SearchHit[] searchHits = hits.getHits();

    for (SearchHit searchHit : searchHits) {

        String source = searchHit.getSourceAsString();

        System.out.println(source);

    }

}

测试结果：

{"bookName":"java","publishDate":"2013-01-30","sales":"100.00"}

 

3、multiMatchQuery(Object text, String... fieldNames)多个字段匹配某一个值

public static void multiMatchQueryTest(RestHighLevelClient client) throws Exception{

    // 1、创建search请求

    SearchRequest searchRequest = new SearchRequest();

    searchRequest.indices("it"); //索引名称

    searchRequest.types("_doc");//类型名称

    // 2、用SearchSourceBuilder来构造查询请求体 ,请仔细查看它的方法，构造各种查询的方法都在这。

    SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();

    //搜索文档

    QueryBuilder queryBuilder = QueryBuilders.multiMatchQuery("java",

            "bookName", "sales");

    sourceBuilder.query(queryBuilder);



    //将请求体加入到请求中

    searchRequest.source(sourceBuilder);

    //3、发送请求

    SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

    SearchHits hits = searchResponse.getHits();

    SearchHit[] searchHits = hits.getHits();

    for (SearchHit searchHit : searchHits) {

        String source = searchHit.getSourceAsString();

        System.out.println(source);

    }

}

测试结果

{"bookName":"java","publishDate":"2013-01-30","sales":"100.00"}

4、        wildcardQuery()模糊查询；模糊查询，?匹配单个字符，*匹配多个字符

public static void wildcardQueryTest(RestHighLevelClient client) throws Exception{

        // 1、创建search请求

        SearchRequest searchRequest = new SearchRequest();

        searchRequest.indices("it"); //索引名称

        searchRequest.types("_doc");//类型名称

        // 2、用SearchSourceBuilder来构造查询请求体 ,请仔细查看它的方法，构造各种查询的方法都在这。

        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();

        //搜索文档

        //搜索名字中含有python文档（bookName中只要包含pyton即可）

//        WildcardQueryBuilder queryBuilder = QueryBuilders.wildcardQuery("bookName",

//                "*python*");



        WildcardQueryBuilder queryBuilder = QueryBuilders.wildcardQuery("reason",

                "*update*");



        sourceBuilder.query(queryBuilder);



        //将请求体加入到请求中

        searchRequest.source(sourceBuilder);

        //3、发送请求

        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

        SearchHits hits = searchResponse.getHits();

        SearchHit[] searchHits = hits.getHits();

        for (SearchHit searchHit : searchHits) {

            String source = searchHit.getSourceAsString();

            System.out.println(source);

        }

    }

测试结果：

{"bookName":"python","publishDate":"2019-06-30T11:45:00.735Z","sales":"100.00","reason":"dailyupdate","updated":"2019-07-13T02:51:27.915Z"}

5、        BoolQueryBuilder复合查询

public static void boolQueryBuilderTest(RestHighLevelClient client) throws Exception{

    // 1、创建search请求

    SearchRequest searchRequest = new SearchRequest();

    searchRequest.indices("it"); //索引名称

    searchRequest.types("_doc");//类型名称

    // 2、用SearchSourceBuilder来构造查询请求体 ,请仔细查看它的方法，构造各种查询的方法都在这。

    SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();

    //搜索文档

    //模糊查询  搜索名字中含有pytond的文档

    WildcardQueryBuilder queryBuilder1 = QueryBuilders.wildcardQuery(

            "bookName", "*python*");

    WildcardQueryBuilder queryBuilder2 = QueryBuilders.wildcardQuery(

            "reason", "*update*");//搜索interest中含有read的文档



    BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();

    //bookName中必须含有python,reason中必须含有update,相当于and

    boolQueryBuilder.must(queryBuilder1);

    boolQueryBuilder.must(queryBuilder2);



    sourceBuilder.query(boolQueryBuilder);



    //将请求体加入到请求中

    searchRequest.source(sourceBuilder);

    //3、发送请求

    SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

    SearchHits hits = searchResponse.getHits();

    SearchHit[] searchHits = hits.getHits();

    for (SearchHit searchHit : searchHits) {

        String source = searchHit.getSourceAsString();

        System.out.println(source);

    }

}

测试结果：

{"bookName":"python","publishDate":"2019-06-30T11:45:00.735Z","sales":"100.00","reason":"dailyupdate","updated":"2019-07-13T02:51:27.915Z"}

 

public static void boolQueryBuilderTest(RestHighLevelClient client) throws Exception{

        // 1、创建search请求

        SearchRequest searchRequest = new SearchRequest();

        searchRequest.indices("it"); //索引名称

        searchRequest.types("_doc");//类型名称

        // 2、用SearchSourceBuilder来构造查询请求体 ,请仔细查看它的方法，构造各种查询的方法都在这。

        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();

        //搜索文档

        //搜索bookName中含有pytond的文档

         WildcardQueryBuilder queryBuilder1 = QueryBuilders.wildcardQuery(

                "bookName", "*python*");

        //搜索reason中含有update的文档

        WildcardQueryBuilder queryBuilder2 = QueryBuilders.wildcardQuery(

                "bookName", "*java*");



        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();

        //bookName中含有python或者bookName含有java，相当于or

        boolQueryBuilder.should(queryBuilder1);

        boolQueryBuilder.should(queryBuilder2);



        sourceBuilder.query(boolQueryBuilder);



        //将请求体加入到请求中

        searchRequest.source(sourceBuilder);

        //3、发送请求

        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

        SearchHits hits = searchResponse.getHits();

        SearchHit[] searchHits = hits.getHits();

        for (SearchHit searchHit : searchHits) {

            String source = searchHit.getSourceAsString();

            System.out.println(source);

        }

    }

测试结果：

{"bookName":"java","publishDate":"2013-01-30","sales":"100.00"}
{"bookName":"python","publishDate":"2019-06-30T11:45:00.735Z","sales":"100.00","reason":"dailyupdate","updated":"2019-07-13T02:51:27.915Z"}


关注我每天进步一点点

11、使用Java High Level REST Client操作elasticsearch_elasticsearch


相关推荐

9、使用Java High Level REST Client操作elasticsearch

幸甚至哉歌以咏志 49 0 0

10、使用Java High Level REST Client操作elasticsearch

小月亮06 104 0 0

Java High Level REST Client

忍禁 107 0 0

ElasticSearch-整合Java High Level REST Client  测试

莞尔小迷糊 133 0 0

7、使用Java Low Level REST Client操作elasticsearch

猎书客er 63 0 0

Java操作Elasticsearch 之 [Java High Level REST Clientedit]

青青子衿谈育儿 84 0 0

Elasticsearch与SpringBoot整合 High-level-client-rest

Separes 92 0 0

Java elasticsearch-rest-high-level-client 学习笔记2--聚合

小云晓云 156 0 0

Java elasticsearch-rest-high-level-client 学习笔记1--查询

凉夜lrs 56 0 0

6、使用Java Low Level REST Client操作elasticsearch.docx

生命中最美的是成长 97 0 0

精彩评论（0）

0 0 举报