Module: Ridgepole::Ext::AbstractMysqlAdapter::SchemaCreation

Included in:
ActiveRecord::ConnectionAdapters::MySQL::SchemaCreation
Defined in:
lib/ridgepole/ext/abstract_mysql_adapter/schema_creation.rb

Instance Method Summary collapse

Instance Method Details

#visit_PartitionDefinition(o) ⇒ Object 



22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/ridgepole/ext/abstract_mysql_adapter/schema_creation.rb', line 22

def visit_PartitionDefinition(o)
  if o.values.key?(:in)
    "PARTITION #{o.name} VALUES IN (#{o.values[:in].map do |value|
      value.is_a?(Array) ? "(#{value.map(&:inspect).join(',')})" : value.inspect
    end.join(',')})"
  elsif o.values.key?(:to)
    "PARTITION #{o.name} VALUES LESS THAN (#{o.values[:to].map(&:inspect).join(',')})"
  else
    raise NotImplementedError
  end
end

#visit_PartitionOptions(o) ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
20
 
# File 'lib/ridgepole/ext/abstract_mysql_adapter/schema_creation.rb', line 9

def visit_PartitionOptions(o)
  sqls = o.partition_definitions.map { |partition_definition| accept partition_definition }
  function = case o.type
             when :list
               "LIST COLUMNS(#{o.columns.map { |column| quote_column_name(column) }.join(',')})"
             when :range
               "RANGE COLUMNS(#{o.columns.map { |column| quote_column_name(column) }.join(',')})"
             else
               raise NotImplementedError
             end
  "ALTER TABLE #{quote_table_name(o.table)} PARTITION BY #{function} (#{sqls.join(',')})"
end