JAVA操作ES增删API


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();

 

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM