springredis：字段范围查询“大于”

我正在使用redis来存储一些数据，然后查询它并用最新的信息更新它。
举个例子：
我接收文件数据，其中包含文件的信息和该文件的物理存储位置。
一个机架有多个机架，每个机架可以有多个文件。
每个文件都有一个版本字段，当对文件执行操作时，它会得到更新（递增）。
我计划如何储存？
我需要根据“shelfid+rack id”进行查询——以获取所有文件。
我需要基于“shelfid+rack id+version>xx”进行查询——以获取所有版本高于指定版本的文件。
现在，在SpringDataRedis中可以获得属于一个架子和机架的所有文件。我创建了一个由2个id和基于这个键的后续查询组合而成的键。

private <T> void save(String id, T entity) {
    redisTemplate.opsForValue().set(id, entity);
  }

但是，如何查询版本字段？我将“version”字段保留为@indexed，但spring存储库查询不起作用。

@RedisHash("shelves")
public class ShelfEntity {

  @Indexed
  @Id
  private String id;

  @Indexed
  private String shelfId;

  @Indexed
  private String rackId;

  @Indexed
  private String fileId;

  @Indexed
  private Integer version;

  private String fileName;    

  // and other updatable fields
}

存储库方法：

List<ShefEntity> findAllByShelfIdAndRackIdAndVersionGreaterThan(String centerCd,
      String floorCd, int version);

上面给出了错误：
java.lang.illegalargumentexception:大于（1）：[isgreaterthan，greaterthan]不支持redis查询派生
问。如何基于大于的版本进行查询？
问。spring数据redis甚至可以吗？
问。如果可能的话，我应该如何建模数据（到什么样的数据结构中），以便进行这样的查询？
问。如果我们不使用spring，那么如何在redis中使用rediscli和数据结构呢？
可能是这样的：
<键，键，值>
<shelfid+rackid，版本，文件数据>
我不知道如何在redis中建模？
更新2：一个机架可以有n个机架。一个机架可以有n个文件。每个文件对象都有一个版本。此版本得到更新（o->1->2….）
我只想存储文件的最新版本。所以，如果我们有1个文件对象shelfid-1 rackid-1 fileid-1 version-0。。。。更新版本时。。。我们应该还有一个文件对象。版本-1
我尝试在散列数据结构中将密钥保留为shelfid+rackid的md5散列。但无法查询版本。
我也试过使用zset。
这样保存：

private void saveSet(List<ShelfEntity> shelfInfo) {
    for (ShelfEntity item : shelfInfo) {
      redisTemplate.opsForZSet()
          .add(item.getId(), item, item.getVersion());
    }
  }

所以，版本就是分数。
但问题是我们不能更新集合的项。因此，对于一个fileid，有多个版本。当我查询时，会得到重复的。
获取代码：

Set<ShelfEntity> objects = (Set<ShelfEntity>) (Object) redisTemplate.opsForZSet()
        .rangeByScore(generateMd5Hash("-", shelfId, rackId), startVersion,
            Double.MAX_VALUE);

现在，这是一个模拟版本>xx的尝试

为每个创建zset shelfId 以及 rackId 结合
使用两种方法在redis中保存和更新记录

// this methods stores all shelf info in db
public void save(List<ShelfEntity> shelfInfo) {
    for (ShelfEntity item : shelfInfo) {
      redisTemplate.opsForZSet()
          .add(item.getId(), clonedItem, item.getVersion());
    }
}

使用update删除旧记录并插入新记录，redis不支持键更新，因为它是一个表，所以需要删除现有记录并添加新记录

public void update(List<ShelfEntity> oldRecords, List<ShelfEntity> newRecords) {
    if (oldRecords.size() != newRecords.size()){
       throw new IlleagalArgumentException("old and new records must have same number of entries");
    }
    for (int i=0;i<oldRecords.size();i++) {
      ShelfEntity oldItem = oldRecords.get(i);
      ShelfEntity newItem = newRecords.get(i);
      redisTemplate.opsForZSet().remove(oldItem.getId(), oldItem); 
      redisTemplate.opsForZSet()
          .add(newItem.getId(), newItem, newItem.getVersion());
    }
}

从zset中读取带有分数的项目。

List<ShefEntity> findAllByShelfIdAndRackIdAndVersionGreaterThan(String shelfId,
      String rackId, int version){
    Set<TypedTuple<ShelfEntity>> objects = (Set<TypedTuple<ShelfEntity>>)  redisTemplate.opsForZSet()
        .rangeWithScores(generateMd5Hash("-", shelfId, rackId), new Double(version),
            Double.MAX_VALUE);

    List<ShelfEntity> shelfEntities = new ArrayList<>();
    for (TypedTuple<ShelfEntity> entry:  objects) {
      shelfEntities.add(entry.getValue().setVersion( entry.getScore().intValue()));
    }
    return shelfEntities;
  }

springredis：字段范围查询“大于”

1条答案

相关问题

热门标签

最新问答