複数のデータベースをActive Recordで使用する

production:
  database: my_primary_database
  adapter: mysql2
  username: root
  password: <%= ENV['ROOT_PASSWORD'] %>

production:
  primary:
    database: my_primary_database
    username: root
    password: <%= ENV['ROOT_PASSWORD'] %>
    adapter: mysql2
  primary_replica:
    database: my_primary_database
    username: root_readonly
    password: <%= ENV['ROOT_READONLY_PASSWORD'] %>
    adapter: mysql2
    replica: true
  animals:
    database: my_animals_database
    username: animals_root
    password: <%= ENV['ANIMALS_ROOT_PASSWORD'] %>
    adapter: mysql2
    migrations_paths: db/animals_migrate
  animals_replica:
    database: my_animals_database
    username: animals_readonly
    password: <%= ENV['ANIMALS_READONLY_PASSWORD'] %>
    adapter: mysql2
    replica: true

class AnimalsRecord < ApplicationRecord
  self.abstract_class = true

  connects_to database: { writing: :animals, reading: :animals_replica }
end

class ApplicationRecord < ActiveRecord::Base
  self.abstract_class = true

  connects_to database: { writing: :primary, reading: :primary_replica }
end

class PrimaryApplicationRecord < ActiveRecord::Base
  primary_abstract_class
end

config.active_record.writing_role = :default
config.active_record.reading_role = :readonly

$ bin/rails -T
bin/rails db:create                          # DATABASE_URLまたはconfig/database.ymlに基づいてデータベースを作成します...
bin/rails db:create:animals                  # 現在の環境のanimalsデータベースを作成します
bin/rails db:create:primary                  # 現在の環境のプライマリデータベースを作成します
bin/rails db:drop                            # DATABASE_URLまたはconfig/database.ymlに基づいてデータベースを削除します...
bin/rails db:drop:animals                    # 現在の環境のanimalsデータベースを削除します
bin/rails db:drop:primary                    # 現在の環境のプライマリデータベースを削除します
bin/rails db:migrate                         # データベースをマイグレーションします（オプション：VERSION=x、VERBOSE=false、SCOPE=blog）
bin/rails db:migrate:animals                 # 現在の環境のanimalsデータベースをマイグレーションします
bin/rails db:migrate:primary                 # 現在の環境のプライマリデータベースをマイグレーションします
bin/rails db:migrate:status                  # マイグレーションのステータスを表示します
bin/rails db:migrate:status:animals          # animalsデータベースのマイグレーションのステータスを表示します
bin/rails db:migrate:status:primary          # プライマリデータベースのマイグレーションのステータスを表示します
bin/rails db:reset                           # 現在の環境のスキーマからすべてのデータベースを削除して再作成し、シードをロードします
bin/rails db:reset:animals                   # 現在の環境のanimalsデータベースをスキーマから削除して再作成し、シードをロードします
bin/rails db:reset:primary                   # 現在の環境のプライマリデータベースをスキーマから削除して再作成し、シードをロードします
bin/rails db:rollback                        # スキーマを前のバージョンにロールバックします（ステップを指定する場合はSTEP=n）
bin/rails db:rollback:animals                # 現在の環境のanimalsデータベースをロールバックします（ステップを指定する場合はSTEP=n）
bin/rails db:rollback:primary                # 現在の環境のプライマリデータベースをロールバックします（ステップを指定する場合はSTEP=n）
bin/rails db:schema:dump                     # データベーススキーマファイルを作成します（db/schema.rbまたはdb/structure.sqlのいずれか...
bin/rails db:schema:dump:animals             # データベーススキーマファイルを作成します（db/schema.rbまたはdb/structure.sqlのいずれか...
bin/rails db:schema:dump:primary             # 任意のDBでポータブルなdb/schema.rbファイルを作成します...
bin/rails db:schema:load                     # データベーススキーマファイルをロードします（db/schema.rbまたはdb/structure.sqlのいずれか...
bin/rails db:schema:load:animals             # データベーススキーマファイルをロードします（db/schema.rbまたはdb/structure.sqlのいずれか...
bin/rails db:schema:load:primary             # データベーススキーマファイルをロードします（db/schema.rbまたはdb/structure.sqlのいずれか...
bin/rails db:setup                           # すべてのデータベースを作成し、すべてのスキーマをロードし、シードデータで初期化します（最初にすべてのデータベースを削除するにはdb:resetを使用します）
bin/rails db:setup:animals                   # animalsデータベースを作成し、スキーマをロードし、シードデータで初期化します（最初にデータベースを削除するにはdb:reset:animalsを使用します）
bin/rails db:setup:primary                   # プライマリデータベースを作成し、スキーマをロードし、シードデータで初期化します（最初にデータベースを削除するにはdb:reset:primaryを使用します）

production:
  primary:
    database: my_database
    adapter: mysql2
  animals:
    database: my_animals_database
    adapter: mysql2
    database_tasks: false

$ bin/rails generate migration CreateDogs name:string --database animals

$ bin/rails generate scaffold Dog name:string --database animals

class AnimalsRecord < ApplicationRecord
  self.abstract_class = true

  connects_to database: { writing: :animals }
end

class Dog < AnimalsRecord
end

$ bin/rails generate scaffold Dog name:string --database animals --parent Animals::Record

$ bin/rails g active_record:multi_db

Rails.application.configure do
  config.active_record.database_selector = { delay: 2.seconds }
  config.active_record.database_resolver = ActiveRecord::Middleware::DatabaseSelector::Resolver
  config.active_record.database_resolver_context = ActiveRecord::Middleware::DatabaseSelector::Resolver::Session
end

class MyCookieResolver << ActiveRecord::Middleware::DatabaseSelector::Resolver
  def self.call(request)
    new(request.cookies)
  end

  def initialize(cookies)
    @cookies = cookies
  end

  attr_reader :cookies

  def last_write_timestamp
    self.class.convert_timestamp_to_time(cookies[:last_write])
  end

  def update_last_write_timestamp
    cookies[:last_write] = self.class.convert_time_to_timestamp(Time.now)
  end

  def save(response)
  end
end

config.active_record.database_selector = { delay: 2.seconds }
config.active_record.database_resolver = ActiveRecord::Middleware::DatabaseSelector::Resolver
config.active_record.database_resolver_context = MyCookieResolver

ActiveRecord::Base.connected_to(role: :reading, prevent_writes: true) do
  # Railsは各クエリを読み取りクエリであることを確認します
end

production:
  primary:
    database: my_primary_database
    adapter: mysql2
  primary_replica:
    database: my_primary_database
    adapter: mysql2
    replica: true
  primary_shard_one:
    database: my_primary_shard_one
    adapter: mysql2
  primary_shard_one_replica:
    database: my_primary_shard_one
    adapter: mysql2
    replica: true

class ApplicationRecord < ActiveRecord::Base
  self.abstract_class = true

  connects_to shards: {
    default: { writing: :primary, reading: :primary_replica },
    shard_one: { writing: :primary_shard_one, reading: :primary_shard_one_replica }
  }
end

ActiveRecord::Base.connected_to(role: :writing, shard: :default) do
  @id = Person.create! # ":default"という名前のシャードにレコードを作成します
end

ActiveRecord::Base.connected_to(role: :writing, shard: :shard_one) do
  Person.find(@id) # レコードが見つからないため、存在しません。なぜなら、それは":default"という名前のシャードで作成されたからです。
end

ActiveRecord::Base.connected_to(role: :reading, shard: :shard_one) do
  Person.first # シャード1の読み取りレプリカからレコードを検索します
end

$ bin/rails g active_record:multi_db

Rails.application.configure do
  config.active_record.shard_selector = { lock: true }
  config.active_record.shard_resolver = ->(request) { Tenant.find_by!(host: request.host).shard }
end

config.active_record.shard_resolver = ->(request) {
  subdomain = request.subdomain
  tenant = Tenant.find_by_subdomain!(subdomain)
  tenant.shard
}

AnimalsRecord.connected_to(role: :reading, shard: :shard_one) do
  Dog.first # shard_one_replicaから読み込み。shard_one_replicaに接続が存在しない場合、ConnectionNotEstablishedエラーが発生します
  Person.first # primary writerから読み込み
end

ApplicationRecord.connected_to(role: :reading, shard: :shard_one) do
  Person.first # primary_shard_one_replicaから読み込み
  Dog.first # animals_primaryから読み込み
end

class Dog < AnimalsRecord
  has_many :treats, through: :humans, disable_joins: true
  has_many :humans

  has_one :home
  has_one :yard, through: :home, disable_joins: true
end

class Home
  belongs_to :dog
  has_one :yard
end

class Yard
  belongs_to :home
end

SELECT "humans"."id" FROM "humans" WHERE "humans"."dog_id" = ?  [["dog_id", 1]]
SELECT "treats".* FROM "treats" WHERE "treats"."human_id" IN (?, ?, ?)  [["human_id", 1], ["human_id", 2], ["human_id", 3]]

SELECT "home"."id" FROM "homes" WHERE "homes"."dog_id" = ? [["dog_id", 1]]
SELECT "yards".* FROM "yards" WHERE "yards"."home_id" = ? [["home_id", 1]]