LANTERN-595, LANTERN-596: Removal and prevention of duplicates in hea…

…lthit_products_map

db/migration/migrations/000028_remove_duplicates_healthit_products_map.down.sql

@@ -0,0 +1,6 @@
+BEGIN;
+
+ALTER TABLE public.healthit_products_map DROP CONSTRAINT unique_id_healthit_product;
+
+
+COMMIT;

db/migration/migrations/000028_remove_duplicates_healthit_products_map.up.sql

@@ -0,0 +1,23 @@
+BEGIN;
+
+CREATE OR REPLACE FUNCTION delete_duplicate_data_in_healthit_products_map() RETURNS VOID as $$
+    BEGIN
+        WITH CTE AS (
+    SELECT 
+        ctid,
+        ROW_NUMBER() OVER(PARTITION BY id, healthit_product_id ORDER BY id) AS DuplicateCount
+    FROM 
+        public.healthit_products_map
+)
+DELETE FROM public.healthit_products_map
+WHERE ctid IN (
+    SELECT ctid
+    FROM CTE
+    WHERE DuplicateCount > 1
+);
+    END;
+$$ LANGUAGE plpgsql;
+
+SELECT delete_duplicate_data_in_healthit_products_map();
+
+COMMIT;

endpointmanager/pkg/endpointmanager/postgresql/healthitproductstore.go

@@ -418,10 +418,7 @@ func (s *Store) DeleteLinksByProduct(ctx context.Context, productID int) error {
 
 func prepareHealthITProductStatements(s *Store) error {
 	var err error
-	addHealthITProductMapStatement, err = s.DB.Prepare(`
-		INSERT INTO healthit_products_map (id, healthit_product_id)
-		VALUES ($1, $2)
-		RETURNING id;`)
+	addHealthITProductMapStatement, err = s.DB.Prepare(`INSERT INTO healthit_products_map (id, healthit_product_id) VALUES ($1, $2) ON CONFLICT (id, healthit_product_id) DO UPDATE SET id=EXCLUDED.id RETURNING id;`)
 	if err != nil {
 		return err
 	}