如何在 Ruby DataMapper 中使用事务？

Question

我有一个执行存储在 YAML 文件中的 SQL 语句（更新、插入和删除）的类。我希望所有报表都成为一笔交易的一部分。如果任何 SQL 语句失败，那么它们将被回滚。如果所有声明都成功，那么它们将被提交。我正在连接到 MySQL 数据库。这是我的代码：

require 'dm-core'

class SqlExecuter

  def initialize(input_yaml_file_name)
    @input_yaml_file_name = input_yaml_file_name
    @adapter = DataMapper.repository(:default).adapter
    @sql_statements = YAML::load(File.open(input_yaml_file_name))
  end

  def execute()
    puts "Executing SQL statements in #{@input_yaml_file_name} file...."

    @sql_statements.each do | sql_statement |
      @adapter.execute(sql_statement)
    end
  end
end # class SqlExecuter

我想让所有 @adapter.execute 调用成为一个事务的一部分。我查看了 dm-transactions gem 中的代码，但我不知道如何在这种情况下使用它。

Answer 1

使用它来在事务中体现您的 SQL 语句，并在发生错误时回滚：

require 'dm-transactions'
YourModel.transaction do |t|
  begin
    @sql_statements.each do |sql_statement|
      DataMapper.repository(:default).adapter.execute(sql_statement)
    end
  rescue DataObjects::Error
    t.rollback
  end
end

看看 通过 Ruby DataMapper 使用事务 和 dm-transactions_spec.rb

Answer 2

据我所知，您不再需要调用 rollback() 来回滚事务。您只需将其包含在事务块中，如下所示：

YourModel.transaction do
  @sql_statements.each do |sql_statement|
    DataMapper.repository(:default).adapter.execute(sql_statement)
  end
end

至少，这就是我阅读 关于回滚的 dm-transactions 规范：

it 'should rollback when an error is raised in a transaction' do
  @user_model.all.size.should == 0
  lambda {
    @user_model.transaction do
      @user_model.create(:name => 'carllerche')
      raise 'I love coffee'
    end
  }.should raise_error('I love coffee')
  @user_model.all.size.should == 0
end

我一直在使用 DataMapper 编写一个相当大的应用程序，其中包含大量事务，但没有使用rollback()，并且我所有失败的事务总是回滚。

另外，根据我对 ActiveRecord 的记忆（我已经使用 AR 一年了），DataMapper 事务行为模仿了 AR 行为。

Answer 3

原则上，这个反应还是正确的。 User.transaction 将在模型“User”附加到的存储库（数据库）上打开一个事务。更通用的方法是

DataMapper.repository(:default).transaction do |t|
    t.commit
end