Knex.js batchInsert处理冲突报错：onConflict不是函数，求解决方案

我曾一次性保存1800行数据，随着数据量增长出现问题，改用.batchInsert()后运行正常，但现在需要处理冲突。我编写的代码如下：

return db
  .batchInsert(payload, "payments", 1000)
  .onConflict("batch_id")
  .merge()
  .returning("*");

但运行时出现报错：

db.batchInsert(...).onConflict is not a function

大部分ORM的batchInsert方法是为批量插入性能优化设计的，并不支持onConflict这类冲突处理的链式调用，以下是几种可行方案：

方案1：用insert配合冲突处理，手动分批 #

如果你的ORM的insert方法支持onConflict，可以将数据按批次拆分，循环执行带冲突处理的插入操作：

const batchSize = 1000;
const results = [];

for (let i = 0; i < payload.length; i += batchSize) {
  const batch = payload.slice(i, i + batchSize);
  const res = await db
    .insert(batch)
    .into("payments")
    .onConflict("batch_id")
    .merge()
    .returning("*");
  results.push(...res);
}

return results;

该方案兼容性强，每批数据都能处理冲突，唯一缺点是会发起多个数据库请求，但合理设置批次大小后，性能差异可忽略。

方案2：直接使用原生SQL构建批量插入+冲突逻辑 #

如果ORM提供的方法无法满足需求，可以直接编写原生SQL（以PostgreSQL为例），同时注意避免SQL注入风险：

// 提取字段名
const columns = Object.keys(payload[0]);
// 生成参数占位符
const placeholders = payload.map((_, idx) => 
  `(${columns.map((_, colIdx) => `$${idx * columns.length + colIdx + 1}`).join(', ')})`
).join(', ');
// 生成冲突更新语句
const updateClause = columns.filter(col => col !== 'batch_id')
  .map(col => `${col} = EXCLUDED.${col}`)
  .join(', ');

const sql = `
  INSERT INTO payments (${columns.join(', ')})
  VALUES ${placeholders}
  ON CONFLICT (batch_id) DO UPDATE SET ${updateClause}
  RETURNING *;
`;

// 整理参数
const params = payload.flatMap(item => columns.map(col => item[col]));

return db.raw(sql, params);

这种方式能完全自定义冲突处理逻辑，适合对SQL语法熟悉的场景。

方案3：检查ORM文档，使用专用批量更新插入方法 #

部分ORM会提供专门的批量Upsert方法（比如upsertBatch），或者在新版本中为batchInsert增加了冲突处理支持，可以查看你使用的ORM官方文档，确认是否有现成的替代方法。

内容的提问来源于stack exchange，提问作者Missak Boyajian