ha

src/main/java/com/alibaba/druid/pool/ha/balance/AbstractBalancer.java

@@ -0,0 +1,18 @@
+package com.alibaba.druid.pool.ha.balance;
+
+import com.alibaba.druid.pool.ha.MultiDataSource;
+
+public abstract class AbstractBalancer implements Balancer {
+
+    private MultiDataSource multiDataSource;
+
+    @Override
+    public void init(MultiDataSource multiDataSource) {
+        this.multiDataSource = multiDataSource;
+    }
+
+    public MultiDataSource getMultiDataSource() {
+        return multiDataSource;
+    }
+
+}

src/main/java/com/alibaba/druid/pool/ha/balance/Balancer.java

@@ -2,6 +2,7 @@ package com.alibaba.druid.pool.ha.balance;
 
 import java.sql.SQLException;
 
+import com.alibaba.druid.pool.ha.DataSourceChangedEvent;
 import com.alibaba.druid.pool.ha.MultiConnectionHolder;
 import com.alibaba.druid.pool.ha.MultiDataSource;
 import com.alibaba.druid.pool.ha.MultiDataSourceConnection;
@@ -10,7 +11,7 @@ public interface Balancer {
 
     void init(MultiDataSource dataSource);
 
-    void afterDataSourceChanged(Object event);
+    void afterDataSourceChanged(DataSourceChangedEvent event);
 
     MultiConnectionHolder getConnection(MultiDataSourceConnection connectionProxy, String sql) throws SQLException;
 }

src/main/java/com/alibaba/druid/pool/ha/balance/LeastConnectionBalancer.java

@@ -0,0 +1,22 @@
+package com.alibaba.druid.pool.ha.balance;
+
+import java.sql.SQLException;
+
+import com.alibaba.druid.pool.ha.DataSourceChangedEvent;
+import com.alibaba.druid.pool.ha.MultiConnectionHolder;
+import com.alibaba.druid.pool.ha.MultiDataSourceConnection;
+
+public class LeastConnectionBalancer extends AbstractBalancer {
+
+    @Override
+    public void afterDataSourceChanged(DataSourceChangedEvent event) {
+
+    }
+
+    @Override
+    public MultiConnectionHolder getConnection(MultiDataSourceConnection connectionProxy, String sql)
+                                                                                                     throws SQLException {
+        return null;
+    }
+
+}

src/main/java/com/alibaba/druid/pool/ha/balance/RoundRobinBlancer.java

@@ -5,6 +5,7 @@ import java.util.concurrent.atomic.AtomicInteger;
 
 import com.alibaba.druid.logging.Log;
 import com.alibaba.druid.logging.LogFactory;
+import com.alibaba.druid.pool.ha.DataSourceChangedEvent;
 import com.alibaba.druid.pool.ha.DataSourceHolder;
 import com.alibaba.druid.pool.ha.MultiConnectionHolder;
 import com.alibaba.druid.pool.ha.MultiDataSource;
@@ -22,7 +23,7 @@ public class RoundRobinBlancer implements Balancer {
 
     }
     
-    public void afterDataSourceChanged(Object event) {
+    public void afterDataSourceChanged(DataSourceChangedEvent event) {
         
     }
 

src/main/java/com/alibaba/druid/pool/ha/balance/WeightBalancer.java

@@ -4,6 +4,7 @@ import java.sql.SQLException;
 import java.util.concurrent.locks.Condition;
 import java.util.concurrent.locks.Lock;
 
+import com.alibaba.druid.pool.ha.DataSourceChangedEvent;
 import com.alibaba.druid.pool.ha.DataSourceHolder;
 import com.alibaba.druid.pool.ha.MultiConnectionHolder;
 import com.alibaba.druid.pool.ha.MultiDataSource;
@@ -20,7 +21,7 @@ public class WeightBalancer implements Balancer {
         this.multiDataSource = multiDataSource;
     }
 
-    public void afterDataSourceChanged(Object event) {
+    public void afterDataSourceChanged(DataSourceChangedEvent event) {
         computeTotalWeight();
     }