关于Node.js Lambda调用AWS Aurora Serverless MySQL是否支持事务的咨询

完全支持包含Commit和Rollback的事务操作

Aurora Serverless MySQL 100%兼容标准MySQL协议，完整实现了ACID特性，包括事务的提交与回滚。Node.js常用的数据库驱动（如mysql2、mysql）都原生提供了事务控制API，和连接普通MySQL或非Serverless的Aurora实例逻辑完全一致。

核心逻辑 #

事务支持由数据库引擎和客户端驱动共同保障：

• Aurora Serverless MySQL作为MySQL兼容引擎，本身支持事务的开启、提交、回滚操作
• Node.js数据库驱动封装了对应的SQL命令（BEGIN、COMMIT、ROLLBACK），通过API即可调用

代码示例（使用mysql2驱动） #

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

exports.handler = async (event) => {
  let connection;
  try {
    // 建立数据库连接
    connection = await mysql.createConnection({
      host: 'your-aurora-serverless-endpoint',
      user: 'db-username',
      password: 'db-password',
      database: 'target-db'
    });

    // 开启事务
    await connection.beginTransaction();

    // 执行多步数据库操作
    await connection.execute('INSERT INTO orders (user_id, amount) VALUES (?, ?)', ['user_123', 99.9]);
    await connection.execute('UPDATE user_balance SET balance = balance - ? WHERE user_id = ?', [99.9, 'user_123']);

    // 提交事务
    await connection.commit();
    return { statusCode: 200, body: JSON.stringify({ message: '事务执行成功' }) };
  } catch (err) {
    // 异常时回滚事务
    if (connection) await connection.rollback();
    return { statusCode: 500, body: JSON.stringify({ error: `事务失败：${err.message}` }) };
  } finally {
    // 关闭连接
    if (connection) await connection.end();
  }
};

注意事项 #

• 超时限制：Lambda函数默认超时3秒，若事务操作复杂耗时，需调整Lambda超时配置（最大支持15分钟）
• 连接管理：Lambda调用建议每次创建新连接，或使用连接池时注意复用场景下的资源泄漏问题
• 错误处理：必须在异常分支显式调用rollback，避免未提交事务占用数据库锁资源

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