单应用连接多数据库遇ActiveRecord连接池错误求解决方案

1. 为每个数据库创建独立的模型子类 #

不要直接修改ActiveRecord::Base的全局连接配置，而是为每个目标数据库定义专属的抽象模型基类，让每个类拥有独立的连接池，避免并发时互相覆盖：

# 定义抽象基类，作为所有自定义数据库模型的父类
class CustomDbBase < ActiveRecord::Base
  self.abstract_class = true # 标记为抽象类，不会生成对应的数据表

  def self.setup_connection(db_config)
    establish_connection(
      adapter: 'mysql2',
      encoding: 'utf8mb4',
      collation: 'utf8mb4_unicode_ci',
      reconnect: true,
      pool: 5,
      database: db_config[:database],
      username: db_config[:username],
      password: db_config[:password],
      host: db_config[:host]
    )
  end
end

# 根据数据库配置生成唯一子类，确保每个数据库对应独立连接池
def get_db_model(db_config)
  # 用数据库名生成唯一类名，避免重复创建
  class_key = "DbModel_#{db_config[:database].gsub(/[^a-z0-9]/i, '_')}"
  return Object.const_get(class_key) if Object.const_defined?(class_key)

  # 创建新子类并配置连接
  new_model = Class.new(CustomDbBase)
  Object.const_set(class_key, new_model)
  new_model.setup_connection(db_config)
  new_model
end

# 任务中使用子类执行查询
db_model = get_db_model({
  database: db_database,
  username: db_username,
  password: db_password,
  host: db_host
})
db_model.connection.execute("SELECT * FROM your_table")

2. 任务执行前后手动管理连接（仅临时应急，不推荐高并发场景） #

如果必须基于ActiveRecord::Base操作，需要在任务开始前保存当前连接配置，执行完成后还原并释放连接，减少并发冲突：

def execute_task(db_config)
  # 保存原始连接配置
  original_config = ActiveRecord::Base.connection_config
  begin
    ActiveRecord::Base.establish_connection(db_config)
    # 执行查询逻辑
    ActiveRecord::Base.connection.execute("SELECT * FROM your_table")
  ensure
    # 断开当前连接池
    ActiveRecord::Base.connection_pool.disconnect!
    # 还原原始连接配置
    ActiveRecord::Base.establish_connection(original_config)
  end
end

注意：这种方式仍存在并发竞争风险，因为ActiveRecord::Base是全局共享的，仅适合低并发场景临时过渡。

3. 手动管理多数据库连接池（复杂场景首选） #

如果涉及大量不同数据库的连接，可以用connection_pool gem手动维护每个数据库的连接池，完全脱离ActiveRecord的全局限制：

# 用线程安全哈希存储所有数据库的连接池
DB_POOLS = Concurrent::Hash.new do |hash, db_identifier|
  # 根据标识获取对应数据库配置
  db_config = fetch_db_config(db_identifier)
  # 创建连接池
  hash[db_identifier] = ConnectionPool.new(size: 5) do
    Mysql2::Client.new(
      host: db_config[:host],
      username: db_config[:username],
      password: db_config[:password],
      database: db_config[:database],
      encoding: 'utf8mb4',
      collation: 'utf8mb4_unicode_ci',
      reconnect: true
    )
  end
end

# 任务中获取连接执行查询
def run_query(db_identifier)
  DB_POOLS[db_identifier].with do |conn|
    conn.query("SELECT * FROM your_table")
  end
end

内容的提问来源于stack exchange，提问作者rhugo