Rails中ActiveRecord跨无模型数据库复制数据的连接隔离问题

你的问题根源在于：调用ActiveRecord::Base.establish_connection切换到旧库后，所有继承自ActiveRecord::Base的模型（包括Batch）都会默认使用这个新连接，所以Batch.count查的是旧库的数据，而非目标新库。

下面提供两种在单循环中实现连接隔离的方案，不用先全量加载旧数据再切换连接插入：

方案一：用connected_to块强制指定模型连接 #

在循环中创建Batch实例时，用connected_to块强制Batch使用新库的连接配置，确保读写隔离：

# 先保存新库的默认连接配置
new_db_config = ActiveRecord::Base.configurations[Rails.env]

# 切换到旧库执行查询
ActiveRecord::Base.establish_connection(adapter: 'sqlite3', database: 'storage/old.sqlite3')
ActiveRecord::Base.connection.execute('SELECT * FROM batches').each do |row|
  # 强制Batch在这个块内使用新库连接
  Batch.connected_to(database: new_db_config) do
    Batch.create(
      # 按需映射旧库row的字段到Batch属性，例如：
      # name: row['name'], created_at: row['created_at']
    )
    puts Batch.count # 此时统计的是新库数据
  end
end

# 最后切回新库默认连接
ActiveRecord::Base.establish_connection(new_db_config)

方案二：创建独立模型操作旧库（更推荐） #

新建一个专门绑定旧库的模型，让它和Batch模型各自使用独立连接，彻底避免全局连接切换的副作用：

# 在app/models目录下新建模型，专门对应旧库的batches表
class OldBatch < ActiveRecord::Base
  self.table_name = 'batches' # 指定旧库的表名
  # 直接绑定旧库连接
  establish_connection(adapter: 'sqlite3', database: 'storage/old.sqlite3')
end

# 直接循环查询旧数据，创建新Batch实例，连接完全隔离
OldBatch.find_each(batch_size: 1000) do |old_batch|
  Batch.create(
    # 映射旧模型属性到新Batch，例如：
    # name: old_batch.name, status: old_batch.status
  )
  puts Batch.count # 正常统计新库数据
end

注意事项 #

• 如果新旧库字段名/结构不一致，需要手动做字段映射转换；
• 数据量较大时，用find_each(batch_size: N)分批加载，避免内存溢出；
• 方案二更清晰，不会影响其他模型的默认连接，推荐优先使用。

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