diff --git a/lib/onceler/transactions/active_record_3.rb b/lib/onceler/transactions/active_record_3.rb index 2e12c28..5cc18ce 100644 --- a/lib/onceler/transactions/active_record_3.rb +++ b/lib/onceler/transactions/active_record_3.rb @@ -1,9 +1,6 @@ module Onceler module Transactions def begin_transaction(conn) - unless conn.instance_variable_get(:@_current_transaction_records) - conn.instance_variable_set(:@_current_transaction_records, []) - end if conn.open_transactions == 0 conn.transaction_joinable = false conn.begin_db_transaction @@ -17,10 +14,8 @@ def rollback_transaction(conn) conn.decrement_open_transactions if conn.open_transactions == 0 conn.rollback_db_transaction - conn.send :rollback_transaction_records, true else conn.rollback_to_savepoint - conn.send :rollback_transaction_records, false end end end