Merge pull request #2149 from renshuaijin/bugfix/replication-bootstrap

Fix Resolve the issue of Replication bootstrap using schemaDatabase for JDBC connection

Author: osheroff

src/main/java/com/zendesk/maxwell/bootstrap/MaxwellBootstrapUtilityConfig.java

@@ -46,7 +46,7 @@ public String getConnectionURI() {
 
 	public String getReplicationConnectionURI( ) {
 		try {
-			return getConfigConnectionURI(replicationMysql);
+			return getConfigReplicationConnectionURI(replicationMysql);
 		} catch (URISyntaxException e) {
 			LOGGER.error(e.getMessage(), e);
 			throw new RuntimeException("Unable to generate bootstrap's replication jdbc connection URI", e);
@@ -65,6 +65,18 @@ private String getConfigConnectionURI(MaxwellMysqlConfig config) throws URISynta
 		return uriBuilder.build().toString();
 	}
 
+	private String getConfigReplicationConnectionURI(MaxwellMysqlConfig config) throws URISyntaxException {
+		URIBuilder uriBuilder = new URIBuilder();
+		uriBuilder.setScheme("jdbc:mysql");
+		uriBuilder.setHost(config.host);
+		uriBuilder.setPort(config.port);
+		uriBuilder.setPath("/" + databaseName);
+		for (Map.Entry<String, String> jdbcOption : config.jdbcOptions.entrySet()) {
+			uriBuilder.addParameter(jdbcOption.getKey(), jdbcOption.getValue());
+		}
+		return uriBuilder.build().toString();
+	}
+
 	protected OptionParser buildOptionParser() {
 		OptionParser parser = new OptionParser();
 		parser.accepts( "config", "location of config.properties file" )