|
Spring Data Key-Value | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.springframework.data.keyvalue.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.keyvalue.redis.connection.RedisListCommands |
---|
RedisListCommands.Position |
Nested classes/interfaces inherited from interface org.springframework.data.keyvalue.redis.connection.RedisZSetCommands |
---|
RedisZSetCommands.Aggregate, RedisZSetCommands.Tuple |
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)
Constructs a new JedisConnection instance backed by a jedis pool. |
Method Summary | |
---|---|
Long |
append(byte[] key,
byte[] value)
|
void |
bgSave()
|
void |
bgWriteAof()
|
List<byte[]> |
bLPop(int timeout,
byte[]... keys)
|
List<byte[]> |
bRPop(int timeout,
byte[]... keys)
|
byte[] |
bRPopLPush(int timeout,
byte[] srcKey,
byte[] dstKey)
|
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()
|
Long |
decr(byte[] key)
|
Long |
decrBy(byte[] key,
long value)
|
Long |
del(byte[]... keys)
|
void |
discard()
|
byte[] |
echo(byte[] message)
|
List<Object> |
exec()
|
Boolean |
exists(byte[] key)
|
Boolean |
expire(byte[] key,
long seconds)
|
Boolean |
expireAt(byte[] key,
long unixTime)
|
void |
flushAll()
|
void |
flushDb()
|
byte[] |
get(byte[] key)
|
Boolean |
getBit(byte[] key,
long offset)
|
List<String> |
getConfig(String param)
|
redis.clients.jedis.Jedis |
getNativeConnection()
Returns the native connection (the underlying library/driver object). |
byte[] |
getRange(byte[] key,
int start,
int end)
|
byte[] |
getSet(byte[] key,
byte[] value)
|
Subscription |
getSubscription()
Returns the current subscription for this connection or null if the connection is not subscribed. |
Boolean |
hDel(byte[] key,
byte[] field)
|
Boolean |
hExists(byte[] key,
byte[] field)
|
byte[] |
hGet(byte[] key,
byte[] field)
|
Map<byte[],byte[]> |
hGetAll(byte[] key)
|
Long |
hIncrBy(byte[] key,
byte[] field,
long delta)
|
Set<byte[]> |
hKeys(byte[] key)
|
Long |
hLen(byte[] key)
|
List<byte[]> |
hMGet(byte[] key,
byte[]... fields)
|
void |
hMSet(byte[] key,
Map<byte[],byte[]> tuple)
|
Boolean |
hSet(byte[] key,
byte[] field,
byte[] value)
|
Boolean |
hSetNX(byte[] key,
byte[] field,
byte[] value)
|
List<byte[]> |
hVals(byte[] key)
|
Long |
incr(byte[] key)
|
Long |
incrBy(byte[] key,
long value)
|
Properties |
info()
|
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. |
Collection<byte[]> |
keys(byte[] pattern)
|
Long |
lastSave()
|
byte[] |
lIndex(byte[] key,
long index)
|
Long |
lInsert(byte[] key,
RedisListCommands.Position where,
byte[] pivot,
byte[] value)
|
Long |
lLen(byte[] key)
|
byte[] |
lPop(byte[] key)
|
Long |
lPush(byte[] key,
byte[] value)
|
Long |
lPushX(byte[] key,
byte[] value)
|
List<byte[]> |
lRange(byte[] key,
long start,
long end)
|
Long |
lRem(byte[] key,
long count,
byte[] value)
|
void |
lSet(byte[] key,
long index,
byte[] value)
|
void |
lTrim(byte[] key,
long start,
long end)
|
List<byte[]> |
mGet(byte[]... keys)
|
void |
mSet(Map<byte[],byte[]> tuples)
|
void |
mSetNX(Map<byte[],byte[]> tuples)
|
void |
multi()
|
void |
openPipeline()
Activates the pipeline mode for this connection. |
Boolean |
persist(byte[] key)
|
String |
ping()
|
void |
pSubscribe(MessageListener listener,
byte[]... patterns)
Subscribes the connection to all channels matching the given patterns. |
Long |
publish(byte[] channel,
byte[] message)
Publishes the given message to the given channel. |
byte[] |
randomKey()
|
void |
rename(byte[] oldName,
byte[] newName)
|
Boolean |
renameNX(byte[] oldName,
byte[] newName)
|
void |
resetConfigStats()
|
byte[] |
rPop(byte[] key)
|
byte[] |
rPopLPush(byte[] srcKey,
byte[] dstKey)
|
Long |
rPush(byte[] key,
byte[] value)
|
Long |
rPushX(byte[] key,
byte[] value)
|
Boolean |
sAdd(byte[] key,
byte[] value)
|
void |
save()
|
Long |
sCard(byte[] key)
|
Set<byte[]> |
sDiff(byte[]... keys)
|
void |
sDiffStore(byte[] destKey,
byte[]... keys)
|
void |
select(int dbIndex)
|
void |
set(byte[] key,
byte[] value)
|
void |
setBit(byte[] key,
long offset,
boolean value)
|
void |
setConfig(String param,
String value)
|
void |
setEx(byte[] key,
long time,
byte[] value)
|
Boolean |
setNX(byte[] key,
byte[] value)
|
void |
setRange(byte[] key,
int start,
int end)
|
void |
shutdown()
|
Set<byte[]> |
sInter(byte[]... keys)
|
void |
sInterStore(byte[] destKey,
byte[]... keys)
|
Boolean |
sIsMember(byte[] key,
byte[] value)
|
Set<byte[]> |
sMembers(byte[] key)
|
Boolean |
sMove(byte[] srcKey,
byte[] destKey,
byte[] value)
|
List<byte[]> |
sort(byte[] key,
SortParameters params)
|
Long |
sort(byte[] key,
SortParameters params,
byte[] sortKey)
|
byte[] |
sPop(byte[] key)
|
byte[] |
sRandMember(byte[] key)
|
Boolean |
sRem(byte[] key,
byte[] value)
|
Long |
strLen(byte[] key)
|
void |
subscribe(MessageListener listener,
byte[]... channels)
Subscribes the connection to the given channels. |
Set<byte[]> |
sUnion(byte[]... keys)
|
void |
sUnionStore(byte[] destKey,
byte[]... keys)
|
Long |
ttl(byte[] key)
|
DataType |
type(byte[] key)
|
void |
unwatch()
|
void |
watch(byte[]... keys)
|
Boolean |
zAdd(byte[] key,
double score,
byte[] value)
|
Long |
zCard(byte[] key)
|
Long |
zCount(byte[] key,
double min,
double max)
|
Double |
zIncrBy(byte[] key,
double increment,
byte[] value)
|
Long |
zInterStore(byte[] destKey,
byte[]... sets)
|
Long |
zInterStore(byte[] destKey,
RedisZSetCommands.Aggregate aggregate,
int[] weights,
byte[]... sets)
|
Set<byte[]> |
zRange(byte[] key,
long start,
long end)
|
Set<byte[]> |
zRangeByScore(byte[] key,
double min,
double max)
|
Set<byte[]> |
zRangeByScore(byte[] key,
double min,
double max,
long offset,
long count)
|
Set<RedisZSetCommands.Tuple> |
zRangeByScoreWithScore(byte[] key,
double min,
double max)
|
Set<RedisZSetCommands.Tuple> |
zRangeByScoreWithScore(byte[] key,
double min,
double max,
long offset,
long count)
|
Set<RedisZSetCommands.Tuple> |
zRangeWithScore(byte[] key,
long start,
long end)
|
Long |
zRank(byte[] key,
byte[] value)
|
Boolean |
zRem(byte[] key,
byte[] value)
|
Long |
zRemRange(byte[] key,
long start,
long end)
|
Long |
zRemRangeByScore(byte[] key,
double min,
double max)
|
Set<byte[]> |
zRevRange(byte[] key,
long start,
long end)
|
Set<RedisZSetCommands.Tuple> |
zRevRangeWithScore(byte[] key,
long start,
long end)
|
Long |
zRevRank(byte[] key,
byte[] value)
|
Double |
zScore(byte[] key,
byte[] value)
|
Long |
zUnionStore(byte[] destKey,
byte[]... sets)
|
Long |
zUnionStore(byte[] destKey,
RedisZSetCommands.Aggregate aggregate,
int[] weights,
byte[]... sets)
|
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)
JedisConnection
instance backed by a jedis pool.
jedis
- pool
- can be null, if no pool is usedMethod Detail |
---|
protected DataAccessException convertJedisAccessException(Exception ex)
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)
sort
in interface RedisCommands
public Long sort(byte[] key, SortParameters params, byte[] sortKey)
sort
in interface RedisCommands
public Long dbSize()
dbSize
in interface RedisServerCommands
public void flushDb()
flushDb
in interface RedisServerCommands
public void flushAll()
flushAll
in interface RedisServerCommands
public void bgSave()
bgSave
in interface RedisServerCommands
public void bgWriteAof()
bgWriteAof
in interface RedisServerCommands
public void save()
save
in interface RedisServerCommands
public List<String> getConfig(String param)
getConfig
in interface RedisServerCommands
public Properties info()
info
in interface RedisServerCommands
public Long lastSave()
lastSave
in interface RedisServerCommands
public void setConfig(String param, String value)
setConfig
in interface RedisServerCommands
public void resetConfigStats()
resetConfigStats
in interface RedisServerCommands
public void shutdown()
shutdown
in interface RedisServerCommands
public byte[] echo(byte[] message)
echo
in interface RedisCommands
public String ping()
ping
in interface RedisCommands
public Long del(byte[]... keys)
del
in interface RedisCommands
public void discard()
discard
in interface RedisTxCommands
public List<Object> exec()
exec
in interface RedisTxCommands
public Boolean exists(byte[] key)
exists
in interface RedisCommands
public Boolean expire(byte[] key, long seconds)
expire
in interface RedisCommands
public Boolean expireAt(byte[] key, long unixTime)
expireAt
in interface RedisCommands
public Collection<byte[]> keys(byte[] pattern)
keys
in interface RedisCommands
public void multi()
multi
in interface RedisTxCommands
public Boolean persist(byte[] key)
persist
in interface RedisCommands
public byte[] randomKey()
randomKey
in interface RedisCommands
public void rename(byte[] oldName, byte[] newName)
rename
in interface RedisCommands
public Boolean renameNX(byte[] oldName, byte[] newName)
renameNX
in interface RedisCommands
public void select(int dbIndex)
select
in interface RedisCommands
public Long ttl(byte[] key)
ttl
in interface RedisCommands
public DataType type(byte[] key)
type
in interface RedisCommands
public void unwatch()
unwatch
in interface RedisTxCommands
public void watch(byte[]... keys)
watch
in interface RedisTxCommands
public byte[] get(byte[] key)
get
in interface RedisStringCommands
public void set(byte[] key, byte[] value)
set
in interface RedisStringCommands
public byte[] getSet(byte[] key, byte[] value)
getSet
in interface RedisStringCommands
public Long append(byte[] key, byte[] value)
append
in interface RedisStringCommands
public List<byte[]> mGet(byte[]... keys)
mGet
in interface RedisStringCommands
public void mSet(Map<byte[],byte[]> tuples)
mSet
in interface RedisStringCommands
public void mSetNX(Map<byte[],byte[]> tuples)
mSetNX
in interface RedisStringCommands
public void setEx(byte[] key, long time, byte[] value)
setEx
in interface RedisStringCommands
public Boolean setNX(byte[] key, byte[] value)
setNX
in interface RedisStringCommands
public byte[] getRange(byte[] key, int start, int end)
getRange
in interface RedisStringCommands
public Long decr(byte[] key)
decr
in interface RedisStringCommands
public Long decrBy(byte[] key, long value)
decrBy
in interface RedisStringCommands
public Long incr(byte[] key)
incr
in interface RedisStringCommands
public Long incrBy(byte[] key, long value)
incrBy
in interface RedisStringCommands
public Boolean getBit(byte[] key, long offset)
getBit
in interface RedisStringCommands
public void setBit(byte[] key, long offset, boolean value)
setBit
in interface RedisStringCommands
public void setRange(byte[] key, int start, int end)
setRange
in interface RedisStringCommands
public Long strLen(byte[] key)
strLen
in interface RedisStringCommands
public Long lPush(byte[] key, byte[] value)
lPush
in interface RedisListCommands
public Long rPush(byte[] key, byte[] value)
rPush
in interface RedisListCommands
public List<byte[]> bLPop(int timeout, byte[]... keys)
bLPop
in interface RedisListCommands
public List<byte[]> bRPop(int timeout, byte[]... keys)
bRPop
in interface RedisListCommands
public byte[] lIndex(byte[] key, long index)
lIndex
in interface RedisListCommands
public Long lInsert(byte[] key, RedisListCommands.Position where, byte[] pivot, byte[] value)
lInsert
in interface RedisListCommands
public Long lLen(byte[] key)
lLen
in interface RedisListCommands
public byte[] lPop(byte[] key)
lPop
in interface RedisListCommands
public List<byte[]> lRange(byte[] key, long start, long end)
lRange
in interface RedisListCommands
public Long lRem(byte[] key, long count, byte[] value)
lRem
in interface RedisListCommands
public void lSet(byte[] key, long index, byte[] value)
lSet
in interface RedisListCommands
public void lTrim(byte[] key, long start, long end)
lTrim
in interface RedisListCommands
public byte[] rPop(byte[] key)
rPop
in interface RedisListCommands
public byte[] rPopLPush(byte[] srcKey, byte[] dstKey)
rPopLPush
in interface RedisListCommands
public byte[] bRPopLPush(int timeout, byte[] srcKey, byte[] dstKey)
bRPopLPush
in interface RedisListCommands
public Long lPushX(byte[] key, byte[] value)
lPushX
in interface RedisListCommands
public Long rPushX(byte[] key, byte[] value)
rPushX
in interface RedisListCommands
public Boolean sAdd(byte[] key, byte[] value)
sAdd
in interface RedisSetCommands
public Long sCard(byte[] key)
sCard
in interface RedisSetCommands
public Set<byte[]> sDiff(byte[]... keys)
sDiff
in interface RedisSetCommands
public void sDiffStore(byte[] destKey, byte[]... keys)
sDiffStore
in interface RedisSetCommands
public Set<byte[]> sInter(byte[]... keys)
sInter
in interface RedisSetCommands
public void sInterStore(byte[] destKey, byte[]... keys)
sInterStore
in interface RedisSetCommands
public Boolean sIsMember(byte[] key, byte[] value)
sIsMember
in interface RedisSetCommands
public Set<byte[]> sMembers(byte[] key)
sMembers
in interface RedisSetCommands
public Boolean sMove(byte[] srcKey, byte[] destKey, byte[] value)
sMove
in interface RedisSetCommands
public byte[] sPop(byte[] key)
sPop
in interface RedisSetCommands
public byte[] sRandMember(byte[] key)
sRandMember
in interface RedisSetCommands
public Boolean sRem(byte[] key, byte[] value)
sRem
in interface RedisSetCommands
public Set<byte[]> sUnion(byte[]... keys)
sUnion
in interface RedisSetCommands
public void sUnionStore(byte[] destKey, byte[]... keys)
sUnionStore
in interface RedisSetCommands
public Boolean zAdd(byte[] key, double score, byte[] value)
zAdd
in interface RedisZSetCommands
public Long zCard(byte[] key)
zCard
in interface RedisZSetCommands
public Long zCount(byte[] key, double min, double max)
zCount
in interface RedisZSetCommands
public Double zIncrBy(byte[] key, double increment, byte[] value)
zIncrBy
in interface RedisZSetCommands
public Long zInterStore(byte[] destKey, RedisZSetCommands.Aggregate aggregate, int[] weights, byte[]... sets)
zInterStore
in interface RedisZSetCommands
public Long zInterStore(byte[] destKey, byte[]... sets)
zInterStore
in interface RedisZSetCommands
public Set<byte[]> zRange(byte[] key, long start, long end)
zRange
in interface RedisZSetCommands
public Set<RedisZSetCommands.Tuple> zRangeWithScore(byte[] key, long start, long end)
zRangeWithScore
in interface RedisZSetCommands
public Set<byte[]> zRangeByScore(byte[] key, double min, double max)
zRangeByScore
in interface RedisZSetCommands
public Set<RedisZSetCommands.Tuple> zRangeByScoreWithScore(byte[] key, double min, double max)
zRangeByScoreWithScore
in interface RedisZSetCommands
public Set<RedisZSetCommands.Tuple> zRevRangeWithScore(byte[] key, long start, long end)
zRevRangeWithScore
in interface RedisZSetCommands
public Set<byte[]> zRangeByScore(byte[] key, double min, double max, long offset, long count)
zRangeByScore
in interface RedisZSetCommands
public Set<RedisZSetCommands.Tuple> zRangeByScoreWithScore(byte[] key, double min, double max, long offset, long count)
zRangeByScoreWithScore
in interface RedisZSetCommands
public Long zRank(byte[] key, byte[] value)
zRank
in interface RedisZSetCommands
public Boolean zRem(byte[] key, byte[] value)
zRem
in interface RedisZSetCommands
public Long zRemRange(byte[] key, long start, long end)
zRemRange
in interface RedisZSetCommands
public Long zRemRangeByScore(byte[] key, double min, double max)
zRemRangeByScore
in interface RedisZSetCommands
public Set<byte[]> zRevRange(byte[] key, long start, long end)
zRevRange
in interface RedisZSetCommands
public Long zRevRank(byte[] key, byte[] value)
zRevRank
in interface RedisZSetCommands
public Double zScore(byte[] key, byte[] value)
zScore
in interface RedisZSetCommands
public Long zUnionStore(byte[] destKey, RedisZSetCommands.Aggregate aggregate, int[] weights, byte[]... sets)
zUnionStore
in interface RedisZSetCommands
public Long zUnionStore(byte[] destKey, byte[]... sets)
zUnionStore
in interface RedisZSetCommands
public Boolean hSet(byte[] key, byte[] field, byte[] value)
hSet
in interface RedisHashCommands
public Boolean hSetNX(byte[] key, byte[] field, byte[] value)
hSetNX
in interface RedisHashCommands
public Boolean hDel(byte[] key, byte[] field)
hDel
in interface RedisHashCommands
public Boolean hExists(byte[] key, byte[] field)
hExists
in interface RedisHashCommands
public byte[] hGet(byte[] key, byte[] field)
hGet
in interface RedisHashCommands
public Map<byte[],byte[]> hGetAll(byte[] key)
hGetAll
in interface RedisHashCommands
public Long hIncrBy(byte[] key, byte[] field, long delta)
hIncrBy
in interface RedisHashCommands
public Set<byte[]> hKeys(byte[] key)
hKeys
in interface RedisHashCommands
public Long hLen(byte[] key)
hLen
in interface RedisHashCommands
public List<byte[]> hMGet(byte[] key, byte[]... fields)
hMGet
in interface RedisHashCommands
public void hMSet(byte[] key, Map<byte[],byte[]> tuple)
hMSet
in interface RedisHashCommands
public List<byte[]> hVals(byte[] key)
hVals
in interface RedisHashCommands
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 names
|
Spring Data Key-Value | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |