Class: Sequent::Core::Transactions::ActiveRecordTransactionProvider

Inherits:
Object
  • Object
show all
Defined in:
lib/sequent/core/transactions/active_record_transaction_provider.rb

Overview

Always require a new transaction.

Read: http://api.rubyonrails.org/classes/ActiveRecord/Transactions/ClassMethods.html

Without this change, there is a potential bug:

ActiveRecord::Base.transaction do
  Sequent.configuration.command_service.execute_commands command
end

on Command do
  do.some.things
  fail ActiveRecord::Rollback
end

In this example, you might be surprised to find that do.some.things does not get rolled back! This is because AR doesn't automatically make a "savepoint" for us when we call .transaction in a nested manner. In order to enable this behaviour, we have to call .transaction like this: .transaction(requires_new: true).

Instance Method Summary collapse

Instance Method Details

#after_commit(&block) ⇒ Object 



40
41
42
 
# File 'lib/sequent/core/transactions/active_record_transaction_provider.rb', line 40

def after_commit(&block)
  after_commit_queue << block
end

#transactional(&block) ⇒ Object 



32
33
34
35
36
37
38
 
# File 'lib/sequent/core/transactions/active_record_transaction_provider.rb', line 32

def transactional(&block)
  result = Sequent::ApplicationRecord.transaction(requires_new: true, &block)
  after_commit_queue.pop.call until after_commit_queue.empty?
  result
ensure
  clear_after_commit_queue
end