zoukankan      html  css  js  c++  java
  • springboot整合es客户端操作elasticsearch(三)

    继续上个随笔:

    那么我们只需要修改controller中文件就可以完成相关操作

    本次主要是对文档得操作:

    更新文档:

    package com.cxy.elasticsearch.controller;
    
    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.update.UpdateRequest;
    import org.elasticsearch.action.update.UpdateResponse;
    import org.elasticsearch.client.RequestOptions;
    import org.elasticsearch.client.RestClient;
    import org.elasticsearch.client.RestHighLevelClient;
    import org.elasticsearch.rest.RestStatus;
    import org.elasticsearch.snapshots.SnapshotShardsService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RestController;
    
    import javax.xml.transform.Source;
    import java.io.IOException;
    import java.util.HashMap;
    import java.util.Map;
    
    @RestController
    public class EsindexController {
        @Autowired
        RestHighLevelClient client;
    
        @Autowired
        RestClient restClient;
    
        @RequestMapping(value = "/updatedoc",method = RequestMethod.GET)
        public String updatedoc(){
            UpdateRequest updateRequest = new UpdateRequest("chenxuyou3","doc","ekBpCG8BAmmLmqjtgRwU");
            HashMap<String, String> stringStringHashMap = new HashMap<>();
            stringStringHashMap.put("name","Ealsticseach学习实战");
            updateRequest.doc(stringStringHashMap);
            UpdateResponse update =null;
            try {
                update= client.update(updateRequest, RequestOptions.DEFAULT);
            } catch (IOException e) {
                e.printStackTrace();
            }
            RestStatus status = update.status();
            System.err.println(status);
    
            return "ok" ;
        }
        @RequestMapping(value = "/deletedoc",method = RequestMethod.GET)
        public String deletedoc(){
           String id ="e0CECG8BAmmLmqjt6hwW";
           DeleteRequest deleteRequest = new DeleteRequest("chenxuyou3", "doc", id);
            DeleteResponse delete = null;
            try {
                delete = client.delete(deleteRequest, RequestOptions.DEFAULT);
            } catch (IOException e) {
                e.printStackTrace();
            }
            RestStatus status = delete.status();
            System.err.println(status);
    
            return "ok" ;
        }
    
    }

    调用接口:

    localhost:8085/updatedoc

    成功:

    调用删除接口,删除得是数据第一条:

     接口:

     可以看到已经删除了。所以对文档得增加,删除,修改,查询已经完成了,下个随便将会写对文档得精确,模糊,分数查询

  • 相关阅读:
    JAVA常见面试题之Forward和Redirect的区别
    [转载]vm文件
    [转载]vm文件
    [转载]心灵丨愿你早一点发现,你才是自己最重要的粉丝
    [转载]心灵丨愿你早一点发现,你才是自己最重要的粉丝
    iBatis整理——Spring环境下批处理实现
    iBatis整理——Spring环境下批处理实现
    SAP HANA 三大特点
    在解决方案中搜索 文件的位置
    我这边测了一下,发现#后面参数变化浏览器不会刷新,但是#一旦去掉就会刷新了,你那边的url拼的时候能不能在没参数的时候#也拼在里面,这样应该就OK了
  • 原文地址:https://www.cnblogs.com/cxyxiaobao/p/12044422.html
Copyright © 2011-2022 走看看