本文介绍了使用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
找到这篇关于使用mysql2和NodeJS的大容量插入抛出500的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！
本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除！