From 64a4b9a2f097d45145c96bac3007f6b95a764c57 Mon Sep 17 00:00:00 2001
From: Grzegorz Michalski <grzegorz.michalski@dxc.com>
Date: Mon, 9 Mar 2026 11:46:01 +0100
Subject: [PATCH] Refactor rollback script to delete specific legacy files and
 adjust object URI construction

---
 ...90_MARS_1005_rollback_delete_csv_files.sql | 25 ++++++++++---------
 1 file changed, 13 insertions(+), 12 deletions(-)

diff --git a/MARS_Packages/REL03/MARS-1005/90_MARS_1005_rollback_delete_csv_files.sql b/MARS_Packages/REL03/MARS-1005/90_MARS_1005_rollback_delete_csv_files.sql
index a647642..42f94bd 100644
--- a/MARS_Packages/REL03/MARS-1005/90_MARS_1005_rollback_delete_csv_files.sql
+++ b/MARS_Packages/REL03/MARS-1005/90_MARS_1005_rollback_delete_csv_files.sql
@@ -35,12 +35,13 @@ BEGIN
         SELECT SOURCE_FILE_NAME
         FROM CT_MRDS.A_SOURCE_FILE_RECEIVED
         WHERE PROCESS_NAME = 'MARS-1005'
-          AND SOURCE_FILE_NAME LIKE vFolderPath || '%'
+          AND SOURCE_FILE_NAME LIKE '%LEGACY_ALLOTMENT_%'
+          AND SOURCE_FILE_NAME NOT LIKE '%MODIFICATION%'
     ) LOOP
         BEGIN
             DBMS_CLOUD.DELETE_OBJECT(
                 credential_name => 'OCI$RESOURCE_PRINCIPAL',
-                object_uri      => vDataBucketUri || rec.SOURCE_FILE_NAME
+                object_uri      => vDataBucketUri || vFolderPath || rec.SOURCE_FILE_NAME
             );
             DBMS_OUTPUT.PUT_LINE('  Deleted: ' || rec.SOURCE_FILE_NAME);
             vFileCount := vFileCount + 1;
@@ -72,10 +73,10 @@ BEGIN
     FOR rec IN (
         SELECT SOURCE_FILE_NAME FROM CT_MRDS.A_SOURCE_FILE_RECEIVED
         WHERE PROCESS_NAME = 'MARS-1005'
-          AND SOURCE_FILE_NAME LIKE vFolderPath || '%'
+          AND SOURCE_FILE_NAME LIKE '%LEGACY_ALLOTMENT_MODIFICATION_HEADER%'
     ) LOOP
         BEGIN
-            DBMS_CLOUD.DELETE_OBJECT(credential_name => 'OCI$RESOURCE_PRINCIPAL', object_uri => vDataBucketUri || rec.SOURCE_FILE_NAME);
+            DBMS_CLOUD.DELETE_OBJECT(credential_name => 'OCI$RESOURCE_PRINCIPAL', object_uri => vDataBucketUri || vFolderPath || rec.SOURCE_FILE_NAME);
             DBMS_OUTPUT.PUT_LINE('  Deleted: ' || rec.SOURCE_FILE_NAME);
             vFileCount := vFileCount + 1;
         EXCEPTION WHEN OTHERS THEN
@@ -100,10 +101,10 @@ BEGIN
     FOR rec IN (
         SELECT SOURCE_FILE_NAME FROM CT_MRDS.A_SOURCE_FILE_RECEIVED
         WHERE PROCESS_NAME = 'MARS-1005'
-          AND SOURCE_FILE_NAME LIKE vFolderPath || '%'
+          AND SOURCE_FILE_NAME LIKE '%LEGACY_ALLOTMENT_MODIFICATION_ITEM%'
     ) LOOP
         BEGIN
-            DBMS_CLOUD.DELETE_OBJECT(credential_name => 'OCI$RESOURCE_PRINCIPAL', object_uri => vDataBucketUri || rec.SOURCE_FILE_NAME);
+            DBMS_CLOUD.DELETE_OBJECT(credential_name => 'OCI$RESOURCE_PRINCIPAL', object_uri => vDataBucketUri || vFolderPath || rec.SOURCE_FILE_NAME);
             DBMS_OUTPUT.PUT_LINE('  Deleted: ' || rec.SOURCE_FILE_NAME);
             vFileCount := vFileCount + 1;
         EXCEPTION WHEN OTHERS THEN
@@ -128,10 +129,10 @@ BEGIN
     FOR rec IN (
         SELECT SOURCE_FILE_NAME FROM CT_MRDS.A_SOURCE_FILE_RECEIVED
         WHERE PROCESS_NAME = 'MARS-1005'
-          AND SOURCE_FILE_NAME LIKE vFolderPath || '%'
+          AND SOURCE_FILE_NAME LIKE '%LEGACY_ANNOUNCEMENT%'
     ) LOOP
         BEGIN
-            DBMS_CLOUD.DELETE_OBJECT(credential_name => 'OCI$RESOURCE_PRINCIPAL', object_uri => vDataBucketUri || rec.SOURCE_FILE_NAME);
+            DBMS_CLOUD.DELETE_OBJECT(credential_name => 'OCI$RESOURCE_PRINCIPAL', object_uri => vDataBucketUri || vFolderPath || rec.SOURCE_FILE_NAME);
             DBMS_OUTPUT.PUT_LINE('  Deleted: ' || rec.SOURCE_FILE_NAME);
             vFileCount := vFileCount + 1;
         EXCEPTION WHEN OTHERS THEN
@@ -156,10 +157,10 @@ BEGIN
     FOR rec IN (
         SELECT SOURCE_FILE_NAME FROM CT_MRDS.A_SOURCE_FILE_RECEIVED
         WHERE PROCESS_NAME = 'MARS-1005'
-          AND SOURCE_FILE_NAME LIKE vFolderPath || '%'
+          AND SOURCE_FILE_NAME LIKE '%LEGACY_FBL_ITEM%'
     ) LOOP
         BEGIN
-            DBMS_CLOUD.DELETE_OBJECT(credential_name => 'OCI$RESOURCE_PRINCIPAL', object_uri => vDataBucketUri || rec.SOURCE_FILE_NAME);
+            DBMS_CLOUD.DELETE_OBJECT(credential_name => 'OCI$RESOURCE_PRINCIPAL', object_uri => vDataBucketUri || vFolderPath || rec.SOURCE_FILE_NAME);
             DBMS_OUTPUT.PUT_LINE('  Deleted: ' || rec.SOURCE_FILE_NAME);
             vFileCount := vFileCount + 1;
         EXCEPTION WHEN OTHERS THEN
@@ -184,10 +185,10 @@ BEGIN
     FOR rec IN (
         SELECT SOURCE_FILE_NAME FROM CT_MRDS.A_SOURCE_FILE_RECEIVED
         WHERE PROCESS_NAME = 'MARS-1005'
-          AND SOURCE_FILE_NAME LIKE vFolderPath || '%'
+          AND SOURCE_FILE_NAME LIKE '%LEGACY_FULLBID_ARRAY_COMPILED%'
     ) LOOP
         BEGIN
-            DBMS_CLOUD.DELETE_OBJECT(credential_name => 'OCI$RESOURCE_PRINCIPAL', object_uri => vDataBucketUri || rec.SOURCE_FILE_NAME);
+            DBMS_CLOUD.DELETE_OBJECT(credential_name => 'OCI$RESOURCE_PRINCIPAL', object_uri => vDataBucketUri || vFolderPath || rec.SOURCE_FILE_NAME);
             DBMS_OUTPUT.PUT_LINE('  Deleted: ' || rec.SOURCE_FILE_NAME);
             vFileCount := vFileCount + 1;
         EXCEPTION WHEN OTHERS THEN