NodeJS：如何同步执行MySQL数据库写入操作？

嘿，我懂这种写两次数据库操作导致代码乱糟糟的感觉！用Node.js + mysql2处理这类同步写入的场景，其实有不少优雅的解决方案，我给你列几个实际项目里常用的：

方案1：用数据库事务保证原子性与代码整洁 #

如果这两次写入是强关联的（比如一次写用户表，一次写用户权限表，必须同时成功或失败），那事务绝对是首选。mysql2原生支持async/await，写起来很清爽：

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

async function createUserWithPermissions(userId, permissions) {
  const connection = await mysql.createConnection({ /* 你的连接配置 */ });
  
  try {
    await connection.beginTransaction();
    
    // 第一次写入：用户表
    await connection.execute(
      'INSERT INTO users (id, created_at) VALUES (?, NOW())',
      [userId]
    );
    
    // 第二次写入：权限表
    await connection.execute(
      'INSERT INTO user_permissions (user_id, permission) VALUES (?, ?)',
      [userId, permissions]
    );
    
    await connection.commit();
    console.log('两次写入都成功啦');
  } catch (err) {
    await connection.rollback();
    console.error('写入失败，已回滚:', err);
    throw err; // 向上抛出错误让调用方处理
  } finally {
    await connection.end();
  }
}

// 调用的时候直接await就行
// await createUserWithPermissions('user123', 'admin');

这个方案不仅让代码逻辑集中，还能避免数据不一致的问题——如果其中一步失败，整个操作都会回滚到初始状态。

方案2：封装成可复用的异步函数 #

如果两次写入没有强关联，但你不想在业务代码里重复写连接、执行的逻辑，把它们封装成一个独立的async函数是个好主意：

async function executeTwoWrites(data1, data2) {
  const connection = await mysql.createConnection({ /* 配置 */ });
  
  try {
    // 第一次写入
    await connection.execute(
      'INSERT INTO table1 (col1, col2) VALUES (?, ?)',
      [data1.col1, data1.col2]
    );
    
    // 第二次写入
    await connection.execute(
      'INSERT INTO table2 (colA, colB) VALUES (?, ?)',
      [data2.colA, data2.colB]
    );
    
    return { success: true };
  } catch (err) {
    console.error('写入出错:', err);
    return { success: false, error: err };
  } finally {
    await connection.end();
  }
}

// 业务代码里调用就很简洁
// const result = await executeTwoWrites({ col1: 'foo', col2: 'bar' }, { colA: 'baz', colB: 'qux' });

这样业务逻辑里就不会充斥着数据库操作的细节，代码可读性和可维护性都会提升不少。

方案3：合并为批量插入（如果适用） #

如果两次写入是往同一张表插入数据，那完全可以把它们合并成一条批量插入语句，减少数据库交互次数，代码也更短：

async function batchInsertRecords(records) {
  const connection = await mysql.createConnection({ /* 配置 */ });
  
  try {
    // 批量插入的SQL语句
    const sql = 'INSERT INTO your_table (col1, col2) VALUES ?';
    // 把records转换成二维数组
    const values = records.map(record => [record.col1, record.col2]);
    
    await connection.execute(sql, [values]);
    console.log(`${records.length}条数据插入成功`);
  } catch (err) {
    console.error('批量插入失败:', err);
  } finally {
    await connection.end();
  }
}

// 调用示例：插入两条数据
// await batchInsertRecords([
//   { col1: 'val1', col2: 'val2' },
//   { col1: 'val3', col2: 'val4' }
// ]);

这个方案不仅代码简洁，还能提升性能——毕竟少一次数据库请求，对高并发场景友好很多。

一些额外的小建议 #

• 尽量用mysql2/promise而不是回调版本，async/await的写法比回调地狱清爽太多；
• 不要忽略错误处理，不管用哪个方案，都要确保异常能被捕获并处理；
• 如果你的项目比较大，可以考虑用ORM（比如Sequelize、Prisma），它们会帮你把数据库操作封装得更优雅，事务、批量操作这些都有现成的API。

内容的提问来源于stack exchange，提问作者Ayoub.A