本文整理了Java中redis.clients.jedis.Transaction.zrangeByScore()
方法的一些代码示例,展示了Transaction.zrangeByScore()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Transaction.zrangeByScore()
方法的具体详情如下:
包路径:redis.clients.jedis.Transaction
类名称:Transaction
方法名:zrangeByScore
暂无
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Set<byte[]> zRangeByScore(byte[] key, String min, String max) {
Assert.notNull(key, "Key must not be null!");
try {
String keyStr = new String(key, StandardCharsets.UTF_8);
if (isPipelined()) {
pipeline(connection.newJedisResult(connection.getRequiredPipeline().zrangeByScore(keyStr, min, max)));
return null;
}
if (isQueueing()) {
transaction(connection.newJedisResult(connection.getRequiredTransaction().zrangeByScore(keyStr, min, max)));
return null;
}
return JedisConverters.stringSetToByteSet().convert(connection.getJedis().zrangeByScore(keyStr, min, max));
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Set<byte[]> zRangeByScore(byte[] key, String min, String max, long offset, long count) {
Assert.notNull(key, "Key must not be null!");
if (offset > Integer.MAX_VALUE || count > Integer.MAX_VALUE) {
throw new IllegalArgumentException(
"Offset and count must be less than Integer.MAX_VALUE for zRangeByScore in Jedis.");
}
try {
String keyStr = new String(key, StandardCharsets.UTF_8);
if (isPipelined()) {
pipeline(connection.newJedisResult(
connection.getRequiredPipeline().zrangeByScore(keyStr, min, max, (int) offset, (int) count)));
return null;
}
if (isQueueing()) {
transaction(connection.newJedisResult(
connection.getRequiredTransaction().zrangeByScore(keyStr, min, max, (int) offset, (int) count)));
return null;
}
return JedisConverters.stringSetToByteSet()
.convert(connection.getJedis().zrangeByScore(keyStr, min, max, (int) offset, (int) count));
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: spring-projects/spring-data-redis
if (limit != null) {
transaction(connection.newJedisResult(
connection.getRequiredTransaction().zrangeByScore(key, min, max, limit.getOffset(), limit.getCount())));
} else {
transaction(connection.newJedisResult(connection.getRequiredTransaction().zrangeByScore(key, min, max)));
代码示例来源:origin: mindwind/craft-atom
private void zrangebyscore_string(String key, String min, String max) {
t.zrangeByScore(key, min, max);
}
代码示例来源:origin: mindwind/craft-atom
private void zrangebyscore_offset_count(String key, double min, double max, int offset, int count) {
t.zrangeByScore(key, min, max, offset, count);
}
代码示例来源:origin: mindwind/craft-atom
private void zrangebyscore_offset_count_string(String key, String min, String max, int offset, int count) {
t.zrangeByScore(key, min, max, offset, count);
}
代码示例来源:origin: mindwind/craft-atom
private void zrangebyscore0(String key, double min, double max) {
t.zrangeByScore(key, min, max);
}
代码示例来源:origin: Impetus/Kundera
Response response = ((Transaction) connection).zrangeByScore(getHashKey(tableName, valueAsStr),
getDouble(valueAsStr), getDouble(valueAsStr));
代码示例来源:origin: Impetus/Kundera
.zrangeByScore(getHashKey(entityMetadata.getTableName(), column), minimum.get(column),
maximum.get(column));
if (resource != null && resource.isActive())
Response response = ((Transaction) connection).zrangeByScore(
getHashKey(entityMetadata.getTableName(), column), value, value);
代码示例来源:origin: Impetus/Kundera
Response response = ((Transaction) connection).zrangeByScore(getHashKey(tableName, columnName),
getDouble(valueAsStr), getDouble(valueAsStr));
代码示例来源:origin: Impetus/Kundera
if (resource != null && resource.isActive())
Response response = ((Transaction) connection).zrangeByScore(getHashKey(tableName, valueAsStr), score,
score);
代码示例来源:origin: Impetus/Kundera
if (resource != null && resource.isActive())
Response response = ((Transaction) connection).zrangeByScore(getHashKey(tableName, valueAsStr), score,
score);
代码示例来源:origin: org.springframework.data/spring-data-redis
@Override
public Set<byte[]> zRangeByScore(byte[] key, String min, String max, long offset, long count) {
Assert.notNull(key, "Key must not be null!");
if (offset > Integer.MAX_VALUE || count > Integer.MAX_VALUE) {
throw new IllegalArgumentException(
"Offset and count must be less than Integer.MAX_VALUE for zRangeByScore in Jedis.");
}
try {
String keyStr = new String(key, StandardCharsets.UTF_8);
if (isPipelined()) {
pipeline(connection.newJedisResult(
connection.getRequiredPipeline().zrangeByScore(keyStr, min, max, (int) offset, (int) count)));
return null;
}
if (isQueueing()) {
transaction(connection.newJedisResult(
connection.getRequiredTransaction().zrangeByScore(keyStr, min, max, (int) offset, (int) count)));
return null;
}
return JedisConverters.stringSetToByteSet()
.convert(connection.getJedis().zrangeByScore(keyStr, min, max, (int) offset, (int) count));
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: apache/servicemix-bundles
@Override
public Set<byte[]> zRangeByScore(byte[] key, String min, String max, long offset, long count) {
Assert.notNull(key, "Key must not be null!");
if (offset > Integer.MAX_VALUE || count > Integer.MAX_VALUE) {
throw new IllegalArgumentException(
"Offset and count must be less than Integer.MAX_VALUE for zRangeByScore in Jedis.");
}
try {
String keyStr = new String(key, StandardCharsets.UTF_8);
if (isPipelined()) {
pipeline(connection.newJedisResult(
connection.getRequiredPipeline().zrangeByScore(keyStr, min, max, (int) offset, (int) count)));
return null;
}
if (isQueueing()) {
transaction(connection.newJedisResult(
connection.getRequiredTransaction().zrangeByScore(keyStr, min, max, (int) offset, (int) count)));
return null;
}
return JedisConverters.stringSetToByteSet()
.convert(connection.getJedis().zrangeByScore(keyStr, min, max, (int) offset, (int) count));
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: org.springframework.data/spring-data-redis
@Override
public Set<byte[]> zRangeByScore(byte[] key, String min, String max) {
Assert.notNull(key, "Key must not be null!");
try {
String keyStr = new String(key, StandardCharsets.UTF_8);
if (isPipelined()) {
pipeline(connection.newJedisResult(connection.getRequiredPipeline().zrangeByScore(keyStr, min, max)));
return null;
}
if (isQueueing()) {
transaction(connection.newJedisResult(connection.getRequiredTransaction().zrangeByScore(keyStr, min, max)));
return null;
}
return JedisConverters.stringSetToByteSet().convert(connection.getJedis().zrangeByScore(keyStr, min, max));
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: apache/servicemix-bundles
@Override
public Set<byte[]> zRangeByScore(byte[] key, String min, String max) {
Assert.notNull(key, "Key must not be null!");
try {
String keyStr = new String(key, StandardCharsets.UTF_8);
if (isPipelined()) {
pipeline(connection.newJedisResult(connection.getRequiredPipeline().zrangeByScore(keyStr, min, max)));
return null;
}
if (isQueueing()) {
transaction(connection.newJedisResult(connection.getRequiredTransaction().zrangeByScore(keyStr, min, max)));
return null;
}
return JedisConverters.stringSetToByteSet().convert(connection.getJedis().zrangeByScore(keyStr, min, max));
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: com.impetus.client/kundera-redis
Response response = ((Transaction) connection).zrangeByScore(getHashKey(tableName, valueAsStr),
getDouble(valueAsStr), getDouble(valueAsStr));
((Transaction) connection).exec();
代码示例来源:origin: com.impetus.client/kundera-redis
Response response = ((Transaction) connection).zrangeByScore(getHashKey(tableName, columnName),
getDouble(valueAsStr), getDouble(valueAsStr));
((Transaction) connection).exec();
代码示例来源:origin: org.springframework.data/spring-data-redis
if (limit != null) {
transaction(connection.newJedisResult(
connection.getRequiredTransaction().zrangeByScore(key, min, max, limit.getOffset(), limit.getCount())));
} else {
transaction(connection.newJedisResult(connection.getRequiredTransaction().zrangeByScore(key, min, max)));
代码示例来源:origin: apache/servicemix-bundles
if (limit != null) {
transaction(connection.newJedisResult(
connection.getRequiredTransaction().zrangeByScore(key, min, max, limit.getOffset(), limit.getCount())));
} else {
transaction(connection.newJedisResult(connection.getRequiredTransaction().zrangeByScore(key, min, max)));
内容来源于网络,如有侵权,请联系作者删除!