Aerospike Spring数据附加到列表

Question

对于给定的id，这是我的主要密钥，如果已经存在id，我想将数据附加到列表类型，如果不是，则我要创建新列表。

这是我的Aerospike模式 -

Column1: columnname=id; columntype=Integer; columnconstraint=primarykey
Column2: columnname=mylist; columntype=List<String>

下面是我的pojo：

public class AeroSpikeModel {
    @Id
    private Integer id;
    private List<String> myList = new ArrayList<>();
   //getter and setter
}

这是我的dao：

@Component
public class MyDAO {
    @Autowired
    private AerospikeRepository<AeroSpikeModel, Integer> aerospikeRepository;
    public void save(List<AeroSpikeModel> model) {
        aerospikeRepository.save(model);
     }
    public AeroSpikeModel get(Integer id) {
        return aerospikeRepository.findOne(id);
    }
}

问题是每次我使用现有id插入时，它会覆盖列表，而不是附加到现有列表中。我如何实现同样的事情，因为Aerospike本来支持附加列表

Answer 1

@Document注释分类是将任何数据保存到存储中的通用实体，因此它不使用数据类型的特定操作。

如果您想直接与列表合作，则应暂时使用RAW Aerospike客户端API。这是一个可以在Java中完成的示例：https://github.com/aerospike/aerospike-client-java/blob/master/master/examples/src/com/com/aerospike/examples/operatelist.java#l53

使用spring-data-aerospike还有另一种解决方案，但它不会像直接使用列表附加操作那样有效，因为您需要首先检索数据，然后进行修改然后保存。

import lombok.Builder;
import lombok.Data;
import org.springframework.data.aerospike.mapping.Document;
    @Document
    @Data
    @Builder(toBuilder=true)
    public static class MyDocument {
        @Id
        public final long id;
        public final Set<String> items;
        public final String someString;
// Stores document version in this field. 
// In Aerospike terms it is referred to as generation. 
// Without this field CAS (compare-and-set) algorithm won't take place in spring-data
        @Version
        public long version;
    public static class MyDocumentBuilder {
        public MyDocumentBuilder addItem(String item) {
            this.items.add(item);
            return this;
        }
    }
}

import org.springframework.data.aerospike.repository.AerospikeRepository;
public interface MyDocumentRepository extends AerospikeRepository<MyDocument, Long> {
}

import lombok.RequiredArgsConstructor;
import org.springframework.dao.OptimisticLockingFailureException;
import org.springframework.retry.annotation.Retryable;
@RequiredArgsConstructor
public class MyDocumentService {
  private final MyDocumentRepository repo;
  // in case version of the document was modified on server -- 
  // we will need to retry our operation from the beginning
  @Retryable(OptimisticLockingFailureException.class)
  public boolean addToCollection(Long id, String itemToAdd) {
    return repo.findById(id)
                .map(found -> updateAndSave(found, itemToAdd))
                .orElse(false);
  }
  private boolean updateAndSave(MyDocument existing, String itemToAdd) {
    MyDocument updated = existing.toBuilder()
            .addItem(itemToAdd)
            .build();
    repo.save(updated);
  }
}

我已经添加了@Version字段和@Retryable，以防万一您在服务器上同时运行更新，您将不会丢失某些更新。该算法称为CAS(您可以在此处阅读有关此信息的更多信息：NOSQL中的CAS和如何使用？(