1

以下の現在のコードでわかるように、recordable_id属性に基づいて重複を見つけています。私がする必要があるのは、user_id、recordable_type、hero_type、recordable_idの4つの一致する属性に基づいて重複を見つけることです。コードをどのように変更する必要がありますか？

heroes = User.heroes

for hero in heroes
  hero_statuses = hero.hero_statuses

  seen = []

  hero_statuses.sort! {|a,b| a.created_at <=> b.created_at } # sort by created_at
  hero_statuses.each do |hero_status|
    if seen.map(&:recordable_id).include? hero_status.recordable_id # check if the id has been seen already
      hero_status.revoke
    else
      seen << hero_status # if not, add it to the seen array
    end
  end
end
4

2 に答える 2

1

これを試して：

HeroStatus.all(:group =>  "user_id, recordable_type, hero_type, recordable_id",
               :having => "count(*) > 1").each do |status|
  status.revoke 
end

編集2 すべての最新の重複エントリを取り消すには、次の手順を実行します。

HeroStatus.all(:joins => "(
     SELECT   user_id, recordable_type, hero_type, 
              recordable_id, MIN(created_at) AS created_at
     FROM     hero_statuses
     GROUP BY user_id, recordable_type, hero_type, recordable_id
     HAVING   COUNT(*) > 1
   ) AS A ON A.user_id         = hero_statuses.user_id         AND 
             A.recordable_type = hero_statuses.recordable_type AND
             A.hero_type       = hero_statuses.hero_type       AND
             A.recordable_id   = hero_statuses.recordable_id   AND
             A.created_at      < hero_statuses.created_
").each do |status|
  status.revoke 
end
于 2010-05-08T00:30:37.270 に答える
0

ストレートRuby（SQLサーバーではない）の使用：

heroes = User.heroes

for hero in heroes
  hero_statuses = hero.hero_statuses

  seen = {}

  hero_statuses.sort_by!(&:created_at)
  hero_statuses.each do |status|
    key = [status.user_id, status.recordable_type, status.hero_type, status.recordable_id]
    if seen.has_key?(key)
      status.revoke
    else
      seen[key] = status # if not, add it to the seen array
    end
  end

  remaining = seen.values
end

ルックアップには、常にHash（またはSet、ただし、ここでは、保持されているステータスを保持するのがよいと思いました）を使用します。

注：私はを使用sort_by!しましたが、これは1.9.2の新機能なので、sort_by（またはrequire "backports"）を使用します。

于 2010-05-08T05:11:20.267 に答える