=== modified file 'src/com/mysql/jdbc/ReplicationConnection.java' --- src/com/mysql/jdbc/ReplicationConnection.java 2009-08-13 20:45:08 +0000 +++ src/com/mysql/jdbc/ReplicationConnection.java 2009-12-11 00:15:22 +0000 @@ -65,11 +65,18 @@ masterUrl.append(masterHost); } - String slaveHost = slaveProperties - .getProperty(NonRegisteringDriver.HOST_PROPERTY_KEY); - - if (slaveHost != null) { - slaveUrl.append(slaveHost); + int numHosts = new Integer( + slaveProperties.getProperty(NonRegisteringDriver.NUM_HOSTS_PROPERTY_KEY)) + .intValue(); + for(int i = 0; i < numHosts; i++){ + String slaveHost = slaveProperties + .getProperty(NonRegisteringDriver.HOST_PROPERTY_KEY + ".1"); + if (slaveHost != null) { + if(i > 0){ + slaveUrl.append(','); + } + slaveUrl.append(slaveHost); + } } String masterDb = masterProperties