Press "Enter" to skip to content

SpringBoot整合SpringDataElasticsearch的基本使用

本站内容均来自兴趣收集,如不慎侵害的您的相关权益,请留言告知,我们将尽快删除.谢谢.

一 Spring Data Elasticsearch 项目环境搭建

 

1.1 修改pom文件添加依赖

 

目前使用spring-boot-starter-parent版本为2.6.8

 

对应spring-data-elasticsearch版本为4.3.4

 

<!-- springDateElasticsearch依赖-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>

 

1.2 修改application.yml配置文件

 

spring:
  elasticsearch:
    rest:
      uris: http://192.168.8.128:9200

 

二    ElasticsearchTemplate的使用

 

2.1  创建实体类

 

@Document指定实体类和索引对应关系

 

indexName:索引名称

 

type: 索引类型(从ES 7.0 开始已经过时了)

 

shards: 主分片数量。从ES 7开始默认1

 

replicas:复制分片数量。从ES 7开始默认1

 

@Id 指定主键

 

@Field指定普通属性

 

type: 对应Elasticsearch中属性类型。使用FiledType枚举可以快速获取。

 

text类型能被分词

 

keywords不能被分词

 

index: 是否创建索引。作为搜索条件时index必须为true

 

analyzer:指定分词器类型。

 

@Data
@Document(indexName = "student_index",shards = 1,replicas = 1)
public class Student {
    @Id
    private String id;
    @Field(type = FieldType.Keyword)
    private String name;
    @Field(type = FieldType.Text,analyzer = "ik_max_word")
    private String desc;
    @Field(type = FieldType.Text,analyzer = "ik_max_word")
    private String data;
    @Field(type = FieldType.Integer)
    private Integer age;
}

 

2.2  初始化索引

 

@Autowired
    private ElasticsearchRestTemplate elasticsearchRestTemplate;
    @Test
    void createIndex() {
        // 从 spring data es 4.0开始所有索引操作都在这个接口
        IndexOperations indexOperations = elasticsearchRestTemplate.indexOps(Student.class);
        // 是否存在,存在则删除
        if(indexOperations.exists()){
            indexOperations.delete();
        }
        // 创建索引
        indexOperations.create();
        // createMapping 根据实体类获取映射关系
        // putMapping 把映射关系添加到索引中
        Document mapping = indexOperations.createMapping(Student.class);
        indexOperations.putMapping(mapping);
    }

 

2.3  删除索引

 

/**
     * 删除索引
     */    @Test
    void deleteIndex() {
        IndexOperations indexOperations = elasticsearchRestTemplate.indexOps(Student.class);
        boolean delete = indexOperations.delete();
        System.out.println(delete);
    }

 

2.4  新增文档

新增单个文档

/**
     * 新增单个文档
     */    @Test
    void insert(){
        Student student = new Student();
        student.setAge(23);
        student.setData("123");
        student.setDesc("华为手机");
        student.setId("1");
        student.setName("张三");
        Student save = elasticsearchRestTemplate.save(student);
        System.out.println(save);
    }

批量新增

/**
     * 批量新增
     */    @Test
    void batchInsert(){
        List<Student> list = new ArrayList<>();
        list.add(new Student("2","李四","苹果手机","1",22));
        list.add(new Student("3","王五","oppo手机","2",24));
        list.add(new Student("4","赵六","voio手机","3",25));
        list.add(new Student("5","田七","小米手机","4",26));
        Iterable<Student> result = elasticsearchRestTemplate.save(list);
        System.out.println(result);
    }

 

2.5  删除操作

根据主键删除

/**
     * 根据主键删除
     */    @Test
    void  deleteById() {
        // 根据id删除
        String delete = elasticsearchRestTemplate.delete("5", Student.class);
        System.out.println(delete);
    }

根据条件删除

/**
     * 根据查询条件删除
     */    @Test
    void  delete() {
        QueryStringQueryBuilder queryBuilder = QueryBuilders.queryStringQuery("张三");
        Query query = new NativeSearchQuery(queryBuilder);
        ByQueryResponse QueryDelete = elasticsearchRestTemplate.delete(query, Student.class);
        System.out.println(QueryDelete);
    }

 

2.6  修改操作

全量替换

/**
     * 批量修改
     */    @Test
    void update(){
        Student student = new Student();
        student.setId("1");
        student.setAge(23);
        student.setData("99");
        student.setDesc("华为手机AND苹果手机");
        student.setName("张三");
        Student save = elasticsearchRestTemplate.save(student);
        System.out.println(save);
    }

部分修改

/**
     * 部分修改
     */    @Test
    void update2(){
        // ctx._source 固定写法
        String script = "ctx._source.age = 27;ctx._source.desc = 'oppo手机and苹果电脑'";
        UpdateQuery build = UpdateQuery.builder("3").withScript(script).build();
        IndexCoordinates indexCoordinates = IndexCoordinates.of("student_index");
        UpdateResponse update = elasticsearchRestTemplate.update(build, indexCoordinates);
        System.out.println(update.getResult());
    }

 

2.7 查询操作

根据主键查询

/**
     * 根据主键查查询
     */    @Test
    void  searchById(){
        Student student = elasticsearchRestTemplate.get("3", Student.class);
        System.out.println(student);
    }

模糊查询

/**
     * 模糊查询
     */    @Test
    void LikeSearch(){
        QueryStringQueryBuilder queryBuilder = QueryBuilders.queryStringQuery("手机");
        Query query = new NativeSearchQuery(queryBuilder);
        SearchHits<Student> search = elasticsearchRestTemplate.search(query, Student.class);
        List<SearchHit<Student>> searchHits = search.getSearchHits();
        List<Student> list = new ArrayList<>();
        searchHits.forEach(sh->{
            list.add(sh.getContent());
        });
        System.out.println(list);
    }

使用match_all查询所有文档

/**
     * 使用match_all查询所有文档
     */    @Test
    void matchAllSearch(){
        MatchAllQueryBuilder queryBuilder = QueryBuilders.matchAllQuery();
        Query query = new NativeSearchQuery(queryBuilder);
        SearchHits<Student> search = elasticsearchRestTemplate.search(query, Student.class);
        List<SearchHit<Student>> searchHits = search.getSearchHits();
        List<Student> list = new ArrayList<>();
        searchHits.forEach(sh->{
            list.add(sh.getContent());
        });
        System.out.println(list);
    }

使用match查询文档

/**
     * 使用match查询文档
     */    @Test
    void matchSearch(){
        Query query = new NativeSearchQuery( QueryBuilders.matchQuery("name","张三"));
        SearchHits<Student> search = elasticsearchRestTemplate.search(query, Student.class);
        List<SearchHit<Student>> searchHits = search.getSearchHits();
        System.out.println(search.getTotalHits());
        List<Student> list = new ArrayList<>();
        searchHits.forEach(sh->{
            list.add(sh.getContent());
        });
        System.out.println(list);
    }

使用match_phrase查询文档

/**
     * 使用match_phrase查询文档
     * 短语搜索是对条件不分词,但是文档中属性根据配置实体类时指定的分词类型进行分词。
     * 如果属性使用ik分词器,从分词后的索引数据中进行匹配。
     */    @Test
    void matchPhraseSearch(){
        Query query = new NativeSearchQuery( QueryBuilders.matchPhraseQuery("desc","电脑"));
        SearchHits<Student> search = elasticsearchRestTemplate.search(query, Student.class);
        List<SearchHit<Student>> searchHits = search.getSearchHits();
        System.out.println(search.getTotalHits());
        List<Student> list = new ArrayList<>();
        searchHits.forEach(sh->{
            list.add(sh.getContent());
        });
        System.out.println(list);
    }

使用range查询文档

/**
     * 使用range查询文档
     */    @Test
    void rangeSearch(){
        Query query = new NativeSearchQuery( QueryBuilders.rangeQuery("age").gte("24").lte(29));
        SearchHits<Student> search = elasticsearchRestTemplate.search(query, Student.class);
        List<SearchHit<Student>> searchHits = search.getSearchHits();
        System.out.println(search.getTotalHits());
        List<Student> list = new ArrayList<>();
        searchHits.forEach(sh->{
            list.add(sh.getContent());
        });
        System.out.println(list);
    }

多条件查询

/**
     *  多条件查询
     */    @Test
    void querysSearch(){
        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
        List<QueryBuilder> listQuery = new ArrayList<>();
        listQuery.add(QueryBuilders.matchQuery("name","张三"));
        listQuery.add(QueryBuilders.matchQuery("age","23"));
        boolQueryBuilder.must().addAll(listQuery);// 逻辑 与
//        boolQueryBuilder.should().addAll(listQuery);// 逻辑 或
        BoolQueryBuilder boolQueryBuilder2 = QueryBuilders.boolQuery();
        List<QueryBuilder> listQuery2 = new ArrayList<>();
        listQuery2.add(QueryBuilders.matchQuery("name","李四"));
        listQuery2.add(QueryBuilders.matchQuery("age","22"));
        boolQueryBuilder2.must().addAll(listQuery2);// 逻辑 与
        BoolQueryBuilder boolQueryBuilder3 = QueryBuilders.boolQuery();
        List<QueryBuilder> listQuery3 = new ArrayList<>();
        listQuery3.add(boolQueryBuilder);
        listQuery3.add(boolQueryBuilder2);
        boolQueryBuilder3.should().addAll(listQuery3);// 逻辑 或
        boolQueryBuilder3.must().addAll(listQuery3);// 逻辑 与
        NativeSearchQuery nativeSearchQuery = new NativeSearchQuery(boolQueryBuilder3);
        SearchHits<Student> search = elasticsearchRestTemplate.search(nativeSearchQuery, Student.class);
        List<SearchHit<Student>> searchHits = search.getSearchHits();
        System.out.println(search.getTotalHits());
        List<Student> list = new ArrayList<>();
        searchHits.forEach(sh->{
            list.add(sh.getContent());
        });
        System.out.println(list);
    }

分页与排序

/**
     * 分页查询
     */    @Test
    void pageSearch(){
        Query query = new NativeSearchQuery(QueryBuilders.matchAllQuery());
        // 排序
        query.addSort(Sort.by(Sort.Direction.DESC,"age"));
        // 分页
        query.setPageable(PageRequest.of(1,2));
        SearchHits<Student> searchHits = elasticsearchRestTemplate.search(query, Student.class);
        System.out.println(searchHits.getTotalHits());
        List<SearchHit<Student>> hitList = searchHits.getSearchHits();
        List<Student> listResult = new ArrayList<>();
        hitList.forEach(list->{
            listResult.add(list.getContent());
        });
        System.out.println(listResult);
    }

Be First to Comment

发表评论

您的电子邮箱地址不会被公开。