Skip to content

Commit b31db25

Browse files
committed
Catch errors client throws in pool
1 parent 9d2c977 commit b31db25

File tree

1 file changed

+18
-14
lines changed

1 file changed

+18
-14
lines changed

Diff for: packages/pg-pool/index.js

+18-14
Original file line numberDiff line numberDiff line change
@@ -364,20 +364,24 @@ class Pool extends EventEmitter {
364364

365365
client.once('error', onError)
366366
this.log('dispatching query')
367-
client.query(text, values, (err, res) => {
368-
this.log('query dispatched')
369-
client.removeListener('error', onError)
370-
if (clientReleased) {
371-
return
372-
}
373-
clientReleased = true
374-
client.release(err)
375-
if (err) {
376-
return cb(err)
377-
} else {
378-
return cb(undefined, res)
379-
}
380-
})
367+
try {
368+
client.query(text, values, (err, res) => {
369+
this.log('query dispatched')
370+
client.removeListener('error', onError)
371+
if (clientReleased) {
372+
return
373+
}
374+
clientReleased = true
375+
client.release(err)
376+
if (err) {
377+
return cb(err)
378+
} else {
379+
return cb(undefined, res)
380+
}
381+
})
382+
} catch (err) {
383+
return cb(err)
384+
}
381385
})
382386
return response.result
383387
}

0 commit comments

Comments
 (0)