Я использую две базы данных в своем проекте с поддержкой по умолчанию rails 6.
database.yml: -
default: &default
adapter: postgresql
migrations_paths: "db/migrate/primary"
encoding: unicode
min_messages: warning
username: ########
password: ########
pool: 5
timeout: 5000
host_name: localhost
development:
primary:
<<: *default
database: primary_db
hrm:
<<: *default
database: hrm_db
migrations_paths: "db/migrate/hrm"
Model'l вторичной базы данных похожи на:
class HRM::ServiceHistory < ApplicationRecord
connects_to database: { writing: :hrm, reading: :hrm }
belongs_to :employee
belongs_to :designation
.
.
Файл миграции: -
class ModifyDesigs < ActiveRecord::Migration[6.0]
def change
add_column :service_histories, :basic_scale, :integer
remove_column :employees, :designation_id
add_column :employees, :current_position_id, :integer
HRM::ServiceHistory.reset_column_information
HRM::Employee.reset_column_information
puts "\n\n=================== #{HRM::Employee.first.name} \n\n"
HRM::Employee.all.each do |emp|
emp.service_histories.each do |sh|
des = sh.designation
sh.basic_scale = des.basic_scale
sh.save!
end
sh = emp.service_histories.order('appointment_date desc').limit(1).first
if sh
emp.current_position = sh
emp.save!
end
end
end
end
Все обычные операторы DDL работают с файлом, даже HRM::Employee.first.name
не вызывает ошибку, но дальнейшие операторы вызывают ошибки:
== 20200409162158 ModifyDesigs: migrating =====================================
-- add_column(:service_histories, :basic_scale, :integer) -> 0.0041s
-- add_column(:service_histories, :scale, :integer) -> 0.0005s
-- add_column(:service_histories, :scale_type, :string, {:limit=>1}) -> 0.0005s
-- remove_column(:employees, :designation_id) -> 0.0050s
-- add_column(:employees, :current_position_id, :integer) -> 0.0004s
-- add_index(:employees, :current_position_id) -> 0.0114s
-- add_foreign_key(:employees, :service_histories, {:column=>:current_position_id}) -> 0.0044s
=================== Employee Name
rails aborted!
ActiveRecord::StatementInvalid: PG::ConnectionBad: connection is closed
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/postgresql/database_statements.rb:65:in `exec'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/postgresql/database_statements.rb:65:in `block (2 levels) in query'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/dependencies/interlock.rb:48:in `block in permit_concurrent_loads'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/concurrency/share_lock.rb:187:in `yield_shares'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/dependencies/interlock.rb:47:in `permit_concurrent_loads'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/postgresql/database_statements.rb:64:in `block in query'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/abstract_adapter.rb:718:in `block (2 levels) in log'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/abstract_adapter.rb:717:in `block in log'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/notifications/instrumenter.rb:24:in `instrument'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/abstract_adapter.rb:708:in `log'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/postgresql/database_statements.rb:63:in `query'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/abstract/database_statements.rb:98:in `query_value'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/postgresql_adapter.rb:383:in `release_advisory_lock'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/migration.rb:1384:in `ensure in with_advisory_lock'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/migration.rb:1385:in `with_advisory_lock'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/migration.rb:1229:in `migrate'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/migration.rb:1061:in `up'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/migration.rb:1036:in `migrate'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/tasks/database_tasks.rb:238:in `migrate'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/railties/databases.rake:114:in `block (4 levels) in <top (required)>'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/railties-6.0.2.1/lib/rails/commands/rake/rake_command.rb:23:in `block in perform'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/railties-6.0.2.1/lib/rails/commands/rake/rake_command.rb:20:in `perform'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/railties-6.0.2.1/lib/rails/command.rb:48:in `invoke'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/railties-6.0.2.1/lib/rails/commands.rb:18:in `<top (required)>'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/bootsnap-1.4.5/lib/bootsnap/load_path_cache/core_ext/kernel_require.rb:22:in `require'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/bootsnap-1.4.5/lib/bootsnap/load_path_cache/core_ext/kernel_require.rb:22:in `block in require_with_bootsnap_lfi'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/bootsnap-1.4.5/lib/bootsnap/load_path_cache/loaded_features_index.rb:92:in `register'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/bootsnap-1.4.5/lib/bootsnap/load_path_cache/core_ext/kernel_require.rb:21:in `require_with_bootsnap_lfi'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/bootsnap-1.4.5/lib/bootsnap/load_path_cache/core_ext/kernel_require.rb:30:in `require'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/dependencies.rb:325:in `block in require'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/dependencies.rb:291:in `load_dependency'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/dependencies.rb:325:in `require'...
Caused by:
PG::ConnectionBad: connection is closed
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/postgresql/database_statements.rb:65:in `exec'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/postgresql/database_statements.rb:65:in `block (2 levels) in query'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/dependencies/interlock.rb:48:in `block in permit_concurrent_loads'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/concurrency/share_lock.rb:187:in `yield_shares'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/dependencies/interlock.rb:47:in `permit_concurrent_loads'...
.
.
Caused by:
StandardError: An error has occurred, this and all later migrations canceled:
PG::ConnectionBad: connection is closed
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/postgresql/database_statements.rb:92:in `exec'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/postgresql/database_statements.rb:92:in `block (2 levels) in execute'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/dependencies/interlock.rb:48:in `block in permit_concurrent_loads'...
.
.
Caused by:
ActiveRecord::StatementInvalid: PG::ConnectionBad: connection is closed
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/postgresql/database_statements.rb:92:in `exec'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/postgresql/database_statements.rb:92:in `block (2 levels) in execute'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/dependencies/interlock.rb:48:in `block in permit_concurrent_loads'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/concurrency/share_lock.rb:187:in `yield_shares'...
.
.
Caused by:
PG::ConnectionBad: connection is closed
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/postgresql/database_statements.rb:92:in `exec'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_adapters/postgresql/database_statements.rb:92:in `block (2 levels) in execute'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/dependencies/interlock.rb:48:in `block in permit_concurrent_loads'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/concurrency/share_lock.rb:187:in `yield_shares'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activesupport-6.0.2.1/lib/active_support/dependencies/interlock.rb:47:in `permit_concurrent_loads'...
.
.
Caused by:
NoMethodError: undefined method `basic_scale=' for #<HRM::ServiceHistory:0x000000000f3b7c98>
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activemodel-6.0.2.1/lib/active_model/attribute_methods.rb:431:in `method_missing'
/var/www/dris/releases/315/db/migrate/hrm/20200409162158_modify_desigs.rb:20:in `block (3 levels) in change'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/relation/delegation.rb:85:in `each'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/relation/delegation.rb:85:in `each'
/var/www/dris/releases/315/db/migrate/hrm/20200409162158_modify_desigs.rb:18:in `block (2 levels) in change'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/relation/delegation.rb:85:in `each'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/relation/delegation.rb:85:in `each'
/var/www/dris/releases/315/db/migrate/hrm/20200409162158_modify_desigs.rb:17:in `block in change'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_handling.rb:269:in `swap_connection_handler'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_handling.rb:176:in `with_handler'
/home/deployer/.rvm/gems/ruby-2.5.1/gems/activerecord-6.0.2.1/lib/active_record/connection_handling.rb:132:in `connected_to'
/var/www/dris/releases/315/db/migrate/hrm/20200409162158_modify_desigs.rb:15:in `change'..
.
.
Это ошибка только одного запуска. Я пытался много раз, иногда задача зависает на puts HRM::Employee.first.name
, а иногда ошибка, как показано выше. Похоже, что выполнялись параллельные миграции, но они не должны. Хотя последний абзац журнала ошибок описывает некоторую ошибку в моих итерациях, но basic_scale=
определен, и я протестировал в консоли. Даже эта миграция успешно выполняется с консоли rails. Я никогда не сталкивался с такой проблемой до использования двух баз данных и до перехода на Rails 6 .
Редактировать: я пытался разделить миграцию в точке DML операторы и миграции выполняются успешно. Если я сбрасываю информацию столбца в одной миграции, это не должно вызывать эту проблему. Довольно странно, почему разделение миграций решает проблему.