From 809b68d15efe4dbc20f2eb28639606529743652d Mon Sep 17 00:00:00 2001 From: zjh <1084500556@qq.com> Date: 星期五, 15 九月 2023 16:34:06 +0800 Subject: [PATCH] zjh 2023/09/15---2 --- ltkj-common/src/main/java/com/ltkj/common/core/redis/RedisCache.java | 12 ++++++++++++ 1 files changed, 12 insertions(+), 0 deletions(-) diff --git a/ltkj-common/src/main/java/com/ltkj/common/core/redis/RedisCache.java b/ltkj-common/src/main/java/com/ltkj/common/core/redis/RedisCache.java index fd83cf0..e124629 100644 --- a/ltkj-common/src/main/java/com/ltkj/common/core/redis/RedisCache.java +++ b/ltkj-common/src/main/java/com/ltkj/common/core/redis/RedisCache.java @@ -8,6 +8,7 @@ import java.util.concurrent.TimeUnit; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory; import org.springframework.data.redis.core.BoundSetOperations; import org.springframework.data.redis.core.HashOperations; import org.springframework.data.redis.core.RedisTemplate; @@ -25,6 +26,17 @@ @Autowired public RedisTemplate redisTemplate; + public RedisTemplate setDataBase(int num) { + LettuceConnectionFactory connectionFactory = (LettuceConnectionFactory) redisTemplate.getConnectionFactory(); + if (connectionFactory != null && num != connectionFactory.getDatabase()) { + connectionFactory.setDatabase(num); + this.redisTemplate.setConnectionFactory(connectionFactory); + connectionFactory.resetConnection(); + connectionFactory.afterPropertiesSet(); + } + return redisTemplate; + } + /** * 缂撳瓨鍩烘湰鐨勫璞★紝Integer銆丼tring銆佸疄浣撶被绛� * -- Gitblit v1.8.0