Как вы предотвращаете откат изменений базы данных внутри фильтра Rails ActiveRecord before_create, когда он возвращает false?

Я просто должен был сделать это недавно. Вам нужно специально запросить другое подключение от AR. Затем выполните свои изменения в этом соединении. Таким образом, если создание завершается ошибкой и транзакция откатывается, изменения вашего обратного вызова уже были зафиксированы в другой транзакции.

Не обращайте внимания на мой ответ выше. Пример кода, который вы только что привели, действительно прояснил ситуацию.

class Foo < ActiveRecord::Base
  before_create :update_instead

  def update_instead
    dbconn = self.class.connection_pool.checkout
    dbconn.transaction do
      dbconn.execute("update foos set name = 'updated'")
    end
    self.class.connection_pool.checkin(dbconn)
    false
  end
end


>> Foo.create(:name => 'sam')
=> #<Foo id: nil, name: "sam", created_at: nil, updated_at: nil>
>> Foo.all
=> [#<Foo id: 2, name: "updated", created_at: "2009-10-21 15:12:55", updated_at: "2009-10-21 15:12:55">]

Используйте транзакцию в фильтре.

Вы пробовали перезаписывать файлы create/save и их деструктивные версии? ActiveRecord::Base.create, ActiveRecord::Base.save и их деструктивные версии завернуты в транзакцию, они также запускают обратные вызовы и проверки. Если вы переопределяете его, только то, что сделано super, будет частью транзакции. Если вам нужно выполнить проверки раньше, вы можете явно вызвать valid, чтобы запустить их все.

Пример:

before_create :before_create_actions_that_can_be_rolled_back

def create
  if valid? && before_create_actions_that_wont_be_rolled_back
    super
  end
end

def before_create_actions_that_wont_be_rolled_back
 # exactly what it sounds like
end

def before_create_actions_that_can_be_rolled_back
 # exactly what it sounds like
end

Предостережение: с этими изменениями методы будут вызываться в следующем порядке:

2. перед проверкой (on_create)
3. подтверждать
4. после проверки (on_create)
5. before_create_actions_that_wont_be_rolled_back
6. перед проверкой (on_create)
7. подтверждать
8. после проверки (on_create)
9. перед сохранением обратных вызовов
10. перед созданием обратных вызовов
11. запись создана
12. после создания обратных вызовов
13. после сохранения обратных вызовов

Если какая-либо проверка завершится неудачно или если какой-либо обратный вызов вернет false на шагах 5–12, база данных будет возвращена в состояние, в котором она находилась до шага 5.

Если действительный? терпит неудачу или before_create_actions_that_wont_be_rolled_back терпит неудачу, то вся цепочка будет остановлена.

Можно ли вместо этого внести эти изменения в after_create?

Здесь используется та же концепция, что и в ответе Рича Кавано. Я добавил родительскую модель, чтобы было понятнее, что делает фильтр. Суть в том, чтобы использовать поток + автоматическую проверку/регистрацию отдельного соединения. Примечание: вы должны убедиться, что значение :pool установлено как минимум на 2 в вашей спецификации соединения, в зависимости от того, сколько параллельных потоков вы будете запускать. Я думаю, что по умолчанию это 5.

class Gadget < ActiveRecord::Base
  has_many :widgets
end

class Widget < ActiveRecord::Base
  belongs_to :gadget
  before_create :update_instead

  def update_some_record_in_same_model
    # the thread forces a new connection to be checked out
    Thread.new do
      ActiveRecord::Base.connection_pool.with_connection do |conn|
        # try this part without the 2 surrounding blocks and it will be rolled back
        gadget.touch_count += 1
        gadget.save!
      end
    end.join
  end
  def some_condition?
    true
  end

  def update_instead
    if some_condition?
      update_some_record_in_same_model # this is getting rolled back
      p [:touch_count_in_filter, gadget.reload.touch_count]
      return false # don't create a new record
    else
      return true # let it continue
    end
  end
end

Контрольная работа:

  g = Gadget.create(:name => 'g1')
  puts "before:"
  p [:touch_count, g.reload.touch_count]
  p [:widget_count, Widget.count]

  g.widgets.create(:name => 'w1')
  puts "after:"
  # Success means the count stays incremented
  p [:touch_count, g.reload.touch_count]
  p [:widget_count, Widget.count]

Дополнительная литература: http://bibwild.wordpress.com/2011/11/14/multi-threading-in-rails-activerecord-3-0-3-1/