src/main/java/org/embulk/output/jdbc/StandardBatchInsert.java in embulk-output-jdbc-0.6.1 vs src/main/java/org/embulk/output/jdbc/StandardBatchInsert.java in embulk-output-jdbc-0.6.2

@@ -17,23 +17,23 @@
         implements BatchInsert
 {
     private final Logger logger = Exec.getLogger(StandardBatchInsert.class);
 
     private final JdbcOutputConnector connector;
-    private final Optional<List<String>> mergeKeys;
+    private final Optional<MergeConfig> mergeConfig;
 
     private JdbcOutputConnection connection;
     private PreparedStatement batch;
     private int index;
     private int batchWeight;
     private int batchRows;
     private long totalRows;
 
-    public StandardBatchInsert(JdbcOutputConnector connector, Optional<List<String>> mergeKeys) throws IOException, SQLException
+    public StandardBatchInsert(JdbcOutputConnector connector, Optional<MergeConfig> mergeConfig) throws IOException, SQLException
     {
         this.connector = connector;
-        this.mergeKeys = mergeKeys;
+        this.mergeConfig = mergeConfig;
     }
 
     public void prepare(String loadTable, JdbcSchema insertSchema) throws SQLException
     {
         this.connection = connector.connect(true);
@@ -44,10 +44,10 @@
         batch.clearBatch();
     }
 
     protected PreparedStatement prepareStatement(String loadTable, JdbcSchema insertSchema) throws SQLException
     {
-        return connection.prepareBatchInsertStatement(loadTable, insertSchema, mergeKeys);
+        return connection.prepareBatchInsertStatement(loadTable, insertSchema, mergeConfig);
     }
 
     public int getBatchWeight()
     {
         return batchWeight;