diff --git a/src/util/batchInsert.js b/src/util/batchInsert.js index b20352e0b..bf8c1fa59 100644 --- a/src/util/batchInsert.js +++ b/src/util/batchInsert.js @@ -19,6 +19,10 @@ export default class BatchInsert { this._returning = void 0; this._transaction = null; this._autoTransaction = true; + + if (client.transacting) { + this.transacting(client); + } } /** diff --git a/test/integration/builder/inserts.js b/test/integration/builder/inserts.js index e09f55814..84d11c1dd 100644 --- a/test/integration/builder/inserts.js +++ b/test/integration/builder/inserts.js @@ -702,6 +702,15 @@ module.exports = function(knex) { }) }); + it('transaction.batchInsert using specified transaction', function() { + return knex.transaction(function(tr) { + tr.batchInsert('BatchInsert', items, 30) + .returning(['Col1', 'Col2']) + .then(tr.commit) + .catch(tr.rollback); + }) + }); + }); it('should validate batchInsert batchSize parameter', function() {