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