Spring Data Elasticsearch入门

Spring Data Elasticsearch入门

Spring Data ElasticSearch是Spring对原生JAVA操作Elasticsearch封装之后的产物。它通过对原生API的 封装，使得JAVA程序员可以简单的对Elasticsearch进行操作。

1.搭建项目

创建SpringBoot项目，加入Spring Data Elasticsearch起步依赖：

org.projectlombok lombok org.springframework.boot spring-boot-starter-data-elasticsearch org.springframework.boot spring-boot-starter-test test org.junit.vintage junit-vintage-engine

写配置文件：

spring: elasticsearch: rest: uris: 一个实体类的所有对象都会存入ES的一个索引中，所以我们在创建实体类时关联ES索引。如果ES中没有 该索引则会自动建索引。

package com.neu.springdataes.model;import lombok.AllArgsConstructor;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;/** * @Author yqq * @Date 2021/11/30 18:29 * @Version 1.0 */@Data@AllArgsConstructor@NoArgsConstructor@Document(indexName = "product",shards = 1,replicas = 1,createIndex = true)public class Product { @Id @Field(type = FieldType.Integer,store = true,index = true) private Integer id; @Field(type = FieldType.Text,store = true,index = true,analyzer = "ik_smart",searchAnalyzer = "ik_smart") private String name; @Field(type = FieldType.Text,store = true,index = true,analyzer = "ik_smart",searchAnalyzer = "ik_smart") private String desc;}

@Document：标记在类上，标记实体类为文档对象，一般有如下属性：indexName：对应索引的名称shards：分片数量replicas：副本数量createIndex：是否自动创建索引

@Id：标记在成员变量上，标记一个字段为主键，该字段的值会同步到ES该文档的id值。

@Field：标记在成员变量上，标记为文档中的域，一般有如下属性：type：域的类型index：是否索引，默认是 truestore：是否单独存储，默认是 falseanalyzer：分词器searchAnalyzer：搜索时的分词器

创建Repository接口 创建Repository接口继承ElasticsearchRepository，该接口提供了文档的增删改查方法

package com.neu.springdataes.model;import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;/** * @Author yqq * @Date 2021/11/30 18:44 * @Version 1.0 */public interface ProductRepository extends ElasticsearchRepository {}

测试方法 编写测试类，注入Repository接口并测试Repository接口的增删改查方法

package com.neu.springdataes;import com.neu.springdataes.model.Product;import com.neu.springdataes.model.ProductRepository;import org.junit.jupiter.api.Test;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import java.util.Optional;@SpringBootTestclass SpringdataesApplicationTests { @Autowired ProductRepository repository; @Test void addDocument() { Product product = new Product(1, "iPhone 12", "iPhone 12是本年度销售最佳手机"); repository.save(product); } @Test void findAllDocument() { Iterable products = repository.findAll(); for (Product product:products) System.out.println(product); } @Test void updateDocument() { Product product = new Product(1, "iPhone 13", "iPhone 13是本年度销售最佳手机"); repository.save(product); } @Test void findDocumentById() { Optional product = repository.findById(1); System.out.println(product.get()); } @Test void deleteDocumentById(){ repository.deleteById(1); }}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。