Commit 0bd09359 authored by Tiger Watson's avatar Tiger Watson

Merge branch 'mr-diff-preloader-perf-improvement' into 'master'

Avoid window functions in MR diff preloader

See merge request gitlab-org/gitlab!60849
parents d0ebade0 bf33c5e1
...@@ -113,14 +113,29 @@ class MergeRequestDiff < ApplicationRecord ...@@ -113,14 +113,29 @@ class MergeRequestDiff < ApplicationRecord
joins(merge_request: :metrics).where(condition) joins(merge_request: :metrics).where(condition)
end end
# This scope uses LATERAL JOIN to find the most recent MR diff association for the given merge requests.
# To avoid joining the merge_requests table, we build an in memory table using the merge request ids.
# Example:
# SELECT ...
# FROM (VALUES (MR_ID_1),(MR_ID_2)) merge_requests (id)
# INNER JOIN LATERAL (...)
scope :latest_diff_for_merge_requests, -> (merge_requests) do scope :latest_diff_for_merge_requests, -> (merge_requests) do
inner_select = MergeRequestDiff mrs = Array(merge_requests)
.default_scoped return MergeRequestDiff.none if mrs.empty?
.distinct
.select("FIRST_VALUE(id) OVER (PARTITION BY merge_request_id ORDER BY created_at DESC) as id")
.where(merge_request: merge_requests)
joins("INNER JOIN (#{inner_select.to_sql}) latest_diffs ON latest_diffs.id = merge_request_diffs.id") merge_request_table = MergeRequest.arel_table
merge_request_diff_table = MergeRequestDiff.arel_table
join_query = MergeRequestDiff
.where(merge_request_table[:id].eq(merge_request_diff_table[:merge_request_id]))
.order(created_at: :desc)
.limit(1)
mr_id_list = mrs.map { |mr| "(#{Integer(mr.id)})" }.join(",")
MergeRequestDiff
.from("(VALUES #{mr_id_list}) merge_requests (id)")
.joins("INNER JOIN LATERAL (#{join_query.to_sql}) #{MergeRequestDiff.table_name} ON TRUE")
.includes(:merge_request_diff_commits) .includes(:merge_request_diff_commits)
end end
......
...@@ -1166,5 +1166,9 @@ RSpec.describe MergeRequestDiff do ...@@ -1166,5 +1166,9 @@ RSpec.describe MergeRequestDiff do
it 'loads nothing if the merge request has no diff record' do it 'loads nothing if the merge request has no diff record' do
expect(described_class.latest_diff_for_merge_requests(merge_request_3)).to be_empty expect(described_class.latest_diff_for_merge_requests(merge_request_3)).to be_empty
end end
it 'loads nothing if nil was passed as merge_request' do
expect(described_class.latest_diff_for_merge_requests(nil)).to be_empty
end
end end
end end
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment