nodejs mysql 批量更新 最优解 完整代码

在Node.js中使用MySQL进行批量更新，为了优化性能和减少数据库交互次数，可以采用预处理语句（PreparedStatement）并使用数组一次性提交多条数据。以下是使用`mysql2`库的一个示例代码：

const mysql = require('mysql2/promise');

// 创建数据库连接池
const pool = createPool({
  host: 'localhost',
  user: 'your_username',
  password: 'your_password',
  database: 'your_database'
});

async function batchUpdate(items) {
  // 使用预处理语句避免SQL注入，并准备更新语句
  const query = await pool.query`
    PREPARE updateStatement FROM
      UPDATE your_table
      SET column1 = ?, column2 = ?
      WHERE id IN (${items.map(item => item.id).join(',')});
  `;
  
  try {
    // 执行批量更新
    await Promise.all(items.map(async (item) => {
      await pool.execute(query[0].updateStatement, [item.value1, item.value2], { type: 'ROW' });
    }));

    // 提交事务
    await pool.commit();

    console.log('Batch update completed successfully.');
  } catch (error) {
    // 如果发生错误，回滚事务
    await pool.rollback();
    console.error('Error during batch update:', error);
  } finally {
    // 关闭预处理语句
    await pool.endTransaction(query[0]);
  }
}

// 示例数据
const items = [
  { id: 1, value1: 'new_value1', value2: 'new_value2' },
  { id: 2, value1: 'another_new_value1', value2: 'another_new_value2' }
];

batchUpdate(items);

在这个例子中，`createPool`函数用于创建一个数据库连接池，`batchUpdate`函数接收一个包含要更新的对象的数组。每个对象有`id`、`value1`和`value2`属性，对应表中的列名。

注意：这只是一个基本的示例，实际生产环境中可能需要处理更复杂的错误情况，比如断线重连等。同时，对于大数据量的批处理操作，可能还需要考虑分页查询或者其他优化策略，以免一次性加载过多数据导致内存压力过大。