{"id":1393,"date":"2023-03-19T11:09:57","date_gmt":"2023-03-19T03:09:57","guid":{"rendered":"https:\/\/www.appblog.cn\/?p=1393"},"modified":"2023-04-28T21:11:04","modified_gmt":"2023-04-28T13:11:04","slug":"elasticsearch-high-level-rest-api-using-template-search","status":"publish","type":"post","link":"https:\/\/www.appblog.cn\/index.php\/2023\/03\/19\/elasticsearch-high-level-rest-api-using-template-search\/","title":{"rendered":"ElasticSearch High Level REST API\uff085\uff09\u4f7f\u7528\u6a21\u677f\u641c\u7d22"},"content":{"rendered":"

ElasticSearch Rest\u9ad8\u7ea7API \u63d0\u4f9b\u4e86\u591a\u79cd\u641c\u7d22\u65b9\u5f0f\uff0c\u9664\u4e86\u524d\u9762\u8bb2\u5230\u7684search\u67e5\u8be2\uff0cElasticSearch \u8fd8\u63d0\u4f9b\u4e86\u901a\u8fc7\u6a21\u677f\u641c\u7d22\u67e5\u8be2\u3002<\/p>\n

\u6211\u4eec\u53ef\u4ee5\u901a\u8fc7\u811a\u672c\u9884\u9009\u6ce8\u518c\u6a21\u677f\uff0c\u5728\u6ce8\u518c\u6a21\u677f\u65f6\u5b9a\u4e49\u4e00\u4e2a\u6a21\u677f\u540d\u79f0\u3002\u5728\u67e5\u8be2\u65f6\u901a\u8fc7\u6a21\u677f\u540d\u79f0\u8c03\u7528\u8be5\u6a21\u677f\u3002<\/p>\n

\u6ce8\u518c\u6a21\u677f<\/h2>\n

<\/p>\n

@Autowired\nprivate RestClient restClient;\n\n@GetMapping("template\/register")\npublic String registerTemplate() {\n    String template = "{\\n" +\n            "  \\"script\\":{\\n" +\n            "    \\"lang\\":\\"mustache\\",\\n" +\n            "    \\"source\\":{\\n" +\n            "      \\"query\\":{\\n" +\n            "        \\"match\\":{\\n" +\n            "          \\"{{key}}\\":\\"{{value}}\\"\\n" +\n            "        }\\n" +\n            "      },\\n" +\n            "      \\"size\\":\\"{{size}}\\"\\n" +\n            "    }\\n" +\n            "  }\\n" +\n            "}";\n    Request scriptRequest = new Request("POST", "_scripts\/title_search");\n    scriptRequest.setJsonEntity(template);\n\n    try {\n        Response response = restClient.performRequest(scriptRequest);\n        \/\/restClient.close();\n        return JSON.toJSONString(response);\n    } catch (IOException e) {\n        e.printStackTrace();\n    }\n    return "";\n}<\/code><\/pre>\n
{\n    "entity":{\n        "chunked":false,\n        "content":{\n\n        },\n        "contentLength":21,\n        "contentType":{\n            "buffer":{\n                "empty":false,\n                "full":false\n            },\n            "elements":[\n                {\n                    "name":"application\/json",\n                    "parameterCount":1,\n                    "parameters":[\n                        {\n                            "name":"charset",\n                            "value":"UTF-8"\n                        }\n                    ]\n                }\n            ],\n            "name":"content-type",\n            "value":"application\/json; charset=UTF-8",\n            "valuePos":13\n        },\n        "repeatable":false,\n        "streaming":true\n    },\n    "headers":[\n        {\n            "$ref":"$.entity.contentType"\n        },\n        {\n            "buffer":{\n                "empty":false,\n                "full":false\n            },\n            "elements":[\n                {\n                    "name":"21",\n                    "parameterCount":0,\n                    "parameters":[\n\n                    ]\n                }\n            ],\n            "name":"content-length",\n            "value":"21",\n            "valuePos":15\n        }\n    ],\n    "host":{\n        "hostName":"192.168.165.239",\n        "port":9200,\n        "schemeName":"http"\n    },\n    "requestLine":{\n        "method":"POST",\n        "protocolVersion":{\n            "major":1,\n            "minor":1,\n            "protocol":"HTTP"\n        },\n        "uri":"_scripts\/title_search"\n    },\n    "statusLine":{\n        "protocolVersion":{\n            "$ref":"$.requestLine.protocolVersion"\n        },\n        "reasonPhrase":"OK",\n        "statusCode":200\n    },\n    "warnings":[\n\n    ]\n}<\/code><\/pre>\n
\u7531\u4e8eElasticSearch 6.5-7.1\u7248\u672c\u7684\u9ad8\u7ea7Rest API\u4e2d\u6682\u65f6\u8fd8\u6ca1\u6709\u63d0\u4f9b\u7528\u4e8e\u6ce8\u518c\u6a21\u677f\u7684\u5b58\u50a8\u811a\u672c\uff0c\u6240\u4ee5\u672c\u793a\u4f8b\u4e2d\u4f7f\u7528\u7684\u4f4e\u7ea7REST\u5ba2\u6237\u7aef\u3002\u672c\u793a\u4f8b\u4e2d\u6ce8\u518c\u4e86\u4e00\u4e2a\u540d\u4e3atitle_search<\/code>\u7684\u6a21\u677f<\/p>\n
\u6709\u4e86\u8fd9\u4e2a\u6a21\u677f\u5c31\u53ef\u4ee5\u901a\u8fc7title_search<\/code>\u53bb\u8c03\u7528\uff0c\u52a8\u6001\u7684\u5c06\u67e5\u8be2\u53c2\u6570\u6dfb\u52a0\u5230\u6a21\u677f\u4e2d\u53bb\u3002\u6a21\u677f\u8c03\u7528\u793a\u4f8b\u5982\u4e0b\uff1a<\/p>\n
@GetMapping("template\/search")\npublic void templateSearch() {\n    try {\n        SearchTemplateRequest request = new SearchTemplateRequest();\n        request.setRequest(new SearchRequest("test"));\n\n        request.setScriptType(ScriptType.STORED);\n        request.setScript("title_search");\n\n        Map<String, Object> params = new HashMap<>();\n        params.put("key", "name");\n        params.put("value", "Joe.Ye");\n        params.put("size", 5);\n        request.setScriptParams(params);\n        try {\n            SearchTemplateResponse searchTemplateResponse = client.searchTemplate(request, RequestOptions.DEFAULT);\n            SearchHit[] hits = searchTemplateResponse.getResponse().getHits().getHits();\n            for (SearchHit hit : hits) {\n                log.info(hit.getSourceAsString());\n            }\n            client.close();\n        } catch (IOException e) {\n            e.printStackTrace();\n        }\n    } catch (Exception e) {\n        e.printStackTrace();\n    }\n}<\/code><\/pre>\n
{"name":"Joe.Ye","email":"yezhou@yezhou.org","homepage":"http:\/\/www.appblog.cn"}\n{"name":"Joe.Ye","age":28,"homepage":"http:\/\/www.appblog.cn"}\n{"name":"Joe.Ye","email":"yezhou@yezhou.org","homepage":"http:\/\/www.appblog.cn"}\n{"name":"Joe.Ye@AppBlog.CN","email":"yezhou@yezhou.org","age":18,"homepage":"http:\/\/www.appblog.cn"}\n{"name":"Joe.Ye@AppBlog.CN","age":18,"homepage":"http:\/\/www.appblog.cn"}<\/code><\/pre>\n
\u9488\u5bf9\u6bcf\u4e2a\u6a21\u677f\u6211\u4eec\u6267\u884c\u4e00\u6b21\u641c\u7d22\u8bf7\u6c42\uff0c\u5982\u679c\u6211\u4eec\u5de5\u4f5c\u4e2d\u9488\u5bf9\u540c\u4e00\u6a21\u677f\u53ef\u80fd\u4f1a\u6709\u4e0d\u6b62\u4e00\u6b21\u7684\u8bf7\u6c42\uff0c\u5982\u679c\u6bcf\u4e2a\u8bf7\u6c42\u90fd\u53bb\u5355\u72ec\u6267\u884c\u7684\u8bdd\u672a\u514d\u6709\u70b9\u7e41\u7410\u3002\u6211\u4eec\u53ef\u4ee5\u901a\u8fc7multiTemplateSearch<\/code>\u5b9e\u73b0\u4e00\u6b21\u8bf7\u6c42\u5b9e\u73b0\u591a\u6761\u641c\u7d22\uff0c\u793a\u4f8b\u5982\u4e0b\uff1a<\/p>\n
@GetMapping("template\/multiSearch")\npublic void multiTemplateSearch() {\n    String[] searchTerms = {"Joe.Ye", "Xiong"}; \/\/ \u8981\u641c\u7d22\u7684\u6761\u4ef6\n    MultiSearchTemplateRequest multiRequest = new MultiSearchTemplateRequest();\n    for (String searchTerm : searchTerms) {\n        SearchTemplateRequest request = new SearchTemplateRequest();\n        request.setRequest(new SearchRequest("person")); \/\/\u6307\u5b9a\u4e3aperson\u7d22\u5f15\u5e93\n\n        request.setScriptType(ScriptType.INLINE);\n        request.setScript(\n                "{\\n" +\n                "  \\"query\\":{\\n" +\n                "    \\"match\\":{\\n" +\n                "      \\"{{key}}\\":\\"{{value}}\\"\\n" +\n                "    }\\n" +\n                "  },\\n" +\n                "  \\"size\\":\\"{{size}}\\"\\n" +\n                "}");\n\n        Map<String, Object> scriptParams = new HashMap<>();\n        \/\/\u5411\u6a21\u677f\u4e2d\u586b\u5145\u5bf9\u5e94\u503c\n        scriptParams.put("key", "name");\n        scriptParams.put("value", searchTerm);\n        scriptParams.put("size", 5);\n        request.setScriptParams(scriptParams);\n\n        multiRequest.add(request);\n    }\n    \/\/\u6267\u884c\u67e5\u8be2\n    try {\n        MultiSearchTemplateResponse multiResponse = client.msearchTemplate(multiRequest, RequestOptions.DEFAULT);\n        \/\/\u8fd4\u56de\u4e00\u7ec4\u54cd\u5e94\uff0c\u6bcf\u4e2a\u8bf7\u6c42\u5bf9\u5e94\u4e00\u4e2a\u54cd\u5e94\n        for (MultiSearchTemplateResponse.Item item : multiResponse.getResponses()) {\n            if (item.isFailure()) {\n                String error = item.getFailureMessage(); \/\/\u641c\u7d22\u8bf7\u6c42\u5931\u8d25\u8fd4\u56de\u9519\u8bef\u4fe1\u606f\n                log.info(error);\n            } else {\n                SearchTemplateResponse searchTemplateResponse = item.getResponse();\n                SearchResponse response = searchTemplateResponse.getResponse();\n                SearchHits hits = response.getHits();\n                for (SearchHit hit : hits) {\n                    log.info(hit.getSourceAsString());\n                }\n            }\n        }\n    } catch (IOException e) {\n        e.printStackTrace();\n    }\n}<\/code><\/pre>\n
{"age":28,"height":175.2,"name":"Joe.Ye"}\n{"age":26,"height":165.5,"name":"Xiong"}<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"
ElasticSearch Rest\u9ad8\u7ea7API \u63d0\u4f9b\u4e86\u591a\u79cd\u641c\u7d22\u65b9\u5f0f\uff0c\u9664\u4e86\u524d\u9762\u8bb2\u5230\u7684search\u67e5\u8be2\uff0cElast […]<\/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-1393","post","type-post","status-publish","format-standard","hentry","category-elasticsearch"],"_links":{"self":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1393","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=1393"}],"version-history":[{"count":0,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1393\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/media?parent=1393"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/categories?post=1393"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/tags?post=1393"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}