AJ-675: modify issue about pool loadBalance compatibility;

chengyitian · chengyitian · commit 90aa8c36b732 · 2024-04-22T12:03:19.000+08:00
diff --git a/src/com/xxdb/ExclusiveDBConnectionPool.java b/src/com/xxdb/ExclusiveDBConnectionPool.java
@@ -108,8 +108,7 @@ public ExclusiveDBConnectionPool(String host, int port, String uid, String pwd,
 			}
 			for (int i=0; i<count; ++i) {
 				DBConnection conn = new DBConnection(false, useSSL, compress, usePython);
-				conn.setLoadBalance(false);
-				if(!conn.connect(hosts[i % nodeCount], ports[i % nodeCount], uid, pwd, initialScript, enableHighAvailability, highAvailabilitySites))
+				if(!conn.connect(hosts[i % nodeCount], ports[i % nodeCount], uid, pwd, initialScript, enableHighAvailability, highAvailabilitySites,false,false))
 					throw new RuntimeException("Can't connect to the host " + nodes.getString(i));
 				workers_.add(new AsyncWorker(conn));
 			}

Original file line number	Diff line number	Diff line change
`@@ -108,8 +108,7 @@ public ExclusiveDBConnectionPool(String host, int port, String uid, String pwd,`
`108`	`108`	`}`
`109`	`109`	`for (int i=0; i<count; ++i) {`
`110`	`110`	`DBConnection conn = new DBConnection(false, useSSL, compress, usePython);`
`111`		`- conn.setLoadBalance(false);`
`112`		`- if(!conn.connect(hosts[i % nodeCount], ports[i % nodeCount], uid, pwd, initialScript, enableHighAvailability, highAvailabilitySites))`
	`111`	`+ if(!conn.connect(hosts[i % nodeCount], ports[i % nodeCount], uid, pwd, initialScript, enableHighAvailability, highAvailabilitySites,false,false))`
`113`	`112`	`throw new RuntimeException("Can't connect to the host " + nodes.getString(i));`
`114`	`113`	`workers_.add(new AsyncWorker(conn));`
`115`	`114`	`}`