springboot ES 根据某个字段批量修改多个字段数据

在Spring Boot中，可以使用Elasticsearch的Java API来根据某个字段批量修改多个字段的数据。下面是一个示例代码：

import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.reindex.BulkByScrollResponse;
import org.elasticsearch.index.reindex.DeleteByQueryRequest;
import org.elasticsearch.index.reindex.UpdateByQueryRequest;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class ElasticsearchService {

    @Autowired
    private RestHighLevelClient elasticsearchClient;

    public void updateDocumentsByField(String indexName, String fieldName, String fieldValue, String[] updateFields, String[] updateValues) {
        try {
            BulkRequest bulkRequest = new BulkRequest();
            UpdateByQueryRequest updateRequest = new UpdateByQueryRequest(indexName);
            updateRequest.setQuery(QueryBuilders.termQuery(fieldName, fieldValue));

            for (int i = 0; i < updateFields.length; i++) {
                String field = updateFields[i];
                String value = updateValues[i];

                XContentBuilder builder = XContentFactory.jsonBuilder();
                builder.startObject();
                builder.field(field, value);
                builder.endObject();

                UpdateRequest update = new UpdateRequest().doc(builder);
                bulkRequest.add(update);
            }

            updateRequest.setScript(null);
            bulkRequest.source(updateRequest);

            BulkResponse bulkResponse = elasticsearchClient.bulk(bulkRequest, RequestOptions.DEFAULT);
            if (bulkResponse.hasFailures()) {
                // 处理错误
            }

        } catch (Exception e) {
            // 处理异常
        }
    }
}

在上面的代码中，updateDocumentsByField方法接收了以下参数：

• indexName：索引名称
• fieldName：要匹配的字段名
• fieldValue：要匹配的字段值
• updateFields：要更新的字段名数组
• updateValues：要更新的字段值数组

首先，创建一个BulkRequest对象用于批量操作，然后创建一个UpdateByQueryRequest对象并设置查询条件，使用QueryBuilders.termQuery方法创建一个精确匹配的查询条件。

然后，使用XContentFactory.jsonBuilder创建一个XContentBuilder对象，设置更新的字段和值。将XContentBuilder对象传递给UpdateRequest，然后将UpdateRequest对象添加到BulkRequest中。

最后，通过elasticsearchClient.bulk方法执行批量操作，如果有错误发生，可以根据需要进行处理。