node.js 事物处理

Node.js 事务处理是指在 Node.js 应用程序中处理数据库事务的过程。事务是一组原子性的操作序列，要么全部成功执行，要么全部失败回滚。事务处理确保了数据的一致性和完整性。

基础概念

ACID 属性：
- 原子性（Atomicity）：事务中的所有操作要么全部完成，要么全部不完成。
- 一致性（Consistency）：事务执行前后，数据库从一个一致状态转移到另一个一致状态。
- 隔离性（Isolation）：并发执行的事务之间互不干扰。
- 持久性（Durability）：事务一旦提交，其结果就是永久性的。

事务管理：
- 开始事务：BEGIN
- 提交事务：COMMIT
- 回滚事务：ROLLBACK

类型

自动提交事务：每条 SQL 语句都是一个独立的事务。
手动提交事务：开发者显式控制事务的开始、提交和回滚。

应用场景

银行转账：从一个账户扣款并同时向另一个账户存款。
订单处理：创建订单、更新库存、扣减余额等操作需作为一个整体完成。
数据同步：多个数据库之间的数据同步操作。

示例代码（使用 MySQL 模块）

const mysql = require('mysql');

const connection = mysql.createConnection({
  host: 'localhost',
  user: 'your_username',
  password: 'your_password',
  database: 'your_database'
});

connection.connect();

connection.beginTransaction(err => {
  if (err) throw err;

  connection.query('INSERT INTO users (name, email) VALUES (?, ?)', ['John Doe', 'john@example.com'], (err, result) => {
    if (err) {
      return connection.rollback(() => {
        throw err;
      });
    }

    const userId = result.insertId;

    connection.query('INSERT INTO orders (user_id, product) VALUES (?, ?)', [userId, 'Laptop'], (err, result) => {
      if (err) {
        return connection.rollback(() => {
          throw err;
        });
      }

      connection.commit(err => {
        if (err) {
          return connection.rollback(() => {
            throw err;
          });
        }
        console.log('Transaction completed successfully!');
      });
    });
  });
});

connection.end();