文章目录

• 工程准备
• 索引操作
• • 创建索引
  • 查询索引
  • 删除索引
• 文档操作
• • 添加文档数据
  • 批量添加文档数据
  • 修改文档数据
  • 根据id查询文档数据
  • 查询当前索引所有文档数据
  • 分页查询
  • 模糊查询
  • 删除文档数据

工程准备

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

 <dependency>     <groupId>org.elasticsearch</groupId>     <artifactId>elasticsearch</artifactId>     <version>7.8.0</version> </dependency>  <dependency>     <groupId>org.elasticsearch.client</groupId>     <artifactId>elasticsearch-rest-high-level-client</artifactId>     <version>7.8.0</version> </dependency>  <dependency>     <groupId>org.apache.logging.log4j</groupId>     <artifactId>log4j-api</artifactId>     <version>2.8.2</version> </dependency> <dependency>     <groupId>org.apache.logging.log4j</groupId>     <artifactId>log4j-core</artifactId>     <version>2.8.2</version> </dependency> <dependency>     <groupId>com.fasterxml.jackson.core</groupId>     <artifactId>jackson-databind</artifactId>     <version>2.9.9</version> </dependency>  <dependency>     <groupId>junit</groupId>     <artifactId>junit</artifactId>     <version>4.12</version> </dependency>

索引操作

创建索引

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

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

查询索引

    @Test    public void index_get_test() throws IOException { //创建Elasticsearch客户端 RestHighLevelClient esClient = new RestHighLevelClient(  RestClient.builder(new HttpHost("localhost",9200,"http")) ); //查询索引 GetIndexRequest getIndexRequest = new GetIndexRequest("student"); GetIndexResponse getIndexResponse = esClient.indices().get(getIndexRequest, RequestOptions.DEFAULT); System.out.println(getIndexResponse.getAliases()); System.out.println(getIndexResponse.getMappings()); System.out.println(getIndexResponse.getSettings());  //关闭Elasticsearch客户端 esClient.close();    }

删除索引

    @Test    public void index_delete_test() throws IOException { //创建Elasticsearch客户端 RestHighLevelClient esClient = new RestHighLevelClient(  RestClient.builder(new HttpHost("localhost",9200,"http")) ); //删除索引 DeleteIndexRequest getIndexRequest = new DeleteIndexRequest("student"); AcknowledgedResponse delete = esClient.indices().delete(getIndexRequest, RequestOptions.DEFAULT); System.out.println(delete.isAcknowledged()); //关闭Elasticsearch客户端 esClient.close();    }

文档操作

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

@Data@AllArgsConstructor@NoArgsConstructor@ToStringpublic class Student {    private String name;    private int age;    private String sex;    private String level;}

添加文档数据

    @Test    public void doc_insert_test() throws IOException { //创建Elasticsearch客户端 RestHighLevelClient esClient = new RestHighLevelClient(  RestClient.builder(new HttpHost("localhost",9200,"http")) ); IndexRequest request = new IndexRequest(); request.index("student").id("10000"); Student student = new Student(); student.setName("王同学"); student.setAge(22); student.setSex("男"); student.setLevel("研究生"); ObjectMapper mapper = new ObjectMapper(); String studentJson = mapper.writeValueAsString(student); request.source(studentJson, XContentType.JSON); IndexResponse response = esClient.index(request, RequestOptions.DEFAULT); System.out.println(response.getResult()); //关闭Elasticsearch客户端 esClient.close();    }

批量添加文档数据

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

修改文档数据

@Test    public void doc_update_test() throws IOException { //创建Elasticsearch客户端 RestHighLevelClient esClient = new RestHighLevelClient(  RestClient.builder(new HttpHost("localhost",9200,"http")) ); UpdateRequest request = new UpdateRequest(); request.index("student").id("10000"); request.doc(XContentType.JSON,"sex","女"); UpdateResponse response = esClient.update(request, RequestOptions.DEFAULT); System.out.println(response.getResult()); //关闭Elasticsearch客户端 esClient.close();    }

根据id查询文档数据

    @Test    public void doc_search_test() throws IOException { //创建Elasticsearch客户端 RestHighLevelClient esClient = new RestHighLevelClient(  RestClient.builder(new HttpHost("localhost",9200,"http")) ); GetRequest request = new GetRequest(); request.index("student").id("10000"); GetResponse response = esClient.get(request, RequestOptions.DEFAULT); System.out.println(response.getSourceAsString()); //关闭Elasticsearch客户端 esClient.close();    }

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

    @Test    public void doc_search_all_test() throws IOException { //创建Elasticsearch客户端 RestHighLevelClient esClient = new RestHighLevelClient(  RestClient.builder(new HttpHost("localhost",9200,"http")) ); SearchRequest request = new SearchRequest(); request.indices("student"); request.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery())); SearchResponse response = esClient.search(request, RequestOptions.DEFAULT); SearchHits hits = response.getHits(); System.out.println(hits.getTotalHits()); for(SearchHit hit:hits){     System.out.println(hit.getSourceAsString()); } //关闭Elasticsearch客户端 esClient.close();    }

分页查询

    @Test    public void doc_search_size_test() throws IOException { //创建Elasticsearch客户端 RestHighLevelClient esClient = new RestHighLevelClient(  RestClient.builder(new HttpHost("localhost",9200,"http")) ); SearchRequest request = new SearchRequest(); request.indices("student"); SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery()); builder.from(0); builder.size(2); request.source(builder); SearchResponse response = esClient.search(request, RequestOptions.DEFAULT); SearchHits hits = response.getHits(); System.out.println(hits.getTotalHits()); for(SearchHit hit:hits){     System.out.println(hit.getSourceAsString()); } //关闭Elasticsearch客户端 esClient.close();    }

模糊查询

    @Test    public void doc_search_match_test() throws IOException { //创建Elasticsearch客户端 RestHighLevelClient esClient = new RestHighLevelClient(  RestClient.builder(new HttpHost("localhost",9200,"http")) ); SearchRequest request = new SearchRequest(); request.indices("student"); request.source(new SearchSourceBuilder().query(QueryBuilders.termQuery("name","王"))); SearchResponse response = esClient.search(request, RequestOptions.DEFAULT); SearchHits hits = response.getHits(); System.out.println(hits.getTotalHits()); for(SearchHit hit:hits){     System.out.println(hit.getSourceAsString()); } //关闭Elasticsearch客户端 esClient.close();    }

删除文档数据

    @Test    public void doc_delete_test() throws IOException { //创建Elasticsearch客户端 RestHighLevelClient esClient = new RestHighLevelClient(  RestClient.builder(new HttpHost("localhost",9200,"http")) ); DeleteRequest request = new DeleteRequest(); request.index("student").id("10000"); DeleteResponse response = esClient.delete(request, RequestOptions.DEFAULT); System.out.println(response.getResult()); //关闭Elasticsearch客户端 esClient.close();    }