Tôi đã tìm kiếm câu hỏi tương tự nhưng vẫn chưa tìm được giải pháp. Với thư viện không đồng bộ, rất đơn giản để sử dụng truy vấn nhiều lần và thực hiện xử lý lỗi cần thiết.
Có thể biến thể mã này hữu ích. (Để chèn 10.000 đối tượng json nhỏ vào cơ sở dữ liệu trống, mất 6 giây).
Christoph
Các giá trịfunction insertData(item,callback) {
client.query('INSERT INTO subscriptions (subscription_guid, employer_guid, employee_guid)
values ($1,$2,$3)', [
item.subscription_guid,
item.employer_guid,
item.employee_guid
],
function(err,result) {
// return any err to async.each iterator
callback(err);
})
}
async.each(datasetArr,insertData,function(err) {
// Release the client to the pg module
done();
if (err) {
set_response(500, err, res);
logger.error('error running query', err);
return console.error('error running query', err);
}
logger.info('subscription with created');
set_response(201);
})