मैंने उसी प्रश्न की खोज की, लेकिन अभी तक कोई समाधान नहीं मिला। async लाइब्रेरी के साथ कई बार क्वेरी का उपयोग करना और आवश्यक त्रुटि प्रबंधन करना बहुत आसान है।
हो सकता है कि यह कोड वैरिएंट मदद करता हो। (खाली डेटाबेस में 10.000 छोटे json ऑब्जेक्ट डालने में 6 सेकंड का समय लगा)।
क्रिस्टोफ़
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);
})