如何为ActiveRecord关联查询添加动态JOIN条件

场景与问题描述 #

我需要统计指定时间段内各部门（Division）的事故（Accident）数量，现有两个关联模型：

class Division < ApplicationRecord
  has_many :accidents
end

class Accident < ApplicationRecord
  belongs_to :division
end

最初写的查询代码是：

Division.left_joins(:accidents).where('accidents.occurred_at > ?', Time.now - 1.year).group(:name).count

但这段代码生成的SQL会把时间条件放在WHERE子句里，导致没有事故的部门不会出现在结果中。我期望的是把时间条件放到LEFT OUTER JOIN的ON子句中，生成类似这样的SQL：

SELECT COUNT(accidents.id) AS "count_all", "divisions"."name" AS "divisions_name"
FROM "divisions"
LEFT OUTER JOIN "accidents" ON "accidents"."division_id" = "divisions"."id" and accidents.occurred_at > '2022-07-30 20:56:10.178153'
GROUP BY "divisions"."name"

已知可以在has_many关联中设置静态条件，但我需要根据用户请求参数动态调整这个时间条件，同时希望避免直接写原生SQL的JOIN条件。请问该如何实现？

解决方案 #

方法1：使用left_joins结合Lambda动态构建JOIN条件 #

ActiveRecord的left_joins支持传入lambda来定义动态的JOIN关联条件，无需硬编码原生SQL：

# 从请求参数获取动态时间，这里做默认值处理
start_time = params[:start_time] || Time.now - 1.year

Division.left_joins(
  accidents: -> { where(occurred_at: start_time..) }
).group(:name).count('accidents.id')

这段代码会自动将时间条件追加到LEFT JOIN的ON子句中，确保所有部门（包括事故数为0的）都能出现在结果里。

方法2：用Arel构建条件，彻底避免原生SQL片段 #

如果想完全脱离原生SQL字符串，可以用Arel的API动态拼接JOIN条件，兼容性和安全性更好：

start_time = params[:start_time] || Time.now - 1.year
division_table = Division.arel_table
accident_table = Accident.arel_table

# 构建带附加条件的LEFT JOIN关联
join_condition = accident_table[:division_id].eq(division_table[:id])
                  .and(accident_table[:occurred_at].gt(start_time))
join = division_table.join(accident_table, Arel::Nodes::OuterJoin).on(join_condition)

Division.joins(join.join_sources)
        .group(:name)
        .count('accidents.id')

方法3：动态定义临时关联（适合复用场景） #

可以在查询时给Division模型临时添加带动态条件的关联，适合需要多次复用该条件的场景：

start_time = params[:start_time] || Time.now - 1.year

# 动态添加带条件的关联
Division.class_eval do
  has_many :recent_accidents, 
           -> { where(occurred_at: start_time..) }, 
           class_name: 'Accident'
end

# 执行查询
Division.left_joins(:recent_accidents).group(:name).count('recent_accidents.id')

# 清理临时关联，避免影响后续查询
Division.send(:remove_method, :recent_accidents) if Division.method_defined?(:recent_accidents)

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