学到了_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 -->
    </relativepath></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&#x4E3B;&#x673A;
  port: elasticsearch&#x7AEF;&#x53E3;&#x53F7;

编写项目启动类

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);
    }

    //&#x6DFB;&#x52A0;&#x7D22;&#x5F15;
    @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());
    }

    //&#x6DFB;&#x52A0;&#x7D22;&#x5F15;&#x5E76;&#x6DFB;&#x52A0;&#x6620;&#x5C04;
    @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());
    }

    //&#x521B;&#x5EFA;&#x7D22;&#x5F15;&#x5E76;&#x6DFB;&#x52A0;&#x6620;&#x5C04;&#x65B9;&#x5F0F;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());

    }

    //&#x67E5;&#x8BE2;&#x7D22;&#x5F15;
    @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());
        }
    }

    //&#x5220;&#x9664;&#x7D22;&#x5F15;
    @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());
    }

    //&#x7D22;&#x5F15;&#x662F;&#x5426;&#x5B58;&#x5728;
    @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);
    }

    //&#x6DFB;&#x52A0;&#x6587;&#x6863; &#x4F7F;&#x7528;map&#x4F5C;&#x4E3A;&#x6570;&#x636E;
    @Test
    public void addDoc() throws IOException {
        Map<string, object> map = new HashMap<>();
        map.put("name", "&#x5C0F;&#x9752;");
        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());
    }

    //&#x6DFB;&#x52A0;&#x6587;&#x6863; &#x4F7F;&#x7528;&#x5BF9;&#x8C61;&#x4F5C;&#x4E3A;&#x6570;&#x636E;
    @Test
    public void addDoc2() throws Exception {
        Person person = new Person();
        person.setId("4");
        person.setName("&#x5C0F;&#x674E;");
        person.setAge(20);
        person.setAddress("&#x6C5F;&#x82CF;&#x5357;&#x4EAC;");
        String data = 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());
    }

    //&#x4FEE;&#x6539;&#x6587;&#x6863;
    //id&#x5B58;&#x5728;&#x65F6;&#x4FEE;&#x6539;&#x6587;&#x6863;  id&#x4E0D;&#x5B58;&#x5728;&#x65F6;&#x5219;&#x6DFB;&#x52A0;
    @Test
    public void UpdateDoc() throws Exception {
        Person person = new Person();
        person.setId("4");
        person.setName("&#x5C0F;&#x674E;");
        person.setAge(20);
        person.setAddress("&#x4E2D;&#x56FD;");
        String data = 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());
    }

    //&#x6839;&#x636E;id&#x67E5;&#x8BE2;&#x6587;&#x6863;
    @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());
    }

    //&#x6839;&#x636E;id&#x5220;&#x9664;&#x6587;&#x6863;
    @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());

    }

    //&#x6309;&#x6761;&#x4EF6;&#x67E5;&#x8BE2;(&#x666E;&#x901A;&#x67E5;&#x8BE2;)
    @Test
    public void queryFind() throws IOException {
        SearchRequest searchRequest = new SearchRequest("index_test_one");
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        //&#x7CBE;&#x51C6;&#x67E5;&#x8BE2;
        TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "&#x5C0F;&#x738B;");
        //&#x8303;&#x56F4;&#x67E5;&#x8BE2; &#x5982;&#x679C;&#x662F;&#x65E5;&#x671F;&#x5219;&#x9700;&#x8981;&#x5728;&#x6700;&#x540E;&#x52A0;&#x4E00;&#x4E2A;format("yyyy-MM-dd")
        RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("age").from(19).to(20);
        //&#x524D;&#x7F00;&#x67E5;&#x8BE2;
//        PrefixQueryBuilder prefixQueryBuilder = QueryBuilders.prefixQuery("name", "&#x5C0F;");
        //&#x901A;&#x914D;&#x7B26;&#x67E5;&#x8BE2;
//        WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("name", "*&#x9752;");
//        //&#x6A21;&#x7CCA;&#x67E5;&#x8BE2;
//        FuzzyQueryBuilder fuzzyQueryBuilder = QueryBuilders.fuzzyQuery("name", "&#x738B;");
        //&#x6309;&#x5E74;&#x9F84;&#x6392;&#x5E8F;
        FieldSortBuilder fieldSortBuilder = SortBuilders.fieldSort("age");
        //&#x4ECE;&#x5C0F;&#x5230;&#x5927;&#x6392;&#x5E8F;
        fieldSortBuilder.sortMode(SortMode.MIN);

        //&#x591A;&#x6761;&#x4EF6;&#x65F6;&#x4F7F;&#x7528;should&#x8FDE;&#x63A5;
        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery().must(termQueryBuilder).should(rangeQueryBuilder);
        sourceBuilder.query(boolQueryBuilder).sort(fieldSortBuilder);
        //&#x8BBE;&#x7F6E;&#x8D85;&#x65F6;&#x65F6;&#x95F4;
        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);
        }
    }

    //&#x6309;&#x6761;&#x4EF6;&#x67E5;&#x8BE2;(&#x805A;&#x5408;&#x67E5;&#x8BE2;)
    @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 + "&#x5C81;&#x7684;&#x6709;" + docCount + "&#x4E2A;");
        }
    }

    //&#x805A;&#x5408;&#x67E5;&#x8BE2;&#x6C42;&#x548C;
    @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);
    }

}

</string,></string,></string,>

需要注意的是GetIndexRequest和CreateIndexRequest的包是 org.elasticsearch.client.indices,而不是包 org.elasticsearch.action.admin.indices,如果引错包,你将会发现create方法显示被弃用、GetIndexRequest方法显示无法传入字符串类型,需要传入StreamInput类型

Original: https://www.cnblogs.com/deanCopy/p/15880373.html
Author: Dean_001
Title: 学到了_SpringBoot项目整合ElasticSearch7.8.1(增删改查索引,增删改查文档)

原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/580078/

转载文章受原作者版权保护。转载请注明原作者出处!

(0)

大家都在看

  • GDB高级一点的命令

    GDB 是我们平时调试 c/c++程序的利器, 查起复杂的 bug 问题,比打印大法要好的多,但是也不得不说, gdb 在默认情况下用起来并不是很好用,最近学习到几个高级点的技巧,…

    Java 2023年5月29日
    076
  • kotlin学习二:初步认识kotlin

    kotlin中支持顶级函数(文件内直接定义函数),对比JAVA来说,JAVA的程序入口是main方法,kotlin也一样,入口为main函数 首先看下kotlin中main函数的定…

    Java 2023年6月16日
    073
  • Jetpack Compose学习(9)——Compose中的列表控件(LazyRow和LazyColumn)

    原文:Jetpack Compose学习(9)——Compose中的列表控件(LazyRow和LazyColumn) – Stars-One的杂货小窝 经过前面的学习,…

    Java 2023年6月13日
    083
  • RabbitMQ与SpringBoot整合

    前文总结了Dubbo与SpringBoot的整合(https://www.cnblogs.com/cott/p/12373043.html),本文基于这套框架,引入RabbitMQ…

    Java 2023年6月9日
    077
  • 期末考试代码

    import javax.swing.*; import java.awt.*; //import java.awt.event.InputEvent; //import java…

    Java 2023年6月9日
    081
  • nginx + nginx-rtmp-module + springboot 搭建直播流服务器实现推流、拉流实时直播功能

    业务需求 最近公司在做养老相关的业务,现在需要子女从小程序端对家里的老人通过家庭终端交互屏进行实时看护。 解决方案 第三方的一些现成的服务:腾讯音视频通话、直播功能; 阿里的音视频…

    Java 2023年6月13日
    067
  • Nginx

    是一个高性能的 HTTP 和反向代理服务器,特点是占有内存少,并发能力强,事实上 nginx 的并发能力确实在同类型的网页服务器中表现较好。 Nginx 可以作为静态页面的 web…

    Java 2023年6月8日
    089
  • Spring常用注解

    Spring部分 @Component 组件,没有明确的角色 @Service 在业务逻辑层使用(service层) @Repository 在数据访问层使用(dao层) @Con…

    Java 2023年6月5日
    075
  • 第2章 Java基本程序设计结构

    404. 抱歉,您访问的资源不存在。 可能是网址有误,或者对应的内容被删除,或者处于私有状态。 代码改变世界,联系邮箱 contact@cnblogs.com 园子的商业化努力-困…

    Java 2023年6月7日
    099
  • linux中find命令的摘要

    find命令的使用 按照时间查找 可以很方便按照时间查找文件 find -[mtime|atime|ctime] n #查找n天前当天[修改|访问|创建]的文件 find -[mt…

    Java 2023年6月7日
    089
  • 集合

    集合 Vector底层结构和ArrayList的比较 底层结构 版本 线程安全(同步)效率 扩容倍数 ArrayList 可变数组 jdk1.2 不安全,效率高 如果有参构造就是1…

    Java 2023年6月5日
    082
  • [springmvc]拦截器功能

    11.拦截器 只会拦截controller的请求,对于静态资源不处理 被spring代理的拦截器实现只需要两步: 1.实现一个拦截器类 package com.spring.con…

    Java 2023年6月6日
    076
  • Spring Boot + Spring Cloud 实现权限管理系统 后端篇(十七):登录验证码实现(Captcha)

    登录验证码 登录验证是一般系统都会有的功能,验证的方式也多种多样,比如输入式验证码,拖动式验证条,拖动式验证拼图等等。 我们这里先实现常规的输入验证码的方式,右边显示验证码图片,点…

    Java 2023年5月30日
    091
  • SpringCloud(一).大话SpringCloud

    学习一个东西,首先要搞清楚这个东西是什么,有什么用,怎么用。最近会坚持写博客,将最近学习的SpringCloud的过程记录下来,很多东西往往看了一遍过一段时间就会遗忘,用博客记录下…

    Java 2023年6月7日
    065
  • SpringCloud : Feign 使用 FastJson 解析数据

    Fastjson 版本1.2.60 Spring 版本 5.1.5.RELEASE SpringBoot 版本 2.1.5.RELEASE SpringCloud 版本 2.1.1…

    Java 2023年5月30日
    075
  • AWS Simple Email Service(SES)邮件发送服务-功能调研

    面向国内用户,发短信或者通知推送居多,发邮件这个功能用的不多,主要还是海外欧美用户比较流行,刚好公司要用,写一篇AWS SES功能调研文章讲解一下,跨境电商的同行可以参考一下。废话…

    Java 2023年6月13日
    089
亲爱的 Coder【最近整理,可免费获取】👉 最新必读书单  | 👏 面试题下载  | 🌎 免费的AI知识星球