Rails 7 条件连接不同数据库失败求助

问题根源分析 #

1. connected_to参数错误：你用了role: :main_red，但你的ExternalRecord是通过connects_to database: {main_red: :main_red...}定义的数据库连接，应该用database:参数指定目标数据库，而非role:。另外，应该针对ExternalRecord切换连接，而不是ActiveRecord::Base——后者默认绑定的是primary数据库。
2. 延迟加载触发的连接异常：result是ActiveRecord关系对象，属于延迟加载模式，你在connected_to块内只是定义了查询逻辑，并没有实际执行查询。当块结束后，连接自动切回primary，这时候调用result.count会触发查询，但此时BulkExport模型找不到对应的连接池，就会抛出ConnectionNotEstablished错误。
3. 模型继承确认：确保Api::V2::BulkExport继承自ExternalRecord，否则它会默认使用primary数据库连接，根本不会用到你定义的main_red/green/blue连接。

修正后的代码示例 #

第一步：确认模型继承

class Api::V2::BulkExport < ExternalRecord
  # 模型逻辑...
end

第二步：修正连接切换与查询执行

# 针对ExternalRecord切换到目标数据库，并在块内完成所有查询操作
result = ExternalRecord.connected_to(database: :main_red) do
  Api::V2::BulkExport.where(Tier: @tier, Version: 'v2')
                     .order(order)
                     .ransack(@params[:q])
                     .result
                     .limit(@limit)
                     .to_a # 转为数组，立即执行查询，避免延迟加载
end

# 插入操作使用默认的primary连接（ActiveRecord::Base默认绑定primary）
track_usage(user_id: @user.id, end_point: request.path, rows_returned: result.size)

额外优化建议 #

• 如果需要动态切换数据库（比如根据参数选择red/green/blue），可以把数据库名作为变量传入：

  target_db = :main_red # 可根据业务逻辑动态赋值
  result = ExternalRecord.connected_to(database: target_db) do
    # 查询逻辑...
  end
  

• 确保track_usage对应的模型继承自ApplicationRecord（而非ExternalRecord），这样它会自动使用primary数据库连接，无需额外切换。

内容的提问来源于stack exchange，提问作者opensource-developer