elasticsearch7.6.2集成springboot2.2.6基本语法---3

package com.zys.es.demo762;

import com.alibaba.fastjson.JSON;
import com.zys.es.demo762.confing.User;
import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
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.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
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.common.unit.TimeValue;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.TermQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.FetchSourceContext;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.test.context.SpringBootTest;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;

@SpringBootTest
class Demo762ApplicationTests {
    @Autowired
    @Qualifier("restHighLevelClient")
    private RestHighLevelClient client;
    /**
     * 创建索引
     * @throws IOException
     */
    @Test
    public void testAdd() throws IOException {
        // 创建索引请求
        CreateIndexRequest request = new CreateIndexRequest("zysnba");
        request.setTimeout(TimeValue.timeValueMinutes(2));//设置创建索引超时2分钟
        CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);
        System.out.println("createIndex: " + JSON.toJSONString(createIndexResponse));
        client.close();
    }

    //索取索引
    @Test
    void testExistIndex() throws IOException {
        //1，创建索引请求
        GetIndexRequest request = new GetIndexRequest("zysnba");
        //2，执行请求,
        boolean bool= client.indices().exists(request, RequestOptions.DEFAULT);
        System.out.println(bool);
    }
    //删除索引
    @Test
    void testDeleteIndex() throws IOException {
        //1，创建索引请求
        DeleteIndexRequest request = new DeleteIndexRequest("zysnba");
        //2，执行请求,
        AcknowledgedResponse response= client.indices().delete(request,RequestOptions.DEFAULT);
        System.out.println("createIndex: " + JSON.toJSONString(response));
    }


    //添加文档
    @Test
    void testAddDocument() throws IOException {
        User user = new User("张三",12);
        //创建链接
        IndexRequest request=new IndexRequest("zysnba");
        request.id("1");
        request.timeout("2s");
        //将我们的数据放到es中，json
        request.source(JSON.toJSONString(user), XContentType.JSON);
        /* 客服端发送请求 */
        IndexResponse indexResponse= client.index(request,RequestOptions.DEFAULT);
        System.out.println(indexResponse.toString());
        System.out.println(indexResponse.status());
    }
    //获取判断是否存在文档
    @Test
    void testIsExistsDocument() throws IOException {
        //创建链接
        GetRequest request=new GetRequest("zysnba","1");
        request.fetchSourceContext(new FetchSourceContext(false));
        request.storedFields("_none_");
        boolean bool= client.exists(request,RequestOptions.DEFAULT);
        /* 客服端发送请求 */
        System.out.println(bool);
    }
    //获取判断是否存在文档
    @Test
    void testGetDocument() throws IOException {
        //创建链接
        GetRequest request=new GetRequest("zysnba","1");
        GetResponse response=client.get(request,RequestOptions.DEFAULT);
        System.out.println(response.getSourceAsString());
        System.out.println(response);
    }

    //更新文档信息
    @Test
    void testUpdateDocument() throws IOException {
        //创建链接
        UpdateRequest request= new UpdateRequest("zysnba","1");
        request.timeout("1s");
        User user = new User("张三好修改了",14);
        request.doc(JSON.toJSONString(user), XContentType.JSON);
        UpdateResponse update = client.update(request, RequestOptions.DEFAULT);
        System.out.println(update.getGetResult());
        System.out.println(update.status());
    }

    //删除文档信息
    @Test
    void testDeleteDocument() throws IOException {
        //创建链接
        DeleteRequest request= new DeleteRequest("zysnba","1");
        request.timeout("1s");
        DeleteResponse delete = client.delete(request, RequestOptions.DEFAULT);
        System.out.println(delete.status());
    }


    //添加文档
    @Test
    void testBulkAddDocument() throws IOException {
        //创建链接
        BulkRequest request=new BulkRequest();
        request.timeout("2s");
        List<User> list= new ArrayList();
        User user1 = new User("张三好1",12);
        User user2 = new User("张三好2",12);
        User user3 = new User("张三好3",12);
        list.add(user1);
        list.add(user2);
        list.add(user3);
       //批处理请求
        for(int i =0;i<list.size();i++  ){
            //批量更新和批量删除，就在这里修改对应的请求即可
            request.add(new IndexRequest("zysnba")
                    //如果setId，自带生成id
//                    .id(""+(i+1))
                    .source(JSON.toJSONString(list.get(i)),XContentType.JSON));
        }
        BulkResponse bulk = client.bulk(request, RequestOptions.DEFAULT);
        System.out.println(bulk.status());
        //是否失败，返回false代表成功
        System.out.println(bulk.hasFailures());
    }

    //查询
    @Test
    void testSearch() throws IOException {
        SearchRequest searchRequest = new SearchRequest("zysnba");
        //构造搜索条件
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        //查询条件，我们可以使用queryBuilder 工具来实现
        //termQuery 精确匹配，注意中文的时候一定要加上name.keyword 坑
        //matchAllQuery() 匹配所有
        TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "zys1");
        searchSourceBuilder.query(termQueryBuilder);
        searchSourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
        searchRequest.source(searchSourceBuilder);
        SearchResponse search = client.search(searchRequest, RequestOptions.DEFAULT);
        System.out.println(JSON.toJSONString(search));
        System.out.println(JSON.toJSONString(search.getHits()));
        System.out.println("--------------------");
        for (SearchHit hit : search.getHits().getHits()) {
            System.out.println(hit.getSourceAsMap());
        }
    }
}