Jag sökte efter samma fråga, men hittade ingen lösning ännu. Med asynkronbiblioteket är det mycket enkelt att använda frågan flera gånger och göra den nödvändiga felhanteringen.
Kanske den här kodvarianten hjälper.(för att infoga 10 000 små json-objekt i en tom databas tog det 6 sekunder).
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);
})