zoukankan      html  css  js  c++  java
  • rails transaction 的用法

    Rails 的 transaction 事务处理

    最近太做一个数据排名统计,统计过程中需要删除旧的缓存统计数据,最开始写的时候就直接 CachePostTotal.connection.execute("truncate table cache_post_totals") 先把这个表给重置了,然后再循环往里面插入新的统计数据。

    但后面发现,这样的做法存在大问题:

    • 当我 truncate table 的时候, cache_post_totals 表已经被清除了。但新的数据还没有存上去,如果在这个时候有人读取这张表时,就会找不到数据,这样是有问题的。
    • 在中间插入新数据的循环中有可能会出现异常、Model 验证不通过等情况而使得统计流程中断,但这个时候 cache_post_totals 表的数据已被改变。

    要解决这个问题哪就要上 事务 了! Rails ActiveRecord 对事务的处理实现的很方便,只用Model.transaction do … end 将对 Model 表的操作的代码包起来就可以了,这样一来,在 transaction do .. end 之间的数据更新动作并不会立刻改变表里面的数据,而是要等到完全执行完成后,过了 end 才更新。

    来看一下这一段例子:

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    
    begin
      Post.transaction do
        # 删除旧数据
        Post.delete_all
    
        # 例子 新数据
        datas [{:title => "title1", :slug => "title-1"},{:title => "Title 2", :slug => "Title 2"}]
        counter = 0
        datas.each do |d|
          post = Post.new(d)
          if not post.save
            raise "*** #{post.errors.full_messages}"
          end
        end
      end
      puts "=== Done"
    rescue Exception => ex
      puts "*** transaction abored!"
      puts "*** errors: #{ex.message}"
    end
    

    另外有个小细节需要注意,如果你是使用 Model.connection.execute() 方法执行的语句,那么事务将不会起作用!

    交易Transactions

    Transaction(交易)保證所有資料的操作都只有在成功的情況下才會寫入到資料庫,最著名的例子也就是銀行的帳戶交易,只有在帳戶提領金額及存入帳戶這兩個動作都成功的情況下才會將這筆操作寫入資料庫,否則在其中一個動作因為某些原因失敗的話就會放棄所有已做的操作將資料回復到交易前的狀態。在Rails中使用交易的方式像這樣:

    ActiveRecord::Base.transaction do
      david.withdrawal(100)
      mary.deposit(100)
    end

    你可以在一個交易中包含不同Active Record的類別或物件,這是因為交易是以資料庫連線為範圍,而不是個別Model

    User.transaction do
      User.create!(:name => 'ihower')
      Feed.create!
    end

    注意到這裡我們要使用create!而不是create,這是因為前者驗證失敗才會丟出例外,好讓整個交易失敗。同理,在交易裡做更新應該使用update_attributes!而不是update_attributes

    單一Modelsavedestroy方法已經幫你使用transaction包起來了,當資料驗證失敗或其中的回呼發生例外時,Rails就會觸發rollback。所以下述的交易區塊是多餘的不需要寫:

    User.transaction do # 這是多餘的
      User.create!(:name => 'ihower')
    end

    另外,由於資料的更新要在交易完成後才能被讀取到,所以如果你在after_save回呼裡讓外部服務存取(例如呼叫全文搜尋引擎做索引),很可能因為交易尚未完成,會讀取不到更新。這時候必須改用after_commit這個回呼,才能確保讀取到交易完成後的資料。

    感谢http://ihower.tw/rails3/activerecord-others.html 和http://huacnlee.com/blog/rails-transaction-tutorial/作者分享知识

  • 相关阅读:
    深析Tomcat容器工作流程
    GC基础
    oracle sql总结
    mybatis返回值类型总结
    eclipse启动javaweb项目后,如何让局域网内的其他人访问
    oracle sql 逗号 分割 REGEXP_SUBSTR 函数
    Oracle12c安装时报"指定的oracle主目录用户已存在"错误
    spring
    Oracle sql where后面的多条件case when判断执行
    Oracle12c安装时报ins-30131
  • 原文地址:https://www.cnblogs.com/chenzhenzhen/p/3855233.html
Copyright © 2011-2022 走看看