在 Rails 中动态创建 mysql 列

Question

我正在开发一个私有 api，它将我们的许多数据库/供应商数据统一到一个 sql 数据库中。

我们的 ESP 面临挑战，我们的营销人员总是在更改/添加新列。我们希望此应用能够随着这些列更改而扩展，并且不需要在每次更改名称或添加新属性时都对列进行按摩。

我需要使用 Rails 动态创建列列表（我们不想在 Mysql 中 100% 执行此操作，因为我们正在重命名映射中的某些列）。

table = "customer"
attrs = ["vendor_cm_name_d", "vendor_cm_email address_d", "vendor_cm_date added_d", "vendor_cm_extid_d" ]

attrs.each_with_index do |attr, i|
  connection = ActiveRecord::Base.connection
  connection.execute( "ALTER TABLE #{table}  ADD COLUMN #{attr} VARCHAR(15);"  )
  # this didnt work :-( connection.close 
end

此方法适用于单个列，但在数组中有多个元素时失败。阅读日志（粘贴在下面）似乎试图将整个语句作为一个调用运行，而不是事务性的。我尝试在每个循环结束之前添加 connection.close ，但这也不起作用。欢迎所有指针。

Mysql2::Error: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'address_d VARCHAR(15)' at line 1: ALTER TABLE customer  ADD COLUMN vendor_cm_email address_d VARCHAR(15);
ActiveRecord::StatementInvalid: Mysql2::Error: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'address_d VARCHAR(15)' at line 1: ALTER TABLE customer  ADD COLUMN vendor_cm_email address_d VARCHAR(15);

Answer 1

您的sql 不起作用，因为列名有空格。用引号将生成的 sql 中的列名括起来。

attrs.each_with_index do |x, i|
  connection = ActiveRecord::Base.connection
  connection.execute "ALTER TABLE #{table}  ADD COLUMN \"#{x}\" VARCHAR(15);" 
# this didnt work :-( connection.close 
end

虽然我宁愿不走自己写 sql 的路。相反，您可以创建这样的服务：

class DbService < ActiveRecord::Migration
  def initialize(table_name)
    @table_name = table_name
  end
  def add_string_column(column_name)
    add_column @table_name, column_name, :string
  end
end

然后做类似的事情

service = DbService.new("customer")
attrs.each do |column_name|
  service.add_string_column(column_name)
end