File tree 1 file changed +4
-3
lines changed 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -21,6 +21,7 @@ function mixinTransaction(PostgreSQL) {
21
21
debug ( 'Begin a transaction with isolation level: %s' , isolationLevel ) ;
22
22
this . pg . connect ( function ( err , connection , done ) {
23
23
if ( err ) return cb ( err ) ;
24
+ connection . autorelease = done ;
24
25
connection . query ( 'BEGIN TRANSACTION ISOLATION LEVEL ' + isolationLevel ,
25
26
function ( err ) {
26
27
if ( err ) return cb ( err ) ;
@@ -63,9 +64,9 @@ function mixinTransaction(PostgreSQL) {
63
64
} ;
64
65
65
66
PostgreSQL . prototype . releaseConnection = function ( connection , err ) {
66
- if ( typeof connection . release === 'function' ) {
67
- connection . release ( err ) ;
68
- connection . release = null ;
67
+ if ( typeof connection . autorelease === 'function' ) {
68
+ connection . autorelease ( err ) ;
69
+ connection . autorelease = null ;
69
70
} else {
70
71
var pool = this . pg ;
71
72
if ( err ) {
You can’t perform that action at this time.
0 commit comments