Rails мигрирует с разными базами данных

Мне нужно использовать Devise с существующей таблицей пользователей в другой базе данных, поэтому я настраиваю свой файл database.yml:

development:
  adapter: postgresql
  encoding: unicode
  database: almoxarifado
  pool: 5
  timeout: 5000
  username: user
  password: pass
  host: localhost

users_development:
  adapter: postgresql
  encoding: unicode
  database: portal 
  pool: 5
  timeout: 5000
  username: user
  password: pass
  host: localhost
  schema_search_path: users  

В своей модели я написал такой код:

class User < ActiveRecord::Base
  establish_connection "users_#{Rails.env}"
  devise :database_authenticatable, :registerable,
         :recoverable, :rememberable, :trackable, :validatable
end

Когда я запускаю Rails c и вызываю класс модели, это работает очень хорошо.

Файл миграции:

class AddDeviseToUsers < ActiveRecord::Migration
  def self.up
    ActiveRecord::Base.establish_connection "users_#{Rails.env}"
    change_table(:users) do |t|
      ## Database authenticatable
      t.string :email,              :null => false, :default => ""
      t.string :encrypted_password, :null => false, :default => ""

      ## Recoverable
      t.string   :reset_password_token
      t.datetime :reset_password_sent_at

      ## Rememberable
      t.datetime :remember_created_at

      ## Trackable
      t.integer  :sign_in_count, :default => 0, :null => false
      t.datetime :current_sign_in_at
      t.datetime :last_sign_in_at
      t.string   :current_sign_in_ip
      t.string   :last_sign_in_ip

      ## Confirmable
      # t.string   :confirmation_token
      # t.datetime :confirmed_at
      # t.datetime :confirmation_sent_at
      # t.string   :unconfirmed_email # Only if using reconfirmable

      ## Lockable
      # t.integer  :failed_attempts, :default => 0, :null => false # Only if lock strategy is :failed_attempts
      # t.string   :unlock_token # Only if unlock strategy is :email or :both
      # t.datetime :locked_at


      # Uncomment below if timestamps were not included in your original model.
      # t.timestamps
    end

    add_index :users, :email,                :unique => true
    add_index :users, :reset_password_token, :unique => true
    # add_index :users, :confirmation_token,   :unique => true
    # add_index :users, :unlock_token,         :unique => true
    ActiveRecord::Base.establish_connection "#{Rails.env}"
  end

  def self.down
    # By default, we don't want to make any assumption about how to roll back a migration when your
    # model already existed. Please edit below which fields you would like to remove in this migration.
    raise ActiveRecord::IrreversibleMigration
  end
end

Но rake db: migrate возвращает эту ошибку:

==  AddDeviseToUsers: migrating =======================================
-- change_table(:users)
rake aborted!
An error has occurred, this and all later migrations canceled:

undefined method `rollback' for #<ActiveRecord::ConnectionAdapters::ClosedTransaction:0xbb06767c>
Tasks: TOP => db:migrate
(See full trace by running task with --trace)

person giordanofalves    schedule 10.12.2013    source источник


Ответы (5)


Поскольку я потратил много времени на попытки со всеми альтернативами в этом и других сообщениях, но безуспешно, вот решение, которое мне подходит

database.yml

external_database:
  adapter: postgresql
  database: <%= ENV['DATABASE_NAME'] %>
  username: <%= ENV['DATABASE_USERNAME'] %>
  password: <%= ENV['DATABASE_PASSWORD'] %>
  host: <%= ENV['DATABASE_HOST'] %>
  port: <%= ENV['DATABASE_PORT'] || 5432 %>

модели / yourmodel.rb

class YourModel < ActiveRecord::Base
  establish_connection :external_database
end

ваша миграция

class YourMigration < ActiveRecord::Migration
  def self.up
    YourModel.connection.enable_extension "plpgsql"
    YourModel.connection.create_table :your_table_name, id: :uuid do |t|
      t.text :title
      ...
    end
  end

  def self.down
    YourModel.connection.drop_table :your_table_name
  end
end

Объяснение: Поскольку ActiveRecord :: Base.establish_connection закрывает соединение, я использую соединение из модели напрямую. Кроме того, поскольку я использую UUID с методом uuid_generate_v4 () по умолчанию, я включил расширение, используя то же соединение

person skozz    schedule 17.01.2018

================================= ОБНОВЛЕНИЕ ================ =================

Я нашел хорошую статью, в которой говорится об этом: http://www.thegreatcodeadventure.com/managing-multiple-databases-in-a-single-rails-application/

================================= ОБНОВЛЕНИЕ ================ =================

Я просто поместил install_connection из класса миграции.

ActiveRecord::Base.establish_connection "users_#{Rails.env}"
class AddDeviseToUsers < ActiveRecord::Migration
  def self.up

    change_table(:users) do |t|
      ## Database authenticatable
      t.string :email,              :null => false, :default => ""
      t.string :encrypted_password, :null => false, :default => ""

      ## Recoverable
      t.string   :reset_password_token
      t.datetime :reset_password_sent_at

      ## Rememberable
      t.datetime :remember_created_at

      ## Trackable
      t.integer  :sign_in_count, :default => 0, :null => false
      t.datetime :current_sign_in_at
      t.datetime :last_sign_in_at
      t.string   :current_sign_in_ip
      t.string   :last_sign_in_ip

      ## Confirmable
      # t.string   :confirmation_token
      # t.datetime :confirmed_at
      # t.datetime :confirmation_sent_at
      # t.string   :unconfirmed_email # Only if using reconfirmable

      ## Lockable
      # t.integer  :failed_attempts, :default => 0, :null => false # Only if lock strategy is :failed_attempts
      # t.string   :unlock_token # Only if unlock strategy is :email or :both
      # t.datetime :locked_at


      # Uncomment below if timestamps were not included in your original model.
      # t.timestamps
    end

    add_index :users, :email,                :unique => true
    add_index :users, :reset_password_token, :unique => true
    # add_index :users, :confirmation_token,   :unique => true
    # add_index :users, :unlock_token,         :unique => true
  end

  def self.down
    # By default, we don't want to make any assumption about how to roll back a migration when your
    # model already existed. Please edit below which fields you would like to remove in this migration.
    raise ActiveRecord::IrreversibleMigration
  end
end
person giordanofalves    schedule 10.12.2013

Создайте метод в своем классе миграции

def self.connection ActiveRecord::Base.establish_connection("#{Rails.env}_yourcustomenv").connection end

Мне потребовалось некоторое время, чтобы понять, что нужен метод, объявленный с помощью self. Это работало на Rails 4.0

person Ryan D    schedule 18.06.2014
comment
@ Райан Д. Спасибо. Я также использую Rails 4.2.0. Мне потребовалось время, чтобы прочитать множество ответов. наконец нашла твое. Просто добавив себя в функцию :) - person aldrien.h; 01.02.2016

Вы почти пришли к решению. Просто пришлось сделать User.connection вместо ActiveRecord::Base.establish_connection.

Взгляните на решение здесь: https://stackoverflow.com/a/34292909/2499227

Способ ActiveRecord::Base.establish_connection всегда вызывал у меня проблемы с schema_migrations и / или закрытием соединения, но соединение с моделью работает гладко.

person MTarantini    schedule 15.12.2015

В вашем config / database.yml:

development_custom_db:
  database: almoxarifado
  username: user
  password: pass
  host: localhost

Создайте файл, содержащий это, по пути config / initializers /:

module Custom
  class Base < ActiveRecord::Base
    self.abstract_class = true

    connection_name = "#{Rails.env}_custom_db"
    if Rails.application.config.database_configuration.has_key?(connection_name)
      establish_connection connection_name.to_sym
    end
  end

  class Migration < ActiveRecord::Migration
    def connection
      @_connection ||= Custom::Base.connection
    end
  end
end

Затем наследуйте его в своем файле миграции:

class AddDeviseToUsers < Custom::Migration
 def up
   change_table(:users) do |t|

   end
 end
end
person EarlyZhao    schedule 20.04.2018
comment
Кажется, это работает правильно, но не добавляет запись в таблицу schema_migrations в правильной базе данных. - person taylorthurlow; 30.05.2019