1

ソーステーブルに制約がないため、ソーステーブルに重複するキーレコードが見つかるまで、あるテーブルから別のテーブルにデータをロードするためにルビースクリプトジョブを毎日実行していました。私のターゲットテーブルは、ターゲットテーブルが列（head_date、center_id、site_url）に主キー制約を持っていたため、これらのレコードを拒否しました。プログラムが停止し、コマンド ラインに以下のエラーが表示されました。:-(

in `async_exec': PG::Error: ERROR:  duplicate key value violates unique constraint "tst_data_pkey" (ActiveRecord::RecordNotUnique)

ソーステーブルには、このような厄介なレコードが他にもあると予想できます。このアクティブなレコードの例外をキャッチした後、処理を続行して次のレコードに進むにはどうすればよいですか?

以下は私の更新/挿入のコードです:

class SiteSection < ActiveRecord::Base

  SiteSection.establish_connection(
        :adapter  => 'postgresql',
        :host     => 'hoster-of-hosts.com',
        :database => 'super-inven',
        :username => 'user',
        :password => 'pass'
                      )
  self.table_name = 'master.target_tbl'  # << insert into this table
end

conn.query("select * from source_tbl") do |row|
  siteData = SiteSection.find_or_initialize_by_head_date_and_center_id_and_site_url(row[:date_c], row[:com_id], row[:site_link])

  siteData[:head_date]      = row[:date_c]
  siteData[:center_id]     = row[:com_id]
  siteData[:site_url]          = row[:site_link].nil? ? 'unknown' : row[:site_link]
  siteData[:people_cnt]      = row[:persons].nil? ? 0 : row[:persons]
  siteData[:ips]     = row[:ip_adds].nil? ? 0 : row[:ip_adds]

  siteData.save
i = i+1
puts "finished: #{i}" if i % 10000 == 0
end
conn.close
4

2 に答える 2

3

あなたが使用することができます

begin

rescue => e

end

このような：

class SiteSection < ActiveRecord::Base

  SiteSection.establish_connection(
        :adapter  => 'postgresql',
        :host     => 'hoster-of-hosts.com',
        :database => 'super-inven',
        :username => 'user',
        :password => 'pass'
                      )
  self.table_name = 'master.target_tbl'  # << insert into this table
end

conn.query("select * from source_tbl") do |row|
  siteData = SiteSection.find_or_initialize_by_head_date_and_center_id_and_site_url(row[:date_c], row[:com_id], row[:site_link])

  siteData[:head_date]      = row[:date_c]
  siteData[:center_id]     = row[:com_id]
  siteData[:site_url]          = row[:site_link].nil? ? 'unknown' : row[:site_link]
  siteData[:people_cnt]      = row[:persons].nil? ? 0 : row[:persons]
  siteData[:ips]     = row[:ip_adds].nil? ? 0 : row[:ip_adds]

  begin
    siteData.save
  rescue => e
    puts e.message
    puts "Error happened but I'll just keep chuggin along"
  end
i = i+1
puts "finished: #{i}" if i % 10000 == 0
end
conn.close

はrescue => eエラーをキャッチすることを期待しています。泡立たないようにすることで、そのエラーを飲み込みます。コードは、例外がクラッシュすることなく引き続き実行されます。

于 2013-03-13T03:21:24.167 に答える
-1

一意のキーがある場合は、それを使用する必要があります-次のようなものです：

i = 0
puts 'loading records'
conn.query("select * from source_tbl") do |row|
  rec = SiteSection.where(
    :head_date => row[:date_c],
    :center_id => row[:com_id],
    :site_url => (row[:site_link] || 'unknown')
  ).first_or_initialize

  rec.people_cnt = (row[:persons] || 0)
  rec.ips => (row[:ip_adds] || 0)

  rec.save!

  i += 1
  print '.' if i % 10000 == 0
end
puts "done\ntotal records: #{i}"

このようにして、レコードを保存するか（新規）、レコードを更新します（見つかった場合）。ActiveRecord::RecordNotUniqueあなたがあなたのpkeyを変えなかったなら、ここにいるべきではありません！

于 2013-03-18T21:16:10.263 に答える