首页 > 技术文章 > JAVA操作ES增删API

yan-zm 2019-11-29 11:27 原文

PS:this.esClient为以配置完成且注入的对象,该随笔只记录相应API基本写法。

 

根据ES自动生成的_id进行单一删除:

DeleteResponse response =this.esClient.prepareDelete(INDEX_NAME, INDEX_TYPE, _id).execute().actionGet();

 

根据查询结果删除(filter内可以使用多种查询):

DeleteByQueryRequestBuilder builder = DeleteByQueryAction.INSTANCE.newRequestBuilder(this.esClient)

                         .filter(QueryBuilders.matchQuery(字段名, 字段值)).source(INDEX_NAME);

BulkByScrollResponse response2 = builder.get();

long deleted = response2.getDeleted();        //获得删除的记录条数

 

Bulk为批量操作,使用bulk可减少请求发送的次数,可提高大数量操作效率,但当bulk的条数过多时,会产生相反效果(比如占用大量内存,一次请求占用太多CPU时间...)。

一次bulk具体数量应多方面权衡,找到最佳平衡点。

BulkRequestBuilder bulkRequestBuilder = this.esClient.prepareBulk();

for (POJO pojo: resultList) {

  bulkRequestBuilder.add(this.esClient.prepareIndex(INDEX_NAME, INDEX_TYPE).setSource(JSON.toJSONString(pojo), XContentType.JSON));

}

BulkResponse response = bulkRequestBuilder.execute().actionGet();

 

 

推荐阅读