{"id":1389,"date":"2023-03-19T11:07:13","date_gmt":"2023-03-19T03:07:13","guid":{"rendered":"https:\/\/www.appblog.cn\/?p=1389"},"modified":"2023-04-28T21:11:31","modified_gmt":"2023-04-28T13:11:31","slug":"elasticsearch-high-level-rest-api-document-basic-operations","status":"publish","type":"post","link":"https:\/\/www.appblog.cn\/index.php\/2023\/03\/19\/elasticsearch-high-level-rest-api-document-basic-operations\/","title":{"rendered":"ElasticSearch High Level REST API\uff081\uff09\u6587\u6863\u57fa\u672c\u64cd\u4f5c"},"content":{"rendered":"

\u83b7\u53d6ES\u5ba2\u6237\u7aef<\/h2>\n

ES\u7684\u63d0\u4f9b\u4e86\u56db\u79cdJava\u5ba2\u6237\u7aef\uff0c\u5206\u522b\u4e3a\u8282\u70b9\u5ba2\u6237\u7aef(node client)\u3001\u4f20\u8f93\u5ba2\u6237\u7aef(Transport Client)\u3001\u4f4e\u7ea7REST\u5ba2\u6237\u7aef\u3001\u9ad8\u7ea7REST\u5ba2\u6237\u7aef\u3002<\/p>\n

\u8282\u70b9\u5ba2\u6237\u7aef\u4f5c\u4e3a\u96c6\u7fa4\u8282\u70b9\u7684\u4e00\u90e8\u5206\uff0c\u5728\u96c6\u7fa4\u8282\u70b9\u8f83\u591a\u7684\u60c5\u51b5\u4e0b\u4f1a\u5f71\u54cd\u96c6\u7fa4\u7684\u53cd\u5e94\u901f\u5ea6\u3002<\/p>\n

<\/p>\n

\u4f20\u8f93\u5ba2\u6237\u7aef\u5ba2\u6237\u7aef\u867d\u7136\u5b9e\u73b0\u4e86\u548c\u96c6\u7fa4\u7684\u89e3\u8026\uff0c\u76f8\u5bf9\u8282\u70b9\u66f4\u201c\u8f7b\u201d\uff0c\u4f46\u662f\u4f1a\u5728ES7.0\u62168.0\u4e4b\u540e\u88ab\u79fb\u9664\uff0c\u88ab\u201c\u9ad8\u7ea7Rest\u5ba2\u6237\u7aef\u201d\u6240\u53d6\u4ee3\u3002<\/p>\n

\u5982\u4e0b\u4e3aES \u5ba2\u6237\u7aef\u7684\u521b\u5efa\uff1a<\/p>\n

@Configuration\npublic class ElasticClient {\n    private String host = "192.168.165.239";\n    private int port = 9200;\n\n    \/**\n     * \u83b7\u53d6Rest\u9ad8\u7ea7\u5ba2\u6237\u7aef\n     * @return\n     *\/\n    @Bean\n    public RestHighLevelClient getRestHighLevelClient(){\n        RestClientBuilder builder = RestClient.builder(new HttpHost(host, port));\n        return new RestHighLevelClient(builder);\n    }\n\n    \/**\n     * \u83b7\u53d6Rest\u4f4e\u7ea7\u5ba2\u6237\u7aef\n     * @return\n     *\/\n    @Bean\n    public RestClient getRestClient(){\n        RestClientBuilder builder = RestClient.builder(new HttpHost(host, port));\n        return builder.build();\n    }\n}<\/code><\/pre>\n
\u4e0b\u9762\u4ecb\u7ecdES\u5728Java\u4e2d\u57fa\u672c\u7684\u6587\u6863\u589e\u5220\u6539\u67e5\u64cd\u4f5c<\/p>\n
\u7d22\u5f15\u64cd\u4f5c<\/h2>\n
\u7d22\u5f15\u5373\u6211\u4eec\u7684\u65b0\u589e\u64cd\u4f5c\uff0cES\u63d0\u4f9b\u4e86\u4e09\u79cd\u5f62\u5f0f\u7684\u7d22\u5f15\uff0c\u5206\u522b\u4e3a\u901a\u8fc7Json\u5b57\u7b26\u4e32\u3001Map\u96c6\u5408\u3001XContentBuilder\u5b9e\u73b0\u7d22\u5f15\u64cd\u4f5c<\/p>\n
@Resource\nprivate RestHighLevelClient client;\n\n@GetMapping("\/index\/create")\npublic String createIndex() {\n    IndexRequest indexRequest = new IndexRequest("test");\n    \/*\n    \/\/Json\u5b57\u7b26\u4e32\u4f5c\u4e3a\u6570\u636e\u6e90\n    String jsonString = "{" +\n            "\\"name\\": \\"Joe.Ye\\"," +\n            "\\"email\\": \\"yezhou@yezhou.org\\"," +\n            "\\"homepage\\": \\"http:\/\/www.appblog.cn\\"" +\n            "}";\n    indexRequest.source(jsonString, XContentType.JSON);\n    *\/\n    \/\/Map\u96c6\u5408\u4f5c\u4e3a\u6570\u636e\u6e90\n    Map<String, Object> map = new HashMap<>();\n    map.put("name", "Joe.Ye");\n    map.put("age", 28);\n    map.put("homepage", "http:\/\/www.appblog.cn");\n    indexRequest.source(map);\n    \/*\n    \/\/XContentBuilder\u4f5c\u4e3a\u6570\u636e\u6e90\n    XContentBuilder builder = null;\n    try {\n        builder = XContentFactory.jsonBuilder();\n        builder.startObject();\n        builder.field("name", "Joe.Ye");\n        builder.timeField("date", new Date());\n        builder.field("homepage", "http:\/\/www.appblog.cn");\n        builder.endObject();\n    } catch (IOException e) {\n        e.printStackTrace();\n    }\n    indexRequest.source(builder);\n    *\/\n    try {\n        IndexResponse indexResponse = client.index(indexRequest, RequestOptions.DEFAULT);\n        log.info("Status: {}", indexResponse.status().getStatus());\n        \/\/client.close();\n        return JSON.toJSONString(indexResponse);\n    } catch (IOException e) {\n        e.printStackTrace();\n    }\n    return "";\n}<\/code><\/pre>\n
Status: 201<\/code><\/pre>\n
{\n    "fragment":false,\n    "id":"zGMq_WoBzwYnh4XWhOrH",\n    "index":"test",\n    "primaryTerm":1,\n    "result":"CREATED",\n    "seqNo":0,\n    "shardId":{\n        "fragment":true,\n        "id":-1,\n        "index":{\n            "fragment":false,\n            "name":"test",\n            "uUID":"_na_"\n        },\n        "indexName":"test"\n    },\n    "shardInfo":{\n        "failed":0,\n        "failures":[\n\n        ],\n        "fragment":false,\n        "successful":1,\n        "total":2\n    },\n    "type":"_doc",\n    "version":1\n}<\/code><\/pre>\n
\u67e5\u8be2\u6587\u6863<\/h2>\n
\u6839\u636e\u7d22\u5f15\u3001ID\u67e5\u8be2\u6587\u6863<\/p>\n
@GetMapping("\/index\/get")\npublic String getIndex() {\n    GetRequest getRequest = new GetRequest(\n            "test",\n            "zGMq_WoBzwYnh4XWhOrH");\n    try {\n        GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT);\n        Map<String, Object> source = getResponse.getSource();\n        if (source != null && !source.isEmpty()) {\n            for (Map.Entry<String, Object> entry : source.entrySet()) {\n                log.info("Key: {}, Value: {}", entry.getKey(), entry.getValue());\n            }\n        }\n        \/\/client.close();\n        return JSON.toJSONString(getResponse);\n    } catch (IOException e) {\n        e.printStackTrace();\n    }\n    return "";\n}<\/code><\/pre>\n
Key: name, Value: Joe.Ye\nKey: email, Value: yezhou@yezhou.org\nKey: homepage, Value: http:\/\/www.appblog.cn<\/code><\/pre>\n
{\n    "exists":true,\n    "fields":{\n\n    },\n    "fragment":false,\n    "id":"zGMq_WoBzwYnh4XWhOrH",\n    "index":"test",\n    "primaryTerm":1,\n    "seqNo":0,\n    "source":{\n        "name":"Joe.Ye",\n        "email":"yezhou@yezhou.org",\n        "homepage":"http:\/\/www.appblog.cn"\n    },\n    "sourceAsBytes":"eyJuYW1lIjoiSm9lLlllIiwiZW1haWwiOiJ5ZXpob3VAeWV6aG91Lm9yZyIsImhvbWVwYWdlIjoiaHR0cDovL3d3dy5hcHBibG9nLmNuIn0=",\n    "sourceAsBytesRef":{\n        "fragment":true\n    },\n    "sourceAsMap":{\n        "$ref":"$.source"\n    },\n    "sourceAsString":"{"name":"Joe.Ye","email":"yezhou@yezhou.org","homepage":"http:\/\/www.appblog.cn"}",\n    "sourceEmpty":false,\n    "sourceInternal":{\n        "$ref":"$.sourceAsBytesRef"\n    },\n    "type":"_doc",\n    "version":1\n}<\/code><\/pre>\n
\u5220\u9664\u6587\u6863<\/h2>\n
@GetMapping("\/index\/delete")\npublic String deleteIndex() {\n    DeleteRequest deleteRequest = new DeleteRequest("test", "DWMz_WoBzwYnh4XWA-s8");\n    deleteRequest.timeout(TimeValue.timeValueMinutes(10));\n    deleteRequest.setRefreshPolicy(WriteRequest.RefreshPolicy.WAIT_UNTIL);\n    try {\n        DeleteResponse deleteResponse = client.delete(deleteRequest, RequestOptions.DEFAULT);\n        log.info("Status: {}", deleteResponse.status().getStatus());\n        \/\/client.close();\n        return JSON.toJSONString(deleteResponse);\n    } catch (IOException e) {\n        e.printStackTrace();\n    }\n    return "";\n}<\/code><\/pre>\n
Status: 200<\/code><\/pre>\n
{\n    "fragment":false,\n    "id":"DWMz_WoBzwYnh4XWA-s8",\n    "index":"test",\n    "primaryTerm":1,\n    "result":"DELETED",\n    "seqNo":6,\n    "shardId":{\n        "fragment":true,\n        "id":-1,\n        "index":{\n            "fragment":false,\n            "name":"test",\n            "uUID":"_na_"\n        },\n        "indexName":"test"\n    },\n    "shardInfo":{\n        "failed":0,\n        "failures":[\n\n        ],\n        "fragment":false,\n        "successful":1,\n        "total":2\n    },\n    "type":"_doc",\n    "version":2\n}<\/code><\/pre>\n
\u518d\u6b21\u67e5\u8be2<\/p>\n
{\n    "exists":false,\n    "fields":{\n\n    },\n    "fragment":false,\n    "id":"DWMz_WoBzwYnh4XWA-s8",\n    "index":"test",\n    "primaryTerm":0,\n    "seqNo":-2,\n    "sourceEmpty":true,\n    "type":"_doc",\n    "version":-1\n}<\/code><\/pre>\n
\u66f4\u65b0\u6587\u6863<\/h2>\n
@GetMapping("\/index\/update")\npublic String updateIndex() {\n    UpdateRequest updateRequest = new UpdateRequest("test", "nWNC_WoBzwYnh4XWTeun");\n    Map<String, Object> map = new HashMap<>();\n    map.put("name", "Joe.Ye@AppBlog.CN");\n    map.put("age", 18);\n    updateRequest.doc(map, XContentType.JSON);\n    try {\n        UpdateResponse updateResponse = client.update(updateRequest, RequestOptions.DEFAULT);\n        log.info("Status: {}", updateResponse.status().getStatus());\n        \/\/client.close();\n        return JSON.toJSONString(updateResponse);\n    } catch (IOException e) {\n        e.printStackTrace();\n    }\n    return "";\n}<\/code><\/pre>\n
Status: 200<\/code><\/pre>\n
{\n    "fragment":false,\n    "id":"nWNC_WoBzwYnh4XWTeun",\n    "index":"test",\n    "primaryTerm":1,\n    "result":"UPDATED",\n    "seqNo":7,\n    "shardId":{\n        "fragment":true,\n        "id":-1,\n        "index":{\n            "fragment":false,\n            "name":"test",\n            "uUID":"_na_"\n        },\n        "indexName":"test"\n    },\n    "shardInfo":{\n        "failed":0,\n        "failures":[\n\n        ],\n        "fragment":false,\n        "successful":1,\n        "total":2\n    },\n    "type":"_doc",\n    "version":2\n}<\/code><\/pre>\n
\u67e5\u8be2\u6587\u6863\u662f\u5426\u5b58\u5728<\/h2>\n
@GetMapping("\/index\/exists")\npublic String existsIndex() {\n    GetRequest getRequest = new GetRequest("test","zGMq_WoBzwYnh4XWhOrH");\n    try {\n        getRequest.fetchSourceContext(new FetchSourceContext(false)); \/\/\u7981\u7528\u83b7\u53d6 _source\u5b57\u6bb5\n        getRequest.storedFields("_none_"); \/\/\u7981\u7528\u83b7\u53d6\u5b58\u50a8\u5b57\u6bb5\n        boolean exists = client.exists(getRequest, RequestOptions.DEFAULT);\n        \/\/client.close();\n        return String.valueOf(exists);\n    } catch (Exception e) {\n        e.printStackTrace();\n    }\n    return "";\n}<\/code><\/pre>\n
true<\/code><\/pre>\n
Bulk\u6279\u91cf\u64cd\u4f5c<\/h2>\n
bulk\u53ef\u4ee5\u6279\u91cf\u6267\u884c\u591a\u6761\u64cd\u4f5c\u8bed\u53e5\uff0cbulk\u652f\u6301\u6279\u91cf\u64cd\u4f5c\u4e0d\u540c\u7684\u547d\u4ee4\uff0c\u4f8b\u5982\u6279\u91cf\u66f4\u65b0\u548c\u5220\u9664<\/p>\n
@GetMapping("\/bulk")\npublic String bulk() {\n    Person person1 = new Person("Joe.Ye", 28, 175.2);\n    Person person2 = new Person("Xiong", 26, 165.5);\n    BulkRequest bulkRequest = new BulkRequest();\n    IndexRequest indexRequest1 = new IndexRequest("person").source(JSON.toJSONString(person1), XContentType.JSON);\n    IndexRequest indexRequest2 = new IndexRequest("person").source(JSON.toJSONString(person2), XContentType.JSON);\n    DeleteRequest deleteRequest = new DeleteRequest("test", "AGMx_WoBzwYnh4XWx-tL");\n    bulkRequest.add(indexRequest1);\n    bulkRequest.add(indexRequest2);\n    bulkRequest.add(deleteRequest);\n    try {\n        BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);\n        log.info("Status: {}", bulkResponse.status().getStatus());\n        \/\/client.close();\n        return JSON.toJSONString(bulkResponse);\n    } catch (IOException e) {\n        e.printStackTrace();\n    }\n    return "";\n}<\/code><\/pre>\n
Status: 200<\/code><\/pre>\n
{\n    "fragment":false,\n    "ingestTook":{\n        "days":0,\n        "daysFrac":-1.1574074074074074e-8,\n        "hours":0,\n        "hoursFrac":-2.7777777777777776e-7,\n        "micros":-1000,\n        "microsFrac":-1000,\n        "millis":-1,\n        "millisFrac":-1,\n        "minutes":0,\n        "minutesFrac":-0.000016666666666666667,\n        "nanos":-1000000,\n        "seconds":0,\n        "secondsFrac":-0.001,\n        "stringRep":"-1"\n    },\n    "ingestTookInMillis":-1,\n    "items":[\n        {\n            "failed":false,\n            "fragment":false,\n            "id":"n2Nh_WoBzwYnh4XWSuxi",\n            "index":"person",\n            "itemId":0,\n            "opType":"INDEX",\n            "response":{\n                "fragment":false,\n                "id":"n2Nh_WoBzwYnh4XWSuxi",\n                "index":"person",\n                "primaryTerm":1,\n                "result":"CREATED",\n                "seqNo":0,\n                "shardId":{\n                    "fragment":true,\n                    "id":-1,\n                    "index":{\n                        "fragment":false,\n                        "name":"person",\n                        "uUID":"_na_"\n                    },\n                    "indexName":"person"\n                },\n                "shardInfo":{\n                    "failed":0,\n                    "failures":[\n\n                    ],\n                    "fragment":false,\n                    "successful":1,\n                    "total":2\n                },\n                "type":"_doc",\n                "version":1\n            },\n            "type":"_doc",\n            "version":1\n        },\n        {\n            "failed":false,\n            "fragment":false,\n            "id":"oGNh_WoBzwYnh4XWSuxi",\n            "index":"person",\n            "itemId":1,\n            "opType":"INDEX",\n            "response":{\n                "fragment":false,\n                "id":"oGNh_WoBzwYnh4XWSuxi",\n                "index":"person",\n                "primaryTerm":1,\n                "result":"CREATED",\n                "seqNo":1,\n                "shardId":{\n                    "fragment":true,\n                    "id":-1,\n                    "index":{\n                        "fragment":false,\n                        "name":"person",\n                        "uUID":"_na_"\n                    },\n                    "indexName":"person"\n                },\n                "shardInfo":{\n                    "failed":0,\n                    "failures":[\n\n                    ],\n                    "fragment":false,\n                    "successful":1,\n                    "total":2\n                },\n                "type":"_doc",\n                "version":1\n            },\n            "type":"_doc",\n            "version":1\n        },\n        {\n            "failed":false,\n            "fragment":false,\n            "id":"AGMx_WoBzwYnh4XWx-tL",\n            "index":"test",\n            "itemId":2,\n            "opType":"DELETE",\n            "response":{\n                "fragment":false,\n                "id":"AGMx_WoBzwYnh4XWx-tL",\n                "index":"test",\n                "primaryTerm":1,\n                "result":"DELETED",\n                "seqNo":8,\n                "shardId":{\n                    "fragment":true,\n                    "id":-1,\n                    "index":{\n                        "fragment":false,\n                        "name":"test",\n                        "uUID":"_na_"\n                    },\n                    "indexName":"test"\n                },\n                "shardInfo":{\n                    "failed":0,\n                    "failures":[\n\n                    ],\n                    "fragment":false,\n                    "successful":1,\n                    "total":2\n                },\n                "type":"_doc",\n                "version":2\n            },\n            "type":"_doc",\n            "version":2\n        }\n    ],\n    "took":{\n        "days":0,\n        "daysFrac":0.000004780092592592592,\n        "hours":0,\n        "hoursFrac":0.00011472222222222222,\n        "micros":413000,\n        "microsFrac":413000,\n        "millis":413,\n        "millisFrac":413,\n        "minutes":0,\n        "minutesFrac":0.006883333333333333,\n        "nanos":413000000,\n        "seconds":0,\n        "secondsFrac":0.413,\n        "stringRep":"413ms"\n    }\n}<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"
\u83b7\u53d6ES\u5ba2\u6237\u7aef ES\u7684\u63d0\u4f9b\u4e86\u56db\u79cdJava\u5ba2\u6237\u7aef\uff0c\u5206\u522b\u4e3a\u8282\u70b9\u5ba2\u6237\u7aef(node client)\u3001\u4f20\u8f93\u5ba2\u6237\u7aef(Tra […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[301],"tags":[],"class_list":["post-1389","post","type-post","status-publish","format-standard","hentry","category-elasticsearch"],"_links":{"self":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1389","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/comments?post=1389"}],"version-history":[{"count":0,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1389\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/media?parent=1389"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/categories?post=1389"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/tags?post=1389"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}