Merge remote-tracking branch 'upstream/pull/2461'

[rails.git] / lib / tasks / add_version_to_nodes.rake

diff --git a/lib/tasks/add_version_to_nodes.rake b/lib/tasks/add_version_to_nodes.rake
index 990ce5c4c164541e6190c78e2aad66180bd42582..4762116f2c198dba6ed3606748ef7ae5b878def9 100644 (file)
--- a/lib/tasks/add_version_to_nodes.rake
+++ b/lib/tasks/add_version_to_nodes.rake
@@ -1,20 +1,19 @@
-namespace 'db' do
-  desc 'Adds a version number to the noes table'
-  task :node_version  do
-    require File.dirname(__FILE__) + '/../../config/environment'
-
-    lower_bound = 0
-    increment = 100
-    node_count = OldNode.count
-    puts node_count
-    
-    while lower_bound < node_count
-    upper_bound = lower_bound + increment
-    hash = {}
-
-      OldNode.find(:all, :conditions => ['id >= ? AND id < ?',lower_bound, upper_bound], :order => 'timestamp').each do |node|
-         hash[node.id] = [] if hash[node.id].nil?
-         hash[node.id] << node
+namespace "db" do
+  desc "Adds a version number to the nodes table"
+  task :node_version => :environment do
+    require File.dirname(__FILE__) + "/../../config/environment"
+
+    increment = 1000
+    offset = 0
+    id_max = OldNode.find(:first, :order => "id desc").id
+
+    while offset < (id_max + increment)
+      hash = {}
+
+      # should be offsetting not selecting
+      OldNode.find(:all, :limit => increment, :offset => offset, :order => "timestamp").each do |node|
+        hash[node.id] ||= []
+        hash[node.id] << node
       end
 
       hash.each_value do |node_array|
@@ -30,16 +29,10 @@ namespace 'db' do
           temp_old_node.tile = node.tile
           temp_old_node.version = n
           temp_old_node.save! || raise
-          n +=1 
+          n += 1
         end
       end
-      lower_bound += increment
+      offset += increment
     end
   end
 end
-
-
-
-
-
-