Elasticsearch java实现增删改查代码
以下是Elasticsearch Java实现增删改查的示例代码:
- 增加文档
IndexRequest request = new IndexRequest("index_name", "doc_type", "doc_id");
String jsonString = "{" +
"\"user\":\"kimchy\"," +
"\"postDate\":\"2013-01-30\"," +
"\"message\":\"trying out Elasticsearch\"" +
"}";
request.source(jsonString, XContentType.JSON);
IndexResponse response = client.index(request, RequestOptions.DEFAULT);
- 获取文档
GetRequest getRequest = new GetRequest("index_name", "doc_type", "doc_id");
GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT);
String sourceAsString = getResponse.getSourceAsString();
- 更新文档
UpdateRequest request = new UpdateRequest("index_name", "doc_type", "doc_id");
String jsonString = "{" +
"\"updated_field\":\"updated_value\"" +
"}";
request.doc(jsonString, XContentType.JSON);
UpdateResponse response = client.update(request, RequestOptions.DEFAULT);
- 删除文档
DeleteRequest request = new DeleteRequest("index_name", "doc_type", "doc_id");
DeleteResponse response = client.delete(request, RequestOptions.DEFAULT);
以上代码示例使用了Elasticsearch7.0及以上版本的Java API。如果使用的是较早的版本,可能需要做一些调整
原文地址: http://www.cveoy.top/t/topic/htLQ 著作权归作者所有。请勿转载和采集!