Node & SQL:复杂的insert与sql函数

const mysql = require('mysql');

// 创建数据库连接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'your_username',
  password: 'your_password',
  database: 'your_database'
});

connection.connect();

// 使用参数化查询和 SQL 函数插入数据
const insertQuery = `
  INSERT INTO users (name, email, created_at)
  VALUES (?, ?, NOW())
`;

const values = ['John Doe', 'john.doe@example.com'];

connection.query(insertQuery, values, (error, results, fields) => {
  if (error) throw error;
  console.log('User inserted:', results);
});

// 关闭连接
connection.end();

const insertQuery = `
  INSERT INTO users (name, email, created_at)
  VALUES (?, ?, NOW())
`;

const values = ['John Doe', 'john.doe@example.com'];
connection.query(insertQuery, values, (error, results, fields) => {
  // 处理结果
});

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

  connection.query('INSERT INTO users SET ?', { name: 'John Doe' }, (error, results, fields) => {
    if (error) {
      return connection.rollback(() => {
        throw error;
      });
    }

    connection.query('UPDATE accounts SET balance = balance - 100 WHERE id = 1', (error, results, fields) => {
      if (error) {
        return connection.rollback(() => {
          throw error;
        });
      }

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