admin/mars
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refactor rollback script to delete specific legacy files and adjust object URI construction

Browse Source
This commit is contained in:
Grzegorz Michalski
2026-03-09 11:46:01 +01:00
parent dec3e7137e
commit 64a4b9a2f0
1 changed files with 13 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
MARS_Packages/REL03/MARS-1005/90_MARS_1005_rollback_delete_csv_files.sql
View File

@@ -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