1

lib/tasks/statistic_subject_info.rake

@@ -25,7 +25,7 @@ namespace :subjects do
         puts "index: #{index}; worker_number: #{Parallel.worker_number}"
         puts "####str: #{str}"
         if buffer_size == 1000 || subject == s.last
-          sql = "REPLACE INTO subject_records(#{column_value}) VALUES #{str.join(",")}"
+          sql = "REPLACE INTO subject_records(#{column_value}) VALUES #{str.uniq.join(",")}"
           puts sql
           ActiveRecord::Base.connection.execute sql
           str = []
@@ -34,7 +34,7 @@ namespace :subjects do
       end
     end
     if buffer_size > 0
-      sql = "REPLACE INTO subject_records(#{column_value}) VALUES #{str.join(",")}"
+      sql = "REPLACE INTO subject_records(#{column_value}) VALUES #{str.uniq.join(",")}"
       puts sql
       ActiveRecord::Base.connection.execute sql
     end