spring-data-elasticsearch中DeleteByQuery实现差异及用法咨询

差异存在的原因 #

Spring Data Elasticsearch对这两个API的实现差异，核心是操作复杂度不同：

• _update_by_query除了查询条件外，还需要处理脚本（Script）、脚本参数、冲突策略等额外配置项，逻辑相对复杂，所以专门设计了UpdateQuery类来封装这些参数，让API调用更清晰。
• _delete_by_query逻辑简单，仅需指定查询条件即可完成删除，不需要额外的配置参数，因此Spring Data没有单独建模类似DeleteQuery的对象，而是复用已有的查询对象（如NativeSearchQuery）来实现，避免冗余的类设计。

执行_delete_by_query的正确方式 #

有两种常用实现方式：

方式1：使用ElasticsearchRestTemplate的delete方法 #

直接传入查询条件和索引信息，底层会自动调用_delete_by_query API：

// 构建查询条件
final BoolQueryBuilder boolQuery = QueryBuilders.boolQuery()
    .filter(QueryBuilders.rangeQuery(STATUS_SEARCH_FIELD).lt(EsMessage.STATUS));
final NativeSearchQuery nsq = new NativeSearchQuery(boolQuery);

// 执行删除
final ByQueryResponse response = esRestTemplate.delete(nsq, IndexCoordinates.of(INDEX_ALIAS));

方式2：直接使用RestHighLevelClient构造DeleteByQueryRequest #

如果需要更精细的控制（比如设置批量大小、超时时间等），可以直接操作底层客户端：

// 构建DeleteByQueryRequest
DeleteByQueryRequest request = new DeleteByQueryRequest(INDEX_ALIAS);
request.setQuery(QueryBuilders.boolQuery()
    .filter(QueryBuilders.rangeQuery(STATUS_SEARCH_FIELD).lt(EsMessage.STATUS)));
// 可选：设置额外参数
request.setBatchSize(1000);
request.setTimeout(TimeValue.timeValueMinutes(2));

// 执行请求
BulkByScrollResponse response = restHighLevelClient.deleteByQuery(request, RequestOptions.DEFAULT);
// 转换为Spring Data的ByQueryResponse（可选）
ByQueryResponse byQueryResponse = ByQueryResponse.from(response);

是否存在操作失误或预期外情况 #

你没有操作失误，这种差异是Spring Data Elasticsearch的设计选择，并非预期外情况。框架根据两个API的复杂度差异，采用了不同的封装方式：复杂操作单独建模，简单操作复用现有组件，既保证API的易用性，又避免不必要的类膨胀。

内容的提问来源于stack exchange，提问作者Rafael