From 87a4d7270bf68bcd2275c0836ed9d568b2719610 Mon Sep 17 00:00:00 2001
From: wanggeng <450292408@qq.com>
Date: Mon, 29 Nov 2021 15:43:37 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=95=B0=E6=8D=AE=E5=BA=93?=
 =?UTF-8?q?=E4=B8=BB=E5=A4=87=E8=87=AA=E5=8A=A8=E5=88=87=E6=8D=A2=E5=8A=9F?=
 =?UTF-8?q?=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../wgink/common/datasource/StandbyDataSource.java  | 13 +++++--------
 1 file changed, 5 insertions(+), 8 deletions(-)

diff --git a/common/src/main/java/ink/wgink/common/datasource/StandbyDataSource.java b/common/src/main/java/ink/wgink/common/datasource/StandbyDataSource.java
index f8e06116..f9bc83d1 100644
--- a/common/src/main/java/ink/wgink/common/datasource/StandbyDataSource.java
+++ b/common/src/main/java/ink/wgink/common/datasource/StandbyDataSource.java
@@ -46,8 +46,7 @@ public class StandbyDataSource extends DruidDataSource implements InitializingBe
     /**
      * 备库url连接
      */
-    private String[] standbyUrls;
-    private volatile int standbyIndex = 0;
+    private String standbyUrl;
 
     @Override
     public void init() throws SQLException {
@@ -56,7 +55,7 @@ public class StandbyDataSource extends DruidDataSource implements InitializingBe
         // 第一次初始化
         if (!lastInited && inited) {
             // 如果没有配置，不启用主备切换
-            if (standbyUrls == null || standbyUrls.length == 0) {
+            if (standbyUrl == null) {
                 return;
             }
             scheduledExecutorService.schedule(new ValidateUrlTask(), 1, TimeUnit.SECONDS);
@@ -79,10 +78,8 @@ public class StandbyDataSource extends DruidDataSource implements InitializingBe
                 //如果这个数据源已经被初始化了,同时连接异常才进行处理
                 if (isInited() && !isConnectionActive()) {
                     // 主库有问题时，切换备库
-                    LOG.debug("Change standby urls, index:{}", standbyIndex);
-                    String standbyUrl = standbyUrls[standbyIndex];
+                    LOG.debug("Change standby urls");
                     changeUrl(standbyUrl);
-                    standbyIndex++;
                     break;
                 }
                 try {
@@ -105,8 +102,8 @@ public class StandbyDataSource extends DruidDataSource implements InitializingBe
         setUrl(url);
     }
 
-    public void setStandbyUrls(String[] standbyUrls) {
-        this.standbyUrls = standbyUrls;
+    public void setStandbyUrl(String standbyUrl) {
+        this.standbyUrl = standbyUrl;
     }
 
     /**