本文整理了Java中org.springframework.data.redis.core.HashOperations
类的一些代码示例,展示了HashOperations
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HashOperations
类的具体详情如下:
包路径:org.springframework.data.redis.core.HashOperations
类名称:HashOperations
[英]Redis map specific operations working on a hash.
[中]Redis映射特定于哈希的操作。
代码示例来源:origin: yu199195/Raincat
@Override
public Boolean addTxTransaction(final String txGroupId, final TxTransactionItem txTransactionItem) {
try {
redisTemplate.opsForHash().put(cacheKey(txGroupId), txTransactionItem.getTaskKey(), txTransactionItem);
} catch (Exception e) {
return false;
}
return true;
}
代码示例来源:origin: yu199195/Raincat
@Override
public int findTxTransactionGroupStatus(final String txGroupId) {
try {
final TxTransactionItem item = (TxTransactionItem)
redisTemplate.opsForHash().get(cacheKey(txGroupId), txGroupId);
return item.getStatus();
} catch (BeansException e) {
e.printStackTrace();
return TransactionStatusEnum.ROLLBACK.getCode();
}
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Long delete(Object... keys) {
return ops.delete(getKey(), keys);
}
代码示例来源:origin: yu199195/Raincat
@Override
public void updateTxTransactionItemStatus(final String key, final String hashKey,
final int status, final Object message) {
try {
final TxTransactionItem item = (TxTransactionItem)
redisTemplate.opsForHash().get(cacheKey(key), hashKey);
item.setStatus(status);
if (Objects.nonNull(message)) {
item.setMessage(message);
}
//计算耗时
final String createDate = item.getCreateDate();
final LocalDateTime now = LocalDateTime.now();
try {
final LocalDateTime createDateTime = DateUtils.parseLocalDateTime(createDate);
final long consumeTime = DateUtils.getSecondsBetween(createDateTime, now);
item.setConsumeTime(consumeTime);
} catch (ParseException e) {
e.printStackTrace();
}
redisTemplate.opsForHash().put(cacheKey(key), item.getTaskKey(), item);
} catch (BeansException e) {
e.printStackTrace();
}
}
代码示例来源: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: com.alibaba/tac-engine
@Override
public Boolean removeMsInst(Long instId) {
String key = String.valueOf(instId);
TacInst tacInst = hashOperations.get(getMainKey(), key);
if (tacInst != null) {
hashOperations.delete(getMainKey() + tacInst.getMsCode(), key);
}
hashOperations.delete(getMainKey(), key);
return true;
}
代码示例来源:origin: zhangxd1989/springboot-dubbox
/**
* 根据key值删除
*
* @param key the key
* @param hashKeys the hash keys
*/
public void delHashValues(String key, Object... hashKeys) {
LOGGER.info("[redisTemplate redis] delHashValues() key={}", key);
opsForHash().delete(key, hashKeys);
}
代码示例来源:origin: zhangxd1989/springboot-dubbox
/**
* 批量添加
*
* @param key the key
* @param map the map
*/
public void putHashValues(String key, Map<String, String> map) {
opsForHash().putAll(key, map);
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public void put(HK key, HV value) {
ops.put(getKey(), key, value);
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public HV get(Object key) {
return ops.get(getKey(), key);
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Map<HK, HV> entries() {
return ops.entries(getKey());
}
代码示例来源:origin: mrdear/JavaWEB
/**
* 查询全部用户
*/
public List<User> query(){
HashOperations<String, String, String> opsForHash = stringRedisTemplate.opsForHash();
List<String> usersJson = opsForHash.values(KEY_PREFIX);
List<User> users = new ArrayList<>(usersJson.size());
usersJson.forEach(x -> {
try {
users.add(objectMapper.readValue(x,User.class));
} catch (IOException e) {
logger.error("read user error id is {}",x);
}
});
return users;
}
}
代码示例来源:origin: xautlx/s2jh4net
@Override
public Collection getKeys() {
CAPTCHA_LOG.debug("Get captcha keys.");
return this.hashOperations.keys(CAPTCHA_SESSION_KEY);
}
代码示例来源:origin: rhettpang/Springboot-Shiro
/**
* 判断key和field下是否有值
*
* @param key 判断的key
* @param field 判断的field
*/
public Boolean hasKey(String key,String field) {
return hashOperations.hasKey(key,field);
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public void putAll(Map<? extends HK, ? extends HV> m) {
ops.putAll(getKey(), m);
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Set<HK> keys() {
return ops.keys(getKey());
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Boolean hasKey(Object key) {
return ops.hasKey(getKey(), key);
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public List<HV> values() {
return ops.values(getKey());
}
代码示例来源: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: ihaolin/antares
@Override
public Boolean unbindJob(Long jobId) {
String jobIdStr = jobId.toString();
String server = String.valueOf(redis.opsForHash().get(RedisKeys.JOB_SERVER_MAPPINGS, jobIdStr));
// remove the job from the server
String serverJobsKey = RedisKeys.keyOfServerJobs(server);
redis.opsForSet().remove(serverJobsKey, jobIdStr);
// remote the job server mapping
redis.opsForHash().delete(RedisKeys.JOB_SERVER_MAPPINGS, jobIdStr);
return Boolean.TRUE;
}
内容来源于网络,如有侵权,请联系作者删除!