aboutsummaryrefslogtreecommitdiffstats
path: root/activerecord/lib/active_record/connection_adapters/abstract/transaction.rb
diff options
context:
space:
mode:
authorMatthew Draper <matthew@trebex.net>2014-09-14 07:17:00 +0930
committerMatthew Draper <matthew@trebex.net>2014-09-14 07:32:53 +0930
commit1d4d15a48d0e422ae3a51920fbf055b0963917fa (patch)
treed9e32c07de1f2f46a9c0639b8f58725d30a75149 /activerecord/lib/active_record/connection_adapters/abstract/transaction.rb
parent457c876b15640d79f4398c3facb8652210d7c2e0 (diff)
parent997a62198c70c85f229bb05a4c1b63f496531cbd (diff)
downloadrails-1d4d15a48d0e422ae3a51920fbf055b0963917fa.tar.gz
rails-1d4d15a48d0e422ae3a51920fbf055b0963917fa.tar.bz2
rails-1d4d15a48d0e422ae3a51920fbf055b0963917fa.zip
Merge pull request #13656 from chanks/rollback_transactions_in_killed_threads
Data corruption risk: Roll back open transactions when the running thread is killed.
Diffstat (limited to 'activerecord/lib/active_record/connection_adapters/abstract/transaction.rb')
-rw-r--r--activerecord/lib/active_record/connection_adapters/abstract/transaction.rb16
1 files changed, 11 insertions, 5 deletions
diff --git a/activerecord/lib/active_record/connection_adapters/abstract/transaction.rb b/activerecord/lib/active_record/connection_adapters/abstract/transaction.rb
index 90be835d8a..fd666c8c39 100644
--- a/activerecord/lib/active_record/connection_adapters/abstract/transaction.rb
+++ b/activerecord/lib/active_record/connection_adapters/abstract/transaction.rb
@@ -190,11 +190,17 @@ module ActiveRecord
rollback_transaction if transaction
raise
ensure
- begin
- commit_transaction unless error
- rescue Exception
- transaction.rollback unless transaction.state.completed?
- raise
+ unless error
+ if Thread.current.status == 'aborting'
+ rollback_transaction
+ else
+ begin
+ commit_transaction
+ rescue Exception
+ transaction.rollback unless transaction.state.completed?
+ raise
+ end
+ end
end
end