diff --git a/src/Helpers.php b/src/Helpers.php
index ab3d8b1..7021565 100644
--- a/src/Helpers.php
+++ b/src/Helpers.php
@@ -55,10 +55,10 @@ public static function executeBatch(Connection $connection, $query, $callback =
 							call_user_func($callback, $q, $db);
 						}
 
-						$db->query($q);
+						$db->exec($q);
 
 					} catch (\Exception $e) {
-						throw new BatchImportException($sql, $e->getMessage(), 0, $e);
+						throw new BatchImportException($q, $e->getMessage(), 0, $e);
 					}
 
 					$query = substr($query, $offset);
@@ -103,7 +103,7 @@ public static function loadFromFile(Connection $connection, $file, $callback = N
 				if ($callback) {
 					call_user_func($callback, $sql, ftell($handle));
 				}
-				$connection->query($sql);
+				$connection->exec($sql);
 				$sql = '';
 				$count++;
 
@@ -116,7 +116,7 @@ public static function loadFromFile(Connection $connection, $file, $callback = N
 			if ($callback) {
 				call_user_func($callback, $sql, ftell($handle));
 			}
-			$connection->query($sql);
+			$connection->exec($sql);
 			$count++;
 		}