node.js 事物处理

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();