如何在 ruby​​ on rails 应用程序中使用 postgresql“内部连接”？

Question

我有一个 PostgreSQL 查询，我正在我的 rails 应用程序中查找。

SQL 查询是：

SELECT *
       FROM event
       INNER  JOIN sensor ON (sensor.sid = event.sid)
       INNER  JOIN iphdr ON (iphdr.cid = event.cid) AND (iphdr.sid = event.sid);

此查询在 PostgreSQL 中运行良好。我希望它可以帮助我在我的 rails 应用程序中实现更少的 N+1 查找，但我没有成功实现它。

这是我的尝试：

ips_events = Event.joins(:sensor).on(:sensor.sid = :event.sid).joins(:ip_hdr).on(:ip_hdr.cid = :event.cid && :ip_hdr.sid = :event.sid).all.(conditions: ['timestamp >= ?', @ts]).reverse.uniq

我收到“NoMethodError: undefined method `sid' for :event:Symbol”

这是传感器模型：

class Sensor < ActiveRecord::Base
  # DB Schema
  # sid | hostname | interface | filter | detail | encoding | last_cid
  #--------------------------------------------------------------------

  attr_accessible :sid, :hostname, :interface, :filter, :detail, :encoding, :last_cid
  self.table_name = 'sensor'

  belongs_to :event,
             :foreign_key => :sid

end

事件模型：

class Event < ActiveRecord::Base
  # DB Schema
  # sid | cid | signature | timestamp
  #----------------------------------

  attr_accessible :sid, :cid, :signature, :timestamp
  self.primary_keys = :sid, :cid
  self.table_name = 'event'
  has_many :sensors,
           :foreign_key => :sid
  has_many :signatures,
           :foreign_key => :sig_id,
           :primary_key => :signature
  has_many :ip_hdrs,
           :foreign_key => [:sid, :cid]
  has_many :tcp_hdrs,
           :foreign_key => [:sid, :cid]
  has_many :udp_hdrs,
           :foreign_key => [:sid, :cid]
end

这是 ip_hdr 模型：

class IpHdr < ActiveRecord::Base
  # DB Schema
  # sid | cid | ip_src | ip_dst | ip_ver | ip_tos | ip_len | ip_id | ip_flags | ip_off | ip_ttl | ip_proto | ip_csum
  #-----------------------------------------------------------------------------------------------------------------

  attr_accessible :sid, :cid, :ip_src, :ip_dst, :ip_ver, :ip_tos, :ip_len, :ip_id, :ip_flags, :ip_off,
                  :ip_ttl, :ip_proto, :ip_csum
  self.primary_keys = :sid, :cid
  self.table_name = 'iphdr'
  belongs_to :event,
             :foreign_key => [:sid, :cid]
end

Answer 1

由于您的模型声明了 Event 和 Sensor 和 IpHdr 之间的关联，因此您可以简单地编写：

Event.
  joins(:sensors, :ip_hdrs).
  where("timestamp >= ?", @ts).
  order("event.timestamp desc").
  uniq

如果您要为上述查询返回的每个events 访问关联的sensors 和ip_hdrs，您应该像这样添加includes：

Event.
  joins(:sensors, :ip_hdrs).
  where("timestamp >= ?", @ts).
  order("event.timestamp desc").
  uniq.
  includes(:sensors, :ip_hdrs)

添加 includes 是 ActiveRecord 加载关联模型的提示。所以上面会发生在三个查询中：一个加载事件，一个加载传感器，一个加载 ip_hdrs。请参阅Active Record Guide 了解更多信息。

Answer 2

这不是 Rails 或 Postgres 本身的问题。 joins 是用于 inner join 的正确方法（这是 Postgres 中的默认 join）。

这里的问题更多是纯代码问题。您提到的错误意味着 symbol :event 引用的 object 没有为它定义 sid 方法，因此 NoMethodError当您尝试调用它时引发。

没有:event 后面的类 的代码，我只能推测，但很可能您需要将sid 作为另一个字段添加到您的数据模型 ，然后应该使该方法可用（假设您正在使用，比如说，ActiveRecord，这似乎很可能，基于上面使用的代码语法）。

此外，您的 Ruby 代码中 tcphdr 的 join 条件与您提供的 SQL 中的条件不同。还有一个额外的表，udphdr，被引用，它不在 SQL 中。