PLUGIN-1374: Update mySql plugin so that rewriteBatchedStatements is set to true

Setting rewriteBatchedStatements to be true by default using MysqlConnectorConfig

Author: ameya0111

mysql-plugin/src/main/java/io/cdap/plugin/mysql/MysqlConnectorConfig.java

@@ -28,6 +28,7 @@ public class MysqlConnectorConfig extends AbstractDBSpecificConnectorConfig {
   private static final String MYSQL_CONNECTION_STRING_FORMAT = "jdbc:mysql://%s:%s";
   private static final String JDBC_PROPERTY_CONNECT_TIMEOUT = "connectTimeout";
   private static final String JDBC_PROPERTY_SOCKET_TIMEOUT = "socketTimeout";
+  private static final String JDBC_REWRITE_BATCHED_STATEMENTS = "rewriteBatchedStatements";
 
   public MysqlConnectorConfig(String host, int port, String user, String password, String jdbcPluginName,
                               String connectionArguments) {
@@ -56,6 +57,7 @@ public Properties getConnectionArgumentsProperties() {
     // the unit below is milli-second
     prop.put(JDBC_PROPERTY_CONNECT_TIMEOUT, "20000");
     prop.put(JDBC_PROPERTY_SOCKET_TIMEOUT, "20000");
+    prop.put(JDBC_REWRITE_BATCHED_STATEMENTS, "true");
     return prop;
   }
 }

mysql-plugin/src/test/java/io/cdap/plugin/mysql/MysqlFailedConnectionTest.java

@@ -32,6 +32,7 @@ public void test() throws ClassNotFoundException, IOException {
 
     super.test(JDBC_DRIVER_CLASS_NAME, connector, "Failed to create connection to database via connection string: " +
                                                     "jdbc:mysql://localhost:3306 and arguments: {user=username, " +
+                                                    "rewriteBatchedStatements=true, "  +
                                                     "connectTimeout=20000, socketTimeout=20000}. Error: " +
                                                     "ConnectException: Connection refused (Connection refused).");
   }