使用 mysql2 和 NodeJs 批量插入会抛出 500

Posted 2023-02-24

【中文标题】使用 mysql2 和 NodeJs 批量插入会抛出 500

【英文标题】：Bulk insert with mysql2 and NodeJs throws 500

【发布时间】：2021-08-12 18:34:10

【问题描述】：

我有一个方法，我想bulk insert 进入 mysql。我正在使用NodeJS 和mysql2。

我的方法：

createWorklog = async ( sqlArray ) => 
        const sql = `INSERT INTO $this.tableName
        (project_id, user_id, date, duration, task, description) VALUES ?`

        const result = await query(sql, [sqlArray])
        const affectedRows = result ? result.affectedRows : 0;

        return affectedRows;

其中sqlArray 是array of arrays，其中所有子数组的长度相同。

而该方法中调用的query方法是下一个：

query = async (sql, values) => 
    return new Promise((resolve, reject) => 
      const callback = (error, result) => 
        if (error) 
          reject(error);
          return;
        
        resolve(result);
      
      // execute will internally call prepare and query
      this.db.execute(sql, values, callback);
    ).catch(err => 
      const mysqlErrorList = Object.keys(HttpStatusCodes);
      // convert mysql errors which in the mysqlErrorList list to http status code
      err.status = mysqlErrorList.includes(err.code) ? HttpStatusCodes[err.code] : err.status;

      throw err;
    );
  

我的问题是 body parameters 没问题（正如我所说，数组数组）但是方法抛出 500。

这可能因为mysql2 中存在的execute 命令而成为可能吗？或者是另一个错误？

感谢您的宝贵时间！

编辑

根据@Gaurav 的回答，我将方法从使用“执行”更改为“查询”，效果很好。

【问题讨论】：

500 是一个 http 错误。它可能是在您在 nodejs 代码中执行 throw err 时生成的。我建议你使用console.err(err) 来显示mysql 错误。此外，npm mysql2 原生处理 await db.execute()；你不需要自己承诺。您可以大大简化您的代码。这将有助于排除故障。

在这里找到有用的资源 --> github.com/sidorares/node-mysql2/issues/830

【参考方案1】：

这是mysql2 中execute 和query 方法的一个已知问题

我找到了一个可行的替代方案。

createWorklog = async ( sqlArray ) => 
        const sql = `INSERT INTO $this.tableName
        (project_id, user_id, date, duration, task, description) VALUES ?`

        const result = await query(sql, [sqlArray], true) // adding true for multiple insert
        const affectedRows = result ? result.affectedRows : 0;

        return affectedRows;

那么查询可以写成如下

    return new Promise((resolve, reject) => 
      const callback = ...

      if (multiple) this.db.query(sql, values, callback);
            else this.db.execute(sql, values, callback);

    ).catch(err => 
      ...
...
    );
  

关于这个问题的更多信息可以在这里找到https://github.com/sidorares/node-mysql2/issues/830

【讨论】：

我喜欢您的想法，我将代码从使用“执行”更改为“查询”并且运行良好，但您的“如果其他”更好，但我仍然需要研究以找到性能“查询”和“执行”之间的差异以及其他细节。感谢您的宝贵时间。