当前位置： 首页 > article >正文

使用Spring Data Elasticsearch 进行索引的增、删、改、查

article 2024/11/15 4:30:03

一 Spring Data Elasticsearch 项目环境搭建

1.1 修改pom文件添加依赖

目前使用spring-boot-starter-parent版本为2.2.8.RELEASE

对应spring-data-elasticsearch版本为2.2.8.RELEASE，版本对应可以自行百度，如果不行直接用elasticsearch-rest-high-level-client工具类吧

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

        <dependency>
            <groupId>org.elasticsearch</groupId>
            <artifactId>elasticsearch</artifactId>
            <version>7.5.0</version>
        </dependency>

        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-client</artifactId>
            <version>7.5.0</version>
        </dependency>

        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-high-level-client</artifactId>
            <version>7.5.0</version>
        </dependency>
1.2 新建配置文件
import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * ES配置类
 *
 * @author lc
 * @version 1.0
 * @date 2022/3/25 10:53
 */
@Configuration
public class ElasticSearchClientConfig {


    @Bean
    public RestHighLevelClient restHighLevelClient() {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("192.168.1.100", 9200, "http")));
        return client;
    }
}

二 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);
    }

http://www.kler.cn/a/107859.html

相关文章：

  • C++《继承》
  • 力扣104 ： 二叉树最大深度
  • 《新智慧》期刊的征稿范围主要包括哪些方面？
  • MySQL数据库：SQL语言入门 【下】（学习笔记）
  • WebRTC API分析
  • 【pytorch】常用强化学习算法实现（持续更新）
  • 第二次课10.28
  • 监控数据控中的数据表
  • Linux cp命令：复制文件和目录
  • 设置Oracle数据库默认为spfle启动，并且设置数据库SGA大小和PGA大小
  • 如何监听/抓取两个设备/芯片之间“UART串口”通信数据--监视TXD和RXD
  • Postman —— 配置环境变量
  • Linux Centos7安装后，无法查询到IP地址，无ens0，只有lo和ens33的解决方案
  • Unity中从3D模型资产中批量提取材质
  • TypeScript -类型断言的简单理解
  • 牛客小白月赛80 D一种因子游戏
  • 【C++】C++入门（下）--内联函数 auto关键字 nullptr
  • Java IDEA controller导出CSV，excel
  • 07-定位布局
  • Nginx的进程结构实例演示
  • RK3568平台 IIC子系统框架
  • Mybatis基础
  • C语言之错误处理
  • 前端CodeReivew实践 | 京东云技术团队
  • lesson2（补充）关于const成员函数
  • IP网络矿用打点紧急广播方案