diff --git a/lib/plugins.js b/lib/plugins.js
index 26c8924a..51da5075 100644
--- a/lib/plugins.js
+++ b/lib/plugins.js
@@ -512,7 +512,7 @@ function plugins (settings, deviceId) {
   }
 
   function recordTradeAndTx (tradeId, internalTxIdList, dbTx) {
-    _.map(internalTxId => {
+    dbTx.batch(_.map(internalTxId => {
       let entry = { trade_id: tradeId }
       if (internalTxId.direction === 'cashIn') {
         entry.cash_in_tx_id = internalTxId.txId
@@ -521,6 +521,7 @@ function plugins (settings, deviceId) {
       entry.cash_out_tx_id = internalTxId.txId
       return dbTx.none(pgp.helpers.insert(entry, null, 'cashout_tx_trades'))
     }, internalTxIdList)
+    )
   }
 
   function convertBigNumFields (obj) {