說明:

SpringDataElasticsearch 是將Spring的核心概念應(yīng)用于ElasticSearch搜索引擎的開發(fā)解決方案,提供一個"模板"作為搞基抽象,用于存儲,查詢,排序和面向文檔
github地址: https://github.com/spring-projects/spring-data-elasticsearch

注: SpringDataElasticsearch使用的時候有版本要求,本示例的版本為
springboot 2.1.3.RELEASE + spring-data-elasticsearch 3.1.5 +elasticsearch 6.4.3

一. 添加依賴

修改Maven依賴,pom.xml如下

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.3.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.jetlee</groupId>
    <artifactId>es</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>es</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

二. 修改application.properties配置文件

添加如下內(nèi)容

# 配置es服務(wù)器地址
spring.data.elasticsearch.cluster-nodes= 127.0.0.1:9300 
# 配置es服務(wù)器集群名稱
spring.data.elasticsearch.cluster-name= my-application

三. 使用示例

以ａｒｔｉｃｌｅ為示例，來寫對ｅｓ的操作

1. 編寫Article的實體類

package com.jetlee.es.domain;

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;
import org.springframework.format.annotation.DateTimeFormat;

import java.util.Date;
// indexName為索引名稱,type為該索引下的類型
@Document(indexName = "blog",type = "article")
public class Article {

    @Id
    private Long id;
　　//設(shè)置字段名稱及索引
    @Field(type = FieldType.Text,analyzer = "ik_max_word")
    private String title;

    @Field(type = FieldType.Text,analyzer = "ik_max_word")
    private String content;

    @Field(type = FieldType.Date)
    private Date publishDate;

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public String getTitle() {
        return title;
    }

    public void setTitle(String title) {
        this.title = title;
    }

    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }

    public Date getPublishDate() {
        return publishDate;
    }

    public void setPublishDate(Date publishDate) {
        this.publishDate = publishDate;
    }
}

2. 編寫ArticleRepository文件

package com.jetlee.es.repository;

import com.jetlee.es.domain.Article;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;

public interface ArticleReposotory extends ElasticsearchRepository<Article,Long> {


    }

3. 編寫ArticleController控制器類

package com.jetlee.es.controller;


import com.jetlee.es.domain.Article;
import com.jetlee.es.repository.ArticleReposotory;
import com.jetlee.es.utils.TimeUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.text.ParseException;


@RestController
public class ArticleController {

    @Autowired
    ArticleReposotory articleReposotory;

    @GetMapping("/article/add")
    public String add(@RequestParam("id") Long id, @RequestParam("title") String title, @RequestParam("content") String content, @RequestParam("publishDate") String publishDate) throws ParseException {

        Article article = new Article();
        article.setId(id);
        article.setTitle(title);
        article.setContent(content);
        article.setPublishDate(TimeUtil.toDate(publishDate));
        return articleReposotory.save(article).toString();

    }

    @GetMapping("/article/get")

    public Object get(){
        Iterable<Article> list = articleReposotory.findAll();
        return list;
    }

4. 啟動服務(wù)

四．使用測試

1.添加數(shù)據(jù)

打開瀏覽器,訪問[http://127.0.0.1:8080/article/add?id=123212&title=測試文章標(biāo)題&content=測試文章內(nèi)容&publishDate=2019-07-05 09:56:29](http://127.0.0.1:8080/article/add?id=123212&title=測試文章標(biāo)題&content=測試文章內(nèi)容&publishDate=2019-07-05 09:56:29)
或者使用postman

圖片.png

返回如下數(shù)據(jù),即為插入成功

2. 查詢剛剛添加上的數(shù)據(jù)

瀏覽器訪問http://127.0.0.1:8080/article/get

或者使用postman

圖片.png

返回如下,讀取成功