File tree 1 file changed +6
-5
lines changed 1 file changed +6
-5
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,15 +64,15 @@ 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 ) {
72
- pool . destroy ( connection ) ;
73
+ pool . pool . destroy ( connection ) ;
73
74
} else {
74
- pool . release ( connection ) ;
75
+ pool . pool . release ( connection ) ;
75
76
}
76
77
}
77
78
} ;
You can’t perform that action at this time.
0 commit comments