使用 mysql2 批量插入并且 NodeJs 抛出 500
Bulk insert with mysql2 and NodeJs throws 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',并且效果很好。
这是 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
我有一个方法想 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',并且效果很好。
这是 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