【问题标题】:Rails - same model with multiple databases (read only)Rails - 具有多个数据库的相同模型(只读)
【发布时间】:2015-08-02 09:39:39
【问题描述】:

我有多个数据库,里面有相同的表和列名(但不同的唯一 ID 和行..)。它不是拥有一个包含所有行的庞大数据库,而是拆分为不同的数据库。这是我无法改变的(你可以认为这是从不同国家收集相同的数据,但每个国家都有自己的数据库)。 这些数据库是“只读的”——这意味着,当我通过 Rails 使用它们时,它只是为了显示数据(或将其保存在本地数据库中)——我不会更改任何远程数据库上的数据。

我的问题是,我需要在 rails 中有 1 个模型,用于从所有这些数据库中收集数据。我们希望能够执行以下操作:

OneModelAllDB.select_where(...)

并且不要将每个搜索拆分为:

data1 = FirstDBModel.select_where(same_condition)
data2 = SecondDBModel.select_where(same_condition)
...
data = data1 + data2 + ...

另外,如果我想用线程(并行搜索)制作 1 个模型,就会出现问题:

[:db1, :db2].each do |db|
  threads << Thread.new do
    self.establish_connection(db)
    results[db] = self.where(bla_bla_condition)
  end
end

因为修改连接不是线程安全的……

有什么办法吗?由于我们不会更改这些数据库中的任何一个,并且每一行都有一个唯一的 id,因此从不同的数据库中获取数据并将它们连接在一起应该没有任何问题......

谢谢!

【问题讨论】:

  • 如果您希望它像一个大数据库一样运行而不实际更改结构,您需要在模型中编写自己的多数据库访问方法,以执行我在回答中显示的操作。 (模型一次只能访问一个实际的数据库。)然后在代码的其他地方你可以引用新方法。

标签: ruby-on-rails database ruby-on-rails-3 model


【解决方案1】:

Rails 活动记录是从数据库连接中抽象出来的。连接是单独管理的。你不会有像FirstDB.select_where(...) 这样的东西。

但是,您可以尝试在 config/database.yml 中定义不同的数据库,例如:

db1:
  adapter: postgresql
  encoding: unicode
  database: database1
  pool: 5
  username: xxx
  password: xxx

db2:
  adapter: postgresql
  encoding: unicode
  database: database2
  pool: 5
  username: xxx
  password: xxx

然后在您的代码中,您将使用ActiveRecord::Base.establish_connection 在运行查询之前重新建立与所需数据库的连接。如果你的活动记录模型被称为Foo,那么:

Foo.establish_connection(:db1)
data1 = Foo.where(...)

Foo.establish_connection(:db2)
data2 = Foo.where(...)

我自己没有详细尝试过,但应该可以这样工作。

【讨论】:

  • 首先 - 感谢您的回答。当我写FirstDB.select_where(same_condition) 时,我的意思是第一个模型是establish_connection(:db1),第二个模型是:db2 等等。问题是我想要一个模型来包含它们(所有数据库),并且能够做到这一点在不同的线程中(建立连接不是线程安全的)
  • @Guy 我显示的答案是使用相同的模型Foo。但是,如果您希望一次调用模型来执行多个数据库访问,则需要为执行不同数据库连接的模型编写自己的类方法,如图所示。
  • @Guy 如果您的数据库都是同一类型(例如,它们都是 MySQL),您可以使用 multi-database queries utilizing UNION 编写您的自定义 Foo.multi_select。当然,您仍然需要对正在访问的所有数据库进行适当的身份验证。
  • 但是如果我想用不同的线程做那些(如在原始帖子中添加的)?有人告诉我这不能使用establish_connection,因为它不是线程安全的。除此之外-您的解决方案正是我的想法,而且很棒!谢谢!
  • @Guy 啊,我明白了。我不熟悉establish_connection 的“线程安全性”或缺乏它。也许您可以使用UNION 技术。无论哪种方式,都需要做一些工作来寻找您想要覆盖或重铸(使用新名称)以利用该技术的 AR 方法。
猜你喜欢
  • 2022-06-21
  • 2023-03-22
  • 2016-09-10
  • 1970-01-01
  • 1970-01-01
  • 2018-01-22
  • 2016-06-16
  • 2019-01-09
  • 2013-05-14
相关资源
最近更新 更多