db/migrate/006_tile_nodes.rb

   1 # frozen_string_literal: true
   2
   3 class TileNodes < ActiveRecord::Migration[4.2]
   4   class Node < ApplicationRecord
   5     self.table_name = "current_nodes"
   6   end
   7
   8   class OldNode < ApplicationRecord
   9     self.table_name = "nodes"
  10   end
  11
  12   def self.upgrade_table(from_table, to_table, model)
  13     execute <<-SQL.squish
  14     INSERT INTO #{to_table} (id, latitude, longitude, user_id, visible, tags, timestamp, tile)
  15     SELECT id, ROUND(latitude * 10000000), ROUND(longitude * 10000000),
  16             user_id, visible, tags, timestamp, 0
  17     FROM #{from_table}
  18     SQL
  19
  20     model.all.each(&:save!)
  21   end
  22
  23   def self.downgrade_table(from_table, to_table)
  24     execute <<-SQL.squish
  25     INSERT INTO #{to_table} (id, latitude, longitude, user_id, visible, tags, timestamp)
  26     SELECT id, latitude / 10000000, longitude / 10000000,
  27            user_id, visible, tags, timestamp
  28     FROM #{from_table}
  29     SQL
  30   end
  31
  32   def self.up
  33     remove_index "current_nodes", :name => "current_nodes_timestamp_idx"
  34
  35     rename_table "current_nodes", "current_nodes_v5"
  36
  37     create_table "current_nodes", :id => false do |t|
  38       t.column "id",        :bigserial, :primary_key => true, :null => false
  39       t.column "latitude",  :integer, :null => false
  40       t.column "longitude", :integer, :null => false
  41       t.column "user_id",   :bigint, :null => false
  42       t.column "visible",   :boolean, :null => false
  43       t.column "tags",      :text, :default => "", :null => false
  44       t.column "timestamp", :datetime, :null => false
  45       t.column "tile",      :integer, :null => false
  46     end
  47
  48     add_index "current_nodes", ["timestamp"], :name => "current_nodes_timestamp_idx"
  49     add_index "current_nodes", ["tile"], :name => "current_nodes_tile_idx"
  50
  51     change_column "current_nodes", "tile", :bigint
  52
  53     upgrade_table "current_nodes_v5", "current_nodes", Node
  54
  55     drop_table "current_nodes_v5"
  56
  57     remove_index "nodes", :name => "nodes_uid_idx"
  58     remove_index "nodes", :name => "nodes_timestamp_idx"
  59     rename_table "nodes", "nodes_v5"
  60
  61     create_table "nodes", :id => false do |t|
  62       t.column "id",        :bigint, :null => false
  63       t.column "latitude",  :integer, :null => false
  64       t.column "longitude", :integer, :null => false
  65       t.column "user_id",   :bigint, :null => false
  66       t.column "visible",   :boolean, :null => false
  67       t.column "tags",      :text, :default => "", :null => false
  68       t.column "timestamp", :datetime, :null => false
  69       t.column "tile",      :integer, :null => false
  70     end
  71
  72     add_index "nodes", ["id"], :name => "nodes_uid_idx"
  73     add_index "nodes", ["timestamp"], :name => "nodes_timestamp_idx"
  74     add_index "nodes", ["tile"], :name => "nodes_tile_idx"
  75
  76     change_column "nodes", "tile", :bigint
  77
  78     upgrade_table "nodes_v5", "nodes", OldNode
  79
  80     drop_table "nodes_v5"
  81   end
  82
  83   def self.down
  84     rename_table "current_nodes", "current_nodes_v6"
  85
  86     create_table "current_nodes", :id => false do |t|
  87       t.column "id",        :bigserial, :primary_key => true, :null => false
  88       t.column "latitude",  :float, :limit => 53, :null => false
  89       t.column "longitude", :float, :limit => 53, :null => false
  90       t.column "user_id",   :bigint, :null => false
  91       t.column "visible",   :boolean, :null => false
  92       t.column "tags",      :text, :default => "", :null => false
  93       t.column "timestamp", :datetime, :null => false
  94     end
  95
  96     add_index "current_nodes", %w[latitude longitude], :name => "current_nodes_lat_lon_idx"
  97     add_index "current_nodes", ["timestamp"], :name => "current_nodes_timestamp_idx"
  98
  99     downgrade_table "current_nodes_v6", "current_nodes"
 100
 101     drop_table "current_nodes_v6"
 102
 103     rename_table "nodes", "nodes_v6"
 104
 105     create_table "nodes", :id => false do |t|
 106       t.column "id",        :bigint, :null => false
 107       t.column "latitude",  :float, :limit => 53, :null => false
 108       t.column "longitude", :float, :limit => 53, :null => false
 109       t.column "user_id",   :bigint, :null => false
 110       t.column "visible",   :boolean, :null => false
 111       t.column "tags",      :text, :default => "", :null => false
 112       t.column "timestamp", :datetime, :null => false
 113     end
 114
 115     add_index "nodes", ["id"], :name => "nodes_uid_idx"
 116     add_index "nodes", %w[latitude longitude], :name => "nodes_latlon_idx"
 117     add_index "nodes", ["timestamp"], :name => "nodes_timestamp_idx"
 118
 119     downgrade_table "nodes_v6", "nodes"
 120
 121     drop_table "nodes_v6"
 122   end
 123 end