have MySQL do the adding of hours

Luke Baker
1 parent a7e18ca8
Showing 1 changed file with 2 additions and 2 deletions Show diff stats
lib/tasks/prune_db.rake
@@ -91,7 +91,7 @@ namespace :prune_db do
                   logger.info "AMBIGUOUS: #{table} #{row["id"]} #{column}: #{value}"
                   updated_values[column] = nil
                 else
-                  updated_values[column] = Time.parse("#{value} UTC") + span[:h].hours
+                  updated_values[column] = span[:h]
                 end
                 break
               end
@@ -105,7 +105,7 @@ namespace :prune_db do
           # remove ambiguous columns (we set them to nil above)
           updated_values.delete_if {|key, value| value.blank? }
           if updated_values.length > 0
-            update = "UPDATE #{table} SET #{updated_values.map{|k,v| "#{k} = '#{v.to_formatted_s(:db)}'"}.join(", ")} WHERE id = #{row["id"]}"
+            update = "UPDATE #{table} SET #{updated_values.map{|k,v| "#{k} = DATE_ADD(#{k}, INTERVAL #{v} HOUR)"}.join(", ")} WHERE id = #{row["id"]}"
 	    num = ActiveRecord::Base.connection.update_sql(update)
 	    if num == 1
               logger.info "UPDATE: #{table} #{row.inspect} #{updated_values.inspect}"
	@@ -91,7 +91,7 @@ namespace :prune_db do		@@ -91,7 +91,7 @@ namespace :prune_db do
91	logger.info "AMBIGUOUS: #{table} #{row["id"]} #{column}: #{value}"	91	logger.info "AMBIGUOUS: #{table} #{row["id"]} #{column}: #{value}"
92	updated_values[column] = nil	92	updated_values[column] = nil
93	else	93	else
94	- updated_values[column] = Time.parse("#{value} UTC") + span[:h].hours	94	+ updated_values[column] = span[:h]
95	end	95	end
96	break	96	break
97	end	97	end
	@@ -105,7 +105,7 @@ namespace :prune_db do		@@ -105,7 +105,7 @@ namespace :prune_db do
105	# remove ambiguous columns (we set them to nil above)	105	# remove ambiguous columns (we set them to nil above)
106	updated_values.delete_if {\|key, value\| value.blank? }	106	updated_values.delete_if {\|key, value\| value.blank? }
107	if updated_values.length > 0	107	if updated_values.length > 0
108	- update = "UPDATE #{table} SET #{updated_values.map{\|k,v\| "#{k} = '#{v.to_formatted_s(:db)}'"}.join(", ")} WHERE id = #{row["id"]}"	108	+ update = "UPDATE #{table} SET #{updated_values.map{\|k,v\| "#{k} = DATE_ADD(#{k}, INTERVAL #{v} HOUR)"}.join(", ")} WHERE id = #{row["id"]}"
109	num = ActiveRecord::Base.connection.update_sql(update)	109	num = ActiveRecord::Base.connection.update_sql(update)
110	if num == 1	110	if num == 1
111	logger.info "UPDATE: #{table} #{row.inspect} #{updated_values.inspect}"	111	logger.info "UPDATE: #{table} #{row.inspect} #{updated_values.inspect}"