Spring Data Elasticsearch 的简单使用

目录

一、简介

二、配置

三、映射

四、 常用方法

五、操作（重点）

1、对索引表的操作

2、对文档的操作（重点）

（1）、添加文档

 （2）、删除文档

（3）、查询文档（重点）

查询全部文档 （两种方式）

matchQuery根据关键字拆分进行全局搜索

matchPhraseQuery短语搜索--完整搜索

rangeQuery范围搜索

termQuery精确搜索

boolQuery()复合查询

withPageable分页查询

withSorts对结果进行排序

高亮查询

---

一、简介

 

springData 操作ES类似于Mybatis-plus操作Mysql,都是简单易用

本博客基于springboot2最新方式操作 Elasticsearch7.12.1

二、配置

采用gradle构建 （maven构建一直失败）

implementation 'org.springframework.boot:spring-boot-starter-data-elasticsearch'

 最新的yml配置

spring:elasticsearch:uris: http://101.201.209.14:9200

三、映射

映射pojo

@Data
@NoArgsConstructor
@AllArgsConstructor
@Document(indexName ="people_index") // 索引名字
public class People {@Id    private String id;    // Keyword类型不被分词索引    类型  分词器@Field(type = FieldType.Text,analyzer = "ik_max_word")private String name;    @Field(type = FieldType.Text,analyzer = "ik_max_word")private String address;    // index = false 不建立分词索引    @Field(type = FieldType.Long,index = true)private int age;
}

根据pojo创建索引

@SpringBootTestclass 
EsDemo1ApplicationTests {// 直接注入使用@Autowired    ElasticsearchRestTemplate elasticsearchTemplate;    @Testvoid esTest(){// 创建索引    IndexOperations indexOperations = elasticsearchTemplate.indexOps(People.class);   if(!indexOperations.exists()) { // 当前索引不存在boolean result1 =indexOperations.create();// 只是创建索引 。mappings没有映射boolean result2 = indexOperations.putMapping();// 映射属性    System.out.println("创建结果：" + ",映射结果：" + result2);}else {System.out.println("文档已存在");}
}

验证索引表是否创建成功

GET people_index/_mapping

四、 常用方法

ElasticsearchRestTemplate 常用方法

1、save ：保存或者更新文档
elasticsearchRestTemplate.save(object);2、index: 保存或更新文档数据到指定索引和类型中
IndexQuery indexQuery = new IndexQueryBuilder().withObject(object).build();
elasticsearchRestTemplate.index(indexQuery, IndexCoordinates.of(indexName));3、get: 根据文档 ID 获取文档数据。
elasticsearchRestTemplate.get(id, DocumentClass.class);4、update: 更新指定文档的数据。
UpdateQuery updateQuery = new UpdateQueryBuilder().withId(id).withObject(updatedObject).build();
elasticsearchRestTemplate.update(updateQuery, IndexCoordinates.of(indexName));5、delete: 删除指定文档。
elasticsearchRestTemplate.delete(id, IndexCoordinates.of(indexName));6、exists: 判断指定文档是否存在。
elasticsearchRestTemplate.exists(id, IndexCoordinates.of(indexName));7、search: 执行搜索操作，使用 Query 条件进行搜索。
NativeSearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(QueryBuilders.matchQuery("field", "value")).build();
List<DocumentClass> resultList = elasticsearchRestTemplate.search(searchQuery, DocumentClass.class, IndexCoordinates.of(indexName));8、count: 计算满足指定条件的文档数量。
NativeSearchQuery countQuery = new NativeSearchQueryBuilder().withQuery(QueryBuilders.matchQuery("field", "value")).build();
long count = elasticsearchRestTemplate.count(countQuery, IndexCoordinates.of(indexName));

IndexOperations 常用方法

1、create()：创建索引。如果索引已存在，则会抛出异常。2、delete()：删除索引。如果索引不存在，则会抛出异常。3、exists()：检查索引是否存在。4、putMapping()：为索引设置映射。MappingContext 是 Spring Data Elasticsearch 提供的用于获取实体类映射信息的接口。5、refresh()：刷新索引，使之可搜索最新添加的文档。在索引文档后，需要调用 refresh() 方法才能保证文档可以被搜索到。6、getIndexSettings()：获取索引的配置信息。7、getAliases()：获取索引的别名信息。8、addAlias(AliasQuery aliasQuery)：添加别名。9、removeAlias(AliasQuery aliasQuery)：移除别名。10、getSettings()：获取索引的详细配置信息。11、updateSettings(UpdateSettingsRequest request)：更新索引的配置信息。

其实真正常用的也就是

        保存/修改文档

        elasticsearchRestTemplate.save()

        查询文档

        elasticsearchRestTemplate.search()  

以及NativeSearchQuery 搜索对象

五、操作（重点）

1、对索引表的操作

对索引表的操作常用的也就是，创建/修改、删除

创建就是上面提到的映射

删除索引表：

@Test
void esTest2(){IndexOperations indexOperations = elasticsearchTemplate.indexOps(People.class);    boolean delete = indexOperations.delete();   // 删除索引      System.out.println("删除索引："+delete);}

2、对文档的操作（重点）

对于ES来说，索引就是表，文档就是数据

（1）、添加文档

添加一条

// 添加文档
@Test
void esTest3(){People people=new People();    people.setId("1232");    people.setName("张三");    people.setAge(32);    // 保存文档--save 根据文档id修改或者创建文档  People save = elasticsearchTemplate.save(people);   }

批量添加

// 批量添加
@Test
void esTest4(){List<People> list= Arrays.asList(new People("1","李四","长沙",23),            new People("2","李四","长沙",23),            new People("3","李四","长沙",23),            new People("4","李四","长沙",23));    Iterable<People> save1 = elasticsearchTemplate.save(list);    System.out.println("数据"+save1);}

检查是否添加完成

GET people_index/_search

 （2）、删除文档

// 删除操作
@Test
void esTest5(){// id   // 对应索引库    
String delete = elasticsearchTemplate.delete("1", People.class);    
}

除了根据id删除文档外，还可以根据条件删除文档，请类比下面的查询操作

（3）、查询文档（重点）

 matchQuery按关键字查询（关键字也会被拆分），示例

@Test
void query(){// 创建查询  字段--索引    NativeSearchQuery searchQuery=new NativeSearchQueryBuilder().withQuery(QueryBuilders.matchQuery("address", "太阳")).build();    // // 查询    SearchHits<People> search1 = elasticsearchTemplate.search(searchQuery, People.class);    search1.forEach(System.out::println);
}

查询全部文档 （两种方式）

// 第一种 ，不加查询条件
@Test
void query(){ // 查询--全部文档SearchHits<People> search1 = elasticsearchTemplate.search(new NativeSearchQueryBuilder().build(), People.class);    search1.forEach(System.out::println);}// 第二种
// 查询全部
//matchAllQuery
@Test
void query3(){// 创建查询  字段--索引    NativeSearchQuery searchQuery=new NativeSearchQueryBuilder()// 根据关键字进行全局模糊搜索            .withQuery(QueryBuilders.matchAllQuery())         .build();    // 查询    SearchHits<People> search1 = elasticsearchTemplate.search(searchQuery,People.class);    search1.forEach(System.out::println);}

matchQuery根据关键字拆分进行全局搜索

@Test
void query1(){// 创建查询  字段--索引    NativeSearchQuery searchQuery=new NativeSearchQueryBuilder()// 根据关键字进行全局模糊搜索            .withQuery(QueryBuilders.matchQuery("李四")) // "李四"会被拆分成关键字进行搜索           .build();    // 查询    SearchHits<People> search1 = elasticsearchTemplate.search(searchQuery,People.class);    search1.forEach(System.out::println);
}

matchPhraseQuery短语搜索--完整搜索

不会对关键字的拆分搜索

// 短语搜索
@Test
void query4(){// 创建查询  字段--索引    NativeSearchQuery searchQuery=new NativeSearchQueryBuilder()// 根据关键字进行全局模糊搜索            .withQuery(QueryBuilders.matchPhraseQuery("address","长沙市"))     // “长沙市” 不会进行拆分.build();    // 查询    SearchHits<People> search1 = elasticsearchTemplate.search(searchQuery,People.class);    search1.forEach(System.out::println);}// 解释下什么是短语搜索比如查询 "小明爱吃葡萄"普通关键字查找（matchQuery），这句查找关键字会被拆分成 "小明","爱吃","葡萄" 等，查出的结果满足一个关键字即可，即查出来的结果可能会出现 "小明爱吃香蕉"短语搜索出来的结果 就是以"小明爱吃葡萄"为关键字去搜索，不会对关键字再进行拆分

rangeQuery范围搜索

适用于数值类型

// 范围搜索
@Test
void query5(){// 创建查询  字段--索引    NativeSearchQuery searchQuery=new NativeSearchQueryBuilder()// 根据关键字进行全局模糊搜索 lte <=  gte >=            .withQuery(QueryBuilders.rangeQuery("age").gte(10).lte(20))          .build();    // 查询    SearchHits<People> search1 = elasticsearchTemplate.search(searchQuery,People.class);    search1.forEach(System.out::println);
}

termQuery精确搜索

注意： 对于text类型且使用的ik分词的字段而言， termQuery的作用和matchPhraseQuery 类似,所以termQuery 适用于keyword类型的字段和数值类型的字段

// 精确搜索
@Test
void query6(){// 创建查询  字段--索引    NativeSearchQuery searchQuery=new NativeSearchQueryBuilder()// 根据关键字进行全局模糊搜索 lte <=  gte >=            .withQuery(QueryBuilders.termQuery("age",15)).build();    // 查询    SearchHits<People> search1 = elasticsearchTemplate.search(searchQuery,People.class);    search1.forEach(System.out::println);}

boolQuery()复合查询

对于优先级别问题 使用多个must 来处理

// 复合查询
@Test
void query7(){// 创建查询  字段--索引    NativeSearchQuery searchQuery=new NativeSearchQueryBuilder()// boolQuery 符合查询，must必须  should 或者            // name=李四 ||age>=30            // QueryBuilders.boolQuery().should(QueryBuilders.termQuery("name","李四")).should(QueryBuilders.rangeQuery("age").gte(30))            // name=李四 && age>=30            // QueryBuilders.boolQuery().must(QueryBuilders.termQuery("name","李四")).must(QueryBuilders.rangeQuery("age").gte(30))            //  (name=李四 || age>=25) && age <=30  使用must 处理优先级问题            .withQuery(QueryBuilders.boolQuery().must(QueryBuilders.boolQuery().should(QueryBuilders.termQuery("name","李四")).should(QueryBuilders.rangeQuery("age").gte(25))).must(QueryBuilders.rangeQuery("age").lte(30))).build();    // 查询    SearchHits<People> search1 = elasticsearchTemplate.search(searchQuery,People.class);    search1.forEach(System.out::println);}

withPageable分页查询

需要对查询结果进行封装

@Test
void query8() throws JsonProcessingException {// 创建查询  字段--索引    NativeSearchQuery searchQuery=new NativeSearchQueryBuilder()                                                                                // 页码(从0开始) 每页条数                                                    .withPageable(PageRequest.of(0,2)).build();    // 查询    SearchHits<People> search = elasticsearchTemplate.search(searchQuery, People.class);    // 对查询结果进行封装--Page    SearchPage<People> searchHits = SearchHitSupport.searchPageFor(search, searchQuery.getPageable());    System.out.println("当前页码(从0开始)：getNumber:"+searchHits.getNumber());    System.out.println("总页数：getTotalPages :"+searchHits.getTotalPages());    System.out.println("每页的最大数据条数：getSize: "+searchHits.getSize());    System.out.println("是否有下一页数据：hasNext: "+searchHits.hasNext());    System.out.println("是否有上一页数据：hasPrevious: "+searchHits.hasPrevious());    System.out.println("当前页数据：getContent: "+searchHits.getContent());   String s = objectMapper.writeValueAsString(searchHits);                System.out.println("json:"+s);
}

withSorts对结果进行排序

@Test
void query8() throws JsonProcessingException {// 创建查询  字段--索引    NativeSearchQuery searchQuery=new NativeSearchQueryBuilder()// 查询全部            .withQuery(QueryBuilders.matchAllQuery())// 根据 age 字段进行从大到小排序            // 字段             排序规则.withSorts(SortBuilders.fieldSort("age").order(SortOrder.DESC)).build();    // 查询    SearchHits<People> search = elasticsearchTemplate.search(searchQuery, People.class);    search.forEach(System.out::println);}

高亮查询

把查询结果的关键字进行高亮处理

// 高亮查询
@Test
void query9() throws JsonProcessingException {// 创建查询  字段--索引    // 创建高亮设置    HighlightBuilder highlightBuilder=new HighlightBuilder();    // 设置高亮的结果字段                        结果前面添加内容                                后续添加内容    highlightBuilder.field("address").preTags("<span style=\"color:red\">").postTags("</span>");    highlightBuilder.field("name").preTags("<span style=\"color:red\">").postTags("</span>");    NativeSearchQuery searchQuery=new NativeSearchQueryBuilder().withQuery(QueryBuilders.matchQuery("address","长沙"))// 处理高亮            .withHighlightBuilder(highlightBuilder).build();    // 查询    SearchHits<People> search = elasticsearchTemplate.search(searchQuery, People.class);    // 查询结果为SearchHits --SearchHit为封装的单个数据，高亮数据在highlightFields 中    List<SearchHit<People>> searchHits = search.getSearchHits();    searchHits.forEach(System.out::println);
}