diff --git a/src/connection.js b/src/connection.js index 97cc97e1..3b29c136 100644 --- a/src/connection.js +++ b/src/connection.js @@ -385,6 +385,9 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose } function queryError(query, err) { + if (query === true) { + return; + } 'query' in err || 'parameters' in err || Object.defineProperties(err, { stack: { value: err.stack + query.origin.replace(/.*\n/, '\n'), enumerable: options.debug }, query: { value: query.string, enumerable: options.debug }, diff --git a/src/index.js b/src/index.js index 2dfd24e8..9a421aa4 100644 --- a/src/index.js +++ b/src/index.js @@ -204,9 +204,10 @@ function Postgres(a, b) { const queue = Queue() const c = open.length ? open.shift() - : await new Promise(r => { - queries.push({ reserve: r }) - closed.length && connect(closed.shift()) + : await new Promise((resolve, reject) => { + const q = { reserve: resolve, reject, origin: 'reserve() call', statement: {} }; + queries.push(q); + closed.length && connect(closed.shift(), q) }) move(c, reserved)