fix postgresql transaction
This commit is contained in:
parent
ffa776cf6a
commit
4bcf00e3a9
|
@ -85,7 +85,7 @@ Transaction.begin = function(connector, options, cb) {
|
||||||
return cb(err);
|
return cb(err);
|
||||||
}
|
}
|
||||||
var tx = connection;
|
var tx = connection;
|
||||||
if (!(connection instanceof Transaction)) {
|
if (!(connection instanceof Transaction) && !(typeof connection.txId === 'string')) {
|
||||||
tx = new Transaction(connector, connection);
|
tx = new Transaction(connector, connection);
|
||||||
}
|
}
|
||||||
cb(err, tx);
|
cb(err, tx);
|
||||||
|
|
Loading…
Reference in New Issue