本文介紹了使用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的文章就介紹到這了，希望我們推薦的答案對大家有所幫助，
