先注入文章來源地址http://www.zghlxwxcb.cn/news/detail-504259.html
@Autowired
private RestHighLevelClient restHighLevelClient;
1:ES根據(jù)單個條件查詢
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執(zhí)行search,得到響應(yīng)結(jié)果
SearchResponse searchResponse =
restHighLevelClient.search(searchRequest,RequestOption.DEFAULT);
//根據(jù)自己返回的數(shù)據(jù)格式取值
SearchHit[] hits = searchResponse.getHits().getHits();
for (SearchHit hit : hits) {
//取值
hit.getSourceAsMap().get("字段");
}
return null;
}
2:ES根據(jù)多個條件查詢
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("拼接后的請求參數(shù): ",searchRequest);
SearchResponse searchResponse = restHighLevelclient.search(searchRequest,RequestOptions .DEFAULT) ;
log.info("查詢后的結(jié)果: ",searchResponse);
//取值
SearchHitl] hits = searchResponse.getHits() .getHits();
3:ES根據(jù)id,局部更新文檔
UpdateRequest updateRequest = new UpdateRequest();
updateRequest.index(索引);
updateRequest.type("_doc");
updateRequest.id(id);
//添加where條件
updateRequest.doc(
XContentFactory.jsonBuilder(
.startobject()
.field( "字段", "值")
.field( "字段", "值")
.endobject()
);
//執(zhí)行
String resultUpdate = restHighlevelClient.update(updateRequest, Request0ptions.DEFAULT).getResult().tostring();
文章來源:http://www.zghlxwxcb.cn/news/detail-504259.html
到了這里,關(guān)于java實現(xiàn) elasticsearch es 的單個條件查詢和多個條件查詢,根據(jù)id更新指定字段的文章就介紹完了。如果您還想了解更多內(nèi)容,請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!