使用 mysql2 批量插入并且 NodeJs 抛出 500

Question

我有一个方法想 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 的回答，我将我的方法从使用 'execute' 更改为 'query'，并且效果很好。

Answer 1

这是 execute 和 query 方法在 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], true) // adding true for multiple insert
        const affectedRows = result ? result.affectedRows : 0;

        return affectedRows;
}

那么query可以这样写

    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

使用 mysql2 批量插入并且 NodeJs 抛出 500

Bulk insert with mysql2 and NodeJs throws 500

mysql

node.js

bulkinsert

node-mysql2