简介
Spring Data for Elasticsearch 是 Spring Data 项目的一部分，该项目旨在为新数据存储提供熟悉且一致的基于 Spring 的编程模型，同时保留特定于存储的特性和功能。
Spring Data Elasticsearch 项目提供了与 Elasticsearch 搜索引擎的集成。Spring Data Elasticsearch 的关键功能领域是以 POJO 为中心的模型，用于与 Elastichsearch 文档交互并轻松编写存储库样式的数据访问层。
简单使用
1.创建SpringBoot项目，导入Spring Data Elasticsearch的起步依赖。
/*elasticsearch的起步依赖*/
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>/*lomobok起步依赖*/<dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional>
</dependency>
2.编写配置文件，连接ElasticSearch
spring:elasticsearch:uris: https://192.168.66.101:9200username: elasticpassword: 12345678
打印日志
logging: pattern: console: '%d{HH:mm:ss.SSS} %clr(%-5level) --- [%-15thread] %cyan(%-50logger{50}):%msg%n'
从 ES8 开始，访问 ES 的协议从 http 变成了 https ，访问 https 请求 需要SSL 证书，在开发环境下我们不需要配置该证书，在项目中 添加一个配置类，跳过SSL 证书检查即可。
3.创建配置类跳过SSL证书检查
@Component
public class RestClientBuilderCustomizerImpl implements RestClientBuilderCustomizer {@Overridepublic void customize(RestClientBuilder builder) {}/*** 跳过SSL的证书检查*/@Overridepublic void customize(HttpAsyncClientBuilder builder) {SSLContextBuilder sscb = SSLContexts.custom();try {sscb.loadTrustMaterial((chain, authType) -> {return true;});} catch (NoSuchAlgorithmException e) {throw new RuntimeException(e);} catch (KeyStoreException e) {throw new RuntimeException(e);}try {builder.setSSLContext(sscb.build());} catch (KeyManagementException | NoSuchAlgorithmException e) {e.printStackTrace();}}
}4.创建实体类
一个实体类的所有对象都会存入 ES 的一个索引中，所以我们在创建实体类时关联ES 索引
@Document(indexName = "product",createIndex = true) //关联名为product的索引
@Data
@AllArgsConstructor
public class Product {@Id //标记在成员变量上，标记一个字段为主键，该字段的值会同步到ES该文档的id值//标记在成员变量上，标记为文档中的域，一般有如下属性->// type域的类型,index是否创建索引,store是否单独存储,analyzer分词器,searchAnalyzer搜索分词器@Field(type = FieldType.Integer,store = true,index = true)private Integer id;@Field(type = FieldType.Text,store = true,index = true,analyzer = "ik_max_word",searchAnalyzer = "ik_max_word")private String productName;@Field(type = FieldType.Text,store = true,index = true,analyzer = "ik_max_word",searchAnalyzer = "ik_max_word")private String productDesc;
}5.创建Repository接口
Repository 接口继承 ElasticsearchRepository， 该接口提供了文档的增删改查方法
@Repository
public interface ProductRepository extends ElasticsearchRepository<Product,Integer> {
}6.测试Repository接口
6.1测试保存和修改方法
@SpringBootTest
public class ProductRepositoryTest {@Autowiredprivate ProductRepository repository;//保存文档public void addProduct(){Product product = new Product(1, "今天是第一天", "第一天plus");repository.save(product);}//修改方法(当该文档已经存在，即对其进行修改)public void addProduct(){Product product = new Product(1, "今天是第first天", "第first天plus");repository.save(product);}
}6.2查找文档方法
6.2.1根据id进行查询
@Testpublic void findById(){Optional<Product> byId = repository.findById(1);System.out.println(byId.get());}6.2.2查询所有文档
@Testpublic void findAll(){repository.findAll().forEach(System.out::println);}6.3测试删除方法
//根据其主键id进行删除
@Testpublic void deleteById(){repository.deleteById(1);}7.使用DSL语句查询文档
query 后的 json 对象称为 DSL语句 ，我们可以在接口方法上使用 @Query注解自定义 DSL 语句查询。
在Repository接口层编写方法
7.1 匹配查询
@Repository
public interface ProductRepository extends ElasticsearchRepository<Product,Integer> {//匹配查询@Query("{\n" +" \"match\": {\n" +" \"productDesc\": \"?0\"\n" +" }\n" +" }")List<Product> findByProductDescMatch(String keyword);
}7.2模糊查询
@Repository
public interface ProductRepository extends ElasticsearchRepository<Product,Integer> {@Query(" {\n" +" \"match\": {\n" +" \"productDesc\":{\n" +" \"query\": \"\\?0\",\n" +" \"fuzziness\": 1\n" +" }\n" +" }\n" +" }")List<Product> findByProductDescFuzzy(String keyword);
}8.按照规则命名方法查询文档
1.只需在 Repository 接口中按照一定的规则命名方法，该方法就能完成相应的查询
2. 规则：查询方法以 findBy 开头，涉及查询条件时，条件的属性用条件关键字连接。
8.1单条件查询
@Repository
public interface ProductRepository extends ElasticsearchRepository<Product,Integer> {//根据规则进行查询-通过productNameList<Product> findByProductName(String productName);
}测试：
@Testpublic void testFindByProductName(){List<Product> byProductName = repository.findByProductName("iphone");byProductName.forEach(System.out::println);}8.2 多条件选择查询
@Repository
public interface ProductRepository extends ElasticsearchRepository<Product,Integer> {
//测试按照规则命名使用 Or 查询
List<Product> findByProductNameOrProductDesc(String productName,String productDesc);
}测试：
@Testpublic void testFindByProductNameOrProductDesc(){repository.findByProductNameOrProductDesc("iphone","三体").forEach(System.out::println);}8.3范围查询
@Repository
public interface ProductRepository extends ElasticsearchRepository<Product,Integer> {//测试使用命名规则进行 范围查询
List<Product> findByIdBetween(Integer start,Integer end);
}测试：
@Testpublic void testFindByProductIdBetween(){repository.findByIdBetween(1,3).forEach(System.out::println);}9.分页查询
在使用继承或自定义的方法时，在方法中添加 Pageable 类型的参 数，返回值为Page 类型即可进行分页查询。
9.1继承方法
@Testpublic void testFindPage(){//参数1：当前页，从0开始,参数2：每页显示多少条Pageable pageable = PageRequest.of(0,3);Page<Product> all = repository.findAll(pageable);System.out.println("总条数："+all.getTotalElements());System.out.println("总页数："+all.getTotalPages());System.out.println("数据："+all.getContent());}10.分页查询并排序
10.1继承方法
使用继承或自定义的方法时，在方法中添加 Sort 类型的参数即可进行结果排序。
@Testpublic void testFindPage2(){//既分页，又排序Sort sort = Sort.by(Sort.Direction.DESC, "id");Pageable pageable = PageRequest.of(0,3,sort);Page<Product> all = repository.findByProductDescMatch("体",pageable);System.out.println("总条数："+all.getTotalElements());System.out.println("总页数："+all.getTotalPages());System.out.println("数据："+all.getContent());}
)
