diff --git a/lib/bulk_insert/worker.rb b/lib/bulk_insert/worker.rb
index 34bb811..4550795 100644
--- a/lib/bulk_insert/worker.rb
+++ b/lib/bulk_insert/worker.rb
@@ -89,8 +89,11 @@ def save!
 
     def execute_query
       if query = compose_insert_query
-        result_set = @connection.exec_query(query)
-        @result_sets.push(result_set) if @return_primary_keys
+        if @return_primary_keys
+          @result_sets.push(@connection.exec_query(query))
+        else
+          @connection.exec_insert(query, 'SQL', [])
+        end
       end
     end