Skip to content

Commit a9d6344

Browse files
author
Lars-Erik Roald
committed
mssql commit rollback
1 parent 864c83d commit a9d6344

File tree

2 files changed

+14
-4
lines changed

2 files changed

+14
-4
lines changed

src/mssql/newDatabase.js

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,12 +68,17 @@ function newDatabase(connectionString, poolOptions) {
6868
function run(fn) {
6969
return p.then(domain.run.bind(domain, fn));
7070
}
71-
return run;
7271

7372
function begin() {
7473
return _begin(domain, options);
7574
}
7675

76+
run.rollback = rollback.bind(null, domain);
77+
run.commit = commit.bind(null, domain);
78+
79+
return run;
80+
81+
7782
};
7883

7984
c.query = function(query) {

src/sap/newDatabase.js

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -70,15 +70,20 @@ function newDatabase(connectionString, poolOptions) {
7070
function run(fn) {
7171
return p.then(() => fn(domain));
7272
}
73-
run.rollback = rollback.bind(null, domain);
74-
run.commit = commit.bind(null, domain);
75-
return run;
7673

7774
function begin() {
7875
return _begin(domain, options);
7976
}
77+
78+
run.rollback = rollback.bind(null, domain);
79+
run.commit = commit.bind(null, domain);
80+
81+
return run;
82+
8083
};
8184

85+
86+
8287
c.query = function(query) {
8388
let domain = createDomain();
8489
let transaction = newTransaction(domain, pool);

0 commit comments

Comments
 (0)