org.springframework.data.redis.core.HashOperations.entries()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(5.9k)|赞(0)|评价(0)|浏览(354)

本文整理了Java中org.springframework.data.redis.core.HashOperations.entries()方法的一些代码示例,展示了HashOperations.entries()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HashOperations.entries()方法的具体详情如下:
包路径:org.springframework.data.redis.core.HashOperations
类名称:HashOperations
方法名:entries

HashOperations.entries介绍

[英]Get entire hash stored at key.
[中]将整个散列存储在密钥处。

代码示例

代码示例来源:origin: spring-projects/spring-data-redis

@Override
public Map<HK, HV> entries() {
  return ops.entries(getKey());
}

代码示例来源:origin: yu199195/Raincat

@Override
public List<TxTransactionItem> listByTxGroupId(final String txGroupId) {
  final Map<Object, TxTransactionItem> entries =
      redisTemplate.opsForHash().entries(cacheKey(txGroupId));
  final Collection<TxTransactionItem> values = entries.values();
  return new ArrayList<>(values);
}

代码示例来源:origin: yu199195/Raincat

@Override
public void removeCommitTxGroup() {
  final Set<String> keys = redisTemplate.keys(Constant.REDIS_KEYS);
  keys.parallelStream().forEach(key -> {
    final Map<Object, TxTransactionItem> entries = redisTemplate.opsForHash().entries(key);
    final Collection<TxTransactionItem> values = entries.values();
    final boolean present = values.stream()
        .anyMatch(item -> item.getStatus() != TransactionStatusEnum.COMMIT.getCode());
    if (!present) {
      redisTemplate.delete(key);
    }
  });
}

代码示例来源:origin: yu199195/Raincat

@Override
public void removeRollBackTxGroup() {
  final Set<String> keys = redisTemplate.keys(Constant.REDIS_KEYS);
  keys.parallelStream().forEach(key -> {
    final Map<Object, TxTransactionItem> entries = redisTemplate.opsForHash().entries(key);
    final Collection<TxTransactionItem> values = entries.values();
    final Optional<TxTransactionItem> any =
        values.stream().filter(item -> item.getRole() == TransactionRoleEnum.START.getCode()
            && item.getStatus() == TransactionStatusEnum.ROLLBACK.getCode())
            .findAny();
    if (any.isPresent()) {
      redisTemplate.delete(key);
    }
  });
}

代码示例来源:origin: yu199195/Raincat

final List<TxTransactionGroupVO> groupVOS = rangeKeys.stream().map((String key) -> {
  final Map<Object, TxTransactionItem> entries = redisTemplate.opsForHash()
      .entries(String.format(CommonConstant.REDIS_PRE_FIX, key));
  final Collection<TxTransactionItem> values = entries.values();
  TxTransactionGroupVO groupVO = new TxTransactionGroupVO();

代码示例来源:origin: zhangxd1989/springboot-dubbox

/**
 * key只匹配map
 *
 * @param key the key
 * @return the hash value
 */
public Map<String, String> getHashValue(String key) {
  LOGGER.info("[redisTemplate redis]  getHashValue()  key={}", key);
  return opsForHash().entries(key);
}

代码示例来源:origin: leechenxiang/imooc-springboot-starter

/**
 * 实现命令:HGETALL key,返回哈希表 key中,所有的域和值。
 * 
 * @param key
 * @return
 */
public Map<Object, Object> hgetall(String key) {
  return redisTemplate.opsForHash().entries(key);
}

代码示例来源:origin: whvcse/EasyWeb

/**
 * 获取所有给定字段的值
 *
 * @param key
 * @return
 */
public Map<Object, Object> hGetAll(String key) {
  return redisTemplate.opsForHash().entries(key);
}

代码示例来源:origin: souyunku/SpringBootExamples

/**
 * 根据key获取所以值
 *
 * @param key
 * @return
 */
public static Map<Object, Object> hgetAll(String key) {
  return cacheUtils.redisTemplate.opsForHash().entries(key);
}

代码示例来源:origin: liuht777/Taroco

/**
 * key只匹配map
 *
 * @param key the key
 * @return the hash value
 */
public Map<String, String> getHashValue(String key) {
  log.debug("[redisTemplate redis]  getHashValue()  key={}", key);
  return opsForHash().entries(key);
}

代码示例来源:origin: com.ecfront.dew/cluster-spi-redis

@Override
public Map<String, String> hgetAll(String key) {
  return redisTemplate.opsForHash().entries(key)
      .entrySet().stream().collect(
          Collectors.toMap(i -> (String) (i.getKey()), i -> (String)(i.getValue())));
}

代码示例来源:origin: gudaoxuri/dew

@Override
public Map<String, String> hgetAll(String key) {
  return redisTemplate.opsForHash().entries(key)
      .entrySet().stream().collect(
          Collectors.toMap(i -> (String) (i.getKey()), i -> (String) (i.getValue())));
}

代码示例来源:origin: tumao2/hdw-dubbo

@Override
public Map<String, Object> mget(String key) {
  Map<Object, Object> resultMap = redisTemplate.opsForHash().entries(key);
  Map<String, Object> map = new HashMap<String, Object>();
  for (Object obj : resultMap.keySet()) {
    map.put(obj.toString(), resultMap.get(obj));
  }
  return map;
}

代码示例来源:origin: RAOE/show-videos

/**
 * 实现命令:HGETALL key,返回哈希表 key中,所有的域和值。
 * 
 * @param key
 * @return
 */
public Map<Object, Object> hgetall(String key) {
  return redisTemplate.opsForHash().entries(key);
}

代码示例来源:origin: wangxinforme/sc

/**
 * 根据Hash表的key获取对应的所有对象(可用于获取多个对象)
 * 
 * @param key Hash表的key
 * @return Map<String, T> Hash表的key对应的所有对象Map
 */
@Override
public <T> Map<String, T> hgetAll(String key) {
  HashOperations<String, String, T> hashOperations = redisTemplate.opsForHash();
  return hashOperations.entries(key);
}

代码示例来源:origin: okhelperTeam/okhelper-service

/**
 * 实现命令:HGETALL key,返回哈希表 key中,所有的域和值。
 *
 * @param key
 * @return
 */
public Map<Object, Object> hgetall(String key) {
  return redisTemplate.opsForHash().entries(key);
}

代码示例来源:origin: com.ecfront.dew/cluster-spi-redis

@Override
public Map<String, M> getAll() {
  Map<Object, Object> map = redisTemplate.opsForHash().entries(mapKey);
  if (map != null) {
    return map.entrySet().stream().collect(Collectors.toMap(i -> (String) (i.getKey()), i -> $.json.toObject(i.getValue(), clazz)));
  } else {
    return null;
  }
}

代码示例来源:origin: gudaoxuri/dew

@Override
public Map<String, M> getAll() {
  Map<Object, Object> map = redisTemplate.opsForHash().entries(mapKey);
  if (map != null) {
    return map.entrySet().stream().collect(Collectors.toMap(i -> (String) (i.getKey()), i -> $.json.toObject(i.getValue(), clazz)));
  } else {
    return null;
  }
}

代码示例来源:origin: ihaolin/antares

@Override
public T findById(Long id) {
  String objKey = objectKey(id);
  Map objectMap = redis.opsForHash().entries(objKey);
  if (objectMap == null || objectMap.isEmpty()){
    return null;
  }
  return (T)Maps.fromMap(objectMap, genericClazz);
}

代码示例来源:origin: ihaolin/diablo

@Override
public T findById(Long id) {
  String objKey = objectKey(id);
  Map objectMap = redis.opsForHash().entries(objKey);
  if (objectMap == null || objectMap.isEmpty()){
    return null;
  }
  return (T)Maps.fromMap(objectMap, genericClazz);
}

相关文章