Add support for COPY.

Closes #2040
Original pull request: #2059.

src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java

@@ -70,6 +70,7 @@ import org.springframework.util.ObjectUtils;
  * @author Tugdual Grall
  * @author Andrey Shlykov
  * @author dengliming
+ * @author ihaohong
  */
 public class DefaultStringRedisConnection implements StringRedisConnection, DecoratedRedisConnection {
 
@@ -276,6 +277,15 @@ public class DefaultStringRedisConnection implements StringRedisConnection, Deco
 		return convertAndReturn(delegate.del(keys), Converters.identityConverter());
 	}
 
+	/*
+	 * (non-Javadoc)
+	 * @see org.springframework.data.redis.connection.RedisKeyCommands#copy(byte[], byte[])
+	 */
+	@Override
+	public Boolean copy(byte[] sourceKey, byte[] targetKey) {
+		return convertAndReturn(delegate.copy(sourceKey, targetKey), Converters.identityConverter());
+	}
+
 	/*
 	 * (non-Javadoc)
 	 * @see org.springframework.data.redis.connection.RedisKeyCommands#unlink(byte[][])
@@ -1917,6 +1927,15 @@ public class DefaultStringRedisConnection implements StringRedisConnection, Deco
 		return del(serializeMulti(keys));
 	}
 
+	/*
+	 * (non-Javadoc)
+	 * @see org.springframework.data.redis.connection.StringRedisConnection#copy(java.lang.String[])
+	 */
+	@Override
+	public Boolean copy(String sourceKey, String targetKey) {
+		return copy(serialize(sourceKey), serialize(targetKey));
+	}
+
 	/*
 	 * (non-Javadoc)
 	 * @see org.springframework.data.redis.connection.StringRedisConnection#unlink(java.lang.String[])

src/main/java/org/springframework/data/redis/connection/DefaultedRedisConnection.java

@@ -57,6 +57,7 @@ import org.springframework.lang.Nullable;
  * @author Tugdual Grall
  * @author Andrey Shlykov
  * @author dengliming
+ * @author ihaohong
  * @since 2.0
  */
 public interface DefaultedRedisConnection extends RedisConnection {
@@ -84,6 +85,13 @@ public interface DefaultedRedisConnection extends RedisConnection {
 		return keyCommands().del(keys);
 	}
 
+	/** @deprecated in favor of {@link RedisConnection#keyCommands()}. */
+	@Override
+	@Deprecated
+	default Boolean copy(byte[] sourceKey, byte[] targetKey) {
+		return keyCommands().copy(sourceKey, targetKey);
+	}
+
 	/** @deprecated in favor of {@link RedisConnection#keyCommands()}. */
 	@Override
 	@Deprecated

src/main/java/org/springframework/data/redis/connection/RedisKeyCommands.java

@@ -31,6 +31,7 @@ import org.springframework.util.Assert;
  * @author Costin Leau
  * @author Christoph Strobl
  * @author Mark Paluch
+ * @author ihaohong
  */
 public interface RedisKeyCommands {
 
@@ -71,6 +72,17 @@ public interface RedisKeyCommands {
 	@Nullable
 	Long del(byte[]... keys);
 
+	/**
+	 * Copy given {@code sourceKey} to {@code targetKey}.
+	 *
+	 * @param sourceKey must not be {@literal null}.
+	 * @param targetKey must not be  {@literal null}.
+	 * @return
+	 * @see <a href="https://redis.io/commands/copy">Redis Documentation: COPY</a>
+	 */
+	@Nullable
+	Boolean copy(byte[] sourceKey, byte[] targetKey);
+
 	/**
 	 * Unlink the {@code keys} from the keyspace. Unlike with {@link #del(byte[]...)} the actual memory reclaiming here
 	 * happens asynchronously.

src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java

@@ -64,6 +64,8 @@ import org.springframework.util.CollectionUtils;
  * @author Tugdual Grall
  * @author Dengliming
  * @author Andrey Shlykov
+ * @author ihaohong
+ *
  * @see RedisCallback
  * @see RedisSerializer
  * @see StringRedisTemplate
@@ -132,6 +134,17 @@ public interface StringRedisConnection extends RedisConnection {
 	 */
 	Long del(String... keys);
 
+	/**
+	 * Copy given {@code sourceKey} to {@code targetKey}.
+	 *
+	 * @param sourceKey must not be {@literal null}.
+	 * @param targetKey must not be {@literal null}.
+	 * @return
+	 * @see <a href="https://redis.io/commands/copy">Redis Documentation: COPY</a>
+	 * @see RedisKeyCommands#copy(byte[], byte[])
+	 */
+	Boolean copy(String sourceKey, String targetKey);
+
 	/**
 	 * Unlink the {@code keys} from the keyspace. Unlike with {@link #del(String...)} the actual memory reclaiming here
 	 * happens asynchronously.

src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterKeyCommands.java

@@ -53,6 +53,7 @@ import org.springframework.util.ObjectUtils;
 /**
  * @author Christoph Strobl
  * @author Mark Paluch
+ * @author ihaohong
  * @since 2.0
  */
 class JedisClusterKeyCommands implements RedisKeyCommands {
@@ -87,6 +88,18 @@ class JedisClusterKeyCommands implements RedisKeyCommands {
 				.resultsAsList().size();
 	}
 
+	/*
+	 * (non-Javadoc)
+	 * @see org.springframework.data.redis.connection.RedisKeyCommands#copy(byte[], byte[])
+	 */
+	@Override
+	public Boolean copy(byte[] sourceKey, byte[] targetKey) {
+		Assert.notNull(sourceKey, "source key must not be null!");
+		Assert.notNull(targetKey, "target key must not be null!");
+
+		return connection.getCluster().copy(sourceKey, targetKey, false);
+	}
+
 	/*
 	 * (non-Javadoc)
 	 * @see org.springframework.data.redis.connection.RedisKeyCommands#unlink(byte[][])

src/main/java/org/springframework/data/redis/connection/jedis/JedisKeyCommands.java

@@ -41,6 +41,7 @@ import org.springframework.util.Assert;
 /**
  * @author Christoph Strobl
  * @author Mark Paluch
+ * @author ihaohong
  * @since 2.0
  */
 class JedisKeyCommands implements RedisKeyCommands {
@@ -90,6 +91,17 @@ class JedisKeyCommands implements RedisKeyCommands {
 		return connection.invoke().just(BinaryJedis::del, MultiKeyPipelineBase::del, keys);
 	}
 
+	/*
+	 * (non-Javadoc)
+	 * @see org.springframework.data.redis.connection.RedisKeyCommands#copy(byte[], byte[])
+	 */
+	public Boolean copy(byte[] sourceKey, byte[] targetKey) {
+		Assert.notNull(sourceKey, "source key must not be null!");
+		Assert.notNull(targetKey, "target key must not be null!");
+
+		return connection.invoke().just(BinaryJedis::copy, MultiKeyPipelineBase::copy, sourceKey, targetKey, false);
+	}
+
 	/*
 	 * (non-Javadoc)
 	 * @see org.springframework.data.redis.connection.RedisKeyCommands#unlink(byte[][])

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java

@@ -86,6 +86,7 @@ import org.springframework.util.ObjectUtils;
  * @author Mark Paluch
  * @author Ninad Divadkar
  * @author Tamil Selvan
+ * @author ihaohong
  */
 public class LettuceConnection extends AbstractRedisConnection {
 
@@ -1161,6 +1162,7 @@ public class LettuceConnection extends AbstractRedisConnection {
 			COMMAND_OUTPUT_TYPE_MAPPING.put(DECR, IntegerOutput.class);
 			COMMAND_OUTPUT_TYPE_MAPPING.put(DECRBY, IntegerOutput.class);
 			COMMAND_OUTPUT_TYPE_MAPPING.put(DEL, IntegerOutput.class);
+			COMMAND_OUTPUT_TYPE_MAPPING.put(COPY, IntegerOutput.class);
 			COMMAND_OUTPUT_TYPE_MAPPING.put(GETBIT, IntegerOutput.class);
 			COMMAND_OUTPUT_TYPE_MAPPING.put(HDEL, IntegerOutput.class);
 			COMMAND_OUTPUT_TYPE_MAPPING.put(HINCRBY, IntegerOutput.class);

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceKeyCommands.java

@@ -41,6 +41,7 @@ import org.springframework.util.Assert;
 /**
  * @author Christoph Strobl
  * @author Mark Paluch
+ * @author ihaohong
  * @since 2.0
  */
 class LettuceKeyCommands implements RedisKeyCommands {
@@ -90,6 +91,18 @@ class LettuceKeyCommands implements RedisKeyCommands {
 		return connection.invoke().just(RedisKeyAsyncCommands::del, keys);
 	}
 
+	/*
+	 * (non-Javadoc)
+	 * @see org.springframework.data.redis.connection.RedisKeyCommands#copy(byte[], byte[])
+	 */
+	@Override
+	public Boolean copy(byte[] sourceKey, byte[] targetKey) {
+		Assert.notNull(sourceKey, "source key must not be null!");
+		Assert.notNull(targetKey, "target key must not be null!");
+
+		return connection.invoke().just(RedisKeyAsyncCommands::copy, targetKey, sourceKey);
+	}
+
 	/*
 	 * (non-Javadoc)
 	 * @see org.springframework.data.redis.connection.RedisKeyCommands#unlink(byte[][])

src/main/java/org/springframework/data/redis/core/RedisOperations.java

@@ -43,6 +43,7 @@ import org.springframework.util.Assert;
  * @author Christoph Strobl
  * @author Ninad Divadkar
  * @author Mark Paluch
+ * @author ihaohong
  */
 public interface RedisOperations<K, V> {
 
@@ -199,6 +200,17 @@ public interface RedisOperations<K, V> {
 	@Nullable
 	Long delete(Collection<K> keys);
 
+	/**
+	 * Copy given {@code sourceKey} to {@code targetKey}.
+	 *
+	 * @param sourceKey must not be {@literal null}.
+	 * @param targetKey must not be {@literal null}.
+	 * @return
+	 * @see <a href="https://redis.io/commands/copy">Redis Documentation: COPY</a>
+	 */
+	@Nullable
+	Boolean copy(K sourceKey, K targetKey);
+
 	/**
 	 * Unlink the {@code key} from the keyspace. Unlike with {@link #delete(Object)} the actual memory reclaiming here
 	 * happens asynchronously.

src/main/java/org/springframework/data/redis/core/RedisTemplate.java

@@ -82,6 +82,8 @@ import org.springframework.util.CollectionUtils;
  * @author Anqing Shao
  * @author Mark Paluch
  * @author Denis Zavedeev
+ * @author ihaohong
+ *
  * @param <K> the Redis key type against which the template works (usually a String)
  * @param <V> the Redis value type against which the template works
  * @see StringRedisTemplate
@@ -710,6 +712,14 @@ public class RedisTemplate<K, V> extends RedisAccessor implements RedisOperation
 		return result != null && result.intValue() == 1;
 	}
 
+	@Override
+	public Boolean copy(K source, K target) {
+		byte[] sourceKey = rawKey(source);
+		byte[] targetKey = rawKey(target);
+
+		return execute(connection -> connection.copy(sourceKey, targetKey), true);
+	}
+
 	/*
 	 * (non-Javadoc)
 	 * @see org.springframework.data.redis.core.RedisOperations#delete(java.util.Collection)