package com.demo;
import co.elastic.clients.elasticsearch._types.query_dsl.IdsQuery;
import co.elastic.clients.elasticsearch._types.query_dsl.QueryBuilders;
import jakarta.annotation.Resource;
import lombok.Data;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.client.elc.ElasticsearchTemplate;
import org.springframework.data.elasticsearch.client.elc.NativeQuery;
import org.springframework.data.elasticsearch.core.query.ByQueryResponse;
import org.springframework.data.elasticsearch.core.query.UpdateQuery;
import org.springframework.util.Assert;

@SpringBootTest
public class UpdateServiceTest {
    
    @Resource
    private ElasticsearchTemplate template;
    @Test
    public void testUpdateByQuery() {
        final IdsQuery query = QueryBuilders.ids().values("1").build();
        final NativeQuery nativeQuery = NativeQuery.builder().withQuery(query._toQuery()).withFields("id", "name").build();
        final UpdateQuery updateQuery = UpdateQuery.builder(nativeQuery).build();
        final ByQueryResponse byQueryResponse = template.updateByQuery(updateQuery, template.getIndexCoordinatesFor(Model.class));
        Assert.isTrue(byQueryResponse.getUpdated() > 0,"updated value is zero");
    }
    
    @Data
    @Document(indexName = "doc_model")
    public static class Model {
        
        @Id
        private String id;
        
        private String name;
    }
}

I found that the updated value was not set in method byQueryResponse

ResponseConverter not set updated value #3108

Description

Metadata

Metadata

Assignees

Labels

Type

Fields

Projects

Milestone

Relationships

Development

Issue actions