src/main/java/org/embulk/output/JdbcOutputPlugin.java in embulk-output-jdbc-0.6.1 vs src/main/java/org/embulk/output/JdbcOutputPlugin.java in embulk-output-jdbc-0.6.2
- old
+ new
@@ -1,8 +1,7 @@
package org.embulk.output;
-import java.util.List;
import java.util.Properties;
import java.sql.Driver;
import java.io.IOException;
import java.sql.Connection;
import java.sql.SQLException;
@@ -11,15 +10,11 @@
import com.google.common.base.Throwables;
import com.google.common.collect.ImmutableSet;
import org.embulk.config.Config;
import org.embulk.config.ConfigDefault;
-import org.embulk.output.jdbc.AbstractJdbcOutputPlugin;
-import org.embulk.output.jdbc.BatchInsert;
-import org.embulk.output.jdbc.StandardBatchInsert;
-import org.embulk.output.jdbc.JdbcOutputConnector;
-import org.embulk.output.jdbc.JdbcOutputConnection;
+import org.embulk.output.jdbc.*;
public class JdbcOutputPlugin
extends AbstractJdbcOutputPlugin
{
public interface GenericPluginTask extends PluginTask
@@ -130,10 +125,10 @@
}
}
}
@Override
- protected BatchInsert newBatchInsert(PluginTask task, Optional<List<String>> mergeKeys) throws IOException, SQLException
+ protected BatchInsert newBatchInsert(PluginTask task, Optional<MergeConfig> mergeConfig) throws IOException, SQLException
{
- return new StandardBatchInsert(getConnector(task, true), mergeKeys);
+ return new StandardBatchInsert(getConnector(task, true), mergeConfig);
}
}