使用mysql2和NodeJS的大容量插入抛出500
我有一个方法,我希望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’,并且运行良好。
解决方案
这是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
找到相关文章