src/main/java/org/embulk/output/MySQLOutputPlugin.java in embulk-output-mysql-0.7.12 vs src/main/java/org/embulk/output/MySQLOutputPlugin.java in embulk-output-mysql-0.7.13

@@ -23,10 +23,14 @@
         extends AbstractJdbcOutputPlugin
 {
     public interface MySQLPluginTask
             extends PluginTask
     {
+        @Config("driver_path")
+        @ConfigDefault("null")
+        public Optional<String> getDriverPath();
+
         @Config("host")
         public String getHost();
 
         @Config("port")
         @ConfigDefault("3306")
@@ -68,9 +72,11 @@
 
     @Override
     protected MySQLOutputConnector getConnector(PluginTask task, boolean retryableMetadataOperation)
     {
         MySQLPluginTask t = (MySQLPluginTask) task;
+
+        loadDriver("com.mysql.jdbc.Driver", t.getDriverPath());
 
         String url = String.format("jdbc:mysql://%s:%d/%s",
                 t.getHost(), t.getPort(), t.getDatabase());
 
         Properties props = new Properties();