同じ質問を検索しましたが、まだ解決策が見つかりませんでした。非同期ライブラリを使用すると、クエリを数回使用して、必要なエラー処理を行うのが非常に簡単です。
このコードバリアントが役立つ可能性があります(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);
})