|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.springframework.data.redis.connection.jedis.JedisConnection
public class JedisConnection
RedisConnection
implementation on top of Jedis library.
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.RedisStringCommands |
---|
RedisStringCommands.BitOperation |
Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.RedisListCommands |
---|
RedisListCommands.Position |
Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.RedisZSetCommands |
---|
RedisZSetCommands.Aggregate, RedisZSetCommands.Tuple |
Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.RedisServerCommands |
---|
RedisServerCommands.ShutdownOption |
Constructor Summary | |
---|---|
JedisConnection(redis.clients.jedis.Jedis jedis)
Constructs a new JedisConnection instance. |
|
JedisConnection(redis.clients.jedis.Jedis jedis,
redis.clients.util.Pool<redis.clients.jedis.Jedis> pool,
int dbIndex)
Constructs a new JedisConnection instance backed by a jedis pool. |
Method Summary | ||
---|---|---|
Long |
append(byte[] key,
byte[] value)
Append a value to key . |
|
void |
bgReWriteAof()
Start an Append Only File rewrite process on server. |
|
void |
bgSave()
Start background saving of db on server. |
|
void |
bgWriteAof()
Deprecated. As of 1.3, use bgReWriteAof() . |
|
Long |
bitCount(byte[] key)
Count the number of set bits (population counting) in value stored at key . |
|
Long |
bitCount(byte[] key,
long begin,
long end)
Count the number of set bits (population counting) of value stored at key between begin and
end . |
|
Long |
bitOp(RedisStringCommands.BitOperation op,
byte[] destination,
byte[]... keys)
Perform bitwise operations between strings. |
|
List<byte[]> |
bLPop(int timeout,
byte[]... keys)
Removes and returns first element from lists stored at keys (see: RedisListCommands.lPop(byte[]) ). |
|
List<byte[]> |
bRPop(int timeout,
byte[]... keys)
Removes and returns last element from lists stored at keys (see: RedisListCommands.rPop(byte[]) ). |
|
byte[] |
bRPopLPush(int timeout,
byte[] srcKey,
byte[] dstKey)
Remove the last element from list at srcKey , append it to dstKey and return its value (see
RedisListCommands.rPopLPush(byte[], byte[]) ). |
|
void |
close()
Closes (or quits) the connection. |
|
List<Object> |
closePipeline()
Executes the commands in the pipeline and returns their result. |
|
protected DataAccessException |
convertJedisAccessException(Exception ex)
|
|
Long |
dbSize()
Get the total number of available keys in currently selected database. |
|
Long |
decr(byte[] key)
Decrement value of key by 1. |
|
Long |
decrBy(byte[] key,
long value)
Increment value of key by value . |
|
Long |
del(byte[]... keys)
Delete given keys . |
|
void |
discard()
Discard all commands issued after RedisTxCommands.multi() . |
|
byte[] |
dump(byte[] key)
Retrieve serialized version of the value stored at key . |
|
byte[] |
echo(byte[] message)
Returns message via server roundtrip. |
|
|
eval(byte[] script,
ReturnType returnType,
int numKeys,
byte[]... keysAndArgs)
Evaluate given script . |
|
|
evalSha(String scriptSha1,
ReturnType returnType,
int numKeys,
byte[]... keysAndArgs)
Evaluate given scriptSha . |
|
List<Object> |
exec()
Executes all queued commands in a transaction started with RedisTxCommands.multi() . |
|
Object |
execute(String command,
byte[]... args)
'Native' or 'raw' execution of the given command along-side the given arguments. |
|
Boolean |
exists(byte[] key)
Determine if given key exists. |
|
Boolean |
expire(byte[] key,
long seconds)
Set time to live for given key in seconds. |
|
Boolean |
expireAt(byte[] key,
long unixTime)
Set the expiration for given key as a UNIX timestamp. |
|
void |
flushAll()
Delete all all keys from all databases. |
|
void |
flushDb()
Delete all keys of the currently selected database. |
|
byte[] |
get(byte[] key)
Get the value of key . |
|
Boolean |
getBit(byte[] key,
long offset)
Get the bit value at offset of value at key . |
|
List<RedisClientInfo> |
getClientList()
Request information and statistics about connected clients. |
|
String |
getClientName()
Returns the name of the current connection. |
|
List<String> |
getConfig(String param)
Load configuration parameters for given pattern from server. |
|
redis.clients.jedis.Jedis |
getNativeConnection()
Returns the native connection (the underlying library/driver object). |
|
byte[] |
getRange(byte[] key,
long start,
long end)
Get a substring of value of key between begin and end . |
|
byte[] |
getSet(byte[] key,
byte[] value)
Set value of key and return its old value. |
|
Subscription |
getSubscription()
Returns the current subscription for this connection or null if the connection is not subscribed. |
|
Long |
hDel(byte[] key,
byte[]... fields)
Delete given hash fields . |
|
Boolean |
hExists(byte[] key,
byte[] field)
Determine if given hash field exists. |
|
byte[] |
hGet(byte[] key,
byte[] field)
Get value for given field from hash at key . |
|
Map<byte[],byte[]> |
hGetAll(byte[] key)
Get entire hash stored at key . |
|
Double |
hIncrBy(byte[] key,
byte[] field,
double delta)
Increment value of a hash field by the given delta . |
|
Long |
hIncrBy(byte[] key,
byte[] field,
long delta)
Increment value of a hash field by the given delta . |
|
Set<byte[]> |
hKeys(byte[] key)
Get key set (fields) of hash at key . |
|
Long |
hLen(byte[] key)
Get size of hash at key . |
|
List<byte[]> |
hMGet(byte[] key,
byte[]... fields)
Get values for given fields from hash at key . |
|
void |
hMSet(byte[] key,
Map<byte[],byte[]> tuple)
Set multiple hash fields to multiple values using data provided in hashes |
|
Boolean |
hSet(byte[] key,
byte[] field,
byte[] value)
Set the value of a hash field . |
|
Boolean |
hSetNX(byte[] key,
byte[] field,
byte[] value)
Set the value of a hash field only if field does not exist. |
|
List<byte[]> |
hVals(byte[] key)
Get entry set (values) of hash at field . |
|
Long |
incr(byte[] key)
Increment value of key by 1. |
|
Double |
incrBy(byte[] key,
double value)
Increment value of key by value . |
|
Long |
incrBy(byte[] key,
long value)
Increment value of key by value . |
|
Properties |
info()
Load default server information like mempory cpu utilization replication |
|
Properties |
info(String section)
Load server information for given selection . |
|
boolean |
isClosed()
Indicates whether the underlying connection is closed or not. |
|
boolean |
isPipelined()
Indicates whether the connection is currently pipelined or not. |
|
boolean |
isQueueing()
Indicates whether the connection is in "queue"(or "MULTI") mode or not. |
|
boolean |
isSubscribed()
Indicates whether the current connection is subscribed (to at least one channel) or not. |
|
Set<byte[]> |
keys(byte[] pattern)
Find all keys matching the given pattern . |
|
void |
killClient(String host,
int port)
<<<<<<< HEAD Closes a given client connection identified by ip:port. |
|
Long |
lastSave()
Get time of last RedisServerCommands.bgSave() operation in seconds. |
|
byte[] |
lIndex(byte[] key,
long index)
Get element at index form list at key . |
|
Long |
lInsert(byte[] key,
RedisListCommands.Position where,
byte[] pivot,
byte[] value)
Insert value RedisListCommands.Position.BEFORE or RedisListCommands.Position.AFTER existing pivot for key . |
|
Long |
lLen(byte[] key)
Get the size of list stored at key . |
|
byte[] |
lPop(byte[] key)
Removes and returns first element in list stored at key . |
|
Long |
lPush(byte[] key,
byte[]... values)
Prepend values to key . |
|
Long |
lPushX(byte[] key,
byte[] value)
Prepend values to key only if the list exits. |
|
List<byte[]> |
lRange(byte[] key,
long start,
long end)
Get elements between begin and end from list at key . |
|
Long |
lRem(byte[] key,
long count,
byte[] value)
Removes the first count occurrences of value from the list stored at key . |
|
void |
lSet(byte[] key,
long index,
byte[] value)
Set the value list element at index . |
|
void |
lTrim(byte[] key,
long start,
long end)
Trim list at key to elements between begin and end . |
|
List<byte[]> |
mGet(byte[]... keys)
Get the values of all given keys . |
|
Boolean |
move(byte[] key,
int dbIndex)
Move given key to database with index . |
|
void |
mSet(Map<byte[],byte[]> tuples)
Set multiple keys to multiple values using key-value pairs provided in tuple . |
|
Boolean |
mSetNX(Map<byte[],byte[]> tuples)
Set multiple keys to multiple values using key-value pairs provided in tuple only if the provided key does
not exist. |
|
void |
multi()
Mark the start of a transaction block. |
|
void |
openPipeline()
Activates the pipeline mode for this connection. |
|
Boolean |
persist(byte[] key)
Remove the expiration from given key . |
|
Boolean |
pExpire(byte[] key,
long millis)
Set time to live for given key in milliseconds. |
|
Boolean |
pExpireAt(byte[] key,
long unixTimeInMillis)
Set the expiration for given key as a UNIX timestamp in milliseconds. |
|
String |
ping()
Test connection. |
|
void |
pSetEx(byte[] key,
long milliseconds,
byte[] value)
Set the value and expiration in milliseconds for key . |
|
void |
pSubscribe(MessageListener listener,
byte[]... patterns)
Subscribes the connection to all channels matching the given patterns. |
|
Long |
pTtl(byte[] key)
Get the time to live for key in milliseconds. |
|
Long |
publish(byte[] channel,
byte[] message)
Publishes the given message to the given channel. |
|
byte[] |
randomKey()
Return a random key from the keyspace. |
|
void |
rename(byte[] oldName,
byte[] newName)
Rename key oleName to newName . |
|
Boolean |
renameNX(byte[] oldName,
byte[] newName)
Rename key oleName to newName only if newName does not exist. |
|
void |
resetConfigStats()
Reset statistic counters on server. |
|
void |
restore(byte[] key,
long ttlInMillis,
byte[] serializedValue)
Create key using the serializedValue , previously obtained using RedisKeyCommands.dump(byte[]) . |
|
byte[] |
rPop(byte[] key)
Removes and returns last element in list stored at key . |
|
byte[] |
rPopLPush(byte[] srcKey,
byte[] dstKey)
Remove the last element from list at srcKey , append it to dstKey and return its value. |
|
Long |
rPush(byte[] key,
byte[]... values)
Append values to key . |
|
Long |
rPushX(byte[] key,
byte[] value)
Append values to key only if the list exists. |
|
Long |
sAdd(byte[] key,
byte[]... values)
Add given values to set at key . |
|
void |
save()
Synchronous save current db snapshot on server. |
|
Long |
sCard(byte[] key)
Get size of set at key . |
|
List<Boolean> |
scriptExists(String... scriptSha1)
Check if given scriptShas exist in script cache. |
|
void |
scriptFlush()
Flush lua script cache. |
|
void |
scriptKill()
Kill current lua script execution. |
|
String |
scriptLoad(byte[] script)
Load lua script into scripts cache, without executing it. |
|
Set<byte[]> |
sDiff(byte[]... keys)
Diff all sets for given keys . |
|
Long |
sDiffStore(byte[] destKey,
byte[]... keys)
Diff all sets for given keys and store result in destKey |
|
void |
select(int dbIndex)
Select the DB with given positive dbIndex . |
|
void |
set(byte[] key,
byte[] value)
Set value for key . |
|
Boolean |
setBit(byte[] key,
long offset,
boolean value)
Sets the bit at offset in value stored at key . |
|
void |
setClientName(byte[] name)
Assign given name to current connection. |
|
void |
setConfig(String param,
String value)
Set server configuration for key to value . |
|
void |
setConvertPipelineAndTxResults(boolean convertPipelineAndTxResults)
Specifies if pipelined results should be converted to the expected data type. |
|
void |
setEx(byte[] key,
long time,
byte[] value)
Set the value and expiration in seconds for key . |
|
Boolean |
setNX(byte[] key,
byte[] value)
Set value for key , only if key does not exist. |
|
void |
setRange(byte[] key,
byte[] value,
long start)
Overwrite parts of key starting at the specified offset with given value . |
|
void |
shutdown()
Shutdown server. |
|
void |
shutdown(RedisServerCommands.ShutdownOption option)
Shutdown server. |
|
Set<byte[]> |
sInter(byte[]... keys)
Returns the members intersecting all given sets at keys . |
|
Long |
sInterStore(byte[] destKey,
byte[]... keys)
Intersect all given sets at keys and store result in destKey . |
|
Boolean |
sIsMember(byte[] key,
byte[] value)
Check if set at key contains value . |
|
void |
slaveOf(String host,
int port)
Change redis replication setting to new master. |
|
void |
slaveOfNoOne()
Change server into master. |
|
Set<byte[]> |
sMembers(byte[] key)
Get all elements of set at key . |
|
Boolean |
sMove(byte[] srcKey,
byte[] destKey,
byte[] value)
Move value from srcKey to |
|
List<byte[]> |
sort(byte[] key,
SortParameters params)
Sort the elements for key . |
|
Long |
sort(byte[] key,
SortParameters params,
byte[] storeKey)
Sort the elements for key and store result in storeKey . |
|
byte[] |
sPop(byte[] key)
Remove and return a random member from set at key . |
|
byte[] |
sRandMember(byte[] key)
Get random element from set at key . |
|
List<byte[]> |
sRandMember(byte[] key,
long count)
Get count random elements from set at key . |
|
Long |
sRem(byte[] key,
byte[]... values)
Remove given values from set at key and return the number of removed elements. |
|
Long |
strLen(byte[] key)
Get the length of the value stored at key . |
|
void |
subscribe(MessageListener listener,
byte[]... channels)
Subscribes the connection to the given channels. |
|
Set<byte[]> |
sUnion(byte[]... keys)
Union all sets at given keys . |
|
Long |
sUnionStore(byte[] destKey,
byte[]... keys)
Union all sets at given keys and store result in destKey . |
|
Long |
time()
Request server timestamp using TIME command. |
|
Long |
ttl(byte[] key)
Get the time to live for key in seconds. |
|
DataType |
type(byte[] key)
Determine the type stored at key . |
|
void |
unwatch()
Flushes all the previously #watch(byte[]) keys. |
|
void |
watch(byte[]... keys)
Watch given keys for modifications during transaction started with RedisTxCommands.multi() . |
|
Boolean |
zAdd(byte[] key,
double score,
byte[] value)
Add value to a sorted set at key , or update its score if it already exists. |
|
Long |
zAdd(byte[] key,
Set<RedisZSetCommands.Tuple> tuples)
Add tuples to a sorted set at key , or update its score if it already exists. |
|
Long |
zCard(byte[] key)
Get the size of sorted set with key . |
|
Long |
zCount(byte[] key,
double min,
double max)
Count number of elements within sorted set with scores between min and max . |
|
Double |
zIncrBy(byte[] key,
double increment,
byte[] value)
Increment the score of element with value in sorted set by increment . |
|
Long |
zInterStore(byte[] destKey,
byte[]... sets)
Intersect sorted sets and store result in destination key . |
|
Long |
zInterStore(byte[] destKey,
RedisZSetCommands.Aggregate aggregate,
int[] weights,
byte[]... sets)
Intersect sorted sets and store result in destination key . |
|
Set<byte[]> |
zRange(byte[] key,
long start,
long end)
Get elements between begin and end from sorted set. |
|
Set<byte[]> |
zRangeByScore(byte[] key,
double min,
double max)
Get elements where score is between min and max from sorted set. |
|
Set<byte[]> |
zRangeByScore(byte[] key,
double min,
double max,
long offset,
long count)
Get elements in range from begin to end where score is between min and max from
sorted set. |
|
Set<RedisZSetCommands.Tuple> |
zRangeByScoreWithScores(byte[] key,
double min,
double max)
Get set of RedisZSetCommands.Tuple s where score is between min and max from sorted set. |
|
Set<RedisZSetCommands.Tuple> |
zRangeByScoreWithScores(byte[] key,
double min,
double max,
long offset,
long count)
Get set of RedisZSetCommands.Tuple s in range from begin to end where score is between min and
max from sorted set. |
|
Set<RedisZSetCommands.Tuple> |
zRangeWithScores(byte[] key,
long start,
long end)
Get set of RedisZSetCommands.Tuple s between begin and end from sorted set. |
|
Long |
zRank(byte[] key,
byte[] value)
Determine the index of element with value in a sorted set. |
|
Long |
zRem(byte[] key,
byte[]... values)
Remove values from sorted set. |
|
Long |
zRemRange(byte[] key,
long start,
long end)
Remove elements in range between begin and end from sorted set with key . |
|
Long |
zRemRangeByScore(byte[] key,
double min,
double max)
Remove elements with scores between min and max from sorted set with key . |
|
Set<byte[]> |
zRevRange(byte[] key,
long start,
long end)
Get elements in range from begin to end from sorted set ordered high -> low. |
|
Set<byte[]> |
zRevRangeByScore(byte[] key,
double min,
double max)
Get elements where score is between min and max from sorted set ordered high -> low. |
|
Set<byte[]> |
zRevRangeByScore(byte[] key,
double min,
double max,
long offset,
long count)
Get elements in range from begin to end where score is between min and max from
sorted set ordered high -> low. |
|
Set<RedisZSetCommands.Tuple> |
zRevRangeByScoreWithScores(byte[] key,
double min,
double max)
Get set of RedisZSetCommands.Tuple where score is between min and max from sorted set ordered high -> low. |
|
Set<RedisZSetCommands.Tuple> |
zRevRangeByScoreWithScores(byte[] key,
double min,
double max,
long offset,
long count)
Get set of RedisZSetCommands.Tuple in range from begin to end where score is between min and
max from sorted set ordered high -> low. |
|
Set<RedisZSetCommands.Tuple> |
zRevRangeWithScores(byte[] key,
long start,
long end)
Get set of RedisZSetCommands.Tuple s in range from begin to end from sorted set ordered high -> low. |
|
Long |
zRevRank(byte[] key,
byte[] value)
Determine the index of element with value in a sorted set when scored high to low. |
|
Double |
zScore(byte[] key,
byte[] value)
Get the score of element with value from sorted set with key key . |
|
Long |
zUnionStore(byte[] destKey,
byte[]... sets)
Union sorted sets and store result in destination key . |
|
Long |
zUnionStore(byte[] destKey,
RedisZSetCommands.Aggregate aggregate,
int[] weights,
byte[]... sets)
Union sorted sets and store result in destination key . |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JedisConnection(redis.clients.jedis.Jedis jedis)
JedisConnection
instance.
jedis
- Jedis entitypublic JedisConnection(redis.clients.jedis.Jedis jedis, redis.clients.util.Pool<redis.clients.jedis.Jedis> pool, int dbIndex)
JedisConnection
instance backed by a jedis pool.
jedis
- pool
- can be null, if no pool is usedMethod Detail |
---|
protected DataAccessException convertJedisAccessException(Exception ex)
public Object execute(String command, byte[]... args)
RedisCommands
execute
in interface RedisCommands
command
- Command to executeargs
- Possible command arguments (may be null)
public void close() throws DataAccessException
RedisConnection
close
in interface RedisConnection
DataAccessException
public redis.clients.jedis.Jedis getNativeConnection()
RedisConnection
getNativeConnection
in interface RedisConnection
public boolean isClosed()
RedisConnection
isClosed
in interface RedisConnection
public boolean isQueueing()
RedisConnection
isQueueing
in interface RedisConnection
public boolean isPipelined()
RedisConnection
isPipelined
in interface RedisConnection
RedisConnection.openPipeline()
,
RedisConnection.isQueueing()
public void openPipeline()
RedisConnection
RedisConnection.closePipeline()
. Calling this method when the connection is already pipelined has no effect.
Pipelining is used for issuing commands without requesting the response right away but rather at the end of the
batch. While somewhat similar to MULTI, pipelining does not guarantee atomicity - it only tries to improve
performance when issuing a lot of commands (such as in batching scenarios).
Note:
Consider doing some performance testing before using this feature since in many cases the performance benefits are minimal yet the impact on usage are not.
openPipeline
in interface RedisConnection
RedisTxCommands.multi()
public List<Object> closePipeline()
RedisConnection
closePipeline
in interface RedisConnection
public List<byte[]> sort(byte[] key, SortParameters params)
RedisKeyCommands
key
.
sort
in interface RedisKeyCommands
http://redis.io/commands/sort
public Long sort(byte[] key, SortParameters params, byte[] storeKey)
RedisKeyCommands
key
and store result in storeKey
.
sort
in interface RedisKeyCommands
http://redis.io/commands/sort
public Long dbSize()
RedisServerCommands
dbSize
in interface RedisServerCommands
http://redis.io/commands/dbsize
public void flushDb()
RedisServerCommands
flushDb
in interface RedisServerCommands
http://redis.io/commands/flushdb
public void flushAll()
RedisServerCommands
flushAll
in interface RedisServerCommands
http://redis.io/commands/flushall
public void bgSave()
RedisServerCommands
bgSave
in interface RedisServerCommands
http://redis.io/commands/bgsave
public void bgReWriteAof()
RedisServerCommands
bgReWriteAof
in interface RedisServerCommands
http://redis.io/commands/bgrewriteaof
@Deprecated public void bgWriteAof()
bgReWriteAof()
.
RedisServerCommands
bgWriteAof
in interface RedisServerCommands
http://redis.io/commands/bgrewriteaof
public void save()
RedisServerCommands
save
in interface RedisServerCommands
http://redis.io/commands/save
public List<String> getConfig(String param)
RedisServerCommands
pattern
from server.
getConfig
in interface RedisServerCommands
http://redis.io/commands/config-get
public Properties info()
RedisServerCommands
info
in interface RedisServerCommands
http://redis.io/commands/info
public Properties info(String section)
RedisServerCommands
selection
.
info
in interface RedisServerCommands
http://redis.io/commands/info
public Long lastSave()
RedisServerCommands
RedisServerCommands.bgSave()
operation in seconds.
lastSave
in interface RedisServerCommands
http://redis.io/commands/lastsave
public void setConfig(String param, String value)
RedisServerCommands
key
to value
.
setConfig
in interface RedisServerCommands
http://redis.io/commands/config-set
public void resetConfigStats()
RedisServerCommands
RedisServerCommands.info()
.
resetConfigStats
in interface RedisServerCommands
http://redis.io/commands/config-resetstat
public void shutdown()
RedisServerCommands
shutdown
in interface RedisServerCommands
http://redis.io/commands/shutdown
public void shutdown(RedisServerCommands.ShutdownOption option)
RedisServerCommands
shutdown
in interface RedisServerCommands
http://redis.io/commands/shutdown
public byte[] echo(byte[] message)
RedisConnectionCommands
message
via server roundtrip.
echo
in interface RedisConnectionCommands
http://redis.io/commands/echo
public String ping()
RedisConnectionCommands
ping
in interface RedisConnectionCommands
http://redis.io/commands/ping
public Long del(byte[]... keys)
RedisKeyCommands
keys
.
del
in interface RedisKeyCommands
http://redis.io/commands/del
public void discard()
RedisTxCommands
RedisTxCommands.multi()
.
discard
in interface RedisTxCommands
http://redis.io/commands/discard
public List<Object> exec()
RedisTxCommands
RedisTxCommands.multi()
. #watch(byte[])
the operation will fail if any of watched keys has been modified.
exec
in interface RedisTxCommands
http://redis.io/commands/exec
public Boolean exists(byte[] key)
RedisKeyCommands
key
exists.
exists
in interface RedisKeyCommands
http://redis.io/commands/exists
public Boolean expire(byte[] key, long seconds)
RedisKeyCommands
key
in seconds.
expire
in interface RedisKeyCommands
http://redis.io/commands/expire
public Boolean expireAt(byte[] key, long unixTime)
RedisKeyCommands
key
as a UNIX timestamp.
expireAt
in interface RedisKeyCommands
http://redis.io/commands/expireat
public Set<byte[]> keys(byte[] pattern)
RedisKeyCommands
pattern
.
keys
in interface RedisKeyCommands
http://redis.io/commands/keys
public void multi()
RedisTxCommands
RedisTxCommands.exec()
or rolled back using RedisTxCommands.discard()
.
multi
in interface RedisTxCommands
http://redis.io/commands/multi
public Boolean persist(byte[] key)
RedisKeyCommands
key
.
persist
in interface RedisKeyCommands
http://redis.io/commands/persist
public Boolean move(byte[] key, int dbIndex)
RedisKeyCommands
key
to database with index
.
move
in interface RedisKeyCommands
http://redis.io/commands/move
public byte[] randomKey()
RedisKeyCommands
randomKey
in interface RedisKeyCommands
http://redis.io/commands/randomkey
public void rename(byte[] oldName, byte[] newName)
RedisKeyCommands
oleName
to newName
.
rename
in interface RedisKeyCommands
http://redis.io/commands/rename
public Boolean renameNX(byte[] oldName, byte[] newName)
RedisKeyCommands
oleName
to newName
only if newName
does not exist.
renameNX
in interface RedisKeyCommands
http://redis.io/commands/renamenx
public void select(int dbIndex)
RedisConnectionCommands
dbIndex
.
select
in interface RedisConnectionCommands
http://redis.io/commands/select
public Long ttl(byte[] key)
RedisKeyCommands
key
in seconds.
ttl
in interface RedisKeyCommands
http://redis.io/commands/ttl
public Boolean pExpire(byte[] key, long millis)
RedisKeyCommands
key
in milliseconds.
pExpire
in interface RedisKeyCommands
http://redis.io/commands/pexpire
public Boolean pExpireAt(byte[] key, long unixTimeInMillis)
RedisKeyCommands
key
as a UNIX timestamp in milliseconds.
pExpireAt
in interface RedisKeyCommands
http://redis.io/commands/pexpireat
public Long pTtl(byte[] key)
RedisKeyCommands
key
in milliseconds.
pTtl
in interface RedisKeyCommands
http://redis.io/commands/pttl
public byte[] dump(byte[] key)
RedisKeyCommands
key
.
dump
in interface RedisKeyCommands
http://redis.io/commands/dump
public void restore(byte[] key, long ttlInMillis, byte[] serializedValue)
RedisKeyCommands
key
using the serializedValue
, previously obtained using RedisKeyCommands.dump(byte[])
.
restore
in interface RedisKeyCommands
http://redis.io/commands/restore
public DataType type(byte[] key)
RedisKeyCommands
key
.
type
in interface RedisKeyCommands
http://redis.io/commands/type
public void unwatch()
RedisTxCommands
#watch(byte[])
keys.
unwatch
in interface RedisTxCommands
http://redis.io/commands/unwatch
public void watch(byte[]... keys)
RedisTxCommands
keys
for modifications during transaction started with RedisTxCommands.multi()
.
watch
in interface RedisTxCommands
http://redis.io/commands/watch
public byte[] get(byte[] key)
RedisStringCommands
key
.
get
in interface RedisStringCommands
http://redis.io/commands/get
public void set(byte[] key, byte[] value)
RedisStringCommands
value
for key
.
set
in interface RedisStringCommands
http://redis.io/commands/set
public byte[] getSet(byte[] key, byte[] value)
RedisStringCommands
key
and return its old value.
getSet
in interface RedisStringCommands
http://redis.io/commands/getset
public Long append(byte[] key, byte[] value)
RedisStringCommands
value
to key
.
append
in interface RedisStringCommands
http://redis.io/commands/append
public List<byte[]> mGet(byte[]... keys)
RedisStringCommands
keys
.
mGet
in interface RedisStringCommands
http://redis.io/commands/mget
public void mSet(Map<byte[],byte[]> tuples)
RedisStringCommands
tuple
.
mSet
in interface RedisStringCommands
http://redis.io/commands/mset
public Boolean mSetNX(Map<byte[],byte[]> tuples)
RedisStringCommands
tuple
only if the provided key does
not exist.
mSetNX
in interface RedisStringCommands
http://redis.io/commands/msetnx
public void setEx(byte[] key, long time, byte[] value)
RedisStringCommands
value
and expiration in seconds
for key
.
setEx
in interface RedisStringCommands
http://redis.io/commands/setex
public void pSetEx(byte[] key, long milliseconds, byte[] value)
RedisStringCommands
value
and expiration in milliseconds
for key
.
pSetEx
in interface RedisStringCommands
http://redis.io/commands/psetex
public Boolean setNX(byte[] key, byte[] value)
RedisStringCommands
value
for key
, only if key
does not exist.
setNX
in interface RedisStringCommands
http://redis.io/commands/setnx
public byte[] getRange(byte[] key, long start, long end)
RedisStringCommands
key
between begin
and end
.
getRange
in interface RedisStringCommands
http://redis.io/commands/getrange
public Long decr(byte[] key)
RedisStringCommands
key
by 1.
decr
in interface RedisStringCommands
http://redis.io/commands/decr
public Long decrBy(byte[] key, long value)
RedisStringCommands
key
by value
.
decrBy
in interface RedisStringCommands
http://redis.io/commands/decrby
public Long incr(byte[] key)
RedisStringCommands
key
by 1.
incr
in interface RedisStringCommands
http://redis.io/commands/incr
public Long incrBy(byte[] key, long value)
RedisStringCommands
key
by value
.
incrBy
in interface RedisStringCommands
http://redis.io/commands/incrby
public Double incrBy(byte[] key, double value)
RedisStringCommands
key
by value
.
incrBy
in interface RedisStringCommands
http://redis.io/commands/incrbyfloat
public Boolean getBit(byte[] key, long offset)
RedisStringCommands
offset
of value at key
.
getBit
in interface RedisStringCommands
http://redis.io/commands/getbit
public Boolean setBit(byte[] key, long offset, boolean value)
RedisStringCommands
offset
in value stored at key
.
setBit
in interface RedisStringCommands
offset
.http://redis.io/commands/setbit
public void setRange(byte[] key, byte[] value, long start)
RedisStringCommands
key
starting at the specified offset
with given value
.
setRange
in interface RedisStringCommands
http://redis.io/commands/setrange
public Long strLen(byte[] key)
RedisStringCommands
key
.
strLen
in interface RedisStringCommands
http://redis.io/commands/strlen
public Long bitCount(byte[] key)
RedisStringCommands
key
.
bitCount
in interface RedisStringCommands
http://redis.io/commands/bitcount
public Long bitCount(byte[] key, long begin, long end)
RedisStringCommands
key
between begin
and
end
.
bitCount
in interface RedisStringCommands
http://redis.io/commands/bitcount
public Long bitOp(RedisStringCommands.BitOperation op, byte[] destination, byte[]... keys)
RedisStringCommands
bitOp
in interface RedisStringCommands
http://redis.io/commands/bitop
public Long lPush(byte[] key, byte[]... values)
RedisListCommands
values
to key
.
lPush
in interface RedisListCommands
http://redis.io/commands/lpush
public Long rPush(byte[] key, byte[]... values)
RedisListCommands
values
to key
.
rPush
in interface RedisListCommands
http://redis.io/commands/rpush
public List<byte[]> bLPop(int timeout, byte[]... keys)
RedisListCommands
keys
(see: RedisListCommands.lPop(byte[])
). timeout
reached.
bLPop
in interface RedisListCommands
http://redis.io/commands/blpop
public List<byte[]> bRPop(int timeout, byte[]... keys)
RedisListCommands
keys
(see: RedisListCommands.rPop(byte[])
). timeout
reached.
bRPop
in interface RedisListCommands
http://redis.io/commands/brpop
public byte[] lIndex(byte[] key, long index)
RedisListCommands
index
form list at key
.
lIndex
in interface RedisListCommands
http://redis.io/commands/lindex
public Long lInsert(byte[] key, RedisListCommands.Position where, byte[] pivot, byte[] value)
RedisListCommands
value
RedisListCommands.Position.BEFORE
or RedisListCommands.Position.AFTER
existing pivot
for key
.
lInsert
in interface RedisListCommands
http://redis.io/commands/linsert
public Long lLen(byte[] key)
RedisListCommands
key
.
lLen
in interface RedisListCommands
http://redis.io/commands/llen
public byte[] lPop(byte[] key)
RedisListCommands
key
.
lPop
in interface RedisListCommands
http://redis.io/commands/lpop
public List<byte[]> lRange(byte[] key, long start, long end)
RedisListCommands
begin
and end
from list at key
.
lRange
in interface RedisListCommands
http://redis.io/commands/lrange
public Long lRem(byte[] key, long count, byte[] value)
RedisListCommands
count
occurrences of value
from the list stored at key
.
lRem
in interface RedisListCommands
http://redis.io/commands/lrem
public void lSet(byte[] key, long index, byte[] value)
RedisListCommands
value
list element at index
.
lSet
in interface RedisListCommands
http://redis.io/commands/lset
public void lTrim(byte[] key, long start, long end)
RedisListCommands
key
to elements between begin
and end
.
lTrim
in interface RedisListCommands
http://redis.io/commands/ltrim
public byte[] rPop(byte[] key)
RedisListCommands
key
.
rPop
in interface RedisListCommands
http://redis.io/commands/rpop
public byte[] rPopLPush(byte[] srcKey, byte[] dstKey)
RedisListCommands
srcKey
, append it to dstKey
and return its value.
rPopLPush
in interface RedisListCommands
http://redis.io/commands/rpoplpush
public byte[] bRPopLPush(int timeout, byte[] srcKey, byte[] dstKey)
RedisListCommands
srcKey
, append it to dstKey
and return its value (see
RedisListCommands.rPopLPush(byte[], byte[])
). timeout
reached.
bRPopLPush
in interface RedisListCommands
http://redis.io/commands/brpoplpush
public Long lPushX(byte[] key, byte[] value)
RedisListCommands
values
to key
only if the list exits.
lPushX
in interface RedisListCommands
http://redis.io/commands/lpushx
public Long rPushX(byte[] key, byte[] value)
RedisListCommands
values to key
only if the list exists.
rPushX
in interface RedisListCommands
http://redis.io/commands/rpushx
public Long sAdd(byte[] key, byte[]... values)
RedisSetCommands
values
to set at key
.
sAdd
in interface RedisSetCommands
http://redis.io/commands/sadd
public Long sCard(byte[] key)
RedisSetCommands
key
.
sCard
in interface RedisSetCommands
http://redis.io/commands/scard
public Set<byte[]> sDiff(byte[]... keys)
RedisSetCommands
keys
.
sDiff
in interface RedisSetCommands
http://redis.io/commands/sdiff
public Long sDiffStore(byte[] destKey, byte[]... keys)
RedisSetCommands
keys
and store result in destKey
sDiffStore
in interface RedisSetCommands
http://redis.io/commands/sdiffstore
public Set<byte[]> sInter(byte[]... keys)
RedisSetCommands
keys
.
sInter
in interface RedisSetCommands
http://redis.io/commands/sinter
public Long sInterStore(byte[] destKey, byte[]... keys)
RedisSetCommands
keys
and store result in destKey
.
sInterStore
in interface RedisSetCommands
http://redis.io/commands/sinterstore
public Boolean sIsMember(byte[] key, byte[] value)
RedisSetCommands
key
contains value
.
sIsMember
in interface RedisSetCommands
http://redis.io/commands/sismember
public Set<byte[]> sMembers(byte[] key)
RedisSetCommands
key
.
sMembers
in interface RedisSetCommands
http://redis.io/commands/smembers
public Boolean sMove(byte[] srcKey, byte[] destKey, byte[] value)
RedisSetCommands
value
from srcKey
to
sMove
in interface RedisSetCommands
http://redis.io/commands/smove
public byte[] sPop(byte[] key)
RedisSetCommands
key
.
sPop
in interface RedisSetCommands
http://redis.io/commands/spop
public byte[] sRandMember(byte[] key)
RedisSetCommands
key
.
sRandMember
in interface RedisSetCommands
http://redis.io/commands/srandmember
public List<byte[]> sRandMember(byte[] key, long count)
RedisSetCommands
count
random elements from set at key
.
sRandMember
in interface RedisSetCommands
http://redis.io/commands/srandmember
public Long sRem(byte[] key, byte[]... values)
RedisSetCommands
values
from set at key
and return the number of removed elements.
sRem
in interface RedisSetCommands
http://redis.io/commands/srem
public Set<byte[]> sUnion(byte[]... keys)
RedisSetCommands
keys
.
sUnion
in interface RedisSetCommands
http://redis.io/commands/sunion
public Long sUnionStore(byte[] destKey, byte[]... keys)
RedisSetCommands
keys
and store result in destKey
.
sUnionStore
in interface RedisSetCommands
http://redis.io/commands/sunionstore
public Boolean zAdd(byte[] key, double score, byte[] value)
RedisZSetCommands
value
to a sorted set at key
, or update its score
if it already exists.
zAdd
in interface RedisZSetCommands
http://redis.io/commands/zadd
public Long zAdd(byte[] key, Set<RedisZSetCommands.Tuple> tuples)
RedisZSetCommands
tuples
to a sorted set at key
, or update its score
if it already exists.
zAdd
in interface RedisZSetCommands
http://redis.io/commands/zadd
public Long zCard(byte[] key)
RedisZSetCommands
key
.
zCard
in interface RedisZSetCommands
http://redis.io/commands/zcard
public Long zCount(byte[] key, double min, double max)
RedisZSetCommands
min
and max
.
zCount
in interface RedisZSetCommands
http://redis.io/commands/zcount
public Double zIncrBy(byte[] key, double increment, byte[] value)
RedisZSetCommands
value
in sorted set by increment
.
zIncrBy
in interface RedisZSetCommands
http://redis.io/commands/zincrby
public Long zInterStore(byte[] destKey, RedisZSetCommands.Aggregate aggregate, int[] weights, byte[]... sets)
RedisZSetCommands
sets
and store result in destination key
.
zInterStore
in interface RedisZSetCommands
http://redis.io/commands/zinterstore
public Long zInterStore(byte[] destKey, byte[]... sets)
RedisZSetCommands
sets
and store result in destination key
.
zInterStore
in interface RedisZSetCommands
http://redis.io/commands/zinterstore
public Set<byte[]> zRange(byte[] key, long start, long end)
RedisZSetCommands
begin
and end
from sorted set.
zRange
in interface RedisZSetCommands
http://redis.io/commands/zrange
public Set<RedisZSetCommands.Tuple> zRangeWithScores(byte[] key, long start, long end)
RedisZSetCommands
RedisZSetCommands.Tuple
s between begin
and end
from sorted set.
zRangeWithScores
in interface RedisZSetCommands
http://redis.io/commands/zrange
public Set<byte[]> zRangeByScore(byte[] key, double min, double max)
RedisZSetCommands
min
and max
from sorted set.
zRangeByScore
in interface RedisZSetCommands
http://redis.io/commands/zrangebyscore
public Set<RedisZSetCommands.Tuple> zRangeByScoreWithScores(byte[] key, double min, double max)
RedisZSetCommands
RedisZSetCommands.Tuple
s where score is between min
and max
from sorted set.
zRangeByScoreWithScores
in interface RedisZSetCommands
http://redis.io/commands/zrangebyscore
public Set<RedisZSetCommands.Tuple> zRevRangeWithScores(byte[] key, long start, long end)
RedisZSetCommands
RedisZSetCommands.Tuple
s in range from begin
to end
from sorted set ordered high -> low.
zRevRangeWithScores
in interface RedisZSetCommands
http://redis.io/commands/zrevrange
public Set<byte[]> zRangeByScore(byte[] key, double min, double max, long offset, long count)
RedisZSetCommands
begin
to end
where score is between min
and max
from
sorted set.
zRangeByScore
in interface RedisZSetCommands
http://redis.io/commands/zrangebyscore
public Set<RedisZSetCommands.Tuple> zRangeByScoreWithScores(byte[] key, double min, double max, long offset, long count)
RedisZSetCommands
RedisZSetCommands.Tuple
s in range from begin
to end
where score is between min
and
max
from sorted set.
zRangeByScoreWithScores
in interface RedisZSetCommands
http://redis.io/commands/zrangebyscore
public Set<byte[]> zRevRangeByScore(byte[] key, double min, double max, long offset, long count)
RedisZSetCommands
begin
to end
where score is between min
and max
from
sorted set ordered high -> low.
zRevRangeByScore
in interface RedisZSetCommands
http://redis.io/commands/zrevrangebyscore
public Set<byte[]> zRevRangeByScore(byte[] key, double min, double max)
RedisZSetCommands
min
and max
from sorted set ordered high -> low.
zRevRangeByScore
in interface RedisZSetCommands
http://redis.io/commands/zrevrange
public Set<RedisZSetCommands.Tuple> zRevRangeByScoreWithScores(byte[] key, double min, double max, long offset, long count)
RedisZSetCommands
RedisZSetCommands.Tuple
in range from begin
to end
where score is between min
and
max
from sorted set ordered high -> low.
zRevRangeByScoreWithScores
in interface RedisZSetCommands
http://redis.io/commands/zrevrangebyscore
public Set<RedisZSetCommands.Tuple> zRevRangeByScoreWithScores(byte[] key, double min, double max)
RedisZSetCommands
RedisZSetCommands.Tuple
where score is between min
and max
from sorted set ordered high -> low.
zRevRangeByScoreWithScores
in interface RedisZSetCommands
http://redis.io/commands/zrevrange
public Long zRank(byte[] key, byte[] value)
RedisZSetCommands
value
in a sorted set.
zRank
in interface RedisZSetCommands
http://redis.io/commands/zrank
public Long zRem(byte[] key, byte[]... values)
RedisZSetCommands
values
from sorted set. Return number of removed elements.
zRem
in interface RedisZSetCommands
http://redis.io/commands/zrem
public Long zRemRange(byte[] key, long start, long end)
RedisZSetCommands
begin
and end
from sorted set with key
.
zRemRange
in interface RedisZSetCommands
http://redis.io/commands/zremrange
public Long zRemRangeByScore(byte[] key, double min, double max)
RedisZSetCommands
min
and max
from sorted set with key
.
zRemRangeByScore
in interface RedisZSetCommands
http://redis.io/commands/zremrangebyscore
public Set<byte[]> zRevRange(byte[] key, long start, long end)
RedisZSetCommands
begin
to end
from sorted set ordered high -> low.
zRevRange
in interface RedisZSetCommands
http://redis.io/commands/zrevrange
public Long zRevRank(byte[] key, byte[] value)
RedisZSetCommands
value
in a sorted set when scored high to low.
zRevRank
in interface RedisZSetCommands
http://redis.io/commands/zrevrank
public Double zScore(byte[] key, byte[] value)
RedisZSetCommands
value
from sorted set with key key
.
zScore
in interface RedisZSetCommands
http://redis.io/commands/zrem
public Long zUnionStore(byte[] destKey, RedisZSetCommands.Aggregate aggregate, int[] weights, byte[]... sets)
RedisZSetCommands
sets
and store result in destination key
.
zUnionStore
in interface RedisZSetCommands
http://redis.io/commands/zunionstore
public Long zUnionStore(byte[] destKey, byte[]... sets)
RedisZSetCommands
sets
and store result in destination key
.
zUnionStore
in interface RedisZSetCommands
http://redis.io/commands/zunionstore
public Boolean hSet(byte[] key, byte[] field, byte[] value)
RedisHashCommands
value
of a hash field
.
hSet
in interface RedisHashCommands
http://redis.io/commands/hset
public Boolean hSetNX(byte[] key, byte[] field, byte[] value)
RedisHashCommands
value
of a hash field
only if field
does not exist.
hSetNX
in interface RedisHashCommands
http://redis.io/commands/hsetnx
public Long hDel(byte[] key, byte[]... fields)
RedisHashCommands
fields
.
hDel
in interface RedisHashCommands
http://redis.io/commands/hdel
public Boolean hExists(byte[] key, byte[] field)
RedisHashCommands
field
exists.
hExists
in interface RedisHashCommands
http://redis.io/commands/hexits
public byte[] hGet(byte[] key, byte[] field)
RedisHashCommands
field
from hash at key
.
hGet
in interface RedisHashCommands
http://redis.io/commands/hget
public Map<byte[],byte[]> hGetAll(byte[] key)
RedisHashCommands
key
.
hGetAll
in interface RedisHashCommands
http://redis.io/commands/hgetall
public Long hIncrBy(byte[] key, byte[] field, long delta)
RedisHashCommands
value
of a hash field
by the given delta
.
hIncrBy
in interface RedisHashCommands
http://redis.io/commands/hincrby
public Double hIncrBy(byte[] key, byte[] field, double delta)
RedisHashCommands
value
of a hash field
by the given delta
.
hIncrBy
in interface RedisHashCommands
http://redis.io/commands/hincrbyfloat
public Set<byte[]> hKeys(byte[] key)
RedisHashCommands
key
.
hKeys
in interface RedisHashCommands
http://redis.io/commands/h?
public Long hLen(byte[] key)
RedisHashCommands
key
.
hLen
in interface RedisHashCommands
http://redis.io/commands/hlen
public List<byte[]> hMGet(byte[] key, byte[]... fields)
RedisHashCommands
fields
from hash at key
.
hMGet
in interface RedisHashCommands
http://redis.io/commands/hmget
public void hMSet(byte[] key, Map<byte[],byte[]> tuple)
RedisHashCommands
hashes
hMSet
in interface RedisHashCommands
http://redis.io/commands/hmset
public List<byte[]> hVals(byte[] key)
RedisHashCommands
field
.
hVals
in interface RedisHashCommands
http://redis.io/commands/hvals
public Long publish(byte[] channel, byte[] message)
RedisPubSubCommands
publish
in interface RedisPubSubCommands
channel
- the channel to publish tomessage
- message to publish
public Subscription getSubscription()
RedisPubSubCommands
getSubscription
in interface RedisPubSubCommands
public boolean isSubscribed()
RedisPubSubCommands
isSubscribed
in interface RedisPubSubCommands
public void pSubscribe(MessageListener listener, byte[]... patterns)
RedisPubSubCommands
pSubscribe
in interface RedisPubSubCommands
listener
- message listenerpatterns
- channel name patternspublic void subscribe(MessageListener listener, byte[]... channels)
RedisPubSubCommands
subscribe
in interface RedisPubSubCommands
listener
- message listenerchannels
- channel namespublic void scriptFlush()
RedisScriptingCommands
scriptFlush
in interface RedisScriptingCommands
http://redis.io/commands/script-flush
public void scriptKill()
RedisScriptingCommands
scriptKill
in interface RedisScriptingCommands
http://redis.io/commands/script-kill
public String scriptLoad(byte[] script)
RedisScriptingCommands
#evalSha(String, ReturnType, int, byte[])
.
scriptLoad
in interface RedisScriptingCommands
http://redis.io/commands/script-load
public List<Boolean> scriptExists(String... scriptSha1)
RedisScriptingCommands
scriptShas
exist in script cache.
scriptExists
in interface RedisScriptingCommands
http://redis.io/commands/script-exits
public <T> T eval(byte[] script, ReturnType returnType, int numKeys, byte[]... keysAndArgs)
RedisScriptingCommands
script
.
eval
in interface RedisScriptingCommands
http://redis.io/commands/eval
public <T> T evalSha(String scriptSha1, ReturnType returnType, int numKeys, byte[]... keysAndArgs)
RedisScriptingCommands
scriptSha
.
evalSha
in interface RedisScriptingCommands
http://redis.io/commands/evalsha
public Long time()
RedisServerCommands
TIME
command.
time
in interface RedisServerCommands
public void killClient(String host, int port)
RedisServerCommands
killClient
in interface RedisServerCommands
host
- of connection to close.port
- of connection to closepublic void slaveOf(String host, int port)
RedisServerCommands
slaveOf
in interface RedisServerCommands
http://redis.io/commands/slaveof
public void setClientName(byte[] name)
RedisServerCommands
setClientName
in interface RedisServerCommands
public String getClientName()
RedisServerCommands
getClientName
in interface RedisServerCommands
http://redis.io/commands/client-getname
public List<RedisClientInfo> getClientList()
RedisServerCommands
getClientList
in interface RedisServerCommands
List
of RedisClientInfo
objects.http://redis.io/commands/client-list
public void slaveOfNoOne()
RedisServerCommands
slaveOfNoOne
in interface RedisServerCommands
http://redis.io/commands/slaveof
public void setConvertPipelineAndTxResults(boolean convertPipelineAndTxResults)
closePipeline()
and exec()
will be of the type returned by the Jedis driver
convertPipelineAndTxResults
- Whether or not to convert pipeline and tx results
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |