ElasticSearch 对索引库的java客户端基础操作

清疚 2022-10-02 06:00 193阅读 0赞

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][]

## **1. 创建索引库** ##

@Test
        public void testCreateIndex() throws IOException {
            CreateIndexRequest xc_course = new CreateIndexRequest("xc_course");
            xc_course.settings(Settings.builder().put("number_of_shards",1).put("number_of_replicas",0));
            xc_course.mapping("doc","{\n" +
                    "\"properties\": {\n" +
                    "\"name\": {\n" +
                    "\"type\": \"text\",\n" +
                    "\"analyzer\":\"ik_max_word\",\n" +
                    "\"search_analyzer\":\"ik_smart\"\n" +
                    "},\n" +
                    "\"description\": {\n" +
                    "\"type\": \"text\",\n" +
                    "\"analyzer\":\"ik_max_word\",\n" +
                    "\"search_analyzer\":\"ik_smart\"\n" +
                    "},\n" +
                    "\"pic\":{\n" +
                    "\"type\":\"text\",\n" +
                    "\"index\":false\n" +
                    "},\n" +
                    "\"studymodel\":{\n" +
                    "\"type\":\"text\"\n" +
                    "}\n" +
                    "}\n" +
                    "}", XContentType.JSON);
    
            IndicesClient indices = restHighLevelClient.indices();
            CreateIndexResponse createIndexResponse = indices.create(xc_course);
            boolean acknowledged = createIndexResponse.isAcknowledged();
            System.out.println(acknowledged);
        }

## **2. 添加文档** ##

@Test
        public void testAddDoc() throws IOException {
            Map<String,Object> jsonMap=new HashMap<>();
            jsonMap.put("name", "spring cloud实战");
            jsonMap.put("description", "本课程主要从四个章节进行讲解： 1.微服务架构入门 2.spring cloud 基础入门 3.实战Spring Boot 4.注册中心eureka。");
            jsonMap.put("studymodel", "201001");
            SimpleDateFormat dateFormat =new SimpleDateFormat("yyyy‐MM‐dd HH:mm:ss");
            jsonMap.put("timestamp", dateFormat.format(new Date()));
            jsonMap.put("price", 5.6f);
    
            IndexRequest indexRequest = new IndexRequest("xc_course", "doc");
            indexRequest.source(jsonMap);
    
            IndexResponse indexResponse = restHighLevelClient.index(indexRequest);
            DocWriteResponse.Result result = indexResponse.getResult();
            System.out.println(result);
        }

## **3. 通过id查询文档** ##

@Test
        public void testGetDoc() throws IOException {
            GetRequest getRequest = new GetRequest("xc_course", "doc", "TJQgSGoB2TKFT6VvSn0T");
            GetResponse getResponse = restHighLevelClient.get(getRequest);
            boolean exists = getResponse.isExists();
            if(exists){
                Map<String, Object> sourceAsMap = getResponse.getSourceAsMap();
                System.out.println(sourceAsMap);
            }else {
                System.out.println(exists);
            }
        }

## **4. 更新文档** ##

@Test
        public void testUpdateDoc() throws IOException {
            UpdateRequest updateRequest = new UpdateRequest("xc_course", "doc", "TJQgSGoB2TKFT6VvSn0T");
            Map<String,Object> jsonMap=new HashMap<>();
            jsonMap.put("name","spring cloud实战");
            updateRequest.doc(jsonMap);
    
            UpdateResponse updateResponse = restHighLevelClient.update(updateRequest);
            RestStatus status = updateResponse.status();
            System.out.println(status);
        }

## **5. 删除文档** ##

@Test
        public void testDeleteDoc() throws IOException {
            String id="TJQgSGoB2TKFT6VvSn0T";
    
            DeleteRequest deleteRequest = new DeleteRequest("xc_course", "doc", id);
            DeleteResponse deleteResponse = restHighLevelClient.delete(deleteRequest);
            RestStatus status = deleteResponse.status();
            System.out.println(status);
        }

转载于:https://my.oschina.net/edisonOnCall/blog/3043235

[2019_Python_]: https://my.oschina.net/u/2663968/blog/3061697
[hot3.png]: /images/20220113/4fd78ec6bdab43cb8170196163b889f2.png