Saya melakukan pencarian untuk pertanyaan yang sama, tetapi belum menemukan solusi. Dengan perpustakaan async, sangat mudah untuk menggunakan kueri beberapa kali, dan melakukan penanganan kesalahan yang diperlukan.
Mungkin varian kode ini membantu. (untuk memasukkan 10.000 objek json kecil ke database kosong butuh 6 detik).
Christoph
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);
})