knex batch insert -> on duplicate key update

knex.js

const { flow, chunk, map } = required('lodash/fp');

// batchInsert
const knexInsert = knex => async rows => knex.batchInsert('equipment_city', rows, BATCH_INSERT);

// batchInsert on duplicate
const knexInsertOnDuplicate = knex => /* async */ rows => flow(
  chunk(BATCH_INSERT),
  map(insertOnDuplicate(knex))
)(rows);


const insertOnDuplicate = knex => async batch => {
  const sql = knex('equipment_city').insert(batch).toSQL().toNative();
  return await knex.raw(sql.sql + ' ON DUPLICATE KEY UPDATE `size`=`size`+VALUES(`size`)', sql.bindings);
}