src/main/java/org/embulk/output/MySQLOutputPlugin.java in embulk-output-mysql-0.8.2 vs src/main/java/org/embulk/output/MySQLOutputPlugin.java in embulk-output-mysql-0.8.3

@@ -10,10 +10,11 @@
 import org.embulk.config.ConfigDefault;
 import org.embulk.output.jdbc.AbstractJdbcOutputPlugin;
 import org.embulk.output.jdbc.Ssl;
 import org.embulk.output.jdbc.BatchInsert;
 import org.embulk.output.jdbc.JdbcOutputConnection;
+import org.embulk.output.jdbc.JdbcOutputConnector;
 import org.embulk.output.jdbc.MergeConfig;
 import org.embulk.output.jdbc.TableIdentifier;
 import org.embulk.output.mysql.MySQLOutputConnection;
 import org.embulk.output.mysql.MySQLOutputConnector;
 import org.embulk.output.mysql.MySQLBatchInsert;
@@ -69,11 +70,11 @@
             .setMaxTableNameLength(64)
             .setIgnoreMergeKeys(true);
     }
 
     @Override
-    protected MySQLOutputConnector getConnector(PluginTask task, boolean retryableMetadataOperation)
+    protected JdbcOutputConnector getConnector(PluginTask task, boolean retryableMetadataOperation)
     {
         MySQLPluginTask t = (MySQLPluginTask) task;
 
         loadDriver("com.mysql.jdbc.Driver", t.getDriverPath());
 
@@ -120,10 +121,10 @@
 
         props.setProperty("user", t.getUser());
         props.setProperty("password", t.getPassword());
         logConnectionProperties(url, props);
 
-        return new MySQLOutputConnector(url, props);
+        return new MySQLOutputConnector(url, props, task.getTransactionIsolation());
     }
 
     @Override
     protected TableIdentifier buildIntermediateTableId(JdbcOutputConnection con, PluginTask task, String tableName) {
         MySQLPluginTask t = (MySQLPluginTask) task;