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、单元测试运行结果
保存结果
根据主键查询结果
更新结果
模糊搜索
7、关于查询与扩展
通过上面简单入门后，关于查询还有计数、排序、分页、条件等高级用法，这里可以在需要用到时再查询官方文档查看
