diff --git a/plugin.xml b/plugin.xml index ca9a779..b9f1a9b 100755 --- a/plugin.xml +++ b/plugin.xml @@ -3,12 +3,13 @@ com.fr.solution.plugin.db.redis.v10 yes - 7.2 + 7.3 10.0 2019-03-29 richie [2019-10-30]适配新服务器数据集接口,在决策平台可以直接定义
[2019-09-29]修复无法兼容老版本的问题。
[2019-09-18]支持手动选择不同JavaScript脚本引擎。
diff --git a/src/main/java/com/fr/plugin/db/redis/core/accessor/category/ClusterRedisClient.java b/src/main/java/com/fr/plugin/db/redis/core/accessor/category/ClusterRedisClient.java index 69d3124..733d2e7 100644 --- a/src/main/java/com/fr/plugin/db/redis/core/accessor/category/ClusterRedisClient.java +++ b/src/main/java/com/fr/plugin/db/redis/core/accessor/category/ClusterRedisClient.java @@ -91,7 +91,10 @@ public class ClusterRedisClient implements EmbedRedis { @Override public void select(int index) { - jedisCluster.select(index); + Map clusterNodes = jedisCluster.getClusterNodes(); + for (Map.Entry entry : clusterNodes.entrySet()) { + entry.getValue().getResource().select(index); + } } @Override