Class: Lhm::Migrator

Inherits:
Object
  • Object
show all
Includes:
Command, SqlHelper
Defined in:
lib/lhm/migrator.rb

Overview

Copies existing schema and applies changes using alter on the empty table. ‘run` returns a Migration which can be used for the remaining process.

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from SqlHelper

#annotation, #idx_name, #idx_spec, #version_string

Methods included from Command

#run

Constructor Details

#initialize(table, connection = nil) ⇒ Migrator

Returns a new instance of Migrator.



18
19
20
21
22
23
 
# File 'lib/lhm/migrator.rb', line 18

def initialize(table, connection = nil)
  @connection = connection
  @origin = table
  @name = table.destination_name
  @statements = []
end

Instance Attribute Details

#conditions ⇒ Object (readonly)

Returns the value of attribute conditions.



16
17
18
 
# File 'lib/lhm/migrator.rb', line 16

def conditions
  @conditions
end

#connection ⇒ Object (readonly)

Returns the value of attribute connection.



16
17
18
 
# File 'lib/lhm/migrator.rb', line 16

def connection
  @connection
end

#name ⇒ Object (readonly)

Returns the value of attribute name.



16
17
18
 
# File 'lib/lhm/migrator.rb', line 16

def name
  @name
end

#statements ⇒ Object (readonly)

Returns the value of attribute statements.



16
17
18
 
# File 'lib/lhm/migrator.rb', line 16

def statements
  @statements
end

Instance Method Details

#add_column(name, definition) ⇒ Object

Add a column to a table

Examples:


Lhm.change_table(:users) do |m|
  m.add_column(:comment, "VARCHAR(12) DEFAULT '0'")
end

Parameters:

  • name (String) —

    Name of the column to add

  • definition (String) —

    Valid SQL column definition



54
55
56
 
# File 'lib/lhm/migrator.rb', line 54

def add_column(name, definition)
  ddl("alter table `%s` add column `%s` %s" % [@name, name, definition])
end

#add_index(columns, index_name = nil) ⇒ Object

Add an index to a table

Examples:


Lhm.change_table(:users) do |m|
  m.add_index(:comment)
  m.add_index([:username, :created_at])
  m.add_index("comment(10)")
end

Parameters:

  • columns (String, Symbol, Array<String, Symbol>) —

    A column name given as String or Symbol. An Array of Strings or Symbols for compound indexes. It’s possible to pass a length limit.

  • index_name (String, Symbol) (defaults to: nil) —

    Optional name of the index to be created



100
101
102
 
# File 'lib/lhm/migrator.rb', line 100

def add_index(columns, index_name = nil)
  ddl(index_ddl(columns, false, index_name))
end

#add_unique_index(columns, index_name = nil) ⇒ Object

Add a unique index to a table

Examples:


Lhm.change_table(:users) do |m|
  m.add_unique_index(:comment)
  m.add_unique_index([:username, :created_at])
  m.add_unique_index("comment(10)")
end

Parameters:

  • columns (String, Symbol, Array<String, Symbol>) —

    A column name given as String or Symbol. An Array of Strings or Symbols for compound indexes. It’s possible to pass a length limit.

  • index_name (String, Symbol) (defaults to: nil) —

    Optional name of the index to be created



119
120
121
 
# File 'lib/lhm/migrator.rb', line 119

def add_unique_index(columns, index_name = nil)
  ddl(index_ddl(columns, true, index_name))
end

#change_column(name, definition) ⇒ Object

Change an existing column to a new definition

Examples:


Lhm.change_table(:users) do |m|
  m.change_column(:comment, "VARCHAR(12) DEFAULT '0' NOT NULL")
end

Parameters:

  • name (String) —

    Name of the column to change

  • definition (String) —

    Valid SQL column definition



68
69
70
 
# File 'lib/lhm/migrator.rb', line 68

def change_column(name, definition)
  ddl("alter table `%s` modify column `%s` %s" % [@name, name, definition])
end

#ddl(statement) ⇒ Object

Note:

Don’t write the table name directly into the statement. Use the #name getter instead, because the alter statement will be executed against a temporary table.

Alter a table with a custom statement

Examples:


Lhm.change_table(:users) do |m|
  m.ddl("ALTER TABLE #{m.name} ADD COLUMN age INT(11)")
end

Parameters:

  • statement (String) —

    SQL alter statement



40
41
42
 
# File 'lib/lhm/migrator.rb', line 40

def ddl(statement)
  statements << statement
end

#filter(sql) ⇒ String

Filter the data that is copied into the new table by the provided SQL. This SQL will be inserted into the copy directly after the “from” statement - so be sure to use inner/outer join syntax and not cross joins.

Examples:

Add a conditions filter to the migration.

Lhm.change_table(:sounds) do |m|
  m.filter("inner join users on users.`id` = sounds.`user_id` and sounds.`public` = 1")
end

Parameters:

  • sql (String) —

    The sql filter.

Returns:

  • (String) —

    The sql filter.



157
158
159
 
# File 'lib/lhm/migrator.rb', line 157

def filter(sql)
  @conditions = sql
end

#remove_column(name) ⇒ Object

Remove a column from a table

Examples:


Lhm.change_table(:users) do |m|
  m.remove_column(:comment)
end

Parameters:

  • name (String) —

    Name of the column to delete



81
82
83
 
# File 'lib/lhm/migrator.rb', line 81

def remove_column(name)
  ddl("alter table `%s` drop `%s`" % [@name, name])
end

#remove_index(columns, index_name = nil) ⇒ Object

Remove an index from a table

Examples:


Lhm.change_table(:users) do |m|
  m.remove_index(:comment)
  m.remove_index([:username, :created_at])
end

Parameters:

  • columns (String, Symbol, Array<String, Symbol>) —

    A column name given as String or Symbol. An Array of Strings or Symbols for compound indexes.

  • index_name (String, Symbol) (defaults to: nil) —

    Optional name of the index to be removed



137
138
139
140
141
142
143
 
# File 'lib/lhm/migrator.rb', line 137

def remove_index(columns, index_name = nil)
  columns = [columns].flatten.map(&:to_sym)
  from_origin = @origin.indices.find {|name, cols| cols.map(&:to_sym) == columns}
  index_name ||= from_origin[0] unless from_origin.nil?
  index_name ||= idx_name(@origin.name, columns)
  ddl("drop index `%s` on `%s`" % [index_name, @name])
end