src/main/java/org/embulk/output/SQLServerOutputPlugin.java in embulk-output-sqlserver-0.6.1 vs src/main/java/org/embulk/output/SQLServerOutputPlugin.java in embulk-output-sqlserver-0.6.2
- old
+ new
@@ -7,10 +7,11 @@
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.MergeConfig;
import org.embulk.output.jdbc.StandardBatchInsert;
import org.embulk.output.jdbc.setter.ColumnSetterFactory;
import org.embulk.output.sqlserver.InsertMethod;
import org.embulk.output.sqlserver.NativeBatchInsert;
import org.embulk.output.sqlserver.SQLServerOutputConnector;
@@ -149,17 +150,17 @@
return new SQLServerOutputConnector(url, props, null);
}
@Override
- protected BatchInsert newBatchInsert(PluginTask task, Optional<List<String>> mergeKeys) throws IOException, SQLException
+ protected BatchInsert newBatchInsert(PluginTask task, Optional<MergeConfig> mergeConfig) throws IOException, SQLException
{
SQLServerPluginTask sqlServerTask = (SQLServerPluginTask) task;
if (sqlServerTask.getInsertMethod() == InsertMethod.NATIVE) {
return new NativeBatchInsert(sqlServerTask.getHost().get(), sqlServerTask.getPort(), sqlServerTask.getInstance(),
sqlServerTask.getDatabase().get(), sqlServerTask.getUser(), sqlServerTask.getPassword());
}
- return new StandardBatchInsert(getConnector(task, true), mergeKeys);
+ return new StandardBatchInsert(getConnector(task, true), mergeConfig);
}
@Override
protected ColumnSetterFactory newColumnSetterFactory(BatchInsert batch, DateTimeZone defaultTimeZone)
{