Как решить этот оператор sql, используя только arel

После долгих возни коллега состряпал следующую инструкцию SQL:

SELECT id, max(updated_at) FROM (
  SELECT (activities.id) as id, (notes.updated_at) as updated_at FROM `activities`
    INNER JOIN `notes` ON `notes`.`activity_id` = `activities`.`id`
    WHERE (context_id = 8) AND (notes.updated_at > '2011-12-01 18:56:16')
  UNION ALL (
    SELECT (activities.id) as id, (transitions.updated_at) as updated_at
    FROM `activities`
      INNER JOIN `transitions` ON (
        `transitions`.`transitionable_id` = `activities`.`id` 
         AND `transitions`.`transitionable_type` = 'Activity'
      )
      WHERE (context_id = 8) AND (transitions.updated_at > '2011-12-01 18:56:16')
  )
  ) transitions
  GROUP BY id ORDER BY updated_at DESC

Теперь давайте не будем вдаваться в детали или достоверность этого утверждения — он спросил меня, могу ли я создать для него прицел AR.

Я придумал следующее решение:

scope :most_recent_since, lambda { |way_back|
  activity_t   = Activity.arel_table
  transition_t = Transition.arel_table
  note_t       = Note.arel_table

  note_activities = activity_t.join(note_t).on(
    note_t[:activity_id].eq(activity_t[:id])
  ).where(
     activity_t[:context_id].eq(8).and(note_t[:updated_at].gt(way_back))
  )  

  transition_activities = activity_t.join(transition_t).on(
    transition_t[:transitionable_id].eq(activity_t[:id]).and(
      transition_t[:transitionable_type].eq('Activity')
    )
  ).where(
    activity_t[:context_id].eq(8).and(
      transition_t[:updated_at].gt(way_back)
    )  
  )  

  union = note_activities.project(
    activity_t[:id], note_t[:updated_at]
  ).union(
    transition_activities.project(activity_t[:id], transition_t[:updated_at])
  )  

  sql = transition_t.project(
    transition_t[:id]
  ).group(
    transition_t[:id]
  ).order(
    'updated_at'
  ).to_sql

  # now fiddle in the union sql - cant seem to find how to do it with Arel
  sql.gsub!("FROM `trans", "FROM #{union.to_sql} `trans")

  where( :id => Transition.find_by_sql(sql) )
}

Нет, мой вопрос; как, черт возьми, я могу заставить этот gsub уйти и выбрать ARel из нескольких источников (включая SQL/union)


ruby sql arel
person Hartog    schedule 09.12.2011    source источник
comment
Боюсь, в ваших вопросах слишком много деталей. Если бы вы могли создать короткий фрагмент, демонстрирующий проблему объединения, возможно, вы получите некоторые ответы.   -  person tokland    schedule 09.12.2011
comment
Еще одно предложение: используйте представления базы данных.   -  person Mladen Jablanović    schedule 09.12.2011

Ответы (1)


arrow_upward
1
arrow_downward

Это решение Arel взято с замечательного сайта scuttle.io:

transitions = Arel::Table.new('transitions')
Activity.select(:id, transitions[:updated_at].maximum).from(
  Activity.select(
    Arel::Nodes::Group.new(Activity.arel_table[:id]).as('id'), Arel::Nodes::Group.new(Transition.arel_table[:updated_at]).as('updated_at')
  ).where(
    Activity.arel_table[:context_id].eq(8).and(
      Transition.arel_table[:updated_at].gt('2011-12-01 18:56:16')
    )
  ).joins(
    Activity.arel_table.join(Note.arel_table).on(
      Note.arel_table[:activity_id].eq(Activity.arel_table[:id])
    ).join_sources
  ).joins(
    Activity.arel_table.join(Transition.arel_table).on(
      Arel::Nodes::Group.new(
        Transition.arel_table[:transitionable_id].eq(Activity.arel_table[:id]).and(
          Transition.arel_table[:transitionable_type].eq('Activity')
        )
      )
    ).join_sources
  ).as('transitions')
).order(:updated_at).reverse_order.group(:id)
person Dan Kohn    schedule 16.10.2014