एक वादा-आधारित इंटरफ़ेस जैसे pg-promise जाने का रास्ता है:
var bluebird = require('bluebird');
var pgp = require('pg-promise')({
promiseLib: bluebird
});
var db = pgp(/*connection details*/);
db.tx(t => {
// BEGIN executed
return t.map('SELECT id, chain FROM mytable where state_ready = $1 and transaction_id = $2', [true, 123], a => {
var chain = data.chain;
var pg_record = data.id;
return t.none('UPDATE mytable SET transaction_id = $1::text where id=$2::int', [transactionHash, pg_record]);
}).then(t.batch); // settling all internal queries
})
.then(data => {
// success, COMMIT executed
})
.catch(error => {
// error, ROLLBACK executed
})
.finally(pgp.end); // shuts down the connection pool
ऊपर दिया गया उदाहरण ठीक वही करता है जो आपने मांगा था, साथ ही यह लेनदेन का उपयोग करता है। लेकिन वास्तव में आप प्रदर्शन कारणों से यह सब एक ही प्रश्न में करना चाहेंगे;)
देखें और उदाहरण ।