如何编写一个 Rails finder 方法来返回按记录分组的最大日期？

Question

我正在使用带有 PostGres 9.5 的 Rails 5。我有一张跟踪价格的表格...

                                         Table "public.crypto_prices"
       Column       |            Type             |                         Modifiers
--------------------+-----------------------------+------------------------------------------------------------
 id                 | integer                     | not null default nextval('crypto_prices_id_seq'::regclass)
 crypto_currency_id | integer                     |
 market_cap_usd     | bigint                      |
 total_supply       | bigint                      |
 last_updated       | timestamp without time zone |
 created_at         | timestamp without time zone | not null
 updated_at         | timestamp without time zone | not null

我想获得选定货币的每种货币的最新价格（last_updated 最高）。我可以找到与某些货币相关的所有价格，像这样

current_prices = CryptoPrice.where(crypto_currency_id: CryptoIndexCurrency.all.pluck(:crypto_currency_id).uniq)

然后我可以按货币将它们排序到数组中，循环遍历每个数组，直到找到具有最大 last_updated 值的那个，但是 我怎样才能编写一个查找器，它会准确地返回每种货币中最大的一行last_updated 日期？

编辑：像这样尝试了 Owl Max 的建议

ids = CryptoIndexCurrency.all.pluck(:crypto_currency_id).uniq
crypto_price_ids = CryptoPrice.where(crypto_currency_id: ids).group(:crypto_currency_id).maximum(:last_updated).keys
puts "price ids: #{crypto_price_ids.length}"
@crypto_prices = CryptoPrice.where(crypto_currency_id: crypto_price_ids)
puts "ids: #{@crypto_prices.size}"

虽然第一个“puts”只显示了“12”的大小，但第二个 put 显示了超过 38,000 个结果。它应该只返回 12 个结果，每种货币一个。

Answer 1

我们可以编写一个查找器，它会以类似的方式为每种货币返回一个具有最大 last_updated 日期的行，例如

current_prices = CryptoPrice.where(crypto_currency_id: CryptoIndexCurrency.all.pluck(:crypto_currency_id).uniq).select("*, id as crypto_price_id, MAX(last_updated) as last_updated").group(:crypto_currency_id)

我希望这会让你更接近你的目标。谢谢。

Answer 2

由于or查询方法，仅适用于Rails5

specific_ids = CryptoIndexCurrency.distinct.pluck(:crypto_currency_id)
hash = CryptoPrice.where(crypto_currency_id: specific_ids)
                  .group(:crypto_currency_id)
                  .maximum(:last_updated)
hash.each_with_index do |(k, v), i|
  if i.zero?
    res = CryptoPrice.where(crypto_currency_id: k, last_updated: v)
  else
    res.or(CryptoPrice.where(crypto_currency_id: k, last_updated: v))
  end
end

说明：

您可以使用group 将您的所有CryptoPrice 对象按表中的每个CryptoIndexCurrency 呈现重新组合。

然后使用maximum（感谢@artgb）取最大的值last_updated。这将输出带有键的Hash：crypto_currency_id 和值 last_updated。

最后，您可以使用keys 仅获得Array 的crypto_currency_id。

CryptoPrice.group(:crypto_currency_id).maximum(:last_updated)
=> => {2285=>2017-06-06 09:06:35 UTC,
       2284=>2017-05-18 15:51:05 UTC,
       2267=>2016-03-22 08:02:53 UTC}

这个解决方案的问题是你得到了每行的最大日期，而没有得到整个记录。

要获取记录，您可以对散列进行成对循环。与crypto_currency_id 和last_updated。这很 hacky，但我找到了唯一的解决方案。

Answer 3

使用此代码，您可以在此处从特定表中获取最新更新的行。

  CryptoPrice.order(:updated_at).pluck(:updated_at).last

这应该对你有帮助。

Answer 4

目前这在 Rails 中通过一个语句/查询来实现并不容易。如果您不介意使用多个语句/查询，那么这就是您的解决方案：

cc_ids = CryptoIndexCurrency.distinct.pluck(:crypto_currency_id)

result = cc_ids.map do |cc_id|
  max_last_updated = CryptoPrice.where(crypto_currency_id: cc_id).maximum(:last_updated)
  CryptoPrice.find_by(crypto_currency_id: cc_id, last_updated: max_last_updated)
end

map 方法的结果就是您要查找的结果。这会为每个 crypto_currency_id 生成 2 个查询，并为请求 crypto_currency_ids 生成 1 个查询。

如果您想通过一个查询来执行此操作，您需要使用OVER (PARTITION BY ...)。以下链接中的更多信息：

• Fetch the row which has the Max value for a column
• https://docs.microsoft.com/en-us/sql/t-sql/queries/select-over-clause-transact-sql
• https://blog.codeship.com/folding-postgres-window-functions-into-rails/

但在这种情况下，您必须编写一些 SQL。

编辑 1：

如果你想要一个不错的 Hash 结果运行：

cc_ids.zip(result).to_h

编辑 2：

如果您想将查询量减半，您可以将max_last_updated 查询推入find_by 作为子查询，如下所示：

cc_ids = CryptoIndexCurrency.distinct.pluck(:crypto_currency_id)

result = cc_ids.map do |cc_id|
  CryptoPrice.find_by(<<~SQL.squish)
    crypto_currency_id = #{cc_id} AND last_updated = (
      SELECT MAX(last_updated) 
      FROM crypto_prices 
      WHERE crypto_currency_id = #{cc_id})
  SQL
end

这会为每个 crypto_currency_id 生成 1 个查询，并为请求 crypto_currency_ids 生成 1 个查询。