From 70909ba8c46173c072e65351ab241da17467f9e2 Mon Sep 17 00:00:00 2001 From: Grzegorz Michalski Date: Mon, 9 Feb 2026 13:42:50 +0100 Subject: [PATCH] Enhance FILE_ARCHIVER package to include ODS bucket URI retrieval and update insert statements for A_TABLE_STAT_HIST and A_TABLE_STAT --- .../MARS-828/new_version/FILE_ARCHIVER.pkb | 12 ++++++++---- README.md | 2 +- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/MARS_Packages/REL01_ADDITIONS/MARS-828/new_version/FILE_ARCHIVER.pkb b/MARS_Packages/REL01_ADDITIONS/MARS-828/new_version/FILE_ARCHIVER.pkb index b427074..b450c57 100644 --- a/MARS_Packages/REL01_ADDITIONS/MARS-828/new_version/FILE_ARCHIVER.pkb +++ b/MARS_Packages/REL01_ADDITIONS/MARS-828/new_version/FILE_ARCHIVER.pkb @@ -411,6 +411,7 @@ AS vTableName VARCHAR2(200); vQuery VARCHAR2(32000); vWhereClause VARCHAR2(4000); + vOdsBucketUri VARCHAR2(1000); BEGIN vParameters := CT_MRDS.ENV_MANAGER.FORMAT_PARAMETERS(SYS.ODCIVARCHAR2LIST('pSourceFileConfigKey => '||nvl(to_char(pSourceFileConfigKey), 'NULL'))); CT_MRDS.ENV_MANAGER.LOG_PROCESS_EVENT('Start','INFO', vParameters); @@ -423,6 +424,9 @@ AS vWhereClause := GET_ARCHIVAL_WHERE_CLAUSE(vSourceFileConfig); CT_MRDS.ENV_MANAGER.LOG_PROCESS_EVENT('vWhereClause','DEBUG',vWhereClause); + -- Get ODS bucket URI before building query + vOdsBucketUri := CT_MRDS.FILE_MANAGER.GET_BUCKET_URI('ODS') || 'ODS/' || vSourceFileConfig.A_SOURCE_KEY || '/' || vSourceFileConfig.TABLE_ID || '/'; + -- Use strategy-based WHERE clause for statistics (MARS-828) vQuery := 'with tmp as ( @@ -457,7 +461,7 @@ AS from tmp_gr t join (SELECT * from DBMS_CLOUD.LIST_OBJECTS( credential_name => '''||CT_MRDS.ENV_MANAGER.gvCredentialName||''', - location_uri => CT_MRDS.FILE_MANAGER.GET_BUCKET_URI(''ODS'')||''ODS/'||vSourceFileConfig.A_SOURCE_KEY||'/'||vSourceFileConfig.TABLE_ID||'/'') + location_uri => '''||vOdsBucketUri||''' ) ) r on t.filename = r.object_name' @@ -466,9 +470,9 @@ AS execute immediate vQuery into vStats; vStats.A_TABLE_STAT_KEY := CT_MRDS.A_TABLE_STAT_KEY_SEQ.NEXTVAL; - insert into A_TABLE_STAT_HIST values vStats; - delete from A_TABLE_STAT where A_SOURCE_FILE_CONFIG_KEY = pSourceFileConfigKey; - insert into A_TABLE_STAT values vStats; + insert into CT_MRDS.A_TABLE_STAT_HIST values vStats; + delete from CT_MRDS.A_TABLE_STAT where A_SOURCE_FILE_CONFIG_KEY = pSourceFileConfigKey; + insert into CT_MRDS.A_TABLE_STAT values vStats; COMMIT; CT_MRDS.ENV_MANAGER.LOG_PROCESS_EVENT('End','INFO',vParameters); diff --git a/README.md b/README.md index 4a7e376..2f37c21 100644 --- a/README.md +++ b/README.md @@ -77,4 +77,4 @@ sql "ADMIN/Cloudpass#34@ggmichalski_high" "@rollback_mars1057.sql" cd .\MARS_Packages\REL01_ADDITIONS\MARS-828 sql "ADMIN/Cloudpass#34@ggmichalski_high" "@install_mars828.sql" sql "ADMIN/Cloudpass#34@ggmichalski_high" "@rollback_mars828.sql" -7z a -pMojeSuperHaslo#123 -mhe=on M826_arch.7z MARS-828\ \ No newline at end of file +7z a -pMojeSuperHaslo#123 -mhe=on M828_arch.7z MARS-828\ \ No newline at end of file