Comparing version
@@ -394,3 +394,3 @@ const net = require('net') | ||
!connection.reserved && !initial && !query && sent.length === 0 | ||
? Promise.resolve(terminate()) | ||
? (terminate(), new Promise(r => socket && socket.readyState !== 'closed' ? socket.once('close', r) : r())) | ||
: ending = new Promise(r => ended = r) | ||
@@ -397,0 +397,0 @@ ) |
@@ -213,5 +213,7 @@ const os = require('os') | ||
let uncaughtError | ||
, result | ||
name && await sql`savepoint ${ sql(name) }` | ||
try { | ||
const result = await new Promise((resolve, reject) => { | ||
result = await new Promise((resolve, reject) => { | ||
const x = fn(sql) | ||
@@ -223,5 +225,2 @@ Promise.resolve(Array.isArray(x) ? Promise.all(x) : x).then(resolve, reject) | ||
throw uncaughtError | ||
!name && await sql`commit` | ||
return result | ||
} catch (e) { | ||
@@ -235,2 +234,5 @@ await (name | ||
!name && await sql`commit` | ||
return result | ||
function savepoint(name, fn) { | ||
@@ -237,0 +239,0 @@ if (name && Array.isArray(name.raw)) |
{ | ||
"name": "postgres", | ||
"version": "3.2.1", | ||
"version": "3.2.2", | ||
"description": "Fastest full featured PostgreSQL client for Node.js", | ||
@@ -5,0 +5,0 @@ "type": "module", |
@@ -394,3 +394,3 @@ import net from 'net' | ||
!connection.reserved && !initial && !query && sent.length === 0 | ||
? Promise.resolve(terminate()) | ||
? (terminate(), new Promise(r => socket && socket.readyState !== 'closed' ? socket.once('close', r) : r())) | ||
: ending = new Promise(r => ended = r) | ||
@@ -397,0 +397,0 @@ ) |
@@ -213,5 +213,7 @@ import os from 'os' | ||
let uncaughtError | ||
, result | ||
name && await sql`savepoint ${ sql(name) }` | ||
try { | ||
const result = await new Promise((resolve, reject) => { | ||
result = await new Promise((resolve, reject) => { | ||
const x = fn(sql) | ||
@@ -223,5 +225,2 @@ Promise.resolve(Array.isArray(x) ? Promise.all(x) : x).then(resolve, reject) | ||
throw uncaughtError | ||
!name && await sql`commit` | ||
return result | ||
} catch (e) { | ||
@@ -235,2 +234,5 @@ await (name | ||
!name && await sql`commit` | ||
return result | ||
function savepoint(name, fn) { | ||
@@ -237,0 +239,0 @@ if (name && Array.isArray(name.raw)) |
195117
0.09%4857
0.04%