本篇内容主要讲解“elasticsearch7.2的增删改查语法”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“elasticsearch7.2的增删改查语法”吧!
计算
安全
数据库
网络和加速
企业服务
<!-- 引入Elasticsearch相关jar包-->
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<version>7.2.0</version>
</dependency>
<!-- <dependency>-->
<!-- <groupId>org.elasticsearch.client</groupId>-->
<!-- <artifactId>transport</artifactId>-->
<!-- <version>7.2.0</version>-->
<!-- </dependency>-->
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-high-level-client</artifactId>
<version>7.2.0</version>
</dependency>
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-client</artifactId>
<version>7.2.0</version>
</dependency>
<!-- <dependency>
<groupId>org.apache.lucene</groupId>
<artifactId>lucene-core</artifactId>
<version>8.0.0</version>
</dependency> -->代码如下：
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import org.apache.http.HttpHost; //import org.elasticsearch.action.get.GetRequest; //import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest; import org.elasticsearch.action.delete.DeleteRequest; import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.action.search.SearchRequest; import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.action.update.UpdateRequest; import org.elasticsearch.client.RequestOptions; import org.elasticsearch.client.RestClient; import org.elasticsearch.client.RestHighLevelClient; import org.elasticsearch.index.query.BoolQueryBuilder; //import org.elasticsearch.index.query.QueryBuilder; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.builder.SearchSourceBuilder; import java.io.IOException; import java.util.*;
public class Demo1 { private static RestHighLevelClient client; private static final String ip="170.60.140.120"; private static final int port=9200;
public static void main(String[] args) throws Exception{
client=new RestHighLevelClient(RestClient.builder(
new HttpHost(ip, port, "http")));
// indexincrement();
indexsearch();
// indexdelete();
// indexupdate();
client.close();
}创建索引
private static void indexincrement() throws Exception{
HashMap<String, Object> jsonmap = new HashMap<>();
jsonmap.put("name","王五");
jsonmap.put("age",32);
IndexRequest indexRequest = new IndexRequest("post").source(jsonmap);
IndexResponse indexResponse = client.index(indexRequest, RequestOptions.DEFAULT);
System.out.println("indexresponse = "+indexResponse);
System.out.println("indexResponse.status() = "+indexResponse.status());
}删除索引
private static void indexdelete() throws Exception{
//第一种，按索引id删除某个文档。
/* DeleteRequest deleteRequest = new DeleteRequest("post", "m56EDXIBK5FuWnazQHHa");
client.delete(deleteRequest,RequestOptions.DEFAULT);*/
//第二种，一次性删除整个索引
/* DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest("post");
client.indices().delete(deleteIndexRequest,RequestOptions.DEFAULT); */
//第三种，先按条件查询出某范围内所有Id，再一个一个删除
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
sourceBuilder.query(boolQueryBuilder);
sourceBuilder.size(100);
SearchRequest searchRequest = new SearchRequest().indices("post");
searchRequest.source(sourceBuilder);
SearchResponse response1 = client.search(searchRequest, RequestOptions.DEFAULT);
SearchHit[] hits = response1.getHits().getHits();
for(SearchHit hit:hits){
String id = hit.getId();
DeleteRequest deleteRequest = new DeleteRequest("post", id);
client.delete(deleteRequest,RequestOptions.DEFAULT);
}更新文档，（以map方式为例）
private static void indexupdate() throws Exception{
UpdateRequest updateRequest = new UpdateRequest("post","kCfJHHIBCUDx2GUCB0Dk");
HashMap<String, Object> jsonmap = new HashMap<>();
jsonmap.put("name","赵六");
jsonmap.put("age",16);
updateRequest.doc(jsonmap);
client.update(updateRequest,RequestOptions.DEFAULT);
}查询索引
private static void indexsearch(Connection conn) throws Exception{
/* 第一种，按某个id号查询方式
GetRequest getRequest = new GetRequest("risklog", "rpBmNnIB76i_tBrAwvlC");
GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT);*/
/*
第二种，按条件查询整个索引表方式
*/
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
sourceBuilder.query(boolQueryBuilder);
//这里设置查询7万条数据
sourceBuilder.size(70000);
// SearchRequest searchRequest=new SearchRequest();
SearchRequest searchRequest = new SearchRequest().indices("middleware_apache_server_access");
searchRequest.source(sourceBuilder);
SearchResponse response1 = client.search(searchRequest, RequestOptions.DEFAULT);
List<JSONObject> list = new ArrayList<>();
response1.getHits().forEach(item -> list.add(JSON.parseObject(item.getSourceAsString())));
System.out.println("list.size() = "+list.size());
// Iterator<JSONObject> iterator = list.iterator();
for(int i=0;i<list.size();i++){
JSONObject jsonObject = list.get(i);
System.out.println("jsonObject = "+jsonObject);
}
}}
到此，相信大家对“elasticsearch7.2的增删改查语法”有了更深的了解，不妨来实际操作一番吧！这里是亿速云网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：http://blog.itpub.net/31537832/viewspace-2696060/
