Skip to content

Commit 85b13f7

Browse files
committed
Use same optimization from relevantSources query
1 parent 12b4193 commit 85b13f7

File tree

1 file changed

+8
-7
lines changed

1 file changed

+8
-7
lines changed

Diff for: pkg/store/sources.go

+8-7
Original file line numberDiff line numberDiff line change
@@ -237,13 +237,14 @@ func (db *psqlxStore) relatedFamilies(sf SourceFamily) (SourceFamilies, error) {
237237
SELECT DISTINCT s.name, s.component, s.target_id
238238
FROM sources s
239239
WHERE s.target_id = $3 AND s.component IN (
240-
SELECT s.component
241-
FROM sources s INNER JOIN source_issues si ON si.source_id = s.id
242-
WHERE s.target_id = $3 AND si.issue_id IN (
243-
SELECT si.issue_id FROM source_issues si
244-
INNER JOIN sources s ON si.source_id = s.id
245-
WHERE name=$1 AND component=$2 AND target_id = $3
246-
)
240+
SELECT UNNEST(comps)
241+
FROM (
242+
SELECT DISTINCT ARRAY_AGG(DISTINCT s.component) comps
243+
FROM sources s INNER JOIN source_issues si ON si.source_id = s.id
244+
WHERE s.target_id = $3 AND s.name=$1
245+
GROUP BY issue_id
246+
HAVING $2 = ANY(ARRAY_AGG(DISTINCT s.component))
247+
) C
247248
)`
248249

249250
args := []interface{}{sf.Name, sf.Component, sf.Target}

0 commit comments

Comments
 (0)