Rails:仅返回所有关联满足条件的对象

CDu*_*Dub 12 ruby postgresql ruby-on-rails ruby-on-rails-3

设置:Rails 3.2.18,Postgres

我有两个对象,例如起见,打电话给他们Author,并Article具有以下设置:

class Author
  has_many :articles

  ...
end

class Article
  belongs_to :author

  class << self

    def published_over_one_year_ago
      where(arel_table[:published_at].lt(1.year.ago))
    end

  end
end
Run Code Online (Sandbox Code Playgroud)

我正在尝试查找一年前发布所有相关记录的所有Author记录.这段代码:Article

Author.joins(:article).merge(Article.published_over_one_year_ago)
Run Code Online (Sandbox Code Playgroud)

...返回一年前发布至少一个关联的Author对象,但我需要记录所有关联记录超过一年的记录.这是可能的arel/ActiveRecord,还是我必须使用原始SQL?Article AuthorArticle

潜在的"工作"SQL解决方案:

query = ERB.new(<<-SQL_END).result(binding)
  'author'.id in (
    select art.author_id
    from articles art
    group by art.author_id
    having sum(case (art.published_at::date >= current_date) when true then 1 else 0 end) = 0 AND
      sum(case(art.published_at::date < current_date) when true then 1 else 0 end) > 0
  )
SQL_END


# The following now appears to do what I want it to do.
Author.includes(:articles).where(query)
Run Code Online (Sandbox Code Playgroud)

更新我看到已经有一个建议的答案使用arel,这是杰出的.如果可能的话,有人建议使用直接的ActiveRecord吗?

Mar*_*rth 16

使用Arel和公用表表达式:

articles = Article.arel_table
authors = Author.arel_table
cte_table = Arel::Table.new(:cte_table)
composed_cte =
     Arel::Nodes::As.new(cte_table,
                         articles.project(articles[:author_id],
                                          articles[:published_at].maximum.as("max_published_at"))
                                 .group(articles[:author_id])
                        )
Run Code Online (Sandbox Code Playgroud)

然后 :

authors
  .join(cte_table).on(cte_table[:author_id].eq(authors[:id]))
  .with(composed_cte)
  .where(cte_table[:max_published_at].lt(1.year.ago))
  .project(authors[:id])
  .to_sql    
Run Code Online (Sandbox Code Playgroud)

返回(为清晰起见而格式化):

WITH "cte_table" AS (
    SELECT articles.author_id,
           MAX(articles.published_at) AS max_published_at
    FROM articles
    GROUP BY articles.author_id
)
SELECT authors.id
FROM authors
INNER JOIN cte_table
ON cte_table.author_id = authors.id
WHERE cte_tble.max_published_at < '2014-01-25 23:04:16.532796'
Run Code Online (Sandbox Code Playgroud)

使用它 :

[2] test»  Article.pluck(:author_id, :published_at)                                                                                                                                    
D, [2015-01-26T00:10:06.763197 #21897] DEBUG -- :    (0.6ms)  SELECT "articles"."author_id", "articles"."published_at" FROM "articles"
=> [
  [0] [
    [0] 1,
    [1] Sun, 25 Jan 2015 23:31:58 UTC +00:00
  ],
  [1] [
    [0] 1,
    [1] Fri, 01 Jan 1999 00:00:00 UTC +00:00
  ],
  [2] [
    [0] 2,
    [1] Fri, 01 Jan 1999 00:00:00 UTC +00:00
  ]
Run Code Online (Sandbox Code Playgroud)

查询返回:

[2015-01-26T00:10:25.279587 #21897] DEBUG -- :    (0.9ms)  WITH "cte_table" AS (SELECT "articles"."author_id", MAX("articles"."published_at") AS max_published_at FROM "articles" GROUP BY "articles"."author_id") SELECT "authors"."id" FROM "authors" INNER JOIN "cte_table" ON "cte_table"."author_id" = "authors"."id" WHERE "cte_table"."max_published_at" < '2014-01-25 23:10:25.277902'
=> [
  [0] {
    "id" => "2"
  }
]
Run Code Online (Sandbox Code Playgroud)

编辑

不使用Arel:

Author.joins(:articles)
      .where("authors.id != ANY (?)",
              Article.select('author_id')
                     .where("published_at > ?", 1.year.ago)
             )
Run Code Online (Sandbox Code Playgroud)

如果您添加.published_last_year到文章:

class Article < ActiveRecord::Base
  belongs_to :author

  def self.published_last_year
    where("published_at > ?", 1.year.ago)
  end  
end
Run Code Online (Sandbox Code Playgroud)

然后

Author.joins(:articles)
      .where("authors.id != ANY (?)",
              Article.published_last_year.select('author_id'))  
Run Code Online (Sandbox Code Playgroud)

Rails4版本

 Author.joins(:articles)
       .where.not(id: Article.published_last_year.select('author_id'))
Run Code Online (Sandbox Code Playgroud)