【Elasticsearch】- 使用JavaAPI操作elasticsearch

转x33g5p2x  于2022-06-13 转载在 ElasticSearch  
字(7.8k)|赞(0)|评价(0)|浏览(671)

工程准备

创建maven工程并引入Elasticsearch相关依赖：

  1. <dependency>
  2.             <groupId>org.elasticsearch</groupId>
  3.             <artifactId>elasticsearch</artifactId>
  4.             <version>7.8.0</version>
  5.         </dependency>
  6.         <!-- elasticsearch 的客户端 -->
  7.         <dependency>
  8.             <groupId>org.elasticsearch.client</groupId>
  9.             <artifactId>elasticsearch-rest-high-level-client</artifactId>
  10.             <version>7.8.0</version>
  11.         </dependency>
  12.         <!-- elasticsearch 依赖 2.x 的 log4j -->
  13.         <dependency>
  14.             <groupId>org.apache.logging.log4j</groupId>
  15.             <artifactId>log4j-api</artifactId>
  16.             <version>2.8.2</version>
  17.         </dependency>
  18.         <dependency>
  19.             <groupId>org.apache.logging.log4j</groupId>
  20.             <artifactId>log4j-core</artifactId>
  21.             <version>2.8.2</version>
  22.         </dependency>
  23.         <dependency>
  24.             <groupId>com.fasterxml.jackson.core</groupId>
  25.             <artifactId>jackson-databind</artifactId>
  26.             <version>2.9.9</version>
  27.         </dependency>
  28.         <!-- junit 单元测试 -->
  29.         <dependency>
  30.             <groupId>junit</groupId>
  31.             <artifactId>junit</artifactId>
  32.             <version>4.12</version>
  33.         </dependency>

索引操作

创建索引

  1. @Test
  2.     public void index_create_test() throws IOException {
  3.         //创建Elasticsearch客户端
  4.         RestHighLevelClient esClient = new RestHighLevelClient(
  5.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
  6.         );
  8.         //创建索引
  9.         CreateIndexRequest request = new CreateIndexRequest("student");
  10.         CreateIndexResponse createIndexResponse = esClient.indices().create(request, RequestOptions.DEFAULT);
  12.         boolean acknowledged = createIndexResponse.isAcknowledged();
  13.         System.out.println("响应状态："+acknowledged);
  15.         //关闭Elasticsearch客户端
  16.         esClient.close();
  17.     }

使用Postman测试索引是否成功：

查询索引

  1. @Test
  2.     public void index_get_test() throws IOException {
  3.         //创建Elasticsearch客户端
  4.         RestHighLevelClient esClient = new RestHighLevelClient(
  5.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
  6.         );
  8.         //查询索引
  9.         GetIndexRequest getIndexRequest = new GetIndexRequest("student");
  10.         GetIndexResponse getIndexResponse = esClient.indices().get(getIndexRequest, RequestOptions.DEFAULT);
  12.         System.out.println(getIndexResponse.getAliases());
  13.         System.out.println(getIndexResponse.getMappings());
  14.         System.out.println(getIndexResponse.getSettings());
  15.         
  16.         //关闭Elasticsearch客户端
  17.         esClient.close();
  18.     }

删除索引

  1. @Test
  2.     public void index_delete_test() throws IOException {
  3.         //创建Elasticsearch客户端
  4.         RestHighLevelClient esClient = new RestHighLevelClient(
  5.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
  6.         );
  8.         //删除索引
  9.         DeleteIndexRequest getIndexRequest = new DeleteIndexRequest("student");
  10.         AcknowledgedResponse delete = esClient.indices().delete(getIndexRequest, RequestOptions.DEFAULT);
  12.         System.out.println(delete.isAcknowledged());
  14.         //关闭Elasticsearch客户端
  15.         esClient.close();
  16.     }

文档操作

进行文档操作前，先创建文档数据对应的java实体类Student：

  1. @Data
  2. @AllArgsConstructor
  3. @NoArgsConstructor
  4. @ToString
  5. public class Student {
  6.     private String name;
  7.     private int age;
  8.     private String sex;
  9.     private String level;
  10. }

添加文档数据

  1. @Test
  2.     public void doc_insert_test() throws IOException {
  3.         //创建Elasticsearch客户端
  4.         RestHighLevelClient esClient = new RestHighLevelClient(
  5.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
  6.         );
  8.         IndexRequest request = new IndexRequest();
  9.         request.index("student").id("10000");
  11.         Student student = new Student();
  12.         student.setName("王同学");
  13.         student.setAge(22);
  14.         student.setSex("男");
  15.         student.setLevel("研究生");
  17.         ObjectMapper mapper = new ObjectMapper();
  18.         String studentJson = mapper.writeValueAsString(student);
  20.         request.source(studentJson, XContentType.JSON);
  21.         IndexResponse response = esClient.index(request, RequestOptions.DEFAULT);
  22.         System.out.println(response.getResult());
  24.         //关闭Elasticsearch客户端
  25.         esClient.close();
  26.     }

批量添加文档数据

  1. @Test
  2.     public void doc_insert_batch_test() throws IOException {
  3.         //创建Elasticsearch客户端
  4.         RestHighLevelClient esClient = new RestHighLevelClient(
  5.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
  6.         );
  8.         BulkRequest request = new BulkRequest();
  10.         request.add(new IndexRequest().index("student").id("10001").source(XContentType.JSON, "name", "张三"));
  11.         request.add(new IndexRequest().index("student").id("10002").source(XContentType.JSON, "name", "李四"));
  12.         request.add(new IndexRequest().index("student").id("10003").source(XContentType.JSON, "name", "王五"));
  14.         BulkResponse response = esClient.bulk(request, RequestOptions.DEFAULT);
  15.         System.out.println(response.getItems());
  17.         //关闭Elasticsearch客户端
  18.         esClient.close();
  19.     }

修改文档数据

  1. @Test
  2.     public void doc_update_test() throws IOException {
  3.         //创建Elasticsearch客户端
  4.         RestHighLevelClient esClient = new RestHighLevelClient(
  5.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
  6.         );
  8.         UpdateRequest request = new UpdateRequest();
  9.         request.index("student").id("10000");
  10.         request.doc(XContentType.JSON,"sex","女");
  12.         UpdateResponse response = esClient.update(request, RequestOptions.DEFAULT);
  13.         System.out.println(response.getResult());
  15.         //关闭Elasticsearch客户端
  16.         esClient.close();
  17.     }

根据id查询文档数据

  1. @Test
  2.     public void doc_search_test() throws IOException {
  3.         //创建Elasticsearch客户端
  4.         RestHighLevelClient esClient = new RestHighLevelClient(
  5.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
  6.         );
  8.         GetRequest request = new GetRequest();
  9.         request.index("student").id("10000");
  10.         GetResponse response = esClient.get(request, RequestOptions.DEFAULT);
  11.         System.out.println(response.getSourceAsString());
  13.         //关闭Elasticsearch客户端
  14.         esClient.close();
  15.     }

查询当前索引所有文档数据

  1. @Test
  2.     public void doc_search_all_test() throws IOException {
  3.         //创建Elasticsearch客户端
  4.         RestHighLevelClient esClient = new RestHighLevelClient(
  5.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
  6.         );
  8.         SearchRequest request = new SearchRequest();
  9.         request.indices("student");
  11.         request.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery()));
  13.         SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
  15.         SearchHits hits = response.getHits();
  16.         System.out.println(hits.getTotalHits());
  17.         for(SearchHit hit:hits){
  18.             System.out.println(hit.getSourceAsString());
  19.         }
  21.         //关闭Elasticsearch客户端
  22.         esClient.close();
  23.     }

分页查询

  1. @Test
  2.     public void doc_search_size_test() throws IOException {
  3.         //创建Elasticsearch客户端
  4.         RestHighLevelClient esClient = new RestHighLevelClient(
  5.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
  6.         );
  8.         SearchRequest request = new SearchRequest();
  9.         request.indices("student");
  11.         SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());
  12.         builder.from(0);
  13.         builder.size(2);
  15.         request.source(builder);
  17.         SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
  19.         SearchHits hits = response.getHits();
  20.         System.out.println(hits.getTotalHits());
  21.         for(SearchHit hit:hits){
  22.             System.out.println(hit.getSourceAsString());
  23.         }
  25.         //关闭Elasticsearch客户端
  26.         esClient.close();
  27.     }

模糊查询

  1. @Test
  2.     public void doc_search_match_test() throws IOException {
  3.         //创建Elasticsearch客户端
  4.         RestHighLevelClient esClient = new RestHighLevelClient(
  5.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
  6.         );
  8.         SearchRequest request = new SearchRequest();
  9.         request.indices("student");
  10.         request.source(new SearchSourceBuilder().query(QueryBuilders.termQuery("name","王")));
  12.         SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
  13.         SearchHits hits = response.getHits();
  14.         System.out.println(hits.getTotalHits());
  15.         for(SearchHit hit:hits){
  16.             System.out.println(hit.getSourceAsString());
  17.         }
  19.         //关闭Elasticsearch客户端
  20.         esClient.close();
  21.     }

删除文档数据

  1. @Test
  2.     public void doc_delete_test() throws IOException {
  3.         //创建Elasticsearch客户端
  4.         RestHighLevelClient esClient = new RestHighLevelClient(
  5.                 RestClient.builder(new HttpHost("localhost",9200,"http"))
  6.         );
  8.         DeleteRequest request = new DeleteRequest();
  9.         request.index("student").id("10000");
  10.         DeleteResponse response = esClient.delete(request, RequestOptions.DEFAULT);
  11.         System.out.println(response.getResult());
  13.         //关闭Elasticsearch客户端
  14.         esClient.close();
  15.     }

版权说明 : 本文为转载文章, 版权归原作者所有 版权申明

原文链接 : https://blog.csdn.net/weixin_43598687/article/details/125204871

内容来源于网络，如有侵权，请联系作者删除！

Java搜索引擎云原生与微服务

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com