From 1d03085a8158ca38d792b8049977b8bc8ea92ebc Mon Sep 17 00:00:00 2001 From: Costin Leau Date: Thu, 21 Jun 2012 17:11:46 +0300 Subject: [PATCH 1/5] add native execute for JedisConnection --- .../DefaultStringRedisConnection.java | 9 + .../data/redis/connection/RedisCommands.java | 12 + .../connection/StringRedisConnection.java | 2 + .../connection/jedis/JedisConnection.java | 319 ++++++++++-------- .../AbstractConnectionIntegrationTests.java | 18 +- 5 files changed, 213 insertions(+), 147 deletions(-) diff --git a/src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java b/src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java index 97012ddaa..9714e51c2 100644 --- a/src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java @@ -1152,4 +1152,13 @@ public class DefaultStringRedisConnection implements StringRedisConnection { public void openPipeline() { delegate.openPipeline(); } + + + public Object execute(String command, byte[]... args) { + return delegate.execute(command, args); + } + + public Object execute(String command, String... args) { + return execute(command, serializeMulti(args)); + } } \ No newline at end of file diff --git a/src/main/java/org/springframework/data/redis/connection/RedisCommands.java b/src/main/java/org/springframework/data/redis/connection/RedisCommands.java index 507d6faee..ff3ff20c7 100644 --- a/src/main/java/org/springframework/data/redis/connection/RedisCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/RedisCommands.java @@ -25,4 +25,16 @@ package org.springframework.data.redis.connection; public interface RedisCommands extends RedisKeyCommands, RedisStringCommands, RedisListCommands, RedisSetCommands, RedisZSetCommands, RedisHashCommands, RedisTxCommands, RedisPubSubCommands, RedisConnectionCommands, RedisServerCommands { + + + /** + * 'Native' or 'raw' execution of the given command along-side the given arguments. + * The command is executed as is, with as little 'interpretation' as possible - it is up to the caller + * to take care of any processing of arguments or the result. + * + * @param command Command to execute + * @param args Possible command arguments (may be null) + * @return execution result. + */ + Object execute(String command, byte[]... args); } \ No newline at end of file diff --git a/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java b/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java index a3edf9984..4d92b09f7 100644 --- a/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java @@ -42,6 +42,8 @@ public interface StringRedisConnection extends RedisConnection { String getValueAsString(); } + Object execute(String command, String... args); + Boolean exists(String key); Long del(String... keys); diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java index 4d45a535c..2ad170877 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java @@ -17,6 +17,7 @@ package org.springframework.data.redis.connection.jedis; import java.io.IOException; import java.lang.reflect.Field; +import java.lang.reflect.Method; import java.util.ArrayList; import java.util.Collections; import java.util.List; @@ -32,14 +33,19 @@ import org.springframework.data.redis.connection.RedisConnection; import org.springframework.data.redis.connection.RedisSubscribedConnectionException; import org.springframework.data.redis.connection.SortParameters; import org.springframework.data.redis.connection.Subscription; +import org.springframework.util.Assert; import org.springframework.util.ReflectionUtils; import redis.clients.jedis.BinaryJedis; import redis.clients.jedis.BinaryJedisPubSub; import redis.clients.jedis.BinaryTransaction; +import redis.clients.jedis.Builder; import redis.clients.jedis.Client; +import redis.clients.jedis.Connection; import redis.clients.jedis.Jedis; import redis.clients.jedis.Pipeline; +import redis.clients.jedis.Protocol.Command; +import redis.clients.jedis.Queable; import redis.clients.jedis.SortingParams; import redis.clients.jedis.Transaction; import redis.clients.jedis.ZParams; @@ -55,10 +61,17 @@ import redis.clients.util.Pool; public class JedisConnection implements RedisConnection { private static final Field CLIENT_FIELD; + private static final Method SEND_COMMAND; + private static final Method GET_RESPONSE; static { CLIENT_FIELD = ReflectionUtils.findField(BinaryJedis.class, "client", Client.class); ReflectionUtils.makeAccessible(CLIENT_FIELD); + SEND_COMMAND = ReflectionUtils.findMethod(Connection.class, "sendCommand", + new Class[] { Command.class, byte[][].class }); + ReflectionUtils.makeAccessible(SEND_COMMAND); + GET_RESPONSE = ReflectionUtils.findMethod(Queable.class, "getResponse", Builder.class); + ReflectionUtils.makeAccessible(GET_RESPONSE); } private final Jedis jedis; @@ -119,7 +132,34 @@ public class JedisConnection implements RedisConnection { return new RedisSystemException("Unknown jedis exception", ex); } - + public Object execute(String command, byte[]... args) { + Assert.hasText(command, "a valid command needs to be specified"); + List mArgs = new ArrayList(); + if (args == null) { + mArgs.add(new byte[0]); + } + else { + Collections.addAll(mArgs, args); + } + + Object result = ReflectionUtils.invokeMethod(SEND_COMMAND, client, + Command.valueOf(command.trim().toUpperCase()), mArgs.toArray(new byte[mArgs.size()][])); + if (isQueueing() || isPipelined()) { + Object target = (isPipelined() ? pipeline : transaction); + ReflectionUtils.invokeMethod(GET_RESPONSE, target, new Builder() { + public Object build(Object data) { + return data; + } + + public String toString() { + return "Object"; + } + }); + } + + return result; + } + public void close() throws DataAccessException { // return the connection to the pool try { @@ -158,12 +198,12 @@ public class JedisConnection implements RedisConnection { } } - + public Jedis getNativeConnection() { return jedis; } - + public boolean isClosed() { try { return !jedis.isConnected(); @@ -172,17 +212,17 @@ public class JedisConnection implements RedisConnection { } } - + public boolean isQueueing() { return client.isInMulti(); } - + public boolean isPipelined() { return (pipeline != null); } - + public void openPipeline() { if (pipeline == null) { pipeline = jedis.pipelined(); @@ -190,7 +230,6 @@ public class JedisConnection implements RedisConnection { } @SuppressWarnings("unchecked") - public List closePipeline() { if (pipeline != null) { List execute = pipeline.syncAndReturnAll(); @@ -201,7 +240,7 @@ public class JedisConnection implements RedisConnection { return Collections.emptyList(); } - + public List sort(byte[] key, SortParameters params) { SortingParams sortParams = JedisUtils.convertSortParams(params); @@ -233,7 +272,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long sort(byte[] key, SortParameters params, byte[] sortKey) { SortingParams sortParams = JedisUtils.convertSortParams(params); @@ -265,14 +304,14 @@ public class JedisConnection implements RedisConnection { } } - + public Long dbSize() { try { if (isQueueing()) { - throw new UnsupportedOperationException(); + transaction.dbSize(); } if (isPipelined()) { - throw new UnsupportedOperationException(); + pipeline.dbSize(); } return jedis.dbSize(); } catch (Exception ex) { @@ -281,14 +320,14 @@ public class JedisConnection implements RedisConnection { } - + public void flushDb() { try { if (isQueueing()) { - throw new UnsupportedOperationException(); + transaction.flushDB(); } if (isPipelined()) { - throw new UnsupportedOperationException(); + pipeline.flushDB(); } jedis.flushDB(); } catch (Exception ex) { @@ -296,14 +335,14 @@ public class JedisConnection implements RedisConnection { } } - + public void flushAll() { try { if (isQueueing()) { - throw new UnsupportedOperationException(); + transaction.flushAll(); } if (isPipelined()) { - throw new UnsupportedOperationException(); + pipeline.flushAll(); } jedis.flushAll(); } catch (Exception ex) { @@ -311,7 +350,7 @@ public class JedisConnection implements RedisConnection { } } - + public void bgSave() { try { if (isQueueing()) { @@ -327,7 +366,7 @@ public class JedisConnection implements RedisConnection { } } - + public void bgWriteAof() { try { if (isQueueing()) { @@ -343,7 +382,7 @@ public class JedisConnection implements RedisConnection { } } - + public void save() { try { if (isQueueing()) { @@ -359,7 +398,7 @@ public class JedisConnection implements RedisConnection { } } - + public List getConfig(String param) { try { if (isQueueing()) { @@ -375,7 +414,7 @@ public class JedisConnection implements RedisConnection { } } - + public Properties info() { try { if (isQueueing()) { @@ -390,7 +429,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long lastSave() { try { if (isQueueing()) { @@ -406,7 +445,7 @@ public class JedisConnection implements RedisConnection { } } - + public void setConfig(String param, String value) { try { if (isQueueing()) { @@ -423,7 +462,7 @@ public class JedisConnection implements RedisConnection { } - + public void resetConfigStats() { try { if (isQueueing()) { @@ -439,7 +478,7 @@ public class JedisConnection implements RedisConnection { } } - + public void shutdown() { try { if (isQueueing()) { @@ -454,7 +493,7 @@ public class JedisConnection implements RedisConnection { } } - + public byte[] echo(byte[] message) { try { if (isQueueing()) { @@ -470,7 +509,7 @@ public class JedisConnection implements RedisConnection { } } - + public String ping() { try { if (isQueueing()) { @@ -485,7 +524,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long del(byte[]... keys) { try { if (isQueueing()) { @@ -502,7 +541,7 @@ public class JedisConnection implements RedisConnection { } } - + public void discard() { try { client.discard(); @@ -511,7 +550,7 @@ public class JedisConnection implements RedisConnection { } } - + public List exec() { try { if (isPipelined()) { @@ -524,7 +563,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean exists(byte[] key) { try { if (isQueueing()) { @@ -541,7 +580,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean expire(byte[] key, long seconds) { try { if (isQueueing()) { @@ -558,7 +597,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean expireAt(byte[] key, long unixTime) { try { if (isQueueing()) { @@ -575,7 +614,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set keys(byte[] pattern) { try { if (isQueueing()) { @@ -592,7 +631,7 @@ public class JedisConnection implements RedisConnection { } } - + public void multi() { if (isQueueing()) { return; @@ -608,7 +647,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean persist(byte[] key) { try { if (isQueueing()) { @@ -625,7 +664,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean move(byte[] key, int dbIndex) { try { if (isQueueing()) { @@ -642,7 +681,7 @@ public class JedisConnection implements RedisConnection { } } - + public byte[] randomKey() { try { if (isQueueing()) { @@ -657,7 +696,7 @@ public class JedisConnection implements RedisConnection { } } - + public void rename(byte[] oldName, byte[] newName) { try { if (isQueueing()) { @@ -674,7 +713,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean renameNX(byte[] oldName, byte[] newName) { try { if (isQueueing()) { @@ -691,7 +730,7 @@ public class JedisConnection implements RedisConnection { } } - + public void select(int dbIndex) { try { if (isQueueing()) { @@ -706,7 +745,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long ttl(byte[] key) { try { if (isQueueing()) { @@ -723,7 +762,7 @@ public class JedisConnection implements RedisConnection { } } - + public DataType type(byte[] key) { try { if (isQueueing()) { @@ -740,7 +779,7 @@ public class JedisConnection implements RedisConnection { } } - + public void unwatch() { try { jedis.unwatch(); @@ -749,7 +788,7 @@ public class JedisConnection implements RedisConnection { } } - + public void watch(byte[]... keys) { if (isQueueing()) { throw new UnsupportedOperationException(); @@ -772,7 +811,7 @@ public class JedisConnection implements RedisConnection { // String commands // - + public byte[] get(byte[] key) { try { if (isQueueing()) { @@ -790,7 +829,7 @@ public class JedisConnection implements RedisConnection { } } - + public void set(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -808,7 +847,7 @@ public class JedisConnection implements RedisConnection { } - + public byte[] getSet(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -825,7 +864,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long append(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -842,7 +881,7 @@ public class JedisConnection implements RedisConnection { } } - + public List mGet(byte[]... keys) { try { if (isQueueing()) { @@ -859,7 +898,7 @@ public class JedisConnection implements RedisConnection { } } - + public void mSet(Map tuples) { try { if (isQueueing()) { @@ -876,7 +915,7 @@ public class JedisConnection implements RedisConnection { } } - + public void mSetNX(Map tuples) { try { if (isQueueing()) { @@ -893,7 +932,7 @@ public class JedisConnection implements RedisConnection { } } - + public void setEx(byte[] key, long time, byte[] value) { try { if (isQueueing()) { @@ -910,7 +949,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean setNX(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -927,7 +966,7 @@ public class JedisConnection implements RedisConnection { } } - + public byte[] getRange(byte[] key, long start, long end) { try { if (isQueueing()) { @@ -944,7 +983,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long decr(byte[] key) { try { if (isQueueing()) { @@ -961,7 +1000,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long decrBy(byte[] key, long value) { try { if (isQueueing()) { @@ -978,7 +1017,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long incr(byte[] key) { try { if (isQueueing()) { @@ -995,7 +1034,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long incrBy(byte[] key, long value) { try { if (isQueueing()) { @@ -1012,7 +1051,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean getBit(byte[] key, long offset) { try { if (isQueueing()) { @@ -1025,7 +1064,7 @@ public class JedisConnection implements RedisConnection { Object getBit = jedis.getbit(key, offset); // Jedis 2.0 if (getBit instanceof Long) { - return (((Long)getBit) == 0 ? Boolean.FALSE : Boolean.TRUE); + return (((Long) getBit) == 0 ? Boolean.FALSE : Boolean.TRUE); } // Jedis 2.1 return ((Boolean) getBit); @@ -1034,7 +1073,7 @@ public class JedisConnection implements RedisConnection { } } - + public void setBit(byte[] key, long offset, boolean value) { try { if (isQueueing()) { @@ -1049,7 +1088,7 @@ public class JedisConnection implements RedisConnection { } } - + public void setRange(byte[] key, byte[] value, long start) { try { if (isQueueing()) { @@ -1064,7 +1103,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long strLen(byte[] key) { try { if (isQueueing()) { @@ -1085,7 +1124,7 @@ public class JedisConnection implements RedisConnection { // List commands // - + public Long lPush(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -1102,7 +1141,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long rPush(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -1119,7 +1158,7 @@ public class JedisConnection implements RedisConnection { } } - + public List bLPop(int timeout, byte[]... keys) { try { if (isQueueing()) { @@ -1136,7 +1175,7 @@ public class JedisConnection implements RedisConnection { } } - + public List bRPop(int timeout, byte[]... keys) { try { if (isQueueing()) { @@ -1152,7 +1191,7 @@ public class JedisConnection implements RedisConnection { } } - + public byte[] lIndex(byte[] key, long index) { try { if (isQueueing()) { @@ -1169,7 +1208,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long lInsert(byte[] key, Position where, byte[] pivot, byte[] value) { try { if (isQueueing()) { @@ -1186,7 +1225,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long lLen(byte[] key) { try { if (isQueueing()) { @@ -1203,7 +1242,7 @@ public class JedisConnection implements RedisConnection { } } - + public byte[] lPop(byte[] key) { try { if (isQueueing()) { @@ -1220,7 +1259,7 @@ public class JedisConnection implements RedisConnection { } } - + public List lRange(byte[] key, long start, long end) { try { if (isQueueing()) { @@ -1237,7 +1276,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long lRem(byte[] key, long count, byte[] value) { try { if (isQueueing()) { @@ -1254,7 +1293,7 @@ public class JedisConnection implements RedisConnection { } } - + public void lSet(byte[] key, long index, byte[] value) { try { if (isQueueing()) { @@ -1271,7 +1310,7 @@ public class JedisConnection implements RedisConnection { } } - + public void lTrim(byte[] key, long start, long end) { try { if (isQueueing()) { @@ -1288,7 +1327,7 @@ public class JedisConnection implements RedisConnection { } } - + public byte[] rPop(byte[] key) { try { if (isQueueing()) { @@ -1305,7 +1344,7 @@ public class JedisConnection implements RedisConnection { } } - + public byte[] rPopLPush(byte[] srcKey, byte[] dstKey) { try { if (isQueueing()) { @@ -1322,7 +1361,7 @@ public class JedisConnection implements RedisConnection { } } - + public byte[] bRPopLPush(int timeout, byte[] srcKey, byte[] dstKey) { try { if (isQueueing()) { @@ -1339,7 +1378,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long lPushX(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -1356,7 +1395,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long rPushX(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -1378,7 +1417,7 @@ public class JedisConnection implements RedisConnection { // Set commands // - + public Boolean sAdd(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -1395,7 +1434,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long sCard(byte[] key) { try { if (isQueueing()) { @@ -1412,7 +1451,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set sDiff(byte[]... keys) { try { if (isQueueing()) { @@ -1429,7 +1468,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long sDiffStore(byte[] destKey, byte[]... keys) { try { if (isQueueing()) { @@ -1446,7 +1485,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set sInter(byte[]... keys) { try { if (isQueueing()) { @@ -1463,7 +1502,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long sInterStore(byte[] destKey, byte[]... keys) { try { if (isQueueing()) { @@ -1480,7 +1519,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean sIsMember(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -1497,7 +1536,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set sMembers(byte[] key) { try { if (isQueueing()) { @@ -1514,7 +1553,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean sMove(byte[] srcKey, byte[] destKey, byte[] value) { try { if (isQueueing()) { @@ -1531,7 +1570,7 @@ public class JedisConnection implements RedisConnection { } } - + public byte[] sPop(byte[] key) { try { if (isQueueing()) { @@ -1548,7 +1587,7 @@ public class JedisConnection implements RedisConnection { } } - + public byte[] sRandMember(byte[] key) { try { if (isQueueing()) { @@ -1565,7 +1604,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean sRem(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -1582,7 +1621,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set sUnion(byte[]... keys) { try { if (isQueueing()) { @@ -1599,7 +1638,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long sUnionStore(byte[] destKey, byte[]... keys) { try { if (isQueueing()) { @@ -1620,7 +1659,7 @@ public class JedisConnection implements RedisConnection { // ZSet commands // - + public Boolean zAdd(byte[] key, double score, byte[] value) { try { if (isQueueing()) { @@ -1637,7 +1676,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long zCard(byte[] key) { try { if (isQueueing()) { @@ -1654,7 +1693,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long zCount(byte[] key, double min, double max) { try { if (isQueueing()) { @@ -1671,7 +1710,7 @@ public class JedisConnection implements RedisConnection { } } - + public Double zIncrBy(byte[] key, double increment, byte[] value) { try { if (isQueueing()) { @@ -1688,7 +1727,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long zInterStore(byte[] destKey, Aggregate aggregate, int[] weights, byte[]... sets) { try { ZParams zparams = new ZParams().weights(weights).aggregate( @@ -1708,7 +1747,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long zInterStore(byte[] destKey, byte[]... sets) { try { if (isQueueing()) { @@ -1725,7 +1764,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set zRange(byte[] key, long start, long end) { try { if (isQueueing()) { @@ -1742,7 +1781,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set zRangeWithScores(byte[] key, long start, long end) { try { if (isQueueing()) { @@ -1759,7 +1798,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set zRangeByScore(byte[] key, double min, double max) { try { if (isQueueing()) { @@ -1776,7 +1815,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set zRangeByScoreWithScores(byte[] key, double min, double max) { try { if (isQueueing()) { @@ -1793,7 +1832,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set zRevRangeWithScores(byte[] key, long start, long end) { try { if (isQueueing()) { @@ -1810,7 +1849,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set zRangeByScore(byte[] key, double min, double max, long offset, long count) { try { if (isQueueing()) { @@ -1827,7 +1866,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set zRangeByScoreWithScores(byte[] key, double min, double max, long offset, long count) { try { if (isQueueing()) { @@ -1844,7 +1883,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set zRevRangeByScore(byte[] key, double min, double max, long offset, long count) { try { if (isQueueing()) { @@ -1859,7 +1898,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set zRevRangeByScore(byte[] key, double min, double max) { try { if (isQueueing()) { @@ -1874,7 +1913,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set zRevRangeByScoreWithScores(byte[] key, double min, double max, long offset, long count) { try { if (isQueueing()) { @@ -1890,7 +1929,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set zRevRangeByScoreWithScores(byte[] key, double min, double max) { try { if (isQueueing()) { @@ -1905,7 +1944,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long zRank(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -1922,7 +1961,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean zRem(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -1939,7 +1978,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long zRemRange(byte[] key, long start, long end) { try { if (isQueueing()) { @@ -1956,7 +1995,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long zRemRangeByScore(byte[] key, double min, double max) { try { if (isQueueing()) { @@ -1973,7 +2012,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set zRevRange(byte[] key, long start, long end) { try { if (isQueueing()) { @@ -1990,7 +2029,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long zRevRank(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -2007,7 +2046,7 @@ public class JedisConnection implements RedisConnection { } } - + public Double zScore(byte[] key, byte[] value) { try { if (isQueueing()) { @@ -2024,7 +2063,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long zUnionStore(byte[] destKey, Aggregate aggregate, int[] weights, byte[]... sets) { try { ZParams zparams = new ZParams().weights(weights).aggregate( @@ -2044,7 +2083,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long zUnionStore(byte[] destKey, byte[]... sets) { try { if (isQueueing()) { @@ -2065,7 +2104,7 @@ public class JedisConnection implements RedisConnection { // Hash commands // - + public Boolean hSet(byte[] key, byte[] field, byte[] value) { try { if (isQueueing()) { @@ -2082,7 +2121,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean hSetNX(byte[] key, byte[] field, byte[] value) { try { if (isQueueing()) { @@ -2099,7 +2138,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean hDel(byte[] key, byte[] field) { try { if (isQueueing()) { @@ -2116,7 +2155,7 @@ public class JedisConnection implements RedisConnection { } } - + public Boolean hExists(byte[] key, byte[] field) { try { if (isQueueing()) { @@ -2133,7 +2172,7 @@ public class JedisConnection implements RedisConnection { } } - + public byte[] hGet(byte[] key, byte[] field) { try { if (isQueueing()) { @@ -2150,7 +2189,7 @@ public class JedisConnection implements RedisConnection { } } - + public Map hGetAll(byte[] key) { try { if (isQueueing()) { @@ -2167,7 +2206,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long hIncrBy(byte[] key, byte[] field, long delta) { try { if (isQueueing()) { @@ -2184,7 +2223,7 @@ public class JedisConnection implements RedisConnection { } } - + public Set hKeys(byte[] key) { try { if (isQueueing()) { @@ -2201,7 +2240,7 @@ public class JedisConnection implements RedisConnection { } } - + public Long hLen(byte[] key) { try { if (isQueueing()) { @@ -2218,7 +2257,7 @@ public class JedisConnection implements RedisConnection { } } - + public List hMGet(byte[] key, byte[]... fields) { try { if (isQueueing()) { @@ -2235,7 +2274,7 @@ public class JedisConnection implements RedisConnection { } } - + public void hMSet(byte[] key, Map tuple) { try { if (isQueueing()) { @@ -2252,7 +2291,7 @@ public class JedisConnection implements RedisConnection { } } - + public List hVals(byte[] key) { try { if (isQueueing()) { @@ -2273,7 +2312,7 @@ public class JedisConnection implements RedisConnection { // // Pub/Sub functionality // - + public Long publish(byte[] channel, byte[] message) { try { if (isQueueing()) { @@ -2289,17 +2328,17 @@ public class JedisConnection implements RedisConnection { } } - + public Subscription getSubscription() { return subscription; } - + public boolean isSubscribed() { return (subscription != null && subscription.isAlive()); } - + public void pSubscribe(MessageListener listener, byte[]... patterns) { if (isSubscribed()) { throw new RedisSubscribedConnectionException( @@ -2324,7 +2363,7 @@ public class JedisConnection implements RedisConnection { } } - + public void subscribe(MessageListener listener, byte[]... channels) { if (isSubscribed()) { throw new RedisSubscribedConnectionException( diff --git a/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java b/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java index 4b4d3276f..6dc0354a9 100644 --- a/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java +++ b/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java @@ -16,7 +16,12 @@ package org.springframework.data.redis.connection; -import static org.junit.Assert.*; +import static org.junit.Assert.assertArrayEquals; +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertNotNull; +import static org.junit.Assert.assertNotSame; +import static org.junit.Assert.assertNull; +import static org.junit.Assert.assertTrue; import java.util.Arrays; import java.util.List; @@ -34,12 +39,6 @@ import org.springframework.dao.DataAccessException; import org.springframework.data.redis.Address; import org.springframework.data.redis.ConnectionFactoryTracker; import org.springframework.data.redis.Person; -import org.springframework.data.redis.connection.DefaultStringRedisConnection; -import org.springframework.data.redis.connection.Message; -import org.springframework.data.redis.connection.MessageListener; -import org.springframework.data.redis.connection.RedisConnection; -import org.springframework.data.redis.connection.RedisConnectionFactory; -import org.springframework.data.redis.connection.StringRedisConnection; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.data.redis.serializer.JdkSerializationRedisSerializer; import org.springframework.data.redis.serializer.RedisSerializer; @@ -333,4 +332,9 @@ public abstract class AbstractConnectionIntegrationTests { th.start(); connection.pSubscribe(listener, expectedPattern); } + + @Test + public void testExecuteNative() throws Exception { + connection.execute("ZADD", getClass() + "#testExecuteNative", "0.9090", "item"); + } } \ No newline at end of file From 42c0ed804fefb5a9f7c078085feaddda1652d5de Mon Sep 17 00:00:00 2001 From: Costin Leau Date: Thu, 21 Jun 2012 17:33:31 +0300 Subject: [PATCH 2/5] add jredis implementation for execute native --- .../connection/jredis/JredisConnection.java | 290 ++++++++++-------- .../AbstractConnectionIntegrationTests.java | 3 + 2 files changed, 160 insertions(+), 133 deletions(-) diff --git a/src/main/java/org/springframework/data/redis/connection/jredis/JredisConnection.java b/src/main/java/org/springframework/data/redis/connection/jredis/JredisConnection.java index 2ea1d5556..e82608e4a 100644 --- a/src/main/java/org/springframework/data/redis/connection/jredis/JredisConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/jredis/JredisConnection.java @@ -15,6 +15,8 @@ */ package org.springframework.data.redis.connection.jredis; +import java.lang.reflect.Method; +import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; import java.util.LinkedHashSet; @@ -28,7 +30,9 @@ import org.jredis.JRedis; import org.jredis.Query.Support; import org.jredis.RedisException; import org.jredis.Sort; +import org.jredis.protocol.Command; import org.jredis.ri.alphazero.JRedisService; +import org.jredis.ri.alphazero.JRedisSupport; import org.springframework.dao.DataAccessException; import org.springframework.data.redis.RedisSystemException; import org.springframework.data.redis.connection.DataType; @@ -37,6 +41,7 @@ import org.springframework.data.redis.connection.RedisConnection; import org.springframework.data.redis.connection.SortParameters; import org.springframework.data.redis.connection.Subscription; import org.springframework.util.Assert; +import org.springframework.util.ReflectionUtils; /** * {@code RedisConnection} implementation on top of JRedis library. @@ -45,10 +50,18 @@ import org.springframework.util.Assert; */ public class JredisConnection implements RedisConnection { + private static final Method SERVICE_REQUEST; + private final JRedis jredis; private final boolean isPool; private boolean isClosed = false; + static { + SERVICE_REQUEST = ReflectionUtils.findMethod(JRedisSupport.class, "serviceRequest", Command.class, + byte[][].class); + ReflectionUtils.makeAccessible(SERVICE_REQUEST); + } + /** * Constructs a new JredisConnection instance. * @@ -73,7 +86,18 @@ public class JredisConnection implements RedisConnection { return new RedisSystemException("Unknown JRedis exception", ex); } - + public Object execute(String command, byte[]... args) { + Assert.hasText(command, "a valid command needs to be specified"); + List mArgs = new ArrayList(); + if (args != null) { + Collections.addAll(mArgs, args); + } + + return ReflectionUtils.invokeMethod(SERVICE_REQUEST, jredis, Command.valueOf(command.trim().toUpperCase()), + mArgs.toArray(new byte[mArgs.size()][])); + + } + public void close() throws RedisSystemException { isClosed = true; @@ -88,37 +112,37 @@ public class JredisConnection implements RedisConnection { } } - + public JRedis getNativeConnection() { return jredis; } - + public boolean isClosed() { return isClosed; } - + public boolean isQueueing() { return false; } - + public boolean isPipelined() { return false; } - + public void openPipeline() { throw new UnsupportedOperationException("Pipelining not supported by JRedis"); } - + public List closePipeline() { return Collections.emptyList(); } - + public List sort(byte[] key, SortParameters params) { Sort sort = jredis.sort(JredisUtils.decode(key)); JredisUtils.applySortingParams(sort, params, null); @@ -129,7 +153,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long sort(byte[] key, SortParameters params, byte[] storeKey) { Sort sort = jredis.sort(JredisUtils.decode(key)); JredisUtils.applySortingParams(sort, params, null); @@ -140,7 +164,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long dbSize() { try { return jredis.dbsize(); @@ -149,7 +173,7 @@ public class JredisConnection implements RedisConnection { } } - + public void flushDb() { try { jredis.flushdb(); @@ -158,7 +182,7 @@ public class JredisConnection implements RedisConnection { } } - + public void flushAll() { try { jredis.flushall(); @@ -167,7 +191,7 @@ public class JredisConnection implements RedisConnection { } } - + public byte[] echo(byte[] message) { try { return jredis.echo(message); @@ -176,7 +200,7 @@ public class JredisConnection implements RedisConnection { } } - + public String ping() { try { jredis.ping(); @@ -186,7 +210,7 @@ public class JredisConnection implements RedisConnection { } } - + public void bgSave() { try { jredis.bgsave(); @@ -195,7 +219,7 @@ public class JredisConnection implements RedisConnection { } } - + public void bgWriteAof() { try { jredis.bgrewriteaof(); @@ -204,7 +228,7 @@ public class JredisConnection implements RedisConnection { } } - + public void save() { try { jredis.save(); @@ -213,12 +237,12 @@ public class JredisConnection implements RedisConnection { } } - + public List getConfig(String pattern) { throw new UnsupportedOperationException(); } - + public Properties info() { try { return JredisUtils.info(jredis.info()); @@ -227,7 +251,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long lastSave() { try { return jredis.lastsave(); @@ -236,22 +260,22 @@ public class JredisConnection implements RedisConnection { } } - + public void setConfig(String param, String value) { throw new UnsupportedOperationException(); } - + public void resetConfigStats() { throw new UnsupportedOperationException(); } - + public void shutdown() { throw new UnsupportedOperationException(); } - + public Long del(byte[]... keys) { try { return jredis.del(JredisUtils.decodeMultiple(keys)); @@ -260,7 +284,7 @@ public class JredisConnection implements RedisConnection { } } - + public void discard() { try { jredis.discard(); @@ -269,12 +293,12 @@ public class JredisConnection implements RedisConnection { } } - + public List exec() { throw new UnsupportedOperationException(); } - + public Boolean exists(byte[] key) { try { return jredis.exists(JredisUtils.decode(key)); @@ -283,7 +307,7 @@ public class JredisConnection implements RedisConnection { } } - + public Boolean expire(byte[] key, long seconds) { try { return jredis.expire(JredisUtils.decode(key), (int) seconds); @@ -292,7 +316,7 @@ public class JredisConnection implements RedisConnection { } } - + public Boolean expireAt(byte[] key, long unixTime) { try { return jredis.expireat(JredisUtils.decode(key), unixTime); @@ -301,7 +325,7 @@ public class JredisConnection implements RedisConnection { } } - + public Set keys(byte[] pattern) { try { return JredisUtils.convertToSet(jredis.keys(JredisUtils.decode(pattern))); @@ -310,18 +334,18 @@ public class JredisConnection implements RedisConnection { } } - + public void multi() { throw new UnsupportedOperationException(); } - + public Boolean persist(byte[] key) { throw new UnsupportedOperationException(); } - + public Boolean move(byte[] key, int dbIndex) { try { return jredis.move(JredisUtils.decode(key), dbIndex); @@ -330,7 +354,7 @@ public class JredisConnection implements RedisConnection { } } - + public byte[] randomKey() { try { return JredisUtils.encode(jredis.randomkey()); @@ -339,7 +363,7 @@ public class JredisConnection implements RedisConnection { } } - + public void rename(byte[] oldName, byte[] newName) { try { jredis.rename(JredisUtils.decode(oldName), JredisUtils.decode(newName)); @@ -348,7 +372,7 @@ public class JredisConnection implements RedisConnection { } } - + public Boolean renameNX(byte[] oldName, byte[] newName) { try { return jredis.renamenx(JredisUtils.decode(oldName), JredisUtils.decode(newName)); @@ -357,12 +381,12 @@ public class JredisConnection implements RedisConnection { } } - + public void select(int dbIndex) { throw new UnsupportedOperationException(); } - + public Long ttl(byte[] key) { try { return jredis.ttl(JredisUtils.decode(key)); @@ -371,7 +395,7 @@ public class JredisConnection implements RedisConnection { } } - + public DataType type(byte[] key) { try { return JredisUtils.convertDataType(jredis.type(JredisUtils.decode(key))); @@ -380,12 +404,12 @@ public class JredisConnection implements RedisConnection { } } - + public void unwatch() { throw new UnsupportedOperationException(); } - + public void watch(byte[]... keys) { throw new UnsupportedOperationException(); } @@ -394,7 +418,7 @@ public class JredisConnection implements RedisConnection { // String operations // - + public byte[] get(byte[] key) { try { return jredis.get(JredisUtils.decode(key)); @@ -403,7 +427,7 @@ public class JredisConnection implements RedisConnection { } } - + public void set(byte[] key, byte[] value) { try { jredis.set(JredisUtils.decode(key), value); @@ -412,7 +436,7 @@ public class JredisConnection implements RedisConnection { } } - + public byte[] getSet(byte[] key, byte[] value) { try { return jredis.getset(JredisUtils.decode(key), value); @@ -421,7 +445,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long append(byte[] key, byte[] value) { try { return jredis.append(JredisUtils.decode(key), value); @@ -430,7 +454,7 @@ public class JredisConnection implements RedisConnection { } } - + public List mGet(byte[]... keys) { try { return jredis.mget(JredisUtils.decodeMultiple(keys)); @@ -439,7 +463,7 @@ public class JredisConnection implements RedisConnection { } } - + public void mSet(Map tuple) { try { jredis.mset(JredisUtils.decodeMap(tuple)); @@ -448,7 +472,7 @@ public class JredisConnection implements RedisConnection { } } - + public void mSetNX(Map tuple) { try { jredis.msetnx(JredisUtils.decodeMap(tuple)); @@ -457,12 +481,12 @@ public class JredisConnection implements RedisConnection { } } - + public void setEx(byte[] key, long seconds, byte[] value) { throw new UnsupportedOperationException(); } - + public Boolean setNX(byte[] key, byte[] value) { try { return jredis.setnx(JredisUtils.decode(key), value); @@ -471,7 +495,7 @@ public class JredisConnection implements RedisConnection { } } - + public byte[] getRange(byte[] key, long start, long end) { try { return jredis.substr(JredisUtils.decode(key), start, end); @@ -480,7 +504,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long decr(byte[] key) { try { return jredis.decr(JredisUtils.decode(key)); @@ -489,7 +513,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long decrBy(byte[] key, long value) { try { return jredis.decrby(JredisUtils.decode(key), (int) value); @@ -498,7 +522,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long incr(byte[] key) { try { return jredis.incr(JredisUtils.decode(key)); @@ -507,7 +531,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long incrBy(byte[] key, long value) { try { return jredis.incrby(JredisUtils.decode(key), (int) value); @@ -516,22 +540,22 @@ public class JredisConnection implements RedisConnection { } } - + public Boolean getBit(byte[] key, long offset) { throw new UnsupportedOperationException(); } - + public void setBit(byte[] key, long offset, boolean value) { throw new UnsupportedOperationException(); } - + public void setRange(byte[] key, byte[] value, long start) { throw new UnsupportedOperationException(); } - + public Long strLen(byte[] key) { throw new UnsupportedOperationException(); } @@ -540,17 +564,17 @@ public class JredisConnection implements RedisConnection { // List commands // - + public List bLPop(int timeout, byte[]... keys) { throw new UnsupportedOperationException(); } - + public List bRPop(int timeout, byte[]... keys) { throw new UnsupportedOperationException(); } - + public byte[] lIndex(byte[] key, long index) { try { return jredis.lindex(JredisUtils.decode(key), index); @@ -559,7 +583,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long lLen(byte[] key) { try { return jredis.llen(JredisUtils.decode(key)); @@ -568,7 +592,7 @@ public class JredisConnection implements RedisConnection { } } - + public byte[] lPop(byte[] key) { try { return jredis.lpop(JredisUtils.decode(key)); @@ -577,7 +601,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long lPush(byte[] key, byte[] value) { try { jredis.lpush(JredisUtils.decode(key), value); @@ -587,7 +611,7 @@ public class JredisConnection implements RedisConnection { } } - + public List lRange(byte[] key, long start, long end) { try { List lrange = jredis.lrange(JredisUtils.decode(key), start, end); @@ -598,7 +622,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long lRem(byte[] key, long count, byte[] value) { try { return jredis.lrem(JredisUtils.decode(key), value, (int) count); @@ -607,7 +631,7 @@ public class JredisConnection implements RedisConnection { } } - + public void lSet(byte[] key, long index, byte[] value) { try { jredis.lset(JredisUtils.decode(key), index, value); @@ -616,7 +640,7 @@ public class JredisConnection implements RedisConnection { } } - + public void lTrim(byte[] key, long start, long end) { try { jredis.ltrim(JredisUtils.decode(key), start, end); @@ -625,7 +649,7 @@ public class JredisConnection implements RedisConnection { } } - + public byte[] rPop(byte[] key) { try { return jredis.rpop(JredisUtils.decode(key)); @@ -634,7 +658,7 @@ public class JredisConnection implements RedisConnection { } } - + public byte[] rPopLPush(byte[] srcKey, byte[] dstKey) { try { return jredis.rpoplpush(JredisUtils.decode(srcKey), JredisUtils.decode(dstKey)); @@ -643,7 +667,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long rPush(byte[] key, byte[] value) { try { jredis.rpush(JredisUtils.decode(key), value); @@ -653,22 +677,22 @@ public class JredisConnection implements RedisConnection { } } - + public Long lInsert(byte[] key, Position where, byte[] pivot, byte[] value) { throw new UnsupportedOperationException(); } - + public byte[] bRPopLPush(int timeout, byte[] srcKey, byte[] dstKey) { throw new UnsupportedOperationException(); } - + public Long lPushX(byte[] key, byte[] value) { throw new UnsupportedOperationException(); } - + public Long rPushX(byte[] key, byte[] value) { throw new UnsupportedOperationException(); } @@ -678,7 +702,7 @@ public class JredisConnection implements RedisConnection { // Set commands // - + public Boolean sAdd(byte[] key, byte[] value) { try { return jredis.sadd(JredisUtils.decode(key), value); @@ -687,7 +711,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long sCard(byte[] key) { try { return jredis.scard(JredisUtils.decode(key)); @@ -696,7 +720,7 @@ public class JredisConnection implements RedisConnection { } } - + public Set sDiff(byte[]... keys) { String destKey = JredisUtils.decode(keys[0]); String[] sets = JredisUtils.decodeMultiple(Arrays.copyOfRange(keys, 1, keys.length)); @@ -709,7 +733,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long sDiffStore(byte[] destKey, byte[]... keys) { String destSet = JredisUtils.decode(destKey); String[] sets = JredisUtils.decodeMultiple(keys); @@ -722,7 +746,7 @@ public class JredisConnection implements RedisConnection { } } - + public Set sInter(byte[]... keys) { String set1 = JredisUtils.decode(keys[0]); String[] sets = JredisUtils.decodeMultiple(Arrays.copyOfRange(keys, 1, keys.length)); @@ -735,7 +759,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long sInterStore(byte[] destKey, byte[]... keys) { String destSet = JredisUtils.decode(destKey); String[] sets = JredisUtils.decodeMultiple(keys); @@ -748,7 +772,7 @@ public class JredisConnection implements RedisConnection { } } - + public Boolean sIsMember(byte[] key, byte[] value) { try { return jredis.sismember(JredisUtils.decode(key), value); @@ -757,7 +781,7 @@ public class JredisConnection implements RedisConnection { } } - + public Set sMembers(byte[] key) { try { return new LinkedHashSet(jredis.smembers(JredisUtils.decode(key))); @@ -766,7 +790,7 @@ public class JredisConnection implements RedisConnection { } } - + public Boolean sMove(byte[] srcKey, byte[] destKey, byte[] value) { try { return jredis.smove(JredisUtils.decode(srcKey), JredisUtils.decode(destKey), value); @@ -775,7 +799,7 @@ public class JredisConnection implements RedisConnection { } } - + public byte[] sPop(byte[] key) { try { return jredis.spop(JredisUtils.decode(key)); @@ -784,7 +808,7 @@ public class JredisConnection implements RedisConnection { } } - + public byte[] sRandMember(byte[] key) { try { return jredis.srandmember(JredisUtils.decode(key)); @@ -793,7 +817,7 @@ public class JredisConnection implements RedisConnection { } } - + public Boolean sRem(byte[] key, byte[] value) { try { return jredis.srem(JredisUtils.decode(key), value); @@ -802,7 +826,7 @@ public class JredisConnection implements RedisConnection { } } - + public Set sUnion(byte[]... keys) { String set1 = JredisUtils.decode(keys[0]); String[] sets = JredisUtils.decodeMultiple(Arrays.copyOfRange(keys, 1, keys.length)); @@ -814,7 +838,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long sUnionStore(byte[] destKey, byte[]... keys) { String destSet = JredisUtils.decode(destKey); String[] sets = JredisUtils.decodeMultiple(keys); @@ -832,7 +856,7 @@ public class JredisConnection implements RedisConnection { // ZSet commands // - + public Boolean zAdd(byte[] key, double score, byte[] value) { try { return jredis.zadd(JredisUtils.decode(key), score, value); @@ -841,7 +865,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long zCard(byte[] key) { try { return jredis.zcard(JredisUtils.decode(key)); @@ -850,7 +874,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long zCount(byte[] key, double min, double max) { try { return jredis.zcount(JredisUtils.decode(key), min, max); @@ -859,7 +883,7 @@ public class JredisConnection implements RedisConnection { } } - + public Double zIncrBy(byte[] key, double increment, byte[] value) { try { return jredis.zincrby(JredisUtils.decode(key), increment, value); @@ -868,17 +892,17 @@ public class JredisConnection implements RedisConnection { } } - + public Long zInterStore(byte[] destKey, Aggregate aggregate, int[] weights, byte[]... sets) { throw new UnsupportedOperationException(); } - + public Long zInterStore(byte[] destKey, byte[]... sets) { throw new UnsupportedOperationException(); } - + public Set zRange(byte[] key, long start, long end) { try { return new LinkedHashSet(jredis.zrange(JredisUtils.decode(key), start, end)); @@ -887,12 +911,12 @@ public class JredisConnection implements RedisConnection { } } - + public Set zRangeWithScores(byte[] key, long start, long end) { throw new UnsupportedOperationException(); } - + public Set zRangeByScore(byte[] key, double min, double max) { try { return new LinkedHashSet(jredis.zrangebyscore(JredisUtils.decode(key), min, max)); @@ -901,42 +925,42 @@ public class JredisConnection implements RedisConnection { } } - + public Set zRangeByScoreWithScores(byte[] key, double min, double max) { throw new UnsupportedOperationException(); } - + public Set zRangeByScore(byte[] key, double min, double max, long offset, long count) { throw new UnsupportedOperationException(); } - + public Set zRangeByScoreWithScores(byte[] key, double min, double max, long offset, long count) { throw new UnsupportedOperationException(); } - + public Set zRevRangeByScore(byte[] key, double min, double max, long offset, long count) { throw new UnsupportedOperationException(); } - + public Set zRevRangeByScore(byte[] key, double min, double max) { throw new UnsupportedOperationException(); } - + public Set zRevRangeByScoreWithScores(byte[] key, double min, double max, long offset, long count) { throw new UnsupportedOperationException(); } - + public Set zRevRangeByScoreWithScores(byte[] key, double min, double max) { throw new UnsupportedOperationException(); } - + public Long zRank(byte[] key, byte[] value) { try { return jredis.zrank(JredisUtils.decode(key), value); @@ -945,7 +969,7 @@ public class JredisConnection implements RedisConnection { } } - + public Boolean zRem(byte[] key, byte[] value) { try { return jredis.zrem(JredisUtils.decode(key), value); @@ -954,7 +978,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long zRemRange(byte[] key, long start, long end) { try { return jredis.zremrangebyrank(JredisUtils.decode(key), start, end); @@ -963,7 +987,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long zRemRangeByScore(byte[] key, double min, double max) { try { return jredis.zremrangebyscore(JredisUtils.decode(key), min, max); @@ -972,7 +996,7 @@ public class JredisConnection implements RedisConnection { } } - + public Set zRevRange(byte[] key, long start, long end) { try { return new LinkedHashSet(jredis.zrevrange(JredisUtils.decode(key), start, end)); @@ -981,12 +1005,12 @@ public class JredisConnection implements RedisConnection { } } - + public Set zRevRangeWithScores(byte[] key, long start, long end) { throw new UnsupportedOperationException(); } - + public Long zRevRank(byte[] key, byte[] value) { try { return jredis.zrevrank(JredisUtils.decode(key), value); @@ -995,7 +1019,7 @@ public class JredisConnection implements RedisConnection { } } - + public Double zScore(byte[] key, byte[] value) { try { return jredis.zscore(JredisUtils.decode(key), value); @@ -1009,17 +1033,17 @@ public class JredisConnection implements RedisConnection { // Hash commands // - + public Long zUnionStore(byte[] destKey, Aggregate aggregate, int[] weights, byte[]... sets) { throw new UnsupportedOperationException(); } - + public Long zUnionStore(byte[] destKey, byte[]... sets) { throw new UnsupportedOperationException(); } - + public Boolean hDel(byte[] key, byte[] field) { try { return jredis.hdel(JredisUtils.decode(key), JredisUtils.decode(field)); @@ -1028,7 +1052,7 @@ public class JredisConnection implements RedisConnection { } } - + public Boolean hExists(byte[] key, byte[] field) { try { return jredis.hexists(JredisUtils.decode(key), JredisUtils.decode(field)); @@ -1037,7 +1061,7 @@ public class JredisConnection implements RedisConnection { } } - + public byte[] hGet(byte[] key, byte[] field) { try { return jredis.hget(JredisUtils.decode(key), JredisUtils.decode(field)); @@ -1046,7 +1070,7 @@ public class JredisConnection implements RedisConnection { } } - + public Map hGetAll(byte[] key) { try { return JredisUtils.encodeMap(jredis.hgetall(JredisUtils.decode(key))); @@ -1055,12 +1079,12 @@ public class JredisConnection implements RedisConnection { } } - + public Long hIncrBy(byte[] key, byte[] field, long delta) { throw new UnsupportedOperationException(); } - + public Set hKeys(byte[] key) { try { return new LinkedHashSet(JredisUtils.convertToSet(jredis.hkeys(JredisUtils.decode(key)))); @@ -1069,7 +1093,7 @@ public class JredisConnection implements RedisConnection { } } - + public Long hLen(byte[] key) { try { return jredis.hlen(JredisUtils.decode(key)); @@ -1078,17 +1102,17 @@ public class JredisConnection implements RedisConnection { } } - + public List hMGet(byte[] key, byte[]... fields) { throw new UnsupportedOperationException(); } - + public void hMSet(byte[] key, Map values) { throw new UnsupportedOperationException(); } - + public Boolean hSet(byte[] key, byte[] field, byte[] value) { try { return jredis.hset(JredisUtils.decode(key), JredisUtils.decode(field), value); @@ -1097,12 +1121,12 @@ public class JredisConnection implements RedisConnection { } } - + public Boolean hSetNX(byte[] key, byte[] field, byte[] value) { throw new UnsupportedOperationException(); } - + public List hVals(byte[] key) { try { return jredis.hvals(JredisUtils.decode(key)); @@ -1115,27 +1139,27 @@ public class JredisConnection implements RedisConnection { // PubSub commands // - + public Subscription getSubscription() { return null; } - + public boolean isSubscribed() { return false; } - + public void pSubscribe(MessageListener listener, byte[]... patterns) { throw new UnsupportedOperationException(); } - + public Long publish(byte[] channel, byte[] message) { throw new UnsupportedOperationException(); } - + public void subscribe(MessageListener listener, byte[]... channels) { throw new UnsupportedOperationException(); } diff --git a/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java b/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java index 6dc0354a9..94badf377 100644 --- a/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java +++ b/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java @@ -336,5 +336,8 @@ public abstract class AbstractConnectionIntegrationTests { @Test public void testExecuteNative() throws Exception { connection.execute("ZADD", getClass() + "#testExecuteNative", "0.9090", "item"); + //connection.execute("PiNg"); + connection.execute("iNFo"); + connection.execute("SET ", getClass() + "testSetNative", UUID.randomUUID().toString()); } } \ No newline at end of file From 05c4d6c7935ed4d5699e11ca96ffd6687894e979 Mon Sep 17 00:00:00 2001 From: Costin Leau Date: Thu, 21 Jun 2012 17:33:54 +0300 Subject: [PATCH 3/5] add disambiguating method on StringRedisConnection --- .../data/redis/connection/DefaultStringRedisConnection.java | 4 ++++ .../data/redis/connection/StringRedisConnection.java | 2 ++ 2 files changed, 6 insertions(+) diff --git a/src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java b/src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java index 9714e51c2..42d2bf091 100644 --- a/src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java @@ -1154,6 +1154,10 @@ public class DefaultStringRedisConnection implements StringRedisConnection { } + public Object execute(String command) { + return execute(command, (byte[][]) null); + } + public Object execute(String command, byte[]... args) { return delegate.execute(command, args); } diff --git a/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java b/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java index 4d92b09f7..39794900d 100644 --- a/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java @@ -44,6 +44,8 @@ public interface StringRedisConnection extends RedisConnection { Object execute(String command, String... args); + Object execute(String command); + Boolean exists(String key); Long del(String... keys); From 68ef9bcb93e72dc53230bffb95664dff4504a2d7 Mon Sep 17 00:00:00 2001 From: Costin Leau Date: Thu, 21 Jun 2012 17:34:35 +0300 Subject: [PATCH 4/5] improve array check --- .../data/redis/connection/jedis/JedisConnection.java | 6 ++---- .../data/redis/connection/jredis/JredisConnection.java | 3 ++- 2 files changed, 4 insertions(+), 5 deletions(-) diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java index 2ad170877..746f6178d 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java @@ -34,6 +34,7 @@ import org.springframework.data.redis.connection.RedisSubscribedConnectionExcept import org.springframework.data.redis.connection.SortParameters; import org.springframework.data.redis.connection.Subscription; import org.springframework.util.Assert; +import org.springframework.util.ObjectUtils; import org.springframework.util.ReflectionUtils; import redis.clients.jedis.BinaryJedis; @@ -135,10 +136,7 @@ public class JedisConnection implements RedisConnection { public Object execute(String command, byte[]... args) { Assert.hasText(command, "a valid command needs to be specified"); List mArgs = new ArrayList(); - if (args == null) { - mArgs.add(new byte[0]); - } - else { + if (!ObjectUtils.isEmpty(args)) { Collections.addAll(mArgs, args); } diff --git a/src/main/java/org/springframework/data/redis/connection/jredis/JredisConnection.java b/src/main/java/org/springframework/data/redis/connection/jredis/JredisConnection.java index e82608e4a..f0cdc25d1 100644 --- a/src/main/java/org/springframework/data/redis/connection/jredis/JredisConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/jredis/JredisConnection.java @@ -41,6 +41,7 @@ import org.springframework.data.redis.connection.RedisConnection; import org.springframework.data.redis.connection.SortParameters; import org.springframework.data.redis.connection.Subscription; import org.springframework.util.Assert; +import org.springframework.util.ObjectUtils; import org.springframework.util.ReflectionUtils; /** @@ -89,7 +90,7 @@ public class JredisConnection implements RedisConnection { public Object execute(String command, byte[]... args) { Assert.hasText(command, "a valid command needs to be specified"); List mArgs = new ArrayList(); - if (args != null) { + if (!ObjectUtils.isEmpty(args)) { Collections.addAll(mArgs, args); } From 2fc50d466d1eed951e52bea3130ccd90aa07478e Mon Sep 17 00:00:00 2001 From: Costin Leau Date: Thu, 21 Jun 2012 18:35:13 +0300 Subject: [PATCH 5/5] add execute native for RjcConnection --- .../redis/connection/rjc/RjcConnection.java | 276 +++++++++--------- 1 file changed, 143 insertions(+), 133 deletions(-) diff --git a/src/main/java/org/springframework/data/redis/connection/rjc/RjcConnection.java b/src/main/java/org/springframework/data/redis/connection/rjc/RjcConnection.java index 67a3b5801..621dc9591 100644 --- a/src/main/java/org/springframework/data/redis/connection/rjc/RjcConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/rjc/RjcConnection.java @@ -28,6 +28,7 @@ import org.idevlab.rjc.SessionFactoryImpl; import org.idevlab.rjc.SortingParams; import org.idevlab.rjc.ZParams; import org.idevlab.rjc.message.RedisNodeSubscriber; +import org.idevlab.rjc.protocol.Protocol.Command; import org.springframework.dao.DataAccessException; import org.springframework.data.redis.RedisSystemException; import org.springframework.data.redis.connection.DataType; @@ -36,6 +37,8 @@ import org.springframework.data.redis.connection.RedisConnection; import org.springframework.data.redis.connection.RedisSubscribedConnectionException; import org.springframework.data.redis.connection.SortParameters; import org.springframework.data.redis.connection.Subscription; +import org.springframework.util.Assert; +import org.springframework.util.ObjectUtils; /** * {@code RedisConnection} implementation on top of rjc library. @@ -49,6 +52,7 @@ public class RjcConnection implements RedisConnection { private final Client client; private final Session session; + private final org.idevlab.rjc.ds.RedisConnection connection; private volatile Client pipeline; private volatile RjcSubscription subscription; @@ -60,6 +64,7 @@ public class RjcConnection implements RedisConnection { subscriber = new RedisNodeSubscriber(); subscriber.setDataSource(new SingleDataSource(new CloseSuppressingRjcConnection(connection))); client = new Client(connection); + this.connection = connection; this.dbIndex = dbIndex; @@ -76,7 +81,13 @@ public class RjcConnection implements RedisConnection { return new RedisSystemException("Unknown rjc exception", ex); } - + public Object execute(String command, byte[]... args) { + Assert.hasText(command, "a valid command needs to be specified"); + connection.sendCommand(Command.valueOf(command.trim().toUpperCase()), + (ObjectUtils.isEmpty(args) ? new byte[0][] : args)); + return connection.getAll(); + } + public void close() throws DataAccessException { isClosed = true; @@ -94,27 +105,27 @@ public class RjcConnection implements RedisConnection { } - + public boolean isClosed() { return isClosed; } - + public Session getNativeConnection() { return session; } - + public boolean isQueueing() { return client.isInMulti(); } - + public boolean isPipelined() { return (pipeline != null); } - + public void openPipeline() { if (pipeline == null) { pipeline = client; @@ -122,7 +133,6 @@ public class RjcConnection implements RedisConnection { } @SuppressWarnings("unchecked") - public List closePipeline() { if (pipeline != null) { List execute = client.getAll(); @@ -133,7 +143,7 @@ public class RjcConnection implements RedisConnection { return Collections.emptyList(); } - + public List sort(byte[] key, SortParameters params) { SortingParams sortParams = RjcUtils.convertSortParams(params); @@ -157,7 +167,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long sort(byte[] key, SortParameters params, byte[] sortKey) { SortingParams sortParams = RjcUtils.convertSortParams(params); @@ -182,7 +192,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long dbSize() { try { if (isPipelined()) { @@ -196,7 +206,7 @@ public class RjcConnection implements RedisConnection { } - + public void flushDb() { try { if (isPipelined()) { @@ -209,7 +219,7 @@ public class RjcConnection implements RedisConnection { } } - + public void flushAll() { try { if (isPipelined()) { @@ -222,7 +232,7 @@ public class RjcConnection implements RedisConnection { } } - + public void bgSave() { try { if (isPipelined()) { @@ -235,7 +245,7 @@ public class RjcConnection implements RedisConnection { } } - + public void bgWriteAof() { try { if (isPipelined()) { @@ -248,7 +258,7 @@ public class RjcConnection implements RedisConnection { } } - + public void save() { try { if (isPipelined()) { @@ -261,7 +271,7 @@ public class RjcConnection implements RedisConnection { } } - + public List getConfig(String param) { try { if (isPipelined()) { @@ -274,7 +284,7 @@ public class RjcConnection implements RedisConnection { } } - + public Properties info() { try { if (isPipelined()) { @@ -287,7 +297,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long lastSave() { try { if (isPipelined()) { @@ -300,7 +310,7 @@ public class RjcConnection implements RedisConnection { } } - + public void setConfig(String param, String value) { try { if (isPipelined()) { @@ -314,7 +324,7 @@ public class RjcConnection implements RedisConnection { } - + public void resetConfigStats() { try { if (isPipelined()) { @@ -328,7 +338,7 @@ public class RjcConnection implements RedisConnection { } } - + public void shutdown() { try { if (isPipelined()) { @@ -341,7 +351,7 @@ public class RjcConnection implements RedisConnection { } } - + public byte[] echo(byte[] message) { String stringMsg = RjcUtils.decode(message); try { @@ -355,7 +365,7 @@ public class RjcConnection implements RedisConnection { } } - + public String ping() { try { if (isPipelined()) { @@ -367,7 +377,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long del(byte[]... keys) { String[] stringKeys = RjcUtils.decodeMultiple(keys); @@ -382,7 +392,7 @@ public class RjcConnection implements RedisConnection { } } - + public void discard() { try { if (isPipelined()) { @@ -396,7 +406,7 @@ public class RjcConnection implements RedisConnection { } } - + public List exec() { try { if (isPipelined()) { @@ -409,7 +419,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean exists(byte[] key) { String stringKey = RjcUtils.decode(key); @@ -424,7 +434,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean expire(byte[] key, long seconds) { String stringKey = RjcUtils.decode(key); @@ -439,7 +449,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean expireAt(byte[] key, long unixTime) { String stringKey = RjcUtils.decode(key); @@ -454,7 +464,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set keys(byte[] pattern) { String stringKey = RjcUtils.decode(pattern); @@ -469,7 +479,7 @@ public class RjcConnection implements RedisConnection { } } - + public void multi() { if (isQueueing()) { return; @@ -485,7 +495,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean persist(byte[] key) { String stringKey = RjcUtils.decode(key); @@ -500,7 +510,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean move(byte[] key, int dbIndex) { String stringKey = RjcUtils.decode(key); @@ -515,7 +525,7 @@ public class RjcConnection implements RedisConnection { } } - + public byte[] randomKey() { try { if (isPipelined()) { @@ -528,7 +538,7 @@ public class RjcConnection implements RedisConnection { } } - + public void rename(byte[] oldName, byte[] newName) { String stringOldKey = RjcUtils.decode(oldName); String stringNewKey = RjcUtils.decode(newName); @@ -544,7 +554,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean renameNX(byte[] oldName, byte[] newName) { String stringOldKey = RjcUtils.decode(oldName); String stringNewKey = RjcUtils.decode(newName); @@ -560,7 +570,7 @@ public class RjcConnection implements RedisConnection { } } - + public void select(int dbIndex) { try { if (isPipelined()) { @@ -573,7 +583,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long ttl(byte[] key) { String stringKey = RjcUtils.decode(key); @@ -588,7 +598,7 @@ public class RjcConnection implements RedisConnection { } } - + public DataType type(byte[] key) { String stringKey = RjcUtils.decode(key); @@ -603,7 +613,7 @@ public class RjcConnection implements RedisConnection { } } - + public void unwatch() { try { if (isPipelined()) { @@ -617,7 +627,7 @@ public class RjcConnection implements RedisConnection { } } - + public void watch(byte[]... keys) { String[] stringKeys = RjcUtils.decodeMultiple(keys); @@ -641,7 +651,7 @@ public class RjcConnection implements RedisConnection { // String commands // - + public byte[] get(byte[] key) { String stringKey = RjcUtils.decode(key); @@ -657,7 +667,7 @@ public class RjcConnection implements RedisConnection { } } - + public void set(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -674,7 +684,7 @@ public class RjcConnection implements RedisConnection { } - + public byte[] getSet(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -690,7 +700,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long append(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -706,7 +716,7 @@ public class RjcConnection implements RedisConnection { } } - + public List mGet(byte[]... keys) { String[] stringKeys = RjcUtils.decodeMultiple(keys); @@ -721,7 +731,7 @@ public class RjcConnection implements RedisConnection { } } - + public void mSet(Map tuples) { String[] decodeMap = RjcUtils.flatten(tuples); @@ -736,7 +746,7 @@ public class RjcConnection implements RedisConnection { } } - + public void mSetNX(Map tuples) { String[] decodeMap = RjcUtils.flatten(tuples); @@ -752,7 +762,7 @@ public class RjcConnection implements RedisConnection { } } - + public void setEx(byte[] key, long time, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -768,7 +778,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean setNX(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -784,7 +794,7 @@ public class RjcConnection implements RedisConnection { } } - + public byte[] getRange(byte[] key, long start, long end) { String stringKey = RjcUtils.decode(key); @@ -799,7 +809,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long decr(byte[] key) { String stringKey = RjcUtils.decode(key); try { @@ -814,7 +824,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long decrBy(byte[] key, long value) { String stringKey = RjcUtils.decode(key); try { @@ -829,7 +839,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long incr(byte[] key) { String stringKey = RjcUtils.decode(key); @@ -845,7 +855,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long incrBy(byte[] key, long value) { String stringKey = RjcUtils.decode(key); @@ -861,7 +871,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean getBit(byte[] key, long offset) { String stringKey = RjcUtils.decode(key); @@ -876,7 +886,7 @@ public class RjcConnection implements RedisConnection { } } - + public void setBit(byte[] key, long offset, boolean value) { String stringKey = RjcUtils.decode(key); @@ -891,7 +901,7 @@ public class RjcConnection implements RedisConnection { } } - + public void setRange(byte[] key, byte[] value, long offset) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -907,7 +917,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long strLen(byte[] key) { String stringKey = RjcUtils.decode(key); @@ -926,7 +936,7 @@ public class RjcConnection implements RedisConnection { // List commands // - + public Long lPush(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -942,7 +952,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long rPush(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -959,7 +969,7 @@ public class RjcConnection implements RedisConnection { } } - + public List bLPop(int timeout, byte[]... keys) { String[] stringKeys = RjcUtils.decodeMultiple(keys); @@ -974,7 +984,7 @@ public class RjcConnection implements RedisConnection { } } - + public List bRPop(int timeout, byte[]... keys) { String[] stringKeys = RjcUtils.decodeMultiple(keys); @@ -989,7 +999,7 @@ public class RjcConnection implements RedisConnection { } } - + public byte[] lIndex(byte[] key, long index) { String stringKey = RjcUtils.decode(key); @@ -1005,7 +1015,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long lInsert(byte[] key, Position where, byte[] pivot, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -1023,7 +1033,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long lLen(byte[] key) { String stringKey = RjcUtils.decode(key); @@ -1039,7 +1049,7 @@ public class RjcConnection implements RedisConnection { } } - + public byte[] lPop(byte[] key) { String stringKey = RjcUtils.decode(key); @@ -1055,7 +1065,7 @@ public class RjcConnection implements RedisConnection { } } - + public List lRange(byte[] key, long start, long end) { String stringKey = RjcUtils.decode(key); @@ -1071,7 +1081,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long lRem(byte[] key, long count, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -1088,7 +1098,7 @@ public class RjcConnection implements RedisConnection { } } - + public void lSet(byte[] key, long index, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -1104,7 +1114,7 @@ public class RjcConnection implements RedisConnection { } } - + public void lTrim(byte[] key, long start, long end) { String stringKey = RjcUtils.decode(key); @@ -1120,7 +1130,7 @@ public class RjcConnection implements RedisConnection { } } - + public byte[] rPop(byte[] key) { String stringKey = RjcUtils.decode(key); @@ -1136,7 +1146,7 @@ public class RjcConnection implements RedisConnection { } } - + public byte[] rPopLPush(byte[] srcKey, byte[] dstKey) { String stringKey = RjcUtils.decode(srcKey); String stringDest = RjcUtils.decode(dstKey); @@ -1153,7 +1163,7 @@ public class RjcConnection implements RedisConnection { } } - + public byte[] bRPopLPush(int timeout, byte[] srcKey, byte[] dstKey) { String stringKey = RjcUtils.decode(srcKey); String stringDest = RjcUtils.decode(dstKey); @@ -1169,7 +1179,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long lPushX(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -1184,7 +1194,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long rPushX(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -1204,7 +1214,7 @@ public class RjcConnection implements RedisConnection { // Set commands // - + public Boolean sAdd(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -1221,7 +1231,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long sCard(byte[] key) { String stringKey = RjcUtils.decode(key); @@ -1237,7 +1247,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set sDiff(byte[]... keys) { String[] stringKeys = RjcUtils.decodeMultiple(keys); @@ -1253,7 +1263,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long sDiffStore(byte[] destKey, byte[]... keys) { String stringKey = RjcUtils.decode(destKey); String[] stringKeys = RjcUtils.decodeMultiple(keys); @@ -1270,7 +1280,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set sInter(byte[]... keys) { String[] stringKeys = RjcUtils.decodeMultiple(keys); try { @@ -1285,7 +1295,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long sInterStore(byte[] destKey, byte[]... keys) { String stringKey = RjcUtils.decode(destKey); String[] stringKeys = RjcUtils.decodeMultiple(keys); @@ -1301,7 +1311,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean sIsMember(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -1318,7 +1328,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set sMembers(byte[] key) { String stringKey = RjcUtils.decode(key); try { @@ -1333,7 +1343,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean sMove(byte[] srcKey, byte[] destKey, byte[] value) { String stringSrc = RjcUtils.decode(srcKey); String stringDest = RjcUtils.decode(destKey); @@ -1351,7 +1361,7 @@ public class RjcConnection implements RedisConnection { } } - + public byte[] sPop(byte[] key) { String stringKey = RjcUtils.decode(key); try { @@ -1366,7 +1376,7 @@ public class RjcConnection implements RedisConnection { } } - + public byte[] sRandMember(byte[] key) { String stringKey = RjcUtils.decode(key); try { @@ -1381,7 +1391,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean sRem(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -1398,7 +1408,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set sUnion(byte[]... keys) { String[] stringKeys = RjcUtils.decodeMultiple(keys); @@ -1414,7 +1424,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long sUnionStore(byte[] destKey, byte[]... keys) { String stringKey = RjcUtils.decode(destKey); String[] stringKeys = RjcUtils.decodeMultiple(keys); @@ -1435,7 +1445,7 @@ public class RjcConnection implements RedisConnection { // ZSet commands // - + public Boolean zAdd(byte[] key, double score, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -1451,7 +1461,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long zCard(byte[] key) { String stringKey = RjcUtils.decode(key); @@ -1466,7 +1476,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long zCount(byte[] key, double min, double max) { String stringKey = RjcUtils.decode(key); try { @@ -1481,7 +1491,7 @@ public class RjcConnection implements RedisConnection { } } - + public Double zIncrBy(byte[] key, double increment, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -1497,7 +1507,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long zInterStore(byte[] destKey, Aggregate aggregate, int[] weights, byte[]... sets) { String stringKey = RjcUtils.decode(destKey); String[] stringKeys = RjcUtils.decodeMultiple(sets); @@ -1515,7 +1525,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long zInterStore(byte[] destKey, byte[]... sets) { String stringKey = RjcUtils.decode(destKey); String[] stringKeys = RjcUtils.decodeMultiple(sets); @@ -1531,7 +1541,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set zRange(byte[] key, long start, long end) { String stringKey = RjcUtils.decode(key); try { @@ -1546,7 +1556,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set zRangeWithScores(byte[] key, long start, long end) { String stringKey = RjcUtils.decode(key); try { @@ -1561,7 +1571,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set zRangeByScore(byte[] key, double min, double max) { String stringKey = RjcUtils.decode(key); String minString = Double.toString(min); @@ -1578,7 +1588,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set zRangeByScore(byte[] key, double min, double max, long offset, long count) { String stringKey = RjcUtils.decode(key); String minString = Double.toString(min); @@ -1597,7 +1607,7 @@ public class RjcConnection implements RedisConnection { } - + public Set zRevRangeByScore(byte[] key, double min, double max, long offset, long count) { String stringKey = RjcUtils.decode(key); String minString = Double.toString(min); @@ -1615,7 +1625,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set zRevRangeByScore(byte[] key, double min, double max) { String stringKey = RjcUtils.decode(key); String minString = Double.toString(min); @@ -1632,7 +1642,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set zRangeByScoreWithScores(byte[] key, double min, double max) { String stringKey = RjcUtils.decode(key); String minString = Double.toString(min); @@ -1649,7 +1659,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set zRevRangeWithScores(byte[] key, long start, long end) { String stringKey = RjcUtils.decode(key); String minString = Long.toString(start); @@ -1667,7 +1677,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set zRangeByScoreWithScores(byte[] key, double min, double max, long offset, long count) { String stringKey = RjcUtils.decode(key); String minString = Double.toString(min); @@ -1686,7 +1696,7 @@ public class RjcConnection implements RedisConnection { } - + public Set zRevRangeByScoreWithScores(byte[] key, double min, double max, long offset, long count) { String stringKey = RjcUtils.decode(key); String minString = Double.toString(min); @@ -1705,7 +1715,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set zRevRangeByScoreWithScores(byte[] key, double min, double max) { String stringKey = RjcUtils.decode(key); String minString = Double.toString(min); @@ -1723,7 +1733,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long zRank(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -1739,7 +1749,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean zRem(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -1755,7 +1765,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long zRemRange(byte[] key, long start, long end) { String stringKey = RjcUtils.decode(key); try { @@ -1769,7 +1779,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long zRemRangeByScore(byte[] key, double min, double max) { String stringKey = RjcUtils.decode(key); String minString = Double.toString(min); @@ -1786,7 +1796,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set zRevRange(byte[] key, long start, long end) { String stringKey = RjcUtils.decode(key); try { @@ -1801,7 +1811,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long zRevRank(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -1817,7 +1827,7 @@ public class RjcConnection implements RedisConnection { } } - + public Double zScore(byte[] key, byte[] value) { String stringKey = RjcUtils.decode(key); String stringValue = RjcUtils.decode(value); @@ -1833,7 +1843,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long zUnionStore(byte[] destKey, Aggregate aggregate, int[] weights, byte[]... sets) { String stringKey = RjcUtils.decode(destKey); String[] stringKeys = RjcUtils.decodeMultiple(destKey); @@ -1851,7 +1861,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long zUnionStore(byte[] destKey, byte[]... sets) { String stringKey = RjcUtils.decode(destKey); String[] stringKeys = RjcUtils.decodeMultiple(sets); @@ -1871,7 +1881,7 @@ public class RjcConnection implements RedisConnection { // Hash commands // - + public Boolean hSet(byte[] key, byte[] field, byte[] value) { String stringKey = RjcUtils.decode(key); String stringField = RjcUtils.decode(field); @@ -1888,7 +1898,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean hSetNX(byte[] key, byte[] field, byte[] value) { String stringKey = RjcUtils.decode(key); String stringField = RjcUtils.decode(field); @@ -1905,7 +1915,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean hDel(byte[] key, byte[] field) { String stringKey = RjcUtils.decode(key); String stringField = RjcUtils.decode(field); @@ -1921,7 +1931,7 @@ public class RjcConnection implements RedisConnection { } } - + public Boolean hExists(byte[] key, byte[] field) { String stringKey = RjcUtils.decode(key); String stringField = RjcUtils.decode(field); @@ -1937,7 +1947,7 @@ public class RjcConnection implements RedisConnection { } } - + public byte[] hGet(byte[] key, byte[] field) { String stringKey = RjcUtils.decode(key); String stringField = RjcUtils.decode(field); @@ -1953,7 +1963,7 @@ public class RjcConnection implements RedisConnection { } } - + public Map hGetAll(byte[] key) { String stringKey = RjcUtils.decode(key); @@ -1968,7 +1978,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long hIncrBy(byte[] key, byte[] field, long delta) { String stringKey = RjcUtils.decode(key); String stringField = RjcUtils.decode(field); @@ -1984,7 +1994,7 @@ public class RjcConnection implements RedisConnection { } } - + public Set hKeys(byte[] key) { String stringKey = RjcUtils.decode(key); try { @@ -1998,7 +2008,7 @@ public class RjcConnection implements RedisConnection { } } - + public Long hLen(byte[] key) { String stringKey = RjcUtils.decode(key); try { @@ -2012,7 +2022,7 @@ public class RjcConnection implements RedisConnection { } } - + public List hMGet(byte[] key, byte[]... fields) { String stringKey = RjcUtils.decode(key); String[] stringKeys = RjcUtils.decodeMultiple(fields); @@ -2028,7 +2038,7 @@ public class RjcConnection implements RedisConnection { } } - + public void hMSet(byte[] key, Map tuple) { String stringKey = RjcUtils.decode(key); Map stringTuple = RjcUtils.decodeMap(tuple); @@ -2044,7 +2054,7 @@ public class RjcConnection implements RedisConnection { } } - + public List hVals(byte[] key) { String stringKey = RjcUtils.decode(key); try { @@ -2063,7 +2073,7 @@ public class RjcConnection implements RedisConnection { // // Pub/Sub functionality // - + public Long publish(byte[] channel, byte[] message) { try { if (isQueueing()) { @@ -2078,17 +2088,17 @@ public class RjcConnection implements RedisConnection { } } - + public Subscription getSubscription() { return subscription; } - + public boolean isSubscribed() { return (subscription != null && subscription.isAlive()); } - + public void pSubscribe(MessageListener listener, byte[]... patterns) { if (isSubscribed()) { throw new RedisSubscribedConnectionException( @@ -2112,7 +2122,7 @@ public class RjcConnection implements RedisConnection { } } - + public void subscribe(MessageListener listener, byte[]... channels) { if (isSubscribed()) { throw new RedisSubscribedConnectionException(