aboutsummaryrefslogtreecommitdiffstats
path: root/activerecord/test/cases/transactions_test.rb
diff options
context:
space:
mode:
authorChris Hanks <christopher.m.hanks@gmail.com>2014-01-09 23:21:41 +0000
committerChris Hanks <christopher.m.hanks@gmail.com>2014-08-22 10:58:04 -0400
commit997a62198c70c85f229bb05a4c1b63f496531cbd (patch)
treea1b44fd4577bfbb00658f25afd112bb102d67010 /activerecord/test/cases/transactions_test.rb
parent5d7c1057684c377bc2801c8851e99ff11ab23530 (diff)
downloadrails-997a62198c70c85f229bb05a4c1b63f496531cbd.tar.gz
rails-997a62198c70c85f229bb05a4c1b63f496531cbd.tar.bz2
rails-997a62198c70c85f229bb05a4c1b63f496531cbd.zip
Roll back open transactions when the running thread is killed.
Diffstat (limited to 'activerecord/test/cases/transactions_test.rb')
-rw-r--r--activerecord/test/cases/transactions_test.rb31
1 files changed, 31 insertions, 0 deletions
diff --git a/activerecord/test/cases/transactions_test.rb b/activerecord/test/cases/transactions_test.rb
index 9cfe041de2..5cccf2dda5 100644
--- a/activerecord/test/cases/transactions_test.rb
+++ b/activerecord/test/cases/transactions_test.rb
@@ -492,6 +492,37 @@ class TransactionTest < ActiveRecord::TestCase
assert topic.frozen?, 'not frozen'
end
+ # The behavior of killed threads having a status of "aborting" was changed
+ # in Ruby 2.0, so Thread#kill on 1.9 will prematurely commit the transaction
+ # and there's nothing we can do about it.
+ unless RUBY_VERSION.start_with? '1.9'
+ def test_rollback_when_thread_killed
+ queue = Queue.new
+ thread = Thread.new do
+ Topic.transaction do
+ @first.approved = true
+ @second.approved = false
+ @first.save
+
+ queue.push nil
+ sleep
+
+ @second.save
+ end
+ end
+
+ queue.pop
+ thread.kill
+ thread.join
+
+ assert @first.approved?, "First should still be changed in the objects"
+ assert !@second.approved?, "Second should still be changed in the objects"
+
+ assert !Topic.find(1).approved?, "First shouldn't have been approved"
+ assert Topic.find(2).approved?, "Second should still be approved"
+ end
+ end
+
def test_restore_active_record_state_for_all_records_in_a_transaction
topic_without_callbacks = Class.new(ActiveRecord::Base) do
self.table_name = 'topics'