Skip to content

Commit db5fd70

Browse files
committed
Add decision inner joins to find duplicates query
As we only want to compare decisions with each other, we explicitly exclude pending proceedings from being taken into account in the query. RISDEV-6661
1 parent ededb38 commit db5fd70

File tree

1 file changed

+18
-2
lines changed

1 file changed

+18
-2
lines changed

backend/src/main/java/de/bund/digitalservice/ris/caselaw/adapter/database/jpa/DatabaseDuplicateCheckRepository.java

+18-2
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,8 @@ HAVING COUNT(*) <= 50
2828
FROM incremental_migration.documentation_unit documentationUnit
2929
JOIN incremental_migration.file_number fileNumber
3030
ON documentationUnit.id = fileNumber.documentation_unit_id
31+
INNER JOIN incremental_migration.decision decision
32+
ON decision.id = documentationUnit.id
3133
WHERE upper(fileNumber.value) IN (SELECT value FROM filtered_file_numbers)
3234
AND documentationUnit.date IN (:allDates)
3335
@@ -39,6 +41,8 @@ AND documentationUnit.date IN (:allDates)
3941
ON documentationUnit.id = fileNumber.documentation_unit_id
4042
JOIN incremental_migration.deviating_date deviatingDate
4143
ON documentationUnit.id = deviatingDate.documentation_unit_id
44+
INNER JOIN incremental_migration.decision decision
45+
ON decision.id = documentationUnit.id
4246
WHERE upper(fileNumber.value) IN (SELECT value FROM filtered_file_numbers)
4347
AND deviatingDate.value IN (:allDates)
4448
@@ -48,6 +52,8 @@ AND deviatingDate.value IN (:allDates)
4852
FROM incremental_migration.documentation_unit documentationUnit
4953
JOIN incremental_migration.deviating_file_number deviatingFileNumber
5054
ON documentationUnit.id = deviatingFileNumber.documentation_unit_id
55+
INNER JOIN incremental_migration.decision decision
56+
ON decision.id = documentationUnit.id
5157
WHERE upper(deviatingFileNumber.value) IN (SELECT value FROM filtered_file_numbers)
5258
AND documentationUnit.date IN (:allDates)
5359
@@ -59,6 +65,8 @@ AND documentationUnit.date IN (:allDates)
5965
ON documentationUnit.id = deviatingFileNumber.documentation_unit_id
6066
JOIN incremental_migration.deviating_date deviatingDate
6167
ON documentationUnit.id = deviatingDate.documentation_unit_id
68+
INNER JOIN incremental_migration.decision decision
69+
ON decision.id = documentationUnit.id
6270
WHERE upper(deviatingFileNumber.value) IN (SELECT value FROM filtered_file_numbers)
6371
AND deviatingDate.value IN (:allDates)
6472
@@ -70,6 +78,8 @@ AND deviatingDate.value IN (:allDates)
7078
ON documentationUnit.id = fileNumber.documentation_unit_id
7179
JOIN incremental_migration.court court
7280
ON documentationUnit.court_id = court.id
81+
INNER JOIN incremental_migration.decision decision
82+
ON decision.id = documentationUnit.id
7383
WHERE upper(fileNumber.value) IN (SELECT value FROM filtered_file_numbers)
7484
AND court.id IN (:allCourtIds)
7585
@@ -81,6 +91,8 @@ AND court.id IN (:allCourtIds)
8191
ON documentationUnit.id = deviatingFileNumber.documentation_unit_id
8292
JOIN incremental_migration.court court
8393
ON documentationUnit.court_id = court.id
94+
INNER JOIN incremental_migration.decision decision
95+
ON decision.id = documentationUnit.id
8496
WHERE upper(deviatingFileNumber.value) IN (SELECT value FROM filtered_file_numbers)
8597
AND court.id IN (:allCourtIds)
8698
@@ -92,6 +104,8 @@ AND court.id IN (:allCourtIds)
92104
ON documentationUnit.id = fileNumber.documentation_unit_id
93105
JOIN incremental_migration.deviating_court deviatingCourt
94106
ON documentationUnit.id = deviatingCourt.documentation_unit_id
107+
INNER JOIN incremental_migration.decision decision
108+
ON decision.id = documentationUnit.id
95109
WHERE upper(fileNumber.value) IN (SELECT value FROM filtered_file_numbers)
96110
AND upper(deviatingCourt.value) IN (:allDeviatingCourts)
97111
@@ -103,22 +117,24 @@ AND upper(deviatingCourt.value) IN (:allDeviatingCourts)
103117
ON documentationUnit.id = deviatingFileNumber.documentation_unit_id
104118
JOIN incremental_migration.deviating_court deviatingCourt
105119
ON documentationUnit.id = deviatingCourt.documentation_unit_id
120+
INNER JOIN incremental_migration.decision decision
121+
ON decision.id = documentationUnit.id
106122
WHERE upper(deviatingFileNumber.value) IN (SELECT value FROM filtered_file_numbers)
107123
AND upper(deviatingCourt.value) IN (:allDeviatingCourts)
108124
109125
UNION
110126
111127
SELECT documentationUnit.id, documentationUnit.duplicate_check AS isJdvDuplicateCheckActive
112128
FROM incremental_migration.documentation_unit documentationUnit
113-
JOIN incremental_migration.decision decision
129+
INNER JOIN incremental_migration.decision decision
114130
ON decision.id = documentationUnit.id
115131
WHERE upper(decision.ecli) IN (:allEclis) AND decision.ecli != ''
116132
117133
UNION
118134
119135
SELECT documentationUnit.id, documentationUnit.duplicate_check AS isJdvDuplicateCheckActive
120136
FROM incremental_migration.documentation_unit documentationUnit
121-
JOIN incremental_migration.decision decision
137+
INNER JOIN incremental_migration.decision decision
122138
ON decision.id = documentationUnit.id
123139
JOIN incremental_migration.deviating_ecli deviatingEcli
124140
ON decision.id = deviatingEcli.documentation_unit_id

0 commit comments

Comments
 (0)