|
|
|
@ -24,7 +24,7 @@ namespace :subjects do
|
|
|
|
|
"'#{Time.now.strftime('%Y-%m-%d %H:%M:%S')}', '#{Time.now.strftime('%Y-%m-%d %H:%M:%S')}')")
|
|
|
|
|
puts "index: #{index}; worker_number: #{Parallel.worker_number}"
|
|
|
|
|
puts "####str: #{str}"
|
|
|
|
|
if buffer_size == 1000 || subject == s.last
|
|
|
|
|
if str.size == 100 || subject == s.last
|
|
|
|
|
sql = "REPLACE INTO subject_records(#{column_value}) VALUES #{str.uniq.join(",")}"
|
|
|
|
|
puts sql
|
|
|
|
|
ActiveRecord::Base.connection.execute sql
|
|
|
|
|