手动实例化ActiveRecord连接池导致数据库读取数据混乱

你的问题核心是完全绕开了ActiveRecord的连接池机制，用单例方式共享了单个数据库连接，这在多线程并发场景下必然出问题：

• MySQL2的底层连接实例不是线程安全的，多个线程同时用同一个连接执行查询时，结果集的元数据（比如列名）、返回数据会被交叉覆盖，就会出现字段值变列名、串请求结果的情况。
• @database1 ||=确实是问题的触发点，但不是语法本身的问题——它让整个进程只创建了一个连接实例，而不是让ActiveRecord为每个线程分配独立连接。你以为调用establish_connection会自动管理连接池，但直接拿.connection返回的是当前线程的连接（第一次调用时创建），后续所有线程都复用这个单例连接，完全没用到连接池的多线程管理能力。

不要手动持有单例连接，让ActiveRecord的连接池来管理连接分配。修改DataSources类：

class DataSources
  # 为database1创建独立的ActiveRecord模型基类，自动绑定连接池
  class Database1Record < ActiveRecord::Base
    self.abstract_class = true
    establish_connection(:database1)
  end

  def self.database1
    Database1Record.connection
  end

  # 封装查询方法，确保用的是连接池分配的连接
  def self.exec_query(sql)
    database1.exec_query(sql)
  end

  def self.query(sql)
    database1.query(sql)
  end
end

为什么这样有效？ #

• 抽象类Database1Record会为:database1配置创建独立的连接池，默认每个线程从池里获取专属连接，用完自动归还。
• 每次调用database1时，ActiveRecord会自动为当前线程分配连接（如果池里有空闲连接就复用，没有就新建，不超过池的最大连接数），完全避免了多线程共享单个连接的竞态问题。

针对只读场景，可以在数据库配置里加上只读相关的参数，同时调整连接池大小：

# config/database.yml
database1:
  adapter: mysql2
  database: your_db
  username: xxx
  password: xxx
  # 只读模式，防止误写
  read_only: true
  # 根据并发量调整连接池大小，默认是5
  pool: 10

• 并发测试：用ab、wrk或者Rails的并发请求测试工具，模拟多请求同时查询，确认数据混乱的问题消失。
• 连接数监控：查看数据库的连接数，确认并发时连接数会随着线程数增加（不超过pool配置的最大值），而不是始终只有1个连接。

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