先注入
@Autowired
private RestHighLevelClient restHighLevelClient;1：ES根据单个条件查询
public String searchEsAttachmentsLink(String riskId,String dataFrom){
try {
//添加条件，
SearchSourceBuilder searchSourceBuilder = SearchSourceBuilder.searchSource()
.size(1)
.query(QueryBuilders.termQuery( name: "字段"， 值));
//拼装
SearchRequest searchRequest = new SearchRequest()
.indices(索引)
.source(searchSourceBuilder);
//用ESClient执行search，得到响应结果
SearchResponse searchResponse =
restHighLevelClient.search(searchRequest,RequestOption.DEFAULT);
//根据自己返回的数据格式取值
SearchHit[] hits = searchResponse.getHits().getHits();
for (SearchHit hit : hits) {
//取值
hit.getSourceAsMap().get("字段");
}
return null;
}2:ES根据多个条件查询
BoolOueryBuilder boolOueryBuilder = new BoolOueryBuilder();
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//用must拼接where条件
boolQueryBuilder.must(QueryBuilders.termQuery("字段"，"值"))
.must(QueryBuilders.termQuery("字段","值");
SearchRequest searchRequest = new SearchRequest()
.indices(索引)
.source(searchSourceBuilder);
searchSourceBuilder.query(boolQueryBuilder);
log.info("拼接后的请求参数: ",searchRequest);
SearchResponse searchResponse = restHighLevelclient.search(searchRequest,RequestOptions .DEFAULT) ;
log.info("查询后的结果: ",searchResponse);
//取值
SearchHitl] hits = searchResponse.getHits() .getHits();3：ES根据id，局部更新文档
UpdateRequest updateRequest = new UpdateRequest();
updateRequest.index(索引);
updateRequest.type("_doc");
updateRequest.id(id);
//添加where条件
updateRequest.doc(
XContentFactory.jsonBuilder(
.startobject()
.field( "字段"， "值")
.field( "字段"， "值")
.endobject()
);
//执行
String resultUpdate = restHighlevelClient.update(updateRequest, Request0ptions.DEFAULT).getResult().tostring();版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之家整理，本文链接：https://www.bmabk.com/index.php/post/160685.html
