Module: JdbcSpec::MySQL

Defined in:
lib/jdbc_adapter/jdbc_mysql.rb

Defined Under Namespace

Modules: Column

Constant Summary collapse

URL_OPTIONS = 
"zeroDateTimeBehavior=convertToNull&jdbcCompliantTruncation=false&useUnicode=true&characterEncoding=utf8"

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.adapter_selector ⇒ Object 



26
27
28
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 26

def self.adapter_selector
  [/mysql/i, lambda {|cfg,adapt| adapt.extend(::JdbcSpec::MySQL)}]
end

.column_selector ⇒ Object 



22
23
24
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 22

def self.column_selector
  [/mysql/i, lambda {|cfg,col| col.extend(::JdbcSpec::MySQL::Column)}]
end

.extended(adapter) ⇒ Object 



30
31
32
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 30

def self.extended(adapter)
  adapter.execute("SET SQL_AUTO_IS_NULL=0")
end

Instance Method Details

#add_limit_offset!(sql, options) ⇒ Object

:nodoc:



206
207
208
209
210
211
212
213
214
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 206

def add_limit_offset!(sql, options) #:nodoc:
  if limit = options[:limit]
    unless offset = options[:offset]
      sql << " LIMIT #{limit}"
    else
      sql << " LIMIT #{offset}, #{limit}"
    end
  end
end

#begin_db_transaction ⇒ Object

:nodoc:



101
102
103
104
105
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 101

def begin_db_transaction #:nodoc:
  @connection.begin
rescue Exception
  # Transactions aren't supported
end

#change_column(table_name, column_name, type, options = {}) ⇒ Object

:nodoc:



186
187
188
189
190
191
192
193
194
195
196
197
198
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 186

def change_column(table_name, column_name, type, options = {}) #:nodoc:
  unless options_include_default?(options)
    if column = columns(table_name).find { |c| c.name == column_name.to_s }
      options[:default] = column.default
    else
      raise "No such column: #{table_name}.#{column_name}"
    end
  end

  change_column_sql = "ALTER TABLE #{quote_table_name(table_name)} CHANGE #{quote_column_name(column_name)} #{quote_column_name(column_name)} #{type_to_sql(type, options[:limit], options[:precision], options[:scale])}"
  add_column_options!(change_column_sql, options)
  execute(change_column_sql)
end

#change_column_default(table_name, column_name, default) ⇒ Object

:nodoc:



180
181
182
183
184
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 180

def change_column_default(table_name, column_name, default) #:nodoc:
  current_type = select_one("SHOW COLUMNS FROM #{quote_table_name(table_name)} LIKE '#{column_name}'")["Type"]

  execute("ALTER TABLE #{quote_table_name(table_name)} CHANGE #{quote_column_name(column_name)} #{quote_column_name(column_name)} #{current_type} DEFAULT #{quote(default)}")
end

#charset ⇒ Object 



222
223
224
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 222

def charset
  show_variable("character_set_database")
end

#collation ⇒ Object 



226
227
228
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 226

def collation
  show_variable("collation_database")
end

#commit_db_transaction ⇒ Object

:nodoc:



107
108
109
110
111
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 107

def commit_db_transaction #:nodoc:
  @connection.commit
rescue Exception
  # Transactions aren't supported
end

#create_database(name, options = {}) ⇒ Object

:nodoc:



156
157
158
159
160
161
162
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 156

def create_database(name, options = {}) #:nodoc:
  if options[:collation]
    execute "CREATE DATABASE `#{name}` DEFAULT CHARACTER SET `#{options[:charset] || 'utf8'}` COLLATE `#{options[:collation]}`"
  else
    execute "CREATE DATABASE `#{name}` DEFAULT CHARACTER SET `#{options[:charset] || 'utf8'}`"
  end
end

#create_table(name, options = {}) ⇒ Object

:nodoc:



172
173
174
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 172

def create_table(name, options = {}) #:nodoc:
  super(name, {:options => "ENGINE=InnoDB CHARACTER SET utf8 COLLATE utf8_bin"}.merge(options))
end

#current_database ⇒ Object 



168
169
170
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 168

def current_database
  select_one("SELECT DATABASE() as db")["db"]
end

#disable_referential_integrity(&block) ⇒ Object

:nodoc:



119
120
121
122
123
124
125
126
127
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 119

def disable_referential_integrity(&block) #:nodoc:
  old = select_value("SELECT @@FOREIGN_KEY_CHECKS")
  begin
    update("SET FOREIGN_KEY_CHECKS = 0")
    yield
  ensure
    update("SET FOREIGN_KEY_CHECKS = #{old}")
  end
end

#drop_database(name) ⇒ Object

:nodoc:



164
165
166
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 164

def drop_database(name) #:nodoc:
  execute "DROP DATABASE IF EXISTS `#{name}`"
end

#modify_types(tp) ⇒ Object 



60
61
62
63
64
65
66
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 60

def modify_types(tp)
  tp[:primary_key] = "int(11) DEFAULT NULL auto_increment PRIMARY KEY"
  tp[:decimal] = { :name => "decimal" }
  tp[:timestamp] = { :name => "datetime" }
  tp[:datetime][:limit] = nil
  tp
end

#quote(value, column = nil) ⇒ Object

QUOTING ==================================================



70
71
72
73
74
75
76
77
78
79
80
81
82
83
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 70

def quote(value, column = nil)
  return value.quoted_id if value.respond_to?(:quoted_id)

  if column && column.type == :primary_key
    value.to_s
  elsif column && String === value && column.type == :binary && column.class.respond_to?(:string_to_binary)
    s = column.class.string_to_binary(value).unpack("H*")[0]
    "x'#{s}'"
  elsif BigDecimal === value
    "'#{value.to_s("F")}'"
  else
    super
  end
end

#quote_column_name(name) ⇒ Object

:nodoc:



85
86
87
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 85

def quote_column_name(name) #:nodoc:
    "`#{name}`"
end

#quote_table_name(name) ⇒ Object

:nodoc:



89
90
91
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 89

def quote_table_name(name) #:nodoc:
  quote_column_name(name).gsub('.', '`.`')
end

#quoted_false ⇒ Object 



97
98
99
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 97

def quoted_false
    "0"
end

#quoted_true ⇒ Object 



93
94
95
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 93

def quoted_true
    "1"
end

#recreate_database(name) ⇒ Object

:nodoc:



151
152
153
154
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 151

def recreate_database(name) #:nodoc:
  drop_database(name)
  create_database(name)
end

#rename_column(table_name, column_name, new_column_name) ⇒ Object

:nodoc:



200
201
202
203
204
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 200

def rename_column(table_name, column_name, new_column_name) #:nodoc:
  cols = select_one("SHOW COLUMNS FROM #{quote_table_name(table_name)} LIKE '#{column_name}'")
  current_type = cols["Type"] || cols["COLUMN_TYPE"]
  execute "ALTER TABLE #{quote_table_name(table_name)} CHANGE #{quote_table_name(column_name)} #{quote_column_name(new_column_name)} #{current_type}"
end

#rename_table(name, new_name) ⇒ Object 



176
177
178
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 176

def rename_table(name, new_name)
  execute "RENAME TABLE #{quote_table_name(name)} TO #{quote_table_name(new_name)}"
end

#rollback_db_transaction ⇒ Object

:nodoc:



113
114
115
116
117
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 113

def rollback_db_transaction #:nodoc:
  @connection.rollback
rescue Exception
  # Transactions aren't supported
end

#show_variable(var) ⇒ Object 



216
217
218
219
220
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 216

def show_variable(var)
  res = execute("show variables like '#{var}'")
  row = res.detect {|row| row["Variable_name"] == var }
  row && row["Value"]
end

#structure_dump ⇒ Object

SCHEMA STATEMENTS ========================================



131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
 
# File 'lib/jdbc_adapter/jdbc_mysql.rb', line 131

def structure_dump #:nodoc:
  if supports_views?
    sql = "SHOW FULL TABLES WHERE Table_type = 'BASE TABLE'"
  else
    sql = "SHOW TABLES"
  end

  select_all(sql).inject("") do |structure, table|
    table.delete('Table_type')

    hash = select_one("SHOW CREATE TABLE #{quote_table_name(table.to_a.first.last)}")

    if(table = hash["Create Table"])
      structure += table + ";\n\n"
    elsif(view = hash["Create View"])
      structure += view + ";\n\n"
    end
  end
end