Node.js mysql2多语句查询占位符使用错误求助

首先，你遇到的TypeError [ERR_INVALID_ARG_TYPE]报错直接原因是字符串拼接语法错误：代码里的query3 =+ 'UPDATE...'是错误写法，应该改为query3 += 'UPDATE...'。=+会将原字符串强制转换为数字（最终得到NaN），导致查询语句参数不是合法字符串，触发类型错误。

以下是修复后的正确实现方案：

基础多语句查询版本 #

// 修复字符串拼接错误：将=+替换为+=
var query3 = 'UPDATE accounts SET balance = ((SELECT balance FROM accounts WHERE id = ?) - ?) WHERE id = ?;';
query3 += 'UPDATE accounts SET balance = ((SELECT balance FROM accounts WHERE id = ?) + ?) WHERE id = ?;';
query3 += 'INSERT INTO transactions SET ?';

// 按查询语句中占位符的顺序，将所有参数整理为一个数组
const queryParams = [
  // 第一个UPDATE语句的3个占位符参数
  result1[0].id, amount, result1[0].id,
  // 第二个UPDATE语句的3个占位符参数
  destination, amount, destination,
  // INSERT语句的对象参数（对应SET ?）
  {
    name: name,
    source_id: result1[0].id,
    destination_id: destination,
    amount: amount,
    type: 1
  }
];

// 执行多语句查询
db.multi.query(query3, queryParams, (err3, result3) => {
  if (err3) throw err3;
  res.redirect('/account/transfer_success');
});

推荐：事务版本（保证原子性） #

转账属于原子操作，必须确保三个语句要么全部成功，要么全部回滚，避免出现余额不一致的情况。用mysql2事务实现更可靠：

// 获取数据库连接并开启事务
db.getConnection((err, conn) => {
  if (err) throw err;

  conn.beginTransaction((err) => {
    if (err) {
      conn.release();
      throw err;
    }

    // 拆分单个查询语句，逻辑更清晰
    const updateSourceSql = 'UPDATE accounts SET balance = balance - ? WHERE id = ?';
    const updateDestSql = 'UPDATE accounts SET balance = balance + ? WHERE id = ?';
    const insertTransSql = 'INSERT INTO transactions SET ?';

    // 执行转出账户余额更新
    conn.query(updateSourceSql, [amount, result1[0].id], (err) => {
      if (err) {
        return conn.rollback(() => {
          conn.release();
          throw err;
        });
      }

      // 执行转入账户余额更新
      conn.query(updateDestSql, [amount, destination], (err) => {
        if (err) {
          return conn.rollback(() => {
            conn.release();
            throw err;
          });
        }

        // 执行交易记录插入
        const transData = {
          name: name,
          source_id: result1[0].id,
          destination_id: destination,
          amount: amount,
          type: 1
        };
        conn.query(insertTransSql, transData, (err) => {
          if (err) {
            return conn.rollback(() => {
              conn.release();
              throw err;
            });
          }

          // 提交事务
          conn.commit((err) => {
            if (err) {
              return conn.rollback(() => {
                conn.release();
                throw err;
              });
            }
            conn.release();
            res.redirect('/account/transfer_success');
          });
        });
      });
    });
  });
});

额外注意点 #

• 你的accounts表主键是id，原查询中写的uid是错误字段，已替换为id，避免字段不存在的报错。
• 事务版本比单纯多语句查询更安全，若中间某一步出错，已执行的操作会自动回滚，不会出现数据不一致问题。

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