aboutsummaryrefslogtreecommitdiffstats
path: root/activerecord/lib/active_record/connection_adapters/mysql
diff options
context:
space:
mode:
authorRyuta Kamizono <kamipo@gmail.com>2019-03-17 10:09:49 +0900
committerRyuta Kamizono <kamipo@gmail.com>2019-03-17 10:09:49 +0900
commit21f0855dd6ee624429f92d0a67d5d95fa75ff9cc (patch)
tree36eaee04883871a7810c1523b8006bf4f8c11537 /activerecord/lib/active_record/connection_adapters/mysql
parent0ad70eb2d063cab577a559f6c3d28e787ca1dca8 (diff)
downloadrails-21f0855dd6ee624429f92d0a67d5d95fa75ff9cc.tar.gz
rails-21f0855dd6ee624429f92d0a67d5d95fa75ff9cc.tar.bz2
rails-21f0855dd6ee624429f92d0a67d5d95fa75ff9cc.zip
Ensure `execute_batch` discards remaining results
Diffstat (limited to 'activerecord/lib/active_record/connection_adapters/mysql')
-rw-r--r--activerecord/lib/active_record/connection_adapters/mysql/database_statements.rb17
1 files changed, 5 insertions, 12 deletions
diff --git a/activerecord/lib/active_record/connection_adapters/mysql/database_statements.rb b/activerecord/lib/active_record/connection_adapters/mysql/database_statements.rb
index 421afc34bc..2158b0091a 100644
--- a/activerecord/lib/active_record/connection_adapters/mysql/database_statements.rb
+++ b/activerecord/lib/active_record/connection_adapters/mysql/database_statements.rb
@@ -68,15 +68,12 @@ module ActiveRecord
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 @@ module ActiveRecord
@connection.last_id
end
- def discard_remaining_results
- @connection.abandon_results!
- end
-
def supports_set_server_option?
@connection.respond_to?(:set_server_option)
end