adjust primary key (#1416)

when we store the batches of two different systems (EFGS/CHGS), we should adjust our primary key!
corona-warn-app · Jun 3, 2021 · 509c4d5 · 509c4d5
1 parent 38c323c
commit 509c4d5
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/...va/app/coronawarn/server/common/persistence/repository/FederationBatchInfoRepository.java b/...va/app/coronawarn/server/common/persistence/repository/FederationBatchInfoRepository.java
@@ -30,7 +30,7 @@ boolean saveDoNothingOnConflict(
   @Query("INSERT INTO federation_batch_info "
       + "(batch_tag, date, status, source_system) "
       + "VALUES (:batchTag, :date, :status, :sourceSystem) "
-      + "ON CONFLICT (batch_tag) DO UPDATE SET status=:status")
+      + "ON CONFLICT (batch_tag, source_system) DO UPDATE SET status=:status")
   void saveDoUpdateStatusOnConflict(
       @Param("batchTag") String batchTag,
       @Param("date") LocalDate date,

diff --git a/common/persistence/src/main/resources/db/migration/V19__fixPKon_federation_batch_info.sql b/common/persistence/src/main/resources/db/migration/V19__fixPKon_federation_batch_info.sql
@@ -0,0 +1,2 @@
+ALTER TABLE federation_batch_info DROP CONSTRAINT federation_batch_info_pkey;
+ALTER TABLE federation_batch_info ADD PRIMARY KEY (batch_tag, source_system);
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		ALTER TABLE federation_batch_info DROP CONSTRAINT federation_batch_info_pkey;
		ALTER TABLE federation_batch_info ADD PRIMARY KEY (batch_tag, source_system);