Module: EM::Synchrony::ActiveRecord::Adapter

Instance Method Summary collapse



44
45
46

# File 'lib/em-synchrony/activerecord.rb', line 44

def configure_connection
  nil
end



66
67
68

# File 'lib/em-synchrony/activerecord.rb', line 66

def decrement_open_transactions
  real_connection.open_transactions -= 1
end



62
63
64

# File 'lib/em-synchrony/activerecord.rb', line 62

def increment_open_transactions
  real_connection.open_transactions += 1
end



58
59
60

# File 'lib/em-synchrony/activerecord.rb', line 58

def open_transactions
  real_connection.open_transactions
end



54
55
56

# File 'lib/em-synchrony/activerecord.rb', line 54

def real_connection
  @connection.connection
end

# File 'lib/em-synchrony/activerecord.rb', line 48

def transaction(*args, &blk)
  @connection.execute(false) do |conn|
    super
  end
end