Ticket #10212: transaction_fix.rb

# This file addresses the issue of Transaction counts that currently exist in ActiveRecoerd::Transactions

# Add a transaction counter to the Connection Object
class ActiveRecord::ConnectionAdapters::AbstractAdapter
  
  def increment_open_transactions
    @open_transactions ||= 0
    @open_transactions += 1
  end
  
  def decrement_open_transactions
    @open_transactions -= 1
  end
  
  def open_transactions
    @open_transactions ||= 0
  end
  
end

# Redefine this transaction method
module ActiveRecord::Transactions::ClassMethods
  def transaction(*objects, &block)
#    raise "HELL"
    previous_handler = trap('TERM') { raise TransactionError, "Transaction aborted" }
    trans_count = connection.increment_open_transactions
    puts "connection #{connection.instance_variable_get(:@config)[:database]} trans count: #{trans_count}"
    start_db_trans = (trans_count == 1)
    puts "connection #{connection.instance_variable_get(:@config)[:database]} start_db_trans #{start_db_trans}"

    begin
      unless objects.empty?
        ActiveSupport::Deprecation.warn "Object transactions are deprecated and will be removed from Rails 2.0.  See http://www.rubyonrails.org/deprecation for details.", caller
        objects.each { |o| o.extend(Transaction::Simple) }
        objects.each { |o| o.start_transaction }
      end
      
      result = connection.transaction(start_db_trans, &block)
      
      objects.each { |o| o.commit_transaction }
      return result
    ensure
      connection.decrement_open_transactions
      trap('TERM', previous_handler)
    end
  end
end