• ELK 基础使用 Java操作elasticseach （四）

    目录

    一、添加依赖

    二、索引操作案例

    1、创建索引的案例

     2、获取索引的案例

    3、删除索引

    三、文档操作案例

    1、创建文档

    2、更新文档

    3、获取文档

    4、删除文档

     5、批量插入

    6、批量删除

    四、高级查询

     1、查询索引下所有文档

     2、条件查询

    3、分页查询

     4、查询排序

    5、过滤查询

    6、组合查询

    7、范围查询

     8、模糊查询

    9、高亮查询

     10、分组查询

    一、添加依赖

    1. <properties>
    2.         <maven.compiler.source>8maven.compiler.source>
    3.         <maven.compiler.target>8maven.compiler.target>
    4.     properties>
    5.  
    6.     <dependencies>
    7.         <dependency>
    8.             <groupId>org.elasticsearchgroupId>
    9.             <artifactId>elasticsearchartifactId>
    10.             <version>7.8.0version>
    11.         dependency>
    12.         
    13.         <dependency>
    14.             <groupId>org.elasticsearch.clientgroupId>
    15.             <artifactId>elasticsearch-rest-high-level-clientartifactId>
    16.             <version>7.8.0version>
    17.         dependency>
    18.         
    19.         <dependency>
    20.             <groupId>org.apache.logging.log4jgroupId>
    21.             <artifactId>log4j-apiartifactId>
    22.             <version>2.17.1version>
    23.         dependency>
    24.         <dependency>
    25.             <groupId>org.apache.logging.log4jgroupId>
    26.             <artifactId>log4j-coreartifactId>
    27.             <version>2.17.1version>
    28.         dependency>
    29.         <dependency>
    30.             <groupId>com.fasterxml.jackson.coregroupId>
    31.             <artifactId>jackson-databindartifactId>
    32.             <version>2.13.3version>
    33.         dependency>
    34.         
    35.         <dependency>
    36.             <groupId>junitgroupId>
    37.             <artifactId>junitartifactId>
    38.             <version>4.13.2version>
    39.             <scope>testscope>
    40.         dependency>
    41.     dependencies>

    二、索引操作案例

    1、创建索引的案例

    先通过ApiPost测试访问

    可以看到运行代码之前customer文档索引是不存在的

    代码：

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.client.RequestOptions;
    5. import org.elasticsearch.client.RestClient;
    6. import org.elasticsearch.client.RestHighLevelClient;
    7. import org.elasticsearch.client.indices.CreateIndexRequest;
    8. import org.elasticsearch.client.indices.CreateIndexResponse;
    9.  
    10. /**
    11.  * @author DragonWu
    12.  * @date 2022-09-17 18:54
    13.  **/
    14. public class ElkTestIndexCreate {
    15.     public static void main(String[] args) throws Exception{
    16.         //创建ES客户端
    17.         RestHighLevelClient esClient=new RestHighLevelClient(
    18.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
    19.         );
    20.  
    21.         //创建索引
    22.         CreateIndexRequest request = new CreateIndexRequest("customer");
    23.         CreateIndexResponse createIndexResponse = esClient.indices().create(request, RequestOptions.DEFAULT);
    24.  
    25.         //响应状态
    26.         boolean acknowledged = createIndexResponse.isAcknowledged();
    27.         System.out.println("索引操作："+acknowledged);
    28.  
    29.         //关闭ES客户端
    30.         esClient.close();
    31.     }
    32. }

     再次查询，可以查询到对应文档索引了，证明代码执行成功

     索引创建成功

     2、获取索引的案例

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.client.RequestOptions;
    5. import org.elasticsearch.client.RestClient;
    6. import org.elasticsearch.client.RestHighLevelClient;
    7. import org.elasticsearch.client.indices.GetIndexRequest;
    8. import org.elasticsearch.client.indices.GetIndexResponse;
    9.  
    10. /**
    11.  * @author DragonWu
    12.  * @date 2022-09-18 9:16
    13.  **/
    14. public class ElkTestIndexSearch {
    15.     public static void main(String[] args) throws Exception{
    16.         //创建ES客户端
    17.         RestHighLevelClient esClient=new RestHighLevelClient(
    18.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
    19.         );
    20.  
    21.        //查询索引
    22.         GetIndexRequest request=new GetIndexRequest("customer");
    23.  
    24.         GetIndexResponse getIndexResponse = esClient.indices().get(request, RequestOptions.DEFAULT);
    25.  
    26.         //响应状态
    27.         System.out.println(getIndexResponse.getAliases());
    28.         System.out.println(getIndexResponse.getMappings());
    29.         System.out.println(getIndexResponse.getSettings());
    30.  
    31.         //关闭ES客户端
    32.         esClient.close();
    33.     }
    34. }

    运行截图

    可以看到该索引已被找到。

    3、删除索引

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
    5. import org.elasticsearch.action.support.master.AcknowledgedResponse;
    6. import org.elasticsearch.client.RequestOptions;
    7. import org.elasticsearch.client.RestClient;
    8. import org.elasticsearch.client.RestHighLevelClient;
    9.  
    10. /**
    11.  * @author DragonWu
    12.  * @date 2022-09-18 9:25
    13.  **/
    14. public class ElkTestIndexDelete {
    15.     public static void main(String[] args) throws Exception{
    16.         //创建ES客户端
    17.         RestHighLevelClient esClient=new RestHighLevelClient(
    18.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
    19.         );
    20.  
    21.         //查询索引
    22.         DeleteIndexRequest request=new DeleteIndexRequest("customer");
    23.  
    24.         AcknowledgedResponse response = esClient.indices().delete(request, RequestOptions.DEFAULT);
    25.  
    26.         //响应状态
    27.         System.out.println(response.isAcknowledged());
    28.  
    29.         //关闭ES客户端
    30.         esClient.close();
    31.     }
    32. }

     运行截图

     删除成功

    三、文档操作案例

    1、创建文档

    首先创建实体类

    1. package com.dragon.test;
    2.  
    3. /**
    4.  * @author DragonWu
    5.  * @date 2022-09-18 9:32
    6.  **/
    7. public class User {
    8.     private String name;
    9.     private String sex;
    10.     private Integer age;
    11.  
    12.     public String getName() {
    13.         return name;
    14.     }
    15.  
    16.     public void setName(String name) {
    17.         this.name = name;
    18.     }
    19.  
    20.     public String getSex() {
    21.         return sex;
    22.     }
    23.  
    24.     public void setSex(String sex) {
    25.         this.sex = sex;
    26.     }
    27.  
    28.     public Integer getAge() {
    29.         return age;
    30.     }
    31.  
    32.     public void setAge(Integer age) {
    33.         this.age = age;
    34.     }
    35. }
    1. package com.dragon.test;
    2.  
    3. import com.fasterxml.jackson.databind.ObjectMapper;
    4. import org.apache.http.HttpHost;
    5. import org.elasticsearch.action.index.IndexRequest;
    6. import org.elasticsearch.action.index.IndexResponse;
    7. import org.elasticsearch.client.RequestOptions;
    8. import org.elasticsearch.client.RestClient;
    9. import org.elasticsearch.client.RestHighLevelClient;
    10. import org.elasticsearch.common.xcontent.XContentType;
    11.  
    12. /**
    13.  * @author DragonWu
    14.  * @date 2022-09-18 9:34
    15.  **/
    16. public class ElkTestDocInsert {
    17.     public static void main(String[] args) throws Exception{
    18.         //创建ES客户端
    19.         RestHighLevelClient esClient=new RestHighLevelClient(
    20.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
    21.         );
    22.  
    23.        //插入数据
    24.         IndexRequest request=new IndexRequest();
    25.         request.index("user").id("1004");
    26.  
    27.         User user=new User();
    28.         user.setName("张三");
    29.         user.setAge(21);
    30.         user.setSex("男");
    31.  
    32.         //向ES中插入数据，必须将数据转换为JSON格式
    33.         ObjectMapper mapper=new ObjectMapper();
    34.         String userJson = mapper.writeValueAsString(user);
    35.         request.source(userJson, XContentType.JSON);
    36.  
    37.         IndexResponse response = esClient.index(request, RequestOptions.DEFAULT);
    38.  
    39. //        System.out.println(response.getResult());
    40.  
    41.         //关闭ES客户端
    42.         esClient.close();
    43.     }
    44. }

    通过ApiPost查询数据：

     可以看到数据已经更新

    2、更新文档

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.update.UpdateRequest;
    5. import org.elasticsearch.action.update.UpdateResponse;
    6. import org.elasticsearch.client.RequestOptions;
    7. import org.elasticsearch.client.RestClient;
    8. import org.elasticsearch.client.RestHighLevelClient;
    9. import org.elasticsearch.common.xcontent.XContentType;
    10.  
    11. /**
    12.  * @author DragonWu
    13.  * @date 2022-09-18 9:34
    14.  **/
    15. public class ElkTestDocUpdate {
    16.     public static void main(String[] args) throws Exception{
    17.         //创建ES客户端
    18.         RestHighLevelClient esClient=new RestHighLevelClient(
    19.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
    20.         );
    21.  
    22.        //修改数据
    23.         UpdateRequest request=new UpdateRequest();
    24.         request.index("user").id("1004");
    25.         request.doc(XContentType.JSON,"sex","女");
    26.  
    27.         UpdateResponse response = esClient.update(request, RequestOptions.DEFAULT);
    28.  
    29.         System.out.println(response.getResult());
    30.  
    31.         //关闭ES客户端
    32.         esClient.close();
    33.     }
    34. }

    再次查询user的id为1004的文档

     可以看到sex已局部更新

    3、获取文档

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.get.GetRequest;
    5. import org.elasticsearch.action.get.GetResponse;
    6. import org.elasticsearch.client.RequestOptions;
    7. import org.elasticsearch.client.RestClient;
    8. import org.elasticsearch.client.RestHighLevelClient;
    9.  
    10. /**
    11.  * @author DragonWu
    12.  * @date 2022-09-18 10:02
    13.  **/
    14. public class ElkTestDocSearch {
    15.     public static void main(String[] args) throws Exception{
    16.         //创建ES客户端
    17.         RestHighLevelClient esClient=new RestHighLevelClient(
    18.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
    19.         );
    20.  
    21.         //查询请求
    22.         GetRequest request=new GetRequest();
    23.         request.index("user").id("1004");
    24.         GetResponse documentFields=esClient.get(request, RequestOptions.DEFAULT);
    25.  
    26.         System.out.println(documentFields.getSourceAsString());
    27.  
    28.         //关闭ES客户端
    29.         esClient.close();
    30.     }
    31. }

    运行截图

    可以看到文档查询成功 

    4、删除文档

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.delete.DeleteRequest;
    5. import org.elasticsearch.action.delete.DeleteResponse;
    6. import org.elasticsearch.client.RequestOptions;
    7. import org.elasticsearch.client.RestClient;
    8. import org.elasticsearch.client.RestHighLevelClient;
    9.  
    10. /**
    11.  * @author DragonWu
    12.  * @date 2022-09-18 10:02
    13.  **/
    14. public class ElkTestDocDelete {
    15.     public static void main(String[] args) throws Exception{
    16.         //创建ES客户端
    17.         RestHighLevelClient esClient=new RestHighLevelClient(
    18.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
    19.         );
    20.  
    21.         //删除文档
    22.         DeleteRequest request=new DeleteRequest();
    23.         request.index("user").id("1004");
    24.  
    25.         DeleteResponse response=esClient.delete(request, RequestOptions.DEFAULT);
    26.         System.out.println(response.toString());
    27.  
    28.         //关闭ES客户端
    29.         esClient.close();
    30.     }
    31. }

    再次查询，可以看到查询失败，证明删除成功

     5、批量插入

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.bulk.BulkRequest;
    5. import org.elasticsearch.action.bulk.BulkResponse;
    6. import org.elasticsearch.action.index.IndexRequest;
    7. import org.elasticsearch.client.RequestOptions;
    8. import org.elasticsearch.client.RestClient;
    9. import org.elasticsearch.client.RestHighLevelClient;
    10. import org.elasticsearch.common.xcontent.XContentType;
    11.  
    12. import java.util.Arrays;
    13.  
    14. /**
    15.  * @author DragonWu
    16.  * @date 2022-09-18 10:29
    17.  **/
    18. public class ElkTestBatchInsert {
    19.     public static void main(String[] args) throws Exception{
    20.         //创建ES客户端
    21.         RestHighLevelClient esClient=new RestHighLevelClient(
    22.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
    23.         );
    24.  
    25.         //批量插入数据
    26.         BulkRequest request=new BulkRequest();
    27.  
    28.         request.add(new IndexRequest().index("user").id("1004").source(XContentType.JSON,"name","李四"));
    29.         request.add(new IndexRequest().index("user").id("1005").source(XContentType.JSON,"name","赵六"));
    30.         request.add(new IndexRequest().index("user").id("1006").source(XContentType.JSON,"name","洪七"));
    31.  
    32.         BulkResponse response = esClient.bulk(request, RequestOptions.DEFAULT);
    33.  
    34.         System.out.println(response.getTook());
    35.         System.out.println(Arrays.toString(response.getItems()));
    36.  
    37.         //关闭ES客户端
    38.         esClient.close();
    39.     }
    40. }

    再次查询

    可以看到批量插入成功

    6、批量删除

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.bulk.BulkRequest;
    5. import org.elasticsearch.action.bulk.BulkResponse;
    6. import org.elasticsearch.action.delete.DeleteRequest;
    7. import org.elasticsearch.client.RequestOptions;
    8. import org.elasticsearch.client.RestClient;
    9. import org.elasticsearch.client.RestHighLevelClient;
    10.  
    11. import java.util.Arrays;
    12.  
    13. /**
    14.  * @author DragonWu
    15.  * @date 2022-09-18 10:29
    16.  **/
    17. public class ElkTestBatchDelete {
    18.     public static void main(String[] args) throws Exception{
    19.         //创建ES客户端
    20.         RestHighLevelClient esClient=new RestHighLevelClient(
    21.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
    22.         );
    23.  
    24.         //批量插入数据
    25.         BulkRequest request=new BulkRequest();
    26.  
    27.         request.add(new DeleteRequest().index("user").id("1004"));
    28.         request.add(new DeleteRequest().index("user").id("1005"));
    29.         request.add(new DeleteRequest().index("user").id("1006"));
    30.  
    31.         BulkResponse response = esClient.bulk(request, RequestOptions.DEFAULT);
    32.  
    33.         System.out.println(response.getTook());
    34.         System.out.println(Arrays.toString(response.getItems()));
    35.  
    36.         //关闭ES客户端
    37.         esClient.close();
    38.     }
    39. }

    四、高级查询

    首先模拟插入数据以便后面的查询

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.bulk.BulkRequest;
    5. import org.elasticsearch.action.bulk.BulkResponse;
    6. import org.elasticsearch.action.index.IndexRequest;
    7. import org.elasticsearch.client.RequestOptions;
    8. import org.elasticsearch.client.RestClient;
    9. import org.elasticsearch.client.RestHighLevelClient;
    10. import org.elasticsearch.common.xcontent.XContentType;
    11.  
    12. import java.util.Arrays;
    13.  
    14. /**
    15.  * @author DragonWu
    16.  * @date 2022-09-18 10:29
    17.  **/
    18. public class ElkTestBatchInsert {
    19.     public static void main(String[] args) throws Exception{
    20.         //创建ES客户端
    21.         RestHighLevelClient esClient=new RestHighLevelClient(
    22.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
    23.         );
    24.  
    25.         //批量插入数据
    26.         BulkRequest request=new BulkRequest();
    27.  
    28.         request.add(new IndexRequest().index("user").id("1004").source(XContentType.JSON,"name","李四","age",30,"sex","男"));
    29.         request.add(new IndexRequest().index("user").id("1005").source(XContentType.JSON,"name","赵六","age",40,"sex","男"));
    30.         request.add(new IndexRequest().index("user").id("1006").source(XContentType.JSON,"name","洪七","age",50,"sex","女"));
    31.         request.add(new IndexRequest().index("user").id("1007").source(XContentType.JSON,"name","王五","age",30,"sex","男"));
    32.         request.add(new IndexRequest().index("user").id("1008").source(XContentType.JSON,"name","张三","age",40,"sex","男"));
    33.         request.add(new IndexRequest().index("user").id("1009").source(XContentType.JSON,"name","王二","age",50,"sex","女"));
    34.  
    35.  
    36.         BulkResponse response = esClient.bulk(request, RequestOptions.DEFAULT);
    37.  
    38.         System.out.println(response.getTook());
    39.         System.out.println(Arrays.toString(response.getItems()));
    40.  
    41.         //关闭ES客户端
    42.         esClient.close();
    43.     }
    44. }

    通过ApiPost查询可以看到如下数据文档列表

    1. {
    2. 	"took": 945,
    3. 	"timed_out": false,
    4. 	"_shards": {
    5. 		"total": 1,
    6. 		"successful": 1,
    7. 		"skipped": 0,
    8. 		"failed": 0
    9. 	},
    10. 	"hits": {
    11. 		"total": {
    12. 			"value": 9,
    13. 			"relation": "eq"
    14. 		},
    15. 		"max_score": 1,
    16. 		"hits": [
    17. 			{
    18. 				"_index": "user",
    19. 				"_id": "1002",
    20. 				"_score": 1,
    21. 				"_source": {
    22. 					"name": "Fack",
    23. 					"sex": "男",
    24. 					"tel": 11011011012
    25. 				}
    26. 			},
    27. 			{
    28. 				"_index": "user",
    29. 				"_id": "1003",
    30. 				"_score": 1,
    31. 				"_source": {
    32. 					"name": "Alice",
    33. 					"sex": "女",
    34. 					"tel": 11011011013
    35. 				}
    36. 			},
    37. 			{
    38. 				"_index": "user",
    39. 				"_id": "1001",
    40. 				"_score": 1,
    41. 				"_source": {
    42. 					"name": "张三",
    43. 					"sex": "男",
    44. 					"age": 21
    45. 				}
    46. 			},
    47. 			{
    48. 				"_index": "user",
    49. 				"_id": "1004",
    50. 				"_score": 1,
    51. 				"_source": {
    52. 					"name": "李四",
    53. 					"age": 30,
    54. 					"sex": "男"
    55. 				}
    56. 			},
    57. 			{
    58. 				"_index": "user",
    59. 				"_id": "1005",
    60. 				"_score": 1,
    61. 				"_source": {
    62. 					"name": "赵六",
    63. 					"age": 40,
    64. 					"sex": "男"
    65. 				}
    66. 			},
    67. 			{
    68. 				"_index": "user",
    69. 				"_id": "1006",
    70. 				"_score": 1,
    71. 				"_source": {
    72. 					"name": "洪七",
    73. 					"age": 50,
    74. 					"sex": "女"
    75. 				}
    76. 			},
    77. 			{
    78. 				"_index": "user",
    79. 				"_id": "1007",
    80. 				"_score": 1,
    81. 				"_source": {
    82. 					"name": "王五",
    83. 					"age": 30,
    84. 					"sex": "男"
    85. 				}
    86. 			},
    87. 			{
    88. 				"_index": "user",
    89. 				"_id": "1008",
    90. 				"_score": 1,
    91. 				"_source": {
    92. 					"name": "张三",
    93. 					"age": 40,
    94. 					"sex": "男"
    95. 				}
    96. 			},
    97. 			{
    98. 				"_index": "user",
    99. 				"_id": "1009",
    100. 				"_score": 1,
    101. 				"_source": {
    102. 					"name": "王二",
    103. 					"age": 50,
    104. 					"sex": "女"
    105. 				}
    106. 			}
    107. 		]
    108. 	}
    109. }

     1、查询索引下所有文档

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.search.SearchRequest;
    5. import org.elasticsearch.action.search.SearchResponse;
    6. import org.elasticsearch.client.RequestOptions;
    7. import org.elasticsearch.client.RestClient;
    8. import org.elasticsearch.client.RestHighLevelClient;
    9. import org.elasticsearch.index.query.QueryBuilders;
    10. import org.elasticsearch.search.SearchHit;
    11. import org.elasticsearch.search.SearchHits;
    12. import org.elasticsearch.search.builder.SearchSourceBuilder;
    13.  
    14. /**
    15.  * @author DragonWu
    16.  * @date 2022-09-18 10:46
    17.  **/
    18. public class DocQuery {
    19.     public static void main(String[] args) throws Exception {
    20.         //创建ES客户端
    21.         RestHighLevelClient esClient = new RestHighLevelClient(
    22.                 RestClient.builder(new HttpHost("localhost", 9200, "http"))
    23.         );
    24.  
    25.         //查询索引中全部数据
    26.         SearchRequest request = new SearchRequest();
    27.         request.indices("user");
    28.  
    29.         request.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery()));
    30.  
    31.         SearchResponse searchResponse = esClient.search(request, RequestOptions.DEFAULT);
    32.  
    33.         SearchHits hits = searchResponse.getHits();
    34.  
    35.         System.out.println(hits.getTotalHits());
    36.         System.out.println(searchResponse.getTook());
    37.  
    38.         for (SearchHit hit : hits) {
    39.             System.out.println(hit.getSourceAsString());
    40.         }
    41.  
    42.         //关闭ES客户端
    43.         esClient.close();
    44.     }
    45. }

    运行截图

    可以看到之前批量插入的数据都获取到了

     2、条件查询

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.search.SearchRequest;
    5. import org.elasticsearch.action.search.SearchResponse;
    6. import org.elasticsearch.client.RequestOptions;
    7. import org.elasticsearch.client.RestClient;
    8. import org.elasticsearch.client.RestHighLevelClient;
    9. import org.elasticsearch.index.query.QueryBuilders;
    10. import org.elasticsearch.search.SearchHit;
    11. import org.elasticsearch.search.SearchHits;
    12. import org.elasticsearch.search.builder.SearchSourceBuilder;
    13.  
    14. /**
    15.  * @author DragonWu
    16.  * @date 2022-09-18 10:46
    17.  **/
    18. public class DocQuery {
    19.     public static void main(String[] args) throws Exception {
    20.         //创建ES客户端
    21.         RestHighLevelClient esClient = new RestHighLevelClient(
    22.                 RestClient.builder(new HttpHost("localhost", 9200, "http"))
    23.         );
    24.  
    25.         //条件查询 : termQuery
    26.         SearchRequest request = new SearchRequest();
    27.         request.indices("user");
    28.  
    29.         request.source(new SearchSourceBuilder().query(QueryBuilders.termQuery("age",30)));
    30.  
    31.         SearchResponse searchResponse = esClient.search(request, RequestOptions.DEFAULT);
    32.  
    33.         SearchHits hits = searchResponse.getHits();
    34.  
    35.         System.out.println(hits.getTotalHits());
    36.         System.out.println(searchResponse.getTook());
    37.  
    38.         for (SearchHit hit : hits) {
    39.             System.out.println(hit.getSourceAsString());
    40.         }
    41.  
    42.         //关闭ES客户端
    43.         esClient.close();
    44.     }
    45. }

    运行截图

    可以看到条件查询的数据 

    3、分页查询

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.search.SearchRequest;
    5. import org.elasticsearch.action.search.SearchResponse;
    6. import org.elasticsearch.client.RequestOptions;
    7. import org.elasticsearch.client.RestClient;
    8. import org.elasticsearch.client.RestHighLevelClient;
    9. import org.elasticsearch.index.query.QueryBuilders;
    10. import org.elasticsearch.search.SearchHit;
    11. import org.elasticsearch.search.SearchHits;
    12. import org.elasticsearch.search.builder.SearchSourceBuilder;
    13.  
    14. /**
    15.  * @author DragonWu
    16.  * @date 2022-09-18 10:46
    17.  **/
    18. public class DocQuery {
    19.     public static void main(String[] args) throws Exception {
    20.         //创建ES客户端
    21.         RestHighLevelClient esClient = new RestHighLevelClient(
    22.                 RestClient.builder(new HttpHost("localhost", 9200, "http"))
    23.         );
    24.  
    25.         //条件查询 : termQuery
    26.         SearchRequest request = new SearchRequest();
    27.         request.indices("user");
    28.  
    29.         SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());
    30.         //(当前页码-1)*每页显示的条数
    31.         builder.from(0);
    32.         builder.size(2);
    33.  
    34.         request.source(builder);
    35.  
    36.         SearchResponse searchResponse = esClient.search(request, RequestOptions.DEFAULT);
    37.  
    38.         SearchHits hits = searchResponse.getHits();
    39.  
    40.         System.out.println(hits.getTotalHits());
    41.         System.out.println(searchResponse.getTook());
    42.  
    43.         for (SearchHit hit : hits) {
    44.             System.out.println(hit.getSourceAsString());
    45.         }
    46.  
    47.         //关闭ES客户端
    48.         esClient.close();
    49.     }
    50. }

    可以看到分页查询成功

     4、查询排序

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.search.SearchRequest;
    5. import org.elasticsearch.action.search.SearchResponse;
    6. import org.elasticsearch.client.RequestOptions;
    7. import org.elasticsearch.client.RestClient;
    8. import org.elasticsearch.client.RestHighLevelClient;
    9. import org.elasticsearch.index.query.QueryBuilders;
    10. import org.elasticsearch.search.SearchHit;
    11. import org.elasticsearch.search.SearchHits;
    12. import org.elasticsearch.search.builder.SearchSourceBuilder;
    13. import org.elasticsearch.search.sort.SortOrder;
    14.  
    15. /**
    16.  * @author DragonWu
    17.  * @date 2022-09-18 10:46
    18.  **/
    19. public class DocQuery {
    20.     public static void main(String[] args) throws Exception {
    21.         //创建ES客户端
    22.         RestHighLevelClient esClient = new RestHighLevelClient(
    23.                 RestClient.builder(new HttpHost("localhost", 9200, "http"))
    24.         );
    25.  
    26.         //条件查询 : termQuery
    27.         SearchRequest request = new SearchRequest();
    28.         request.indices("user");
    29.  
    30.         SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());
    31.         builder.sort("age", SortOrder.DESC);
    32.  
    33.         request.source(builder);
    34.  
    35.         SearchResponse searchResponse = esClient.search(request, RequestOptions.DEFAULT);
    36.  
    37.         SearchHits hits = searchResponse.getHits();
    38.  
    39.         System.out.println(hits.getTotalHits());
    40.         System.out.println(searchResponse.getTook());
    41.  
    42.         for (SearchHit hit : hits) {
    43.             System.out.println(hit.getSourceAsString());
    44.         }
    45.  
    46.         //关闭ES客户端
    47.         esClient.close();
    48.     }
    49. }

    排序成功

    5、过滤查询

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.search.SearchRequest;
    5. import org.elasticsearch.action.search.SearchResponse;
    6. import org.elasticsearch.client.RequestOptions;
    7. import org.elasticsearch.client.RestClient;
    8. import org.elasticsearch.client.RestHighLevelClient;
    9. import org.elasticsearch.index.query.QueryBuilders;
    10. import org.elasticsearch.search.SearchHit;
    11. import org.elasticsearch.search.SearchHits;
    12. import org.elasticsearch.search.builder.SearchSourceBuilder;
    13.  
    14. /**
    15.  * @author DragonWu
    16.  * @date 2022-09-18 10:46
    17.  **/
    18. public class DocQuery {
    19.     public static void main(String[] args) throws Exception {
    20.         //创建ES客户端
    21.         RestHighLevelClient esClient = new RestHighLevelClient(
    22.                 RestClient.builder(new HttpHost("localhost", 9200, "http"))
    23.         );
    24.  
    25.         SearchRequest request = new SearchRequest();
    26.         request.indices("user");
    27.  
    28.         SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());
    29.         String[] excludes={};
    30.         String[] includes={"name"};
    31.         builder.fetchSource(includes,excludes);
    32.  
    33.         request.source(builder);
    34.  
    35.         SearchResponse searchResponse = esClient.search(request, RequestOptions.DEFAULT);
    36.  
    37.         SearchHits hits = searchResponse.getHits();
    38.  
    39.         System.out.println(hits.getTotalHits());
    40.         System.out.println(searchResponse.getTook());
    41.  
    42.         for (SearchHit hit : hits) {
    43.             System.out.println(hit.getSourceAsString());
    44.         }
    45.  
    46.         //关闭ES客户端
    47.         esClient.close();
    48.     }
    49. }

    可以看到过滤后只剩下name字段 

    6、组合查询

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.search.SearchRequest;
    5. import org.elasticsearch.action.search.SearchResponse;
    6. import org.elasticsearch.client.RequestOptions;
    7. import org.elasticsearch.client.RestClient;
    8. import org.elasticsearch.client.RestHighLevelClient;
    9. import org.elasticsearch.index.query.BoolQueryBuilder;
    10. import org.elasticsearch.index.query.QueryBuilders;
    11. import org.elasticsearch.search.SearchHit;
    12. import org.elasticsearch.search.SearchHits;
    13. import org.elasticsearch.search.builder.SearchSourceBuilder;
    14.  
    15. /**
    16.  * @author DragonWu
    17.  * @date 2022-09-18 10:46
    18.  **/
    19. public class DocQuery {
    20.     public static void main(String[] args) throws Exception {
    21.         //创建ES客户端
    22.         RestHighLevelClient esClient = new RestHighLevelClient(
    23.                 RestClient.builder(new HttpHost("localhost", 9200, "http"))
    24.         );
    25.  
    26.         SearchRequest request = new SearchRequest();
    27.         request.indices("user");
    28.  
    29.         SearchSourceBuilder builder = new SearchSourceBuilder();
    30.         BoolQueryBuilder boolQueryBuilder= QueryBuilders.boolQuery();
    31.  
    32.         boolQueryBuilder.should(QueryBuilders.matchQuery("age",30));
    33.         boolQueryBuilder.should(QueryBuilders.matchQuery("age",40));
    34.  
    35.         builder.query(boolQueryBuilder);
    36.  
    37.         request.source(builder);
    38.  
    39.         SearchResponse searchResponse = esClient.search(request, RequestOptions.DEFAULT);
    40.  
    41.         SearchHits hits = searchResponse.getHits();
    42.  
    43.         System.out.println(hits.getTotalHits());
    44.         System.out.println(searchResponse.getTook());
    45.  
    46.         for (SearchHit hit : hits) {
    47.             System.out.println(hit.getSourceAsString());
    48.         }
    49.  
    50.         //关闭ES客户端
    51.         esClient.close();
    52.     }
    53. }

    运行截图

    7、范围查询

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.search.SearchRequest;
    5. import org.elasticsearch.action.search.SearchResponse;
    6. import org.elasticsearch.client.RequestOptions;
    7. import org.elasticsearch.client.RestClient;
    8. import org.elasticsearch.client.RestHighLevelClient;
    9. import org.elasticsearch.index.query.QueryBuilders;
    10. import org.elasticsearch.index.query.RangeQueryBuilder;
    11. import org.elasticsearch.search.SearchHit;
    12. import org.elasticsearch.search.SearchHits;
    13. import org.elasticsearch.search.builder.SearchSourceBuilder;
    14.  
    15. /**
    16.  * @author DragonWu
    17.  * @date 2022-09-18 10:46
    18.  **/
    19. public class DocQuery {
    20.     public static void main(String[] args) throws Exception {
    21.         //创建ES客户端
    22.         RestHighLevelClient esClient = new RestHighLevelClient(
    23.                 RestClient.builder(new HttpHost("localhost", 9200, "http"))
    24.         );
    25.  
    26.         SearchRequest request = new SearchRequest();
    27.         request.indices("user");
    28.  
    29.         SearchSourceBuilder builder = new SearchSourceBuilder();
    30.         RangeQueryBuilder rangeQuery = QueryBuilders.rangeQuery("age");
    31.  
    32.         rangeQuery.gte(30);
    33.         rangeQuery.lte(40);
    34.  
    35.         builder.query(rangeQuery);
    36.  
    37.         request.source(builder);
    38.  
    39.         SearchResponse searchResponse = esClient.search(request, RequestOptions.DEFAULT);
    40.  
    41.         SearchHits hits = searchResponse.getHits();
    42.  
    43.         System.out.println(hits.getTotalHits());
    44.         System.out.println(searchResponse.getTook());
    45.  
    46.         for (SearchHit hit : hits) {
    47.             System.out.println(hit.getSourceAsString());
    48.         }
    49.  
    50.         //关闭ES客户端
    51.         esClient.close();
    52.     }
    53. }

     

     8、模糊查询

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.search.SearchRequest;
    5. import org.elasticsearch.action.search.SearchResponse;
    6. import org.elasticsearch.client.RequestOptions;
    7. import org.elasticsearch.client.RestClient;
    8. import org.elasticsearch.client.RestHighLevelClient;
    9. import org.elasticsearch.common.unit.Fuzziness;
    10. import org.elasticsearch.index.query.QueryBuilders;
    11. import org.elasticsearch.search.SearchHit;
    12. import org.elasticsearch.search.SearchHits;
    13. import org.elasticsearch.search.builder.SearchSourceBuilder;
    14.  
    15. /**
    16.  * @author DragonWu
    17.  * @date 2022-09-18 10:46
    18.  **/
    19. public class DocQuery {
    20.     public static void main(String[] args) throws Exception {
    21.         //创建ES客户端
    22.         RestHighLevelClient esClient = new RestHighLevelClient(
    23.                 RestClient.builder(new HttpHost("localhost", 9200, "http"))
    24.         );
    25.  
    26.         SearchRequest request = new SearchRequest();
    27.         request.indices("user");
    28.  
    29.         SearchSourceBuilder builder = new SearchSourceBuilder();
    30.  
    31.         builder.query(QueryBuilders.fuzzyQuery("name","张三").fuzziness(Fuzziness.ONE));
    32.  
    33.         request.source(builder);
    34.  
    35.         SearchResponse searchResponse = esClient.search(request, RequestOptions.DEFAULT);
    36.  
    37.         SearchHits hits = searchResponse.getHits();
    38.  
    39.         System.out.println(hits.getTotalHits());
    40.         System.out.println(searchResponse.getTook());
    41.  
    42.         for (SearchHit hit : hits) {
    43.             System.out.println(hit.getSourceAsString());
    44.         }
    45.  
    46.         //关闭ES客户端
    47.         esClient.close();
    48.     }
    49. }

    9、高亮查询

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.search.SearchRequest;
    5. import org.elasticsearch.action.search.SearchResponse;
    6. import org.elasticsearch.client.RequestOptions;
    7. import org.elasticsearch.client.RestClient;
    8. import org.elasticsearch.client.RestHighLevelClient;
    9. import org.elasticsearch.index.query.QueryBuilders;
    10. import org.elasticsearch.index.query.TermsQueryBuilder;
    11. import org.elasticsearch.search.SearchHit;
    12. import org.elasticsearch.search.SearchHits;
    13. import org.elasticsearch.search.builder.SearchSourceBuilder;
    14. import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
    15.  
    16. /**
    17.  * @author DragonWu
    18.  * @date 2022-09-18 10:46
    19.  **/
    20. public class DocQuery {
    21.     public static void main(String[] args) throws Exception {
    22.         //创建ES客户端
    23.         RestHighLevelClient esClient = new RestHighLevelClient(
    24.                 RestClient.builder(new HttpHost("localhost", 9200, "http"))
    25.         );
    26.  
    27.         SearchRequest request = new SearchRequest();
    28.         request.indices("user");
    29.  
    30.         SearchSourceBuilder builder = new SearchSourceBuilder();
    31.         TermsQueryBuilder termsQueryBuilder = QueryBuilders.termsQuery("name", "李四");
    32.  
    33.         HighlightBuilder highlightBuilder=new HighlightBuilder();
    34.         highlightBuilder.preTags("");
    35.         highlightBuilder.postTags("");
    36.         highlightBuilder.field("name");
    37.  
    38.         builder.highlighter(highlightBuilder);
    39.         builder.query(termsQueryBuilder);
    40.  
    41.         request.source(builder);
    42.  
    43.         SearchResponse searchResponse = esClient.search(request, RequestOptions.DEFAULT);
    44.         SearchHits hits = searchResponse.getHits();
    45.  
    46.         System.out.println(hits.getTotalHits());
    47.         System.out.println(searchResponse.getTook());
    48.  
    49.         for (SearchHit hit : hits) {
    50.             System.out.println(hit.getSourceAsString());
    51.         }
    52.  
    53.         //关闭ES客户端
    54.         esClient.close();
    55.     }
    56. }

     10、分组查询

    1. package com.dragon.test;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.search.SearchRequest;
    5. import org.elasticsearch.action.search.SearchResponse;
    6. import org.elasticsearch.client.RequestOptions;
    7. import org.elasticsearch.client.RestClient;
    8. import org.elasticsearch.client.RestHighLevelClient;
    9. import org.elasticsearch.search.SearchHit;
    10. import org.elasticsearch.search.SearchHits;
    11. import org.elasticsearch.search.aggregations.AggregationBuilders;
    12. import org.elasticsearch.search.aggregations.bucket.terms.TermsAggregationBuilder;
    13. import org.elasticsearch.search.builder.SearchSourceBuilder;
    14.  
    15. /**
    16.  * @author DragonWu
    17.  * @date 2022-09-18 10:46
    18.  **/
    19. public class DocQuery {
    20.     public static void main(String[] args) throws Exception {
    21.         //创建ES客户端
    22.         RestHighLevelClient esClient = new RestHighLevelClient(
    23.                 RestClient.builder(new HttpHost("localhost", 9200, "http"))
    24.         );
    25.  
    26.         SearchRequest request = new SearchRequest();
    27.         request.indices("user");
    28.  
    29.         SearchSourceBuilder builder=new SearchSourceBuilder();
    30.  
    31.         TermsAggregationBuilder aggregationBuilder = AggregationBuilders.terms("ageGroup").field("age");
    32.         builder.aggregation(aggregationBuilder);
    33.  
    34.         request.source(builder);
    35.         SearchResponse searchResponse = esClient.search(request, RequestOptions.DEFAULT);
    36.  
    37.         SearchHits hits = searchResponse.getHits();
    38.  
    39.         System.out.println(hits.getTotalHits());
    40.         System.out.println(searchResponse.getTook());
    41.  
    42.         for (SearchHit hit : hits) {
    43.             System.out.println(hit.getSourceAsString());
    44.         }
    45.  
    46.         //关闭ES客户端
    47.         esClient.close();
    48.     }
    49. }

  • 相关阅读:
    Vue3, setup语法糖、Composition API全方位解读
    Win10文件资源管理器卡顿不流畅的解决方法
    Maven下载、安装、配置教程
    javascript： Sorting Algorithms
    Linux端口相关命令行
    基于随机无迹σ变异的改进HHO算法
    antv x6 沿边图标循环动画实现
    MYSQL快速从另外一张表中更新数据
    Android开发学习日记--简单页面跳转、延时页面跳转
    Ps：选框工具
  • 原文地址：https://blog.csdn.net/qq_50909707/article/details/126909308