aboutsummaryrefslogtreecommitdiffstats
path: root/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb
diff options
context:
space:
mode:
Diffstat (limited to 'activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb')
-rw-r--r--activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb11
1 files changed, 7 insertions, 4 deletions
diff --git a/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb b/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb
index 809424c078..febc702922 100644
--- a/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb
+++ b/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb
@@ -39,17 +39,20 @@ module ActiveRecord
# Wrap a block in a transaction. Returns result of block.
def transaction(start_db_transaction = true)
+ needs_commit = false
begin
if block_given?
begin_db_transaction if start_db_transaction
- result = yield
- commit_db_transaction if start_db_transaction
- result
+ needs_commit = start_db_transaction
+ yield
end
rescue Exception => database_transaction_rollback
rollback_db_transaction if start_db_transaction
+ needs_commit = false
raise
end
+ ensure
+ commit_db_transaction if needs_commit
end
# Begins the transaction (and turns off auto-committing).
@@ -81,4 +84,4 @@ module ActiveRecord
end
end
end
-end \ No newline at end of file
+end