SpringBoot整合ElasticSearch7.8.1(增刪改查索引，增刪改查檔案)-有解無憂

創建SpringBoot工程，更改pom檔案

以下依賴全部使用到了，所以無比全部添加

<?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.6.3</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.example</groupId>
    <artifactId>ElasticSearch</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>ElasticSearch</name>
    <description>ElasticSearch</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-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-high-level-client</artifactId>
            <version>7.8.1</version>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-client</artifactId>
            <version>7.8.1</version>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch</groupId>
            <artifactId>elasticsearch</artifactId>
            <version>7.8.1</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-configuration-processor</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.47</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombok</groupId>
                            <artifactId>lombok</artifactId>
                        </exclude>
                    </excludes>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

撰寫ElasticSearch配置類

package com.example.config;

import lombok.Data;
import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Data
@Configuration
@ConfigurationProperties(prefix = "elasticsearch")
public class ElasticSearchConfig {
    private String host;
    private int port;

    @Bean
    public RestHighLevelClient client() {
        return new RestHighLevelClient(RestClient.builder(new HttpHost(host, port, "http")));
    }
}

yml組態檔中配置elasticsearch的主機和埠號

elasticsearch:
  host: elasticsearch主機
  port: elasticsearch埠號

撰寫專案啟動類

package com.example;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class ElasticSearchApplication {

    public static void main(String[] args) {
        SpringApplication.run(ElasticSearchApplication.class, args);
    }

}

使用SpringBoot Test撰寫測驗用例

package com.example;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.example.dto.Person;
import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.IndicesClient;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.CreateIndexRequest;
import org.elasticsearch.client.indices.CreateIndexResponse;
import org.elasticsearch.client.indices.GetIndexRequest;
import org.elasticsearch.client.indices.GetIndexResponse;
import org.elasticsearch.cluster.metadata.MappingMetadata;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.RangeQueryBuilder;
import org.elasticsearch.index.query.TermQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.Aggregation;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.Aggregations;
import org.elasticsearch.search.aggregations.bucket.terms.ParsedLongTerms;
import org.elasticsearch.search.aggregations.bucket.terms.Terms;
import org.elasticsearch.search.aggregations.bucket.terms.TermsAggregationBuilder;
import org.elasticsearch.search.aggregations.metrics.Sum;
import org.elasticsearch.search.aggregations.metrics.SumAggregationBuilder;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.sort.FieldSortBuilder;
import org.elasticsearch.search.sort.SortBuilders;
import org.elasticsearch.search.sort.SortMode;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.io.IOException;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;

@SpringBootTest
class ElasticSearchApplicationTests {
    @Autowired
    RestHighLevelClient client;

    @Test
    void contextLoads() {
        System.out.println(client);
    }

    //添加索引
    @Test
    public void createIndex() throws IOException {
        IndicesClient indices = client.indices();
        CreateIndexRequest createIndexRequest = new CreateIndexRequest("index_test");
        CreateIndexResponse createIndexResponse = indices.create(createIndexRequest, RequestOptions.DEFAULT);
        System.out.println(createIndexResponse.isAcknowledged());
    }

    //添加索引并添加映射
    @Test
    public void addIndexMapping() throws IOException {
        IndicesClient indices = client.indices();
        CreateIndexRequest createIndexRequest = new CreateIndexRequest("index_test_one");
        String mapping = "{\n" + "      \"properties\" : {\n" + "        \"address\" : {\n" + "          \"type\" : \"text\",\n" + "          \"analyzer\" : \"ik_max_word\"\n" + "        },\n" + "        \"age\" : {\n" + "          \"type\" : \"long\"\n" + "        },\n" + "        \"name\" : {\n" + "          \"type\" : \"keyword\"\n" + "        }\n" + "      }\n" + "    }";
        createIndexRequest.mapping(mapping, XContentType.JSON);
        CreateIndexResponse createIndexResponse = indices.create(createIndexRequest, RequestOptions.DEFAULT);

        System.out.println(createIndexResponse.isAcknowledged());
    }

    //創建索引并添加映射方式2
    @Test
    public void createIndexAddMapping() throws Exception {
        IndicesClient indices = client.indices();
        XContentBuilder builder = XContentFactory.jsonBuilder().startObject().field("properties").startObject().field("name").startObject().field("index", "true").field("type", "keyword").endObject().field("money").startObject().field("index", "true").field("type", "double").endObject().field("birthday").startObject().field("index", "true").field("type", "date").field("format", "strict_date_optional_time||epoch_millis").endObject().endObject().endObject();
        CreateIndexRequest createIndexRequest = new CreateIndexRequest("index_test");
        createIndexRequest.mapping(builder);
        CreateIndexResponse response = indices.create(createIndexRequest, RequestOptions.DEFAULT);
        System.out.println(response.isAcknowledged());

    }

    //查詢索引
    @Test
    public void getIndex() throws IOException {
        IndicesClient indices = client.indices();

        GetIndexRequest getIndexRequest = new GetIndexRequest("index_test_one");
        GetIndexResponse getIndexResponse = indices.get(getIndexRequest, RequestOptions.DEFAULT);
        Map<String, MappingMetadata> mappings = getIndexResponse.getMappings();
        for (String key : mappings.keySet()) {
            System.out.println("key:" + mappings.get(key).getSourceAsMap());
        }
    }

    //洗掉索引
    @Test
    public void deleteIndex() throws IOException {
        IndicesClient indices = client.indices();
        DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest("index_test");
        AcknowledgedResponse delete = indices.delete(deleteIndexRequest, RequestOptions.DEFAULT);
        System.out.println(delete.isAcknowledged());
    }

    //索引是否存在
    @Test
    public void existIndex() throws IOException {
        IndicesClient indices = client.indices();
        GetIndexRequest getIndexRequest = new GetIndexRequest("index_test");
        boolean exists = indices.exists(getIndexRequest, RequestOptions.DEFAULT);
        System.out.println(exists);
    }

    //添加檔案 使用map作為資料
    @Test
    public void addDoc() throws IOException {
        Map<String, Object> map = new HashMap<>();
        map.put("name", "小青");
        map.put("money", 300.00);
        map.put("birthday", new Date());
        IndexRequest request = new IndexRequest("index_test").id("2").source(map);
        IndexResponse res = client.index(request, RequestOptions.DEFAULT);
        System.out.println(res.getId());
    }

    //添加檔案 使用物件作為資料
    @Test
    public void addDoc2() throws Exception {
        Person person = new Person();
        person.setId("4");
        person.setName("小李");
        person.setAge(20);
        person.setAddress("江蘇南京");
        String data = https://www.cnblogs.com/deanCopy/archive/2022/02/10/JSON.toJSONString(person);

        IndexRequest indexRequest = new IndexRequest("index_test_one").id(person.getId()).source(data, XContentType.JSON);
        IndexResponse response = client.index(indexRequest, RequestOptions.DEFAULT);
        System.out.println(response.getId());
    }

    //修改檔案
    //id存在時修改檔案  id不存在時則添加
    @Test
    public void UpdateDoc() throws Exception {
        Person person = new Person();
        person.setId("4");
        person.setName("小李");
        person.setAge(20);
        person.setAddress("中國");
        String data = https://www.cnblogs.com/deanCopy/archive/2022/02/10/JSON.toJSONString(person);

        IndexRequest indexRequest = new IndexRequest("index_test_one").id(person.getId()).source(data, XContentType.JSON);
        IndexResponse response = client.index(indexRequest, RequestOptions.DEFAULT);
        System.out.println(response.getId());
    }

    //根據id查詢檔案
    @Test
    public void getDocById() throws Exception {
        GetRequest indexRequest = new GetRequest("index_test_one", "4");

        GetResponse response = client.get(indexRequest, RequestOptions.DEFAULT);
        System.out.println(response.getSourceAsMap());
    }

    //根據id洗掉檔案
    @Test
    public void deleteDoc() throws IOException {
        DeleteRequest deleteRequest = new DeleteRequest("index_test_one", "1");
        DeleteResponse respone = client.delete(deleteRequest, RequestOptions.DEFAULT);
        System.out.println(respone.getId());

    }

    //按條件查詢(普通查詢)
    @Test
    public void queryFind() throws IOException {
        SearchRequest searchRequest = new SearchRequest("index_test_one");
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        //精準查詢
        TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "小王");
        //范圍查詢 如果是日期則需要在最后加一個format("yyyy-MM-dd")
        RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("age").from(19).to(20);
        //前綴查詢
//        PrefixQueryBuilder prefixQueryBuilder = QueryBuilders.prefixQuery("name", "小");
        //通配符查詢
//        WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("name", "*青");
//        //模糊查詢
//        FuzzyQueryBuilder fuzzyQueryBuilder = QueryBuilders.fuzzyQuery("name", "王");
        //按年齡排序
        FieldSortBuilder fieldSortBuilder = SortBuilders.fieldSort("age");
        //從小到大排序
        fieldSortBuilder.sortMode(SortMode.MIN);

        //多條件時使用should連接
        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery().must(termQueryBuilder).should(rangeQueryBuilder);
        sourceBuilder.query(boolQueryBuilder).sort(fieldSortBuilder);
        //設定超時時間
        sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
        searchRequest.source(sourceBuilder);

        SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
        SearchHits hits = response.getHits();
        for (SearchHit hit : hits) {
            String souceAsString = hit.getSourceAsString();
            JSONObject jsonObject = JSON.parseObject(souceAsString);
            System.out.println(jsonObject);
        }
    }

    //按條件查詢(聚合查詢)
    @Test
    public void aggregationQuery() throws Exception {
        SearchRequest searchRequest = new SearchRequest("index_test_one");
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        TermsAggregationBuilder termsAggregationBuilder = AggregationBuilders.terms("by_age").field("age");
        sourceBuilder.aggregation(termsAggregationBuilder);
        sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
        searchRequest.source(sourceBuilder);

        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        Aggregations aggregations = searchResponse.getAggregations();
        Map<String, Aggregation> stringAggregationMap = aggregations.getAsMap();
        ParsedLongTerms parsedLongTerms = (ParsedLongTerms) stringAggregationMap.get("by_age");
        List<? extends Terms.Bucket> buckets = parsedLongTerms.getBuckets();
        for (Terms.Bucket bucket : buckets) {
            Long docCount = bucket.getDocCount();
            Number keyAsNumber = bucket.getKeyAsNumber();
            System.out.println(keyAsNumber + "歲的有" + docCount + "個");
        }
    }

    //聚合查詢求和
    @Test
    public void aggregationSum() throws Exception {
        SearchRequest searchRequest = new SearchRequest("index_test");
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        SumAggregationBuilder sumAggregationBuilder = AggregationBuilders.sum("money_total").field("money");
        sourceBuilder.aggregation(sumAggregationBuilder);
        sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
        searchRequest.source(sourceBuilder);

        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        Aggregations aggregations = searchResponse.getAggregations();
        Sum moneyTotal = aggregations.get("money_total");
        Double moneyTotalDouble = moneyTotal.getValue();
        System.out.println(moneyTotalDouble);
    }

}

需要注意的是GetIndexRequest和CreateIndexRequest的包是org.elasticsearch.client.indices，而不是包org.elasticsearch.action.admin.indices，如果引錯包，你將會發現create方法顯示被棄用、GetIndexRequest方法顯示無法傳入字串型別，需要傳入StreamInput型別

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/423638.html

標籤：其他

上一篇：Java中如何遍歷字串呢？

下一篇：Android 如何回傳ASYNCTASK中的任務完成狀態