简单spring5.x整合elasticsearch7.x

痛定思痛。 2023-06-07 10:55 20阅读 0赞

导入spring和elasticsearch7的jar包，如下

<dependency>
      <groupId>org.springframework.data</groupId>
      <artifactId>spring-data-elasticsearch</artifactId>
      <version>3.2.0.RELEASE</version>
    </dependency>
    
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-context</artifactId>
      <version>5.2.0.RELEASE</version>
    </dependency>
    
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-beans</artifactId>
      <version>5.2.0.RELEASE</version>
    </dependency>
    
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-core</artifactId>
      <version>5.2.0.RELEASE</version>
    </dependency>
    
    <dependency>
      <groupId>org.apache.logging.log4j</groupId>
      <artifactId>log4j-core</artifactId>
      <version>2.12.1</version>
    </dependency>
    
    <dependency>
      <groupId>net.sf.json-lib</groupId>
      <artifactId>json-lib</artifactId>
      <version>2.4</version>
    </dependency>
    
    <dependency>
      <groupId>log4j</groupId>
      <artifactId>log4j</artifactId>
      <version>1.2.17</version>
    </dependency>

2 常见spring-elasticsearch配置文件

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:elasticsearch="http://www.springframework.org/schema/data/elasticsearch"
           xmlns:context="http://www.springframework.org/schema/context"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                                http://www.springframework.org/schema/data/elasticsearch http://www.springframework.org/schema/data/elasticsearch/spring-elasticsearch.xsd
                                http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
        <elasticsearch:transport-client id="client"
                                        cluster-nodes="127.0.0.1:9300" cluster-name="my-application" />
    
        <bean name="elasticsearchTemplate"
              class="org.springframework.data.elasticsearch.core.ElasticsearchTemplate">
            <constructor-arg ref="client" />
        </bean>
    </beans>

3 启动本地的es服务，编写测试用例

ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring-elasticsearch.xml");
    ElasticsearchTemplate elasticsearchTemplate = context.getBean(ElasticsearchTemplate.class);

//实体类
    
    import org.springframework.data.annotation.Id;
    import org.springframework.data.elasticsearch.annotations.Document;
    
    import java.io.Serializable;
    
    @Document(indexName = "product")
    public class Product implements Serializable {
    
        @Id
        private String skuId;
    
        private String name;
    
        private String category;
    
    
        private Integer price;
    
        private String brand;
    
        public String getSkuId() {
            return skuId;
        }
    
        public void setSkuId(String skuId) {
            this.skuId = skuId;
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    
        public String getCategory() {
            return category;
        }
    
        public void setCategory(String category) {
            this.category = category;
        }
    
        public Integer getPrice() {
            return price;
        }
    
        public void setPrice(Integer price) {
            this.price = price;
        }
    
        public String getBrand() {
            return brand;
        }
    
        public void setBrand(String brand) {
            this.brand = brand;
        }
    
        public Integer getStock() {
            return stock;
        }
    
        public void setStock(Integer stock) {
            this.stock = stock;
        }
    
        private Integer stock;
    
        public Product() {
        }
    }

//add 
    Product product = new Product();
    product.setSkuId("111");
    product.setName("测试的商品");
    product.setCategory("101");
    product.setPrice(160);
    product.setBrand("测试供应商");
    
    IndexQuery indexQuery = new IndexQueryBuilder().withObject(product).build();
    elasticsearchTemplate.index(indexQuery);
    //查询
    SearchQuery searchQuery = new NativeSearchQueryBuilder()
            .withQuery(QueryBuilders.matchQuery("name", "商品"))
            .build();
    List<Product> list = elasticsearchTemplate.queryForList(searchQuery, Product.class);
    System.out.println(list.get(0).getName());