diff --git a/sqlest/src/main/scala/sqlest/executor/Database.scala b/sqlest/src/main/scala/sqlest/executor/Database.scala
index af1feff..58a255a 100644
--- a/sqlest/src/main/scala/sqlest/executor/Database.scala
+++ b/sqlest/src/main/scala/sqlest/executor/Database.scala
@@ -304,9 +304,9 @@ case class Transaction(database: Database) extends Session(database) {
       val statement = connection.createStatement
       try {
         batchCommands foreach { command =>
-          val commandSql = database.statementBuilder.generateRawSql(command)
-          logger.debug(s"Adding batch operation: $commandSql")
-          statement.addBatch(commandSql)
+          val (preprocessedCommand, sql, argumentLists) = database.statementBuilder(command)
+          val preparedStatement: PreparedStatement = prepareStatement(connection, preprocessedCommand, sql, argumentLists)
+          logger.debug(s"Adding batch operation: ${logDetails(connection, sql, argumentLists)}")
         }
 
         statement.executeBatch.toList