快捷導(dǎo)航

SpringBoot3.x使用es進(jìn)行數(shù)據(jù)查詢的方式

更新時(shí)間：2025年12月30日 16:57:51 作者：樂韻天城

SpringBoot3中,Elasticsearch的版本升級(jí)至8.x,相關(guān)寫法有所改變,SpringBoot2中的ElasticsearchRestTemplate已被移除,推薦使用ElasticsearchTemplate或ElasticsearchClient進(jìn)行交互,本文介紹這兩個(gè)類的使用方式,并說明了依賴引入和自動(dòng)裝配的配置,感興趣的朋友一起看看吧

概要

SpringBoot3中的elasticsearch版本已經(jīng)來到8.x版本，相比較于SpringBoot2中的7.x版本相關(guān)寫法已經(jīng)發(fā)生改變。在SpringBoot2中會(huì)使用ElasticsearchRestTemplate和es進(jìn)行交互，但這個(gè)類在SpringBoot3中已經(jīng)被移除，需要使用ElasticsearchTemplate或者ElasticsearchClient和es進(jìn)行交互。下面介紹這兩個(gè)類的基本使用方式。

ElasticsearchTemplate

    @Test
    void test_1() {
        NativeQuery query = new NativeQueryBuilder()
                .withPageable(Pageable.ofSize(100))
                //使用lambda表達(dá)式使其更符合es語句的寫法
                .withQuery(q -> q
                        .bool(b -> b
                                .filter(f -> f
                                        .term(t -> t
                                                .field("Name")
                                                .value("test")))))
                .withSort(s -> s
                        .field(f -> f
                                .field("Name")
                                .order(SortOrder.Desc)))
                .build();
        SearchHits<User> search = elasticsearchTemplate.search(query, User.class, IndexCoordinates.of("test-topic"));
        List<SearchHit<User>> searchHits = search.getSearchHits();
        for (SearchHit<User> searchHit : searchHits) {
            System.out.println(searchHit.getContent().getName());
        }
    }

以上的es查詢語句等價(jià)于

{
    "query": {
        "bool": {
            "filter": [
                {
                    "term": {
                        "Name": {
                            "value": "test"
                        }
                    }
                }
            ]
        }
    },
    "from": 0,
    "size": 100,
    "sort": [
        {
            "Name": {
                "order": "desc"
            }
        }
    ]
}

ElasticsearchClient

    @Test
    void test_2() throws IOException {
        Function<SearchRequest.Builder, ObjectBuilder<SearchRequest>> query = fn-> fn
                .index("test-topic")
                .size(100)
                //使用lambda表達(dá)式使其更符合es語句的寫法
                .query(q -> q
                                .bool(b -> b
                                        .filter(f -> f
                                                .term(t -> t
                                                        .field("Name")
                                                        .value("test")))))
                .sort(s -> s
                        .field(f -> f
                                .field("Name")
                                .order(SortOrder.Desc)));
        SearchResponse<User> search = elasticsearchClient.search(query, User.class);
        List<Hit<User>> hits = search.hits().hits();
        for (Hit<User> hit : hits) {
            System.out.println(hit.source().getName());
        }
    }

小結(jié)

1.依賴引入

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

2.ElasticsearchTemplate和ElasticsearchClient已經(jīng)自動(dòng)裝配，業(yè)務(wù)類中直接注入即可。
3.User類

    /**
     * test_1：使用第一種測(cè)試時(shí)，實(shí)體屬性和es字段屬性不對(duì)應(yīng)時(shí)需要使用@Field（org.springframework.data.elasticsearch.annotations.Field）注解標(biāo)識(shí)
     * test_2：使用第二種測(cè)試時(shí)，實(shí)體屬性和es字段屬性不對(duì)應(yīng)時(shí)需要使用@JsonProperty（com.fasterxml.jackson.annotation.JsonProperty）注解標(biāo)識(shí)
     */
    @Data
    public class User {
        @Id
        private String id;
        @Field("Name")
        @JsonProperty("Name")
        private String name;
    }

到此這篇關(guān)于SpringBoot3.x使用es進(jìn)行數(shù)據(jù)查詢的方式的文章就介紹到這了,更多相關(guān)springboot使用es數(shù)據(jù)查詢內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: