Node.js使用mysql2 库批量更新(Bulk Update)多条数据的方案

const mysql = require('mysql2/promise');
async function batchUpdate(data) {
  const connection = await mysql.createConnection({/* config */});
  // 假设 data 结构为: [{id: 1, name: 'A', age: 20}, {id: 2, name: 'B', age: 25}]
  let ids = [];
  let nameCases = '';
  let ageCases = '';
  let params = [];
  data.forEach(item => {
    ids.push(item.id);
    nameCases += `WHEN ? THEN ? `;
    params.push(item.id, item.name);
    ageCases += `WHEN ? THEN ? `;
    params.push(item.id, item.age);
  });
  // 最后的 params 顺序需要和 SQL 中的问号顺序一致
  // 这里为了简化演示直接拼接，实际建议通过数组 push 控制顺序
  const sql = `
    UPDATE users 
    SET 
      name = CASE id ${nameCases} END,
      age = CASE id ${ageCases} END
    WHERE id IN (${ids.map(() => '?').join(',')})
  `;
  // 合并参数：[name的id和值..., age的id和值..., WHERE用的id列表]
  const finalParams = [...params, ...ids];
  await connection.execute(sql, finalParams);
}

const mysql = require('mysql2/promise');
async function batchUpdateUpsert(data) {
  const connection = await mysql.createConnection({/* config */});
  // 将数据转为二维数组: [[1, 'A', 20], [2, 'B', 25]]
  const values = data.map(item => [item.id, item.name, item.age]);
  const sql = `
    INSERT INTO users (id, name, age) 
    VALUES ? 
    ON DUPLICATE KEY UPDATE 
      name = VALUES(name), 
      age = VALUES(age)
  `;
  // mysql2 的 query 方法支持传入二维数组来替换 VALUES ?
  await connection.query(sql, [values]);
}

const mysql = require('mysql2/promise');
async function batchUpdateTransaction(data) {
  const connection = await mysql.createConnection({/* config */});
  try {
    await connection.beginTransaction();
    for (const item of data) {
      await connection.execute(
        'UPDATE users SET name = ?, age = ? WHERE id = ?',
        [item.name, item.age, item.id]
      );
    }
    await connection.commit();
  } catch (error) {
    await connection.rollback();
    throw error;
  }
}