在Spring Data for ElasticSearch中，乐观锁机制不起作用。

huangapple
未分类评论53阅读模式
英文:

Optimistic lock in Spring data for ElasticSearch doesn't work

问题

Spring Data for ElasticSearch 是否支持通过 @Version 进行文档版本控制？
看起来不支持。如果不支持，如何正确实现？

示例：

ElasticSearchConfig：

  1. @Configuration
  2. public class ElasticSearchConfig extends AbstractElasticsearchConfiguration {
  4.     @Override
  5.     public RestHighLevelClient elasticsearchClient() {
  6.         String host = "localhost"; int port = 9200;
  7.         try {
  8.             System.out.println("ElasticSearch host: " + host + ", port: " + port);
  9.             ClientConfiguration clientConfiguration = ClientConfiguration.builder()
  10.                     .connectedTo(host + ":" + port)
  11.                     .build();
  12.             return RestClients.create(clientConfiguration).rest();
  13.         } catch (Exception e) {
  14.             throw new RuntimeException(e);
  15.         }
  16.     }
  17. }

实体：

  1. @Document(indexName = Ent.INDEX_ENTITY, type = "_doc")
  2. public class Ent {
  3.     public static final String INDEX_ENTITY = "entity";
  4.     @Id
  5.     public String id;
  6.     public String data;
  7.     public Ent(String data) {
  8.         this.data = data;
  9.     }
  10.     @JsonIgnore
  11.     public long version;
  12.     public Ent setData(String arg) {
  13.         this.data = arg;
  14.         return this;
  15.     }
  16. }

测试应用：

  1. @SpringBootApplication
  2. public class App {
  4.     @Autowired
  5.     ObjectMapper objectMapper;
  6.     @Autowired
  7.     protected ElasticsearchOperations elasticsearchOperations;
  9.     public static void main(String[] args) {
  10.         SpringApplication.run(App.class, args);
  11.     }
  13.     @Autowired
  14.     EntRepository entRepository;
  16.     @PostConstruct
  17.     public void testUpdate() throws Exception {
  18.         Ent ent = entRepository.save(new Ent("some data"));
  19.         for (int i = 0; i < 3; i++) {
  20.             update(ent.setData("data-"+System.currentTimeMillis()));
  21.             System.out.println("version = " + ent.version);
  22.         }
  23.     }
  25.     public Ent update(Ent ent) throws JsonProcessingException {
  26.         UpdateQuery updateQuery = new UpdateQuery();
  27.         updateQuery.setIndexName(Ent.INDEX_ENTITY);
  28.         updateQuery.setId(ent.id);
  29.         updateQuery.setType("_doc");
  30.         updateQuery.setUpdateRequest(
  31.                 new UpdateRequest()
  32.                         .version(1)
  33.                         .versionType(VersionType.EXTERNAL_GTE) // doesn't affect actually...
  34.                         .doc(objectMapper.writeValueAsString(ent), XContentType.JSON)
  35.         );
  36.         UpdateResponse updateResponse = elasticsearchOperations.update(updateQuery);
  37.         ent.version = updateResponse.getVersion();
  38.         return ent;
  39.     }
  41. }

所以，我得到输出：

  1. version = 2
  2. version = 3
  3. version = 4

但是即使我设置了 new UpdateRequest().version(1)，它从未失败。
那么如何做到如果版本不如预期（或低于预期）则使其失败？

英文:

Does Spring Data for ElasticSearch support document versioning via @Version?
Seems no. If doesn't support, how to do it properly?

Example:

ElasticSearchConfig:

  1. @Configuration
  2. public class ElasticSearchConfig extends AbstractElasticsearchConfiguration {
  4.     @Override
  5.     public RestHighLevelClient elasticsearchClient() {
  6.         String host = &quot;localhost&quot;; int port = 9200;
  7.         try {
  8.             System.out.println(&quot;ElasticSearch host: &quot; + host + &quot;, port: &quot; + port);
  9.             ClientConfiguration clientConfiguration = ClientConfiguration.builder()
  10.                     .connectedTo(host + &quot;:&quot; + port)
  11.                     .build();
  12.             return  RestClients.create(clientConfiguration).rest();
  13.         } catch (Exception e) {
  14.             throw new RuntimeException(e);
  15.         }
  16.     }
  17. }

Entity:

  1. @Document(indexName = Ent.INDEX_ENTITY, type = &quot;_doc&quot;)
  2. public class Ent {
  3.     public static final String INDEX_ENTITY = &quot;entity&quot;;
  4.     @Id
  5.     public String id;
  6.     public String data;
  7.     public Ent(String data) {
  8.         this.data = data;
  9.     }
  10.     @JsonIgnore
  11.     public long version;
  12.     public Ent setData(String arg) {
  13.         this.data = arg;
  14.         return this;
  15.     }
  16. }

Test App:

  1. @SpringBootApplication
  2. public class App {
  4. @Autowired
  5. ObjectMapper objectMapper;
  6. @Autowired
  7. protected ElasticsearchOperations elasticsearchOperations;
  9. public static void main(String[] args) {
  10.     SpringApplication.run(App.class, args);
  11. }
  13. @Autowired
  14. EntRepository entRepository;
  16. @PostConstruct
  17. public void testUpdate() throws Exception {
  18.     Ent ent = entRepository.save(new Ent(&quot;some data&quot;));
  19.     for (int i = 0; i &lt; 3; i++) {
  20.         update(ent.setData(&quot;data-&quot;+System.currentTimeMillis()));
  21.         System.out.println(&quot;version = &quot; + ent.version);
  22.     }
  23. }
  25. public Ent update(Ent ent) throws JsonProcessingException {
  26.     UpdateQuery updateQuery = new UpdateQuery();
  27.     updateQuery.setIndexName(Ent.INDEX_ENTITY);
  28.     updateQuery.setId(ent.id);
  29.     updateQuery.setType(&quot;_doc&quot;);
  30.     updateQuery.setUpdateRequest(
  31.             new UpdateRequest()
  32.                     .version(1)
  33.                     .versionType(VersionType.EXTERNAL_GTE) // doesn&#39;t affect actually...
  34.                     .doc(objectMapper.writeValueAsString(ent), XContentType.JSON)
  35.     );
  36.     UpdateResponse updateResponse = elasticsearchOperations.update(updateQuery);
  37.     ent.version = updateResponse.getVersion();
  38.     return ent;
  39. }
  41. }

so, i'm getting output:

  1. version = 2
  2. version = 3
  3. version = 4

but it never fails although I set
new UpdateRequest().version(1)

So how to do so that it fails if version is not as expected (or lower than expected) ?

huangapple
  • 本文由 发表于 2020年4月7日 18:06:07
  • 转载请务必保留本文链接：https://java.coder-hub.com/61077507.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定