SpringBoot整合ES

1.引入依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    <version>2.6.3</version>
</dependency>

2.config配置文件

@Configuration
public class RestClientConfig extends AbstractElasticsearchConfiguration {@Override@Beanpublic RestHighLevelClient elasticsearchClient() {final ClientConfiguration clientConfiguration =ClientConfiguration.builder().connectedTo("xx.xxx.xxx.xx:9200") //地址.build();return RestClients.create(clientConfiguration).rest();}
}

         会返回两个客户端对象，分别是ElasticsearchOperations和RestHighLevelClient(更推荐使用)。前者是通过面向对象的形式来操作的，后者是通过客户端的方式操作的。

3.索引相关操作

/*索引相关操作*/
public class Test1 {RestHighLevelClient restHighLevelClient;@Beforepublic void init(){final ClientConfiguration clientConfiguration =ClientConfiguration.builder().connectedTo("xx.xxxx.xxx.xx:xxxx").build();this.restHighLevelClient = RestClients.create(clientConfiguration).rest();}@Test//创建索引public void createIndex() throws IOException {CreateIndexRequest createIndexRequest = new CreateIndexRequest("products");//指定映射 参数1：指定映射json结构 参数2：指定数据类型createIndexRequest.mapping("{\n" +"    \"properties\": {\n" +"        \"id\":{\n" +"          \"type\":\"integer\"\n" +"        },\n" +"        \"title\":{\n" +"          \"type\":\"keyword\"\n" +"        },\n" +"        \"price\":{\n" +"          \"type\":\"double\"\n" +"        },\n" +"        \"created_at\":{\n" +"          \"type\":\"date\"\n" +"        },\n" +"        \"description\":{\n" +"          \"type\":\"text\",\n" +"          \"analyzer\": \"ik_max_word\"\n" +"        }\n" +"    }\n" +"  }", XContentType.JSON);//参数1：创建索引请求对象  参数2：请求配置对象CreateIndexResponse createIndexResponse = restHighLevelClient.indices().create(createIndexRequest, RequestOptions.DEFAULT);System.out.println("创建状态："+createIndexResponse.isAcknowledged()); //打印返回信息restHighLevelClient.close(); //关闭资源}@Test//删除索引public void deleteIndex() throws IOException {AcknowledgedResponse acknowledgedResponse = restHighLevelClient.indices().delete(new DeleteIndexRequest("products"), RequestOptions.DEFAULT);System.out.println("删除状态："+acknowledgedResponse.isAcknowledged()); //打印返回信息restHighLevelClient.close(); //关闭资源}
}

4.文档相关操作

/*文档相关操作(document)*/
public class Test2 {RestHighLevelClient restHighLevelClient;@Beforepublic void init(){final ClientConfiguration clientConfiguration =ClientConfiguration.builder().connectedTo("xx.xxx.xxx.xx:9200").build();this.restHighLevelClient = RestClients.create(clientConfiguration).rest();}@Test  //创建文档public void createDoc() throws IOException {IndexRequest indexRequest = new IndexRequest("products");indexRequest.id("2") //手动指定文档的id，如果不指定则会用uuid.source("{\n" +"  \"title\":\"瑞星咖啡\",\n" +"  \"price\": 9.8,\n" +"  \"created_at\":\"2023-11-18\",\n" +"  \"description\":\"瑞星咖啡我最爱了，好喝\"\n" +"}", XContentType.JSON);//参数1：索引请求对象，参数2：请求配置对象IndexResponse indexResponse = restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);System.out.println(indexResponse.status());restHighLevelClient.close();}@Test  //修改文档public void updateDoc() throws IOException {UpdateRequest updateRequest = new UpdateRequest("products","1");updateRequest.doc("{\n" +"    \"title\":\"库迪咖啡非\"\n" +"  }",XContentType.JSON);//参数1：索引请求对象，参数2：请求配置对象UpdateResponse updateResponse = restHighLevelClient.update(updateRequest, RequestOptions.DEFAULT);System.out.println(updateResponse.status());restHighLevelClient.close();}@Test  //删除文档public void deleteDoc() throws IOException {DeleteRequest deleteRequest = new DeleteRequest("products","2");//参数1：索引请求对象，参数2：请求配置对象DeleteResponse deleteResponse = restHighLevelClient.delete(deleteRequest, RequestOptions.DEFAULT);System.out.println(deleteResponse.status());restHighLevelClient.close();}@Test  //基于id查询文档public void searchDocById() throws IOException {GetRequest getRequest = new GetRequest("products", "1");GetResponse getResponse = restHighLevelClient.get(getRequest, RequestOptions.DEFAULT);System.out.println(getResponse.getId());System.out.println(getResponse.getSourceAsString());}}

5.高级查询

public class Test3 {RestHighLevelClient restHighLevelClient;@Beforepublic void init(){final ClientConfiguration clientConfiguration =ClientConfiguration.builder().connectedTo("xx.xxx.xxx.xx:9200").build();this.restHighLevelClient = RestClients.create(clientConfiguration).rest();}@Test //查询一个索引中的所有文档public void searchAll() throws IOException {SearchRequest searchRequest = new SearchRequest("products");searchRequest.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery()));//查询所有//参数1：搜索请求对象 参数2：请求配置对象SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);System.out.println("查询出来的总条数："+searchResponse.getHits().getTotalHits().value);System.out.println("查询出来的最大得分"+searchResponse.getHits().getMaxScore());//拿到数据结果SearchHit[] hits = searchResponse.getHits().getHits();for(SearchHit hit:hits){String id = hit.getId();System.out.println("id: "+id+" source: "+hit.getSourceAsString());}}@Test //基于关键词查询public void search() throws IOException {SearchRequest searchRequest = new SearchRequest("products");searchRequest.source(new SearchSourceBuilder().query(QueryBuilders.termQuery("description","好喝")));//查询所有//参数1：搜索请求对象 参数2：请求配置对象SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);System.out.println("查询出来的总条数："+searchResponse.getHits().getTotalHits().value);System.out.println("查询出来的最大得分"+searchResponse.getHits().getMaxScore());//拿到数据结果SearchHit[] hits = searchResponse.getHits().getHits();for(SearchHit hit:hits){String id = hit.getId();System.out.println("id: "+id+" source: "+hit.getSourceAsString());}}/** 分页查询* 排序* 字段*/@Test //分页查询 与排序public void search2() throws IOException {SearchRequest searchRequest = new SearchRequest("products");SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();searchSourceBuilder.query(QueryBuilders.matchAllQuery()).from(1) //起始位置 start=(page-1)*size.size(1) //每页显示条数.sort("price", SortOrder.ASC) //字段排序.fetchSource(new String[]{},new String[]{"created_at"}); //参数1：包含字段数组  参数2：排除字段数组searchRequest.source(searchSourceBuilder);//查询所有//参数1：搜索请求对象 参数2：请求配置对象SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);System.out.println("查询出来的总条数："+searchResponse.getHits().getTotalHits().value);System.out.println("查询出来的最大得分"+searchResponse.getHits().getMaxScore());//拿到数据结果SearchHit[] hits = searchResponse.getHits().getHits();for(SearchHit hit:hits){String id = hit.getId();System.out.println("id: "+id+" source: "+hit.getSourceAsString());}}@Test //高亮public void search3() throws IOException {SearchRequest searchRequest = new SearchRequest("products");SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();HighlightBuilder highlightBuilder = new HighlightBuilder();highlightBuilder.requireFieldMatch(false).field("description").field("title").preTags("<span style='color:red;'>").postTags("</span>");searchSourceBuilder.query(QueryBuilders.termQuery("description","好喝")).highlighter(highlightBuilder);searchRequest.source(searchSourceBuilder);//查询所有//参数1：搜索请求对象 参数2：请求配置对象SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);System.out.println("查询出来的总条数："+searchResponse.getHits().getTotalHits().value);System.out.println("查询出来的最大得分"+searchResponse.getHits().getMaxScore());//拿到数据结果SearchHit[] hits = searchResponse.getHits().getHits();for(SearchHit hit:hits){System.out.println("id: "+hit.getId()+" source: "+hit.getSourceAsString());//获取高亮字段Map<String, HighlightField> highlightFields = hit.getHighlightFields();if(highlightFields.containsKey("description")){System.out.println("description高亮结果： "+highlightFields.get("description").fragments()[0]);}if(highlightFields.containsKey("title")){System.out.println("title高亮结果： "+highlightFields.get("title").fragments()[0]);}}}@Test //过滤查询public void search4() throws IOException {SearchRequest searchRequest = new SearchRequest("products");SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();searchSourceBuilder.query(QueryBuilders.matchAllQuery()).postFilter(QueryBuilders.idsQuery().addIds("1")); //指定过滤条件searchRequest.source(searchSourceBuilder);//查询所有//参数1：搜索请求对象 参数2：请求配置对象SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);System.out.println("查询出来的总条数："+searchResponse.getHits().getTotalHits().value);System.out.println("查询出来的最大得分"+searchResponse.getHits().getMaxScore());//拿到数据结果SearchHit[] hits = searchResponse.getHits().getHits();for(SearchHit hit:hits){String id = hit.getId();System.out.println("id: "+id+" source: "+hit.getSourceAsString());}}
}