Ensure `execute_batch` discards remaining results

activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb

@@ -153,7 +153,6 @@ def truncate_tables(*table_names) # :nodoc:
             disable_referential_integrity do
               Array(build_truncate_statements(*table_names)).each do |sql|
                 execute_batch(sql, "Truncate Tables")
-                yield if block_given?
               end
             end
           end
@@ -394,7 +393,6 @@ def insert_fixtures_set(fixture_set, tables_to_delete = [])
             transaction(requires_new: true) do
               total_sql.each do |sql|
                 execute_batch(sql, "Fixtures Load")
-                yield if block_given?
               end
             end
           end

activerecord/lib/active_record/connection_adapters/mysql/database_statements.rb

@@ -68,15 +68,12 @@ def exec_delete(sql, name = nil, binds = [])
         end
         alias :exec_update :exec_delete
 
-        def insert_fixtures_set(fixture_set, tables_to_delete = []) # :nodoc:
-          super { discard_remaining_results }
-        end
-
-        def truncate_tables(*table_names) # :nodoc:
-          super { discard_remaining_results }
-        end
-
         private
+          def execute_batch(sql, name = nil)
+            super
+            @connection.abandon_results!
+          end
+
           def default_insert_value(column)
             Arel.sql("DEFAULT") unless column.auto_increment?
           end
@@ -85,10 +82,6 @@ def last_inserted_id(result)
             @connection.last_id
           end
 
-          def discard_remaining_results
-            @connection.abandon_results!
-          end
-
           def supports_set_server_option?
             @connection.respond_to?(:set_server_option)
           end