SpringBoot中整合ElasticSearch实现增删改查等操作

场景

SpringBoot中整合ElasticSearch快速入门以及踩坑记录：

https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/135599698

在上面进行集成的基础上，实现对ES数据的增删改查等操作。

注：

博客：
霸道流氓气质-CSDN博客

实现

1、ElastciSearch的对象映射

Spring Data Elasticsearch - Reference Documentation

Spring Data Elasticsearch 对象映射是将 Java 对象（域实体）映射到存储在 Elasticsearch 中的 JSON 表示并返回的过程。

可用注解参考官网明细：

@Document：在类级别应用，以指示此类是映射到数据库的候选项。最重要的属性是：

indexName：要存储此实体的索引的名称。这可以包含一个 SpEL 模板表达式，例如"log-#{T(java.time.LocalDate).now().toString()}"

type：映射类型。如果未设置，则使用类的小写简单名称。（自 4.0 版起已弃用）

shards：索引的分片数。

replicas：索引的副本数。

refreshIntervall：索引的刷新间隔。用于创建索引。默认值为“1s”。

indexStoreType：索引的索引存储类型。用于创建索引。默认值为“fs”。

createIndex：标记是否在存储库引导时创建索引。默认值为 true。请参阅使用相应映射自动创建索引

versionType：版本管理的配置。默认值为 EXTERNAL。

@Id：在字段级别应用以标记用于标识目的的字段。

@Transient：默认情况下，所有字段在存储或检索文档时都映射到文档，此注释不包括该字段。

@PersistenceConstructor：标记给定的构造函数（甚至是受包保护的构造函数）以在从数据库实例化对象时使用。构造函数参数按名称映射到检索到的 Document 中的键值。

@Field：应用于字段级别并定义字段的属性，大部分属性映射到相应的 Elasticsearch Mapping 定义（以下列表不完整，请查看注解 Javadoc 以获取完整参考）：

name：将在 Elasticsearch 文档中表示的字段名称，如果未设置，则使用 Java 字段名称。

type：字段类型，可以是 Text、Keyword、Long、Integer、Short、Byte、Double、Float、Half_Float、Scaled_Float、Date、Date_Nanos、Boolean、Binary、Integer_Range、Float_Range、Long_Range、Double_Range、Date_Range、Ip_Range、Object、Nested、Ip、TokenCount、Percolator、Flattened、Search_As_You_Type之一。请参阅 Elasticsearch 映射类型

format以及 Date 类型的定义。pattern

store：标记是否应将原始字段值存储在 Elasticsearch 中，默认值为 false。

analyzer、，用于指定自定义分析器和规范化程序。searchAnalyzernormalizer

@GeoPoint：将字段标记为geo_point数据类型。如果字段是类的实例，则可以省略。GeoPoint

当然也可以自定义转换规则：

按照以上注解说明，新建实体类

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;

@Document(indexName="books",createIndex = true)
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class ElasticBook {
    @Id
    private Integer id;

    @Field(type = FieldType.Text)
    private String name;

    @Field(type = FieldType.Text)
    private String summary;

    @Field(type = FieldType.Integer)
    private Integer price;
}

这里createIndex 默认就是true,可以不写，代表如果索引不存在则创建。

2、增删改查实现

新建接口Repository，使其继承ElasticsearchRepository

import com.ruoyi.system.domain.study.ElasticBook;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Repository;
import java.util.List;

@Repository
public interface ElasticSearchRepository extends ElasticsearchRepository<ElasticBook,Integer> {
    List<ElasticBook> findByName(String name);
}

则可以直接使用其自带的各种方法

也可以自定义方法，比如findByName就是根据书名模糊搜索

自定义派生的方法不用实现，只要符合其关键字和规则可自动实现。

这块可参考官网从方法名称创建查询说明：

Spring Data Elasticsearch - Reference Documentation

3、新建Service接口

import java.util.List;

public interface IElasticSearchService {

    void save(ElasticBook book);

    ElasticBook findById(Integer id);

    void update(ElasticBook book);

    void deleteById(Integer id);

    List<ElasticBook> findByName(String name);
}

4、新建service实现

import com.ruoyi.system.repository.ElasticSearchRepository;
import com.ruoyi.system.service.IElasticSearchService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;

@Service
public class ElasticSearchServiceImpl implements IElasticSearchService {

    @Autowired
    private ElasticSearchRepository repository;

    @Override
    public void save(ElasticBook book) {
        repository.save(book);
    }

    @Override
    public ElasticBook findById(Integer id) {
        return repository.findById(id).get();
    }

    @Override
    public void update(ElasticBook book) {
        repository.save(book);
    }

    @Override
    public void deleteById(Integer id) {
        repository.deleteById(id);
    }

    @Override
    public List<ElasticBook> findByName(String name) {
        return repository.findByName(name);
    }
}

5、编写单元测试

@RunWith(SpringRunner.class)
@SpringBootTest(classes = RuoYiApplication.class,webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
public class ElasticSearchTest {

    @Autowired
    @Qualifier("elasticsearchClient")
    public RestHighLevelClient highLevelClient;

    @Autowired
    private IElasticSearchService iElasticSearchService;

    @Test
    public void connecTest() throws IOException {
        CreateIndexRequest request = new CreateIndexRequest("test");
        CreateIndexResponse response = highLevelClient.indices().create(request, RequestOptions.DEFAULT);
        // 查看是否创建成功
        System.out.println(response.isAcknowledged());
        highLevelClient.close();
    }

    //保存
    @Test
    public void saveTest() throws IOException {
        ElasticBook book = ElasticBook.builder().id(1).name("书名1").summary("霸道的程序猿").price(100).build();
        iElasticSearchService.save(book);
        highLevelClient.close();
        System.out.println("保存成功");
    }

    //根据主键查询
    @Test
    public void findTest() throws IOException {
        ElasticBook book = ElasticBook.builder().id(2).name("书名2").summary("霸道的程序猿").price(80).build();
        iElasticSearchService.save(book);
        ElasticBook book1 = iElasticSearchService.findById(2);
        highLevelClient.close();
        System.out.println("查询成功");
        System.out.println(book1);
    }

    //根据主键更新
    @Test
    public void updateTest() throws IOException {
        ElasticBook book = ElasticBook.builder().id(2).name("书名2更新").summary("霸道的程序猿").price(80).build();
        iElasticSearchService.update(book);
        ElasticBook book1 = iElasticSearchService.findById(2);
        highLevelClient.close();
        System.out.println("更新成功");
        System.out.println(book1);
    }

    //根据主键删除
    @Test
    public void deleteTest() throws IOException {
        iElasticSearchService.deleteById(1);
        highLevelClient.close();
        System.out.println("删除成功");
    }

    //派生查询
    @Test
    public void findByNameTest() throws IOException {
        List<ElasticBook> bookList = iElasticSearchService.findByName("书名");
        highLevelClient.close();
        System.out.println("查询成功");
        System.out.println(bookList);
    }
}

6、单元测试运行结果

保存结果