summaryrefslogtreecommitdiff
path: root/app/models/concerns/from_union.rb
blob: e25d603b80240c2c6f1681828f9e289bc8fbb710 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
# frozen_string_literal: true

module FromUnion
  extend ActiveSupport::Concern

  class_methods do
    # Produces a query that uses a FROM to select data using a UNION.
    #
    # Using a FROM for a UNION has in the past lead to better query plans. As
    # such, we generally recommend this pattern instead of using a WHERE IN.
    #
    # Example:
    #     users = User.from_union([User.where(id: 1), User.where(id: 2)])
    #
    # This would produce the following SQL query:
    #
    #     SELECT *
    #     FROM (
    #       SELECT *
    #       FROM users
    #       WHERE id = 1
    #
    #       UNION
    #
    #       SELECT *
    #       FROM users
    #       WHERE id = 2
    #     ) users;
    #
    # members - An Array of ActiveRecord::Relation objects to use in the UNION.
    #
    # remove_duplicates - A boolean indicating if duplicate entries should be
    #                     removed. Defaults to true.
    #
    # alias_as - The alias to use for the sub query. Defaults to the name of the
    #            table of the current model.
    # rubocop: disable Gitlab/Union
    extend FromSetOperator
    define_set_operator Gitlab::SQL::Union

    alias_method :from_union_set_operator, :from_union
    def from_union(members, remove_duplicates: true, alias_as: table_name)
      if Feature.enabled?(:sql_set_operators)
        from_union_set_operator(members, remove_duplicates: remove_duplicates, alias_as: alias_as)
      else
        # The original from_union method.
        standard_from_union(members, remove_duplicates: remove_duplicates, alias_as: alias_as)
      end
    end

    private

    def standard_from_union(members, remove_duplicates: true, alias_as: table_name)
      union = Gitlab::SQL::Union
        .new(members, remove_duplicates: remove_duplicates)
        .to_sql

      from(Arel.sql("(#{union}) #{alias_as}"))
    end

    # rubocop: enable Gitlab/Union
  end
end