如何使用springData來操作es

這篇文章主要介紹“如何使用springData來操作es”，在日常操作中，相信很多人在如何使用springData來操作es問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”如何使用springData來操作es”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！

1 Es 的配置文件 elasticsearch.yml

http.cors.enabled: true
http.cors.allow-origin: "*"

network.host: 127.0.0.1

2 配置中文分詞器 （見之前的博客）

3 導入jar

<?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 https://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.7.RELEASE</version>
		<relativePath/> <!-- lookup parent from repository -->
	</parent>
	<groupId>com.example</groupId>
	<artifactId>demo</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<name>demo</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</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>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-test</artifactId>
		</dependency>
	</dependencies>

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

</project>

4 編寫配置文件 (7.3 暫時springdata暫時不支持)

# elasticsearch-6.5.4 需要再配置文件配置上ip地址
spring.data.elasticsearch.cluster-name=elasticsearch
spring.data.elasticsearch.cluster-nodes=127.0.0.1:9300
#設置連接超時時間
spring.data.elasticsearch.properties.transport.tcp.connect_timeout=120s

5 實體類上增加注解

/**
 * @author shihaifeng
 * @date 2019-08-29 14:06
 * @desc (描述)
 **/
@Document(indexName = "book",type = "user")
public class Book implements Serializable{
    @Id     //主鍵
    private Integer id;

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

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

    @Field(type = FieldType.Text, analyzer = "ik_smart")
    private String auto;
}

6 編寫接口

package com.example.demo.inter;

import com.example.demo.entity.Book;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;

/**
 * @author shihaifeng
 * @date 2019-08-29 14:47
 * @desc (書接口 - 用來直接操作)
 *
 *  Book 實體對象
 *  Integer 是主鍵
 **/
public interface IBookServer extends ElasticsearchRepository<Book,Integer> {
}

7 測試

package com.example.demo;

import com.example.demo.entity.Book;
import com.example.demo.inter.IBookServer;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.TermQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import org.springframework.data.elasticsearch.core.SearchResultMapper;
import org.springframework.data.elasticsearch.core.aggregation.AggregatedPage;
import org.springframework.data.elasticsearch.core.aggregation.impl.AggregatedPageImpl;
import org.springframework.data.elasticsearch.core.query.NativeSearchQuery;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.*;

;

/**
 * @author shihaifeng
 * @date 2019-08-29 14:52
 * @desc (描述)
 **/
@RunWith(SpringRunner.class)
@SpringBootTest
public class BookTest {

    @Autowired
    private IBookServer bookServer;

    @Autowired
    private ElasticsearchTemplate elasticsearchTemplate;

    /**
     * 添加數據
     */
    @Test
    public void addBook() {
        //添加一條數據
        bookServer.save(new Book(1, "書名", "書內容", "作者"));

        List<Book> list = new ArrayList<>();
        list.add(new Book(2, "《阿彌陀佛么么噠》", "大冰，本名焉冰，1980年10月23日出生于山東省煙臺市萊陽市，中國內地主持人、民謠歌手、作家、油畫畫師，畢業于山東藝術學院。", "大冰"));
        list.add(new Book(3, "《我不》", "善意能消戾，善意能得緣，善意能帶業往生，善意能回頭是岸。 善意能夠幫人捕捉并建立起獨特的幸福感。 “我不”是一種善意坦然，也是一種善意的隨緣，更是一句善意的自省", "大冰"));
        list.add(new Book(4, "《乖，摸摸頭》", "是由主持人大冰所著，湖南文藝出版社的一本記錄了大冰十余年的江湖游歷，以及他和他朋友們的愛與溫暖的傳奇故事的書籍。", "大冰"));
        list.add(new Book(5, "《他們最幸福》", "書中講述的故事是有關于主角大冰一段十年的精彩生長之路，也是路途中十個不同他們幸福的故事，更是一段對當下價值觀有形無聲的生活抗議。 多棲身份的大冰，從主持人到民謠歌手，從江湖游俠到資深文青，他抱著一只手鼓行唱在天涯中，卻從未將故事寫在紙面上。", "大冰"));

        list.add(new Book(6, "《邊城》", "沈從文的創作風格趨向浪漫主義，他要求小說的詩意效果，融寫實、紀夢、象征于一體，語言格調古樸，\n" +
                "沈從文及其作品沈從文及其作品(5張)句式簡峭、主干突出，單純而又厚實，樸訥而又傳神", "沈從文"));
        list.add(new Book(7, "《湘行散記》", "沈從文是具有特殊意義的鄉村世界的主要表現者和反思者，他認為“美在生命”，雖身處于虛偽、自私和冷漠的都市，卻醉心于人性之美", "沈從文"));
        list.add(new Book(8, "《長河》", "“我不知道為什么忽然愛上你了。”身為任課教師的沈從文悄悄地給學生張兆和寫信，他在信里這么說。", "沈從文"));
        bookServer.saveAll(list);//批量添加數據
    }

    /**
     * 查詢信息
     */
    @Test
    public void query() {
        Optional<Book> book = bookServer.findById(3);
        System.out.println("------------findById-----------------");
        System.out.println(book.get().toString());

        Iterable<Book> books = bookServer.findAll();
        System.out.println("------------findAll-----------------");
        for (Book book1 : books) {
            System.out.println(book1);
        }

        System.out.println("------------search QueryBuilder-----------------");
        Page<Book> search = bookServer.search(new TermQueryBuilder("context", "沈從文"), PageRequest.of(0, 10));
        for (Book book1 : search.getContent()) {
            System.out.println(book1);
        }

        System.out.println("------------search SearchQuery (高亮顯示)-----------------");
        NativeSearchQuery searchQuery = new NativeSearchQueryBuilder()
                .withQuery(QueryBuilders.termQuery("context", "沈從文"))       //設置查詢內容
                .withHighlightFields(new HighlightBuilder.Field("context").preTags("<前綴>").postTags("</后綴>")).build()  //設置高亮顯示
                .setPageable(PageRequest.of(0, 10));//設置分頁信息
        AggregatedPage<Book> page = elasticsearchTemplate.queryForPage(searchQuery, Book.class, new SearchResultMapper() {
            @Override
            public <T> AggregatedPage<T> mapResults(SearchResponse searchResponse, Class<T> aClass, Pageable pageable) {
                //返回結果集重新映射
                List<Book> list = new ArrayList<>();

                SearchHits hits = searchResponse.getHits();
                Iterator<SearchHit> iterator = hits.iterator();
                while (iterator.hasNext()){
                    Book book = new Book();
                    SearchHit searchHit = iterator.next();

                    Map<String, Object> source = searchHit.getSourceAsMap();
                    book.setId(Integer.valueOf(source.get("id").toString()));//設置id
                    book.setName(source.get("name").toString());//設置書名
                    book.setAuto(source.get("auto").toString());//設置作者

                    Map<String, HighlightField> highlightFields = searchHit.getHighlightFields();//獲取高亮顯示的列
                    book.setContext(highlightFields.get("context").toString());//設置高亮顯示的列
                    System.out.println("高亮顯示的值是 = " + highlightFields.get("context"));

                    list.add(book);
                }

                //返回查詢的結果
                return new AggregatedPageImpl(list);
            }
        });
        List<Book> content = page.getContent();
        System.out.println("查出的總數是 = " + content.size());
    }


    /**
     * 跟新數據
     */
    @Test
    public void update(){
        bookServer.save(new Book(1, "書名3", "書內容3", "作者3"));
    }

    /**
     * 刪除數據
     */
    @Test
    public void delete(){
        bookServer.delete(new Book(1, "書名3", "書內容3", "作者3"));
    }

}

到此，關于“如何使用springData來操作es”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續學習更多相關知識，請繼續關注億速云網站，小編會繼續努力為大家帶來更多實用的文章！