Ako môžem nájsť spojené tabuľka najstarší záznam filtrovanie jedným z jej atribútov?

0

Otázka

Mám model Subscription ktoré has_many Versions.

A Versionstatus, plan_id a authorized_at dátum.

Všetky zmeny Subscription pochádza z Version zmeny aktualizácia je rodič Subscription.

Cieľom je nájsť každý Predplatné' Version s najstaršou authorized_at dátum WHERE na versions.plan_id je rovnaký ako subscriptions.plan_id (inými slovami, potrebujem povolenie dátum Version kde plan_id zmeniť na aktuálnu Subscription"s plan_id).

Je to dotaz som prišiel s. Vypisuje chybu v agregačnú funkciu syntax:

syntax error at or near "MIN" LINE 3: MIN (authorized_at) from versions ^

dotaz:

select subscriptions.id,
MIN (authorized_at) from versions
where versions.plan_id = subscriptions.plan_id
) as current_version
from subscriptions
join versions on subscriptions.id = versions.subscription_id
where versions.status = 'processed'

Tiež som si nie som istý, či by som mal byť zoskupovanie podľa verzie plan_id a potom vybrať z každej skupiny. Som typ stratil.

database postgresql ruby ruby-on-rails
2021-11-23 14:26:06
3

Najlepšiu odpoveď

1

Môžete použiť bočné poddotaz , ktoré môže byť najlepšie popísaný ako foreach slučky v SQL. Sú extrémne výkonný spôsob, ako vybrať stĺpce z jedného súvisí záznam alebo dokonca kamenivo zo skupiny súvisiacich záznamov.

Pre každý riadok v predplatné DB bude vyberte jeden riadok z verzie zoradené podľa authorized_at:

SELECT "subscriptions".*,
       "latest_version"."authorized_at" AS current_version,
       "latest_version"."id" AS current_version_id -- could be very useful
FROM   "subscriptions" 
LATERAL
  (
     SELECT   "versions"."authorized_at", "versions"."id"
     FROM     "versions"
     WHERE    "versions"."subscription_id" = "subscriptions"."id" -- lateral reference
     AND      "versions"."plan_id" = "subscriptions"."plan_id"
     AND      "versions"."status" = 'processed'
     ORDER BY "versions"."authorized_at" ASC
     LIMIT 1
  ) latest_version ON TRUE

Vytvorenie bočnej spája v ActiveRecord môže byť vykonané buď s SQL reťazce alebo Arel:

class Subscription < ApplicationRecord
  # Performs a lateral join and selects the 
  # authorized_at of the latest version 
  def self.with_current_version
    lateral = Version.arel_table.then do |v|
      v.project(
        v[:authorized_at],
        v[:id] # optional
      ).where(
        v[:subscription_id].eq(arel_table[:id])
          .and(v[:plan_id].eq(arel_table[:plan_id]) )
          .and(v[:status].eq('processed'))
      )
      .order(v[:authorized_at].asc)
      .take(1) # limit 1
      .lateral('latest_version ON TRUE')
    end
    lv = Arel::Table.new(:latest_version) # just a table alias
    select(
      *where(nil).arel.projections, # selects everything previously selected
      lv[:authorized_at].as("current_version"),
      lv[:id].as("current_version_id") # optional
    ).joins(lateral.to_sql)
  end
end

Ak si len chcete vybrať id a current_version stĺpca, mali by ste zvážiť použitie trhať namiesto výberu databázy modelov, ktoré nie sú správne hydratovaná.

2021-11-23 16:49:48
1

Môžete použiť DISTINCT ON filtrovať riadky a udržať jeden za predplatné -- prvý na skupiny podľa ORDER BY doložka.

Napríklad:

select distinct on (s.id) s.id, v.authorized_at
from subscription s
join versions v on v.subscription_id = s.id and v.plan_id = s.plan_id
where v.status = 'processed'
order by s.id, v.authorized_at
2021-11-23 16:40:51

Ďakujem. Dotaz zdá sa, že práca v konzole, ale keď som skúste ju použiť v moje názory ako model rozsah dostanem ActiveRecord::StatementInvalid: PG::SyntaxError: ERROR: syntax error at or near "WHERE" LINE 6: ...s.id, v.authorized_at WHERE "sub...
pinkfloyd90

@pinkfloyd90 nie som žiadny expert na ActiveRecord, ale možno, že to nefunguje, pretože pohľad je pravdepodobne nie updatable.
The Impaler
0

Kód nižšie vám versions kde Verzie plan_id je rovná Predplatné' plan_id.

@versions = Version.joins("LEFT JOIN subscriptions ON subscriptions.plan_id = versions.plan_id")

Ak chcete filtrovať záznamy Verzia status

@versions = Version.joins("LEFT JOIN subscriptions ON subscriptions.plan_id = versions.plan_id").where(status: "processed")

Ak chcete filtrovať záznamy Verzia status a objednávka authorized_at vo vzostupnom poradí.

@versions = Version.joins("LEFT JOIN subscriptions ON subscriptions.plan_id = versions.plan_id").where(status: "processed").order(:authorized_at)

Ak chcete filtrovať záznamy Verzia status a objednávka authorized_at v decending objednávky.

@versions = Version.joins("LEFT JOIN subscriptions ON subscriptions.plan_id = versions.plan_id").where(status: "processed").order(authorized_at: :desc)

Dúfam, že to funguje pre vás!

2021-11-23 14:33:48

Myslím si, že je potrebné spojiť na subscriptions.id = versions.subscription_id alebo dostanete verzií v tom, že výsledkom, ktoré nepatria do tohto predplatného. Môžete tiež ešte ani nedotkol na základné otázky, ktoré je výber agregát.
max

V iných jazykoch

Táto stránka je v iných jazykoch

Русский
..................................................................................................................
Italiano
..................................................................................................................
Polski
..................................................................................................................
Română
..................................................................................................................
한국어
..................................................................................................................
हिन्दी
..................................................................................................................
Français
..................................................................................................................
Türk
..................................................................................................................
Česk
..................................................................................................................
Português
..................................................................................................................
ไทย
..................................................................................................................
中文
..................................................................................................................
Español
..................................................................................................................