Compare commits
3 Commits
b6f6446232
...
057a4e7ce3
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
057a4e7ce3 | ||
|
|
a9a51f19be | ||
|
|
fc6304c60b |
@@ -81,6 +81,8 @@ SELECT CT_MRDS.FILE_ARCHIVER.GET_VERSION() as package_version FROM DUAL;
|
|||||||
-- 7. Test trigger validation
|
-- 7. Test trigger validation
|
||||||
PROMPT
|
PROMPT
|
||||||
PROMPT 7. Testing trigger validation (should fail)...
|
PROMPT 7. Testing trigger validation (should fail)...
|
||||||
|
WHENEVER SQLERROR CONTINUE
|
||||||
|
SET SERVEROUTPUT ON
|
||||||
DECLARE
|
DECLARE
|
||||||
vTestPassed BOOLEAN := FALSE;
|
vTestPassed BOOLEAN := FALSE;
|
||||||
BEGIN
|
BEGIN
|
||||||
@@ -107,14 +109,16 @@ EXCEPTION
|
|||||||
WHEN OTHERS THEN
|
WHEN OTHERS THEN
|
||||||
IF SQLCODE = -20999 THEN
|
IF SQLCODE = -20999 THEN
|
||||||
DBMS_OUTPUT.PUT_LINE('SUCCESS: Trigger validation working correctly');
|
DBMS_OUTPUT.PUT_LINE('SUCCESS: Trigger validation working correctly');
|
||||||
DBMS_OUTPUT.PUT_LINE('Expected error: ' || SQLERRM);
|
DBMS_OUTPUT.PUT_LINE('Trigger correctly rejected MINIMUM_AGE_MONTHS strategy without required value');
|
||||||
vTestPassed := TRUE;
|
vTestPassed := TRUE;
|
||||||
ELSE
|
ELSE
|
||||||
DBMS_OUTPUT.PUT_LINE('ERROR: Unexpected error: ' || SQLERRM);
|
DBMS_OUTPUT.PUT_LINE('ERROR: Unexpected error occurred during trigger validation');
|
||||||
|
DBMS_OUTPUT.PUT_LINE('Error code: ' || SQLCODE);
|
||||||
END IF;
|
END IF;
|
||||||
ROLLBACK;
|
ROLLBACK;
|
||||||
END;
|
END;
|
||||||
/
|
/
|
||||||
|
WHENEVER SQLERROR EXIT FAILURE
|
||||||
|
|
||||||
PROMPT
|
PROMPT
|
||||||
PROMPT ========================================
|
PROMPT ========================================
|
||||||
|
|||||||
@@ -234,7 +234,7 @@ AS
|
|||||||
|
|
||||||
-- Note: DBMS_CLOUD.EXPORT_DATA may create multiple parquet files (parallel execution)
|
-- Note: DBMS_CLOUD.EXPORT_DATA may create multiple parquet files (parallel execution)
|
||||||
-- Instead of tracking individual files, we store the archive directory prefix
|
-- Instead of tracking individual files, we store the archive directory prefix
|
||||||
-- ARCH_FILE_NAME will contain the directory URI where all parquet files are located
|
-- ARCH_PATH contain the directory URI where all parquet files are located
|
||||||
vFilename := vUri; -- Store directory prefix instead of individual filename
|
vFilename := vUri; -- Store directory prefix instead of individual filename
|
||||||
|
|
||||||
-- Try to drop EXPORTED FILES ("regular data files")
|
-- Try to drop EXPORTED FILES ("regular data files")
|
||||||
@@ -245,7 +245,7 @@ AS
|
|||||||
BEGIN
|
BEGIN
|
||||||
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
||||||
SET PROCESSING_STATUS = 'ARCHIVED_AND_TRASHED' -- Status reflects file is archived and kept in TRASH
|
SET PROCESSING_STATUS = 'ARCHIVED_AND_TRASHED' -- Status reflects file is archived and kept in TRASH
|
||||||
,ARCH_FILE_NAME = vFilename -- Now contains directory prefix, not individual file
|
,ARCH_PATH = vFilename -- Now contains directory prefix, not individual file
|
||||||
,PARTITION_YEAR = ym_loop.year -- Record which partition year the data was archived to
|
,PARTITION_YEAR = ym_loop.year -- Record which partition year the data was archived to
|
||||||
,PARTITION_MONTH = ym_loop.month -- Record which partition month the data was archived to
|
,PARTITION_MONTH = ym_loop.month -- Record which partition month the data was archived to
|
||||||
WHERE r.a_source_file_config_key= pSourceFileConfigKey
|
WHERE r.a_source_file_config_key= pSourceFileConfigKey
|
||||||
@@ -324,7 +324,7 @@ AS
|
|||||||
|
|
||||||
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
||||||
SET PROCESSING_STATUS = 'INGESTED'
|
SET PROCESSING_STATUS = 'INGESTED'
|
||||||
,ARCH_FILE_NAME = NULL
|
,ARCH_PATH = NULL
|
||||||
WHERE r.a_source_file_config_key = pSourceFileConfigKey
|
WHERE r.a_source_file_config_key = pSourceFileConfigKey
|
||||||
AND r.source_file_name = f.filename
|
AND r.source_file_name = f.filename
|
||||||
;
|
;
|
||||||
@@ -579,7 +579,7 @@ AS
|
|||||||
|
|
||||||
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED
|
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED
|
||||||
SET PROCESSING_STATUS = 'INGESTED',
|
SET PROCESSING_STATUS = 'INGESTED',
|
||||||
ARCH_FILE_NAME = NULL,
|
ARCH_PATH = NULL,
|
||||||
PARTITION_YEAR = NULL,
|
PARTITION_YEAR = NULL,
|
||||||
PARTITION_MONTH = NULL
|
PARTITION_MONTH = NULL
|
||||||
WHERE A_SOURCE_FILE_RECEIVED_KEY = pSourceFileReceivedKey
|
WHERE A_SOURCE_FILE_RECEIVED_KEY = pSourceFileReceivedKey
|
||||||
@@ -620,7 +620,7 @@ AS
|
|||||||
|
|
||||||
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED
|
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED
|
||||||
SET PROCESSING_STATUS = 'INGESTED',
|
SET PROCESSING_STATUS = 'INGESTED',
|
||||||
ARCH_FILE_NAME = NULL,
|
ARCH_PATH = NULL,
|
||||||
PARTITION_YEAR = NULL,
|
PARTITION_YEAR = NULL,
|
||||||
PARTITION_MONTH = NULL
|
PARTITION_MONTH = NULL
|
||||||
WHERE A_SOURCE_FILE_CONFIG_KEY = pSourceFileConfigKey
|
WHERE A_SOURCE_FILE_CONFIG_KEY = pSourceFileConfigKey
|
||||||
@@ -660,7 +660,7 @@ AS
|
|||||||
|
|
||||||
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED
|
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED
|
||||||
SET PROCESSING_STATUS = 'INGESTED',
|
SET PROCESSING_STATUS = 'INGESTED',
|
||||||
ARCH_FILE_NAME = NULL,
|
ARCH_PATH = NULL,
|
||||||
PARTITION_YEAR = NULL,
|
PARTITION_YEAR = NULL,
|
||||||
PARTITION_MONTH = NULL
|
PARTITION_MONTH = NULL
|
||||||
WHERE PROCESSING_STATUS = 'ARCHIVED_AND_TRASHED';
|
WHERE PROCESSING_STATUS = 'ARCHIVED_AND_TRASHED';
|
||||||
|
|||||||
@@ -181,7 +181,7 @@ AS
|
|||||||
BEGIN
|
BEGIN
|
||||||
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
||||||
SET PROCESSING_STATUS = 'ARCHIVED'
|
SET PROCESSING_STATUS = 'ARCHIVED'
|
||||||
,ARCH_FILE_NAME = vUri||vFilename
|
,ARCH_PATH = vUri||vFilename
|
||||||
WHERE r.a_source_file_config_key= pSourceFileConfigKey
|
WHERE r.a_source_file_config_key= pSourceFileConfigKey
|
||||||
AND r.source_file_name = f.filename
|
AND r.source_file_name = f.filename
|
||||||
AND r.processing_status = 'INGESTED'
|
AND r.processing_status = 'INGESTED'
|
||||||
@@ -244,7 +244,7 @@ AS
|
|||||||
|
|
||||||
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
||||||
SET PROCESSING_STATUS = 'INGESTED'
|
SET PROCESSING_STATUS = 'INGESTED'
|
||||||
,ARCH_FILE_NAME = NULL
|
,ARCH_PATH = NULL
|
||||||
WHERE r.a_source_file_config_key = pSourceFileConfigKey
|
WHERE r.a_source_file_config_key = pSourceFileConfigKey
|
||||||
AND r.source_file_name = f.filename
|
AND r.source_file_name = f.filename
|
||||||
;
|
;
|
||||||
|
|||||||
@@ -231,7 +231,7 @@ AS
|
|||||||
BEGIN
|
BEGIN
|
||||||
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
||||||
SET PROCESSING_STATUS = 'ARCHIVED'
|
SET PROCESSING_STATUS = 'ARCHIVED'
|
||||||
,ARCH_FILE_NAME = vUri||vFilename
|
,ARCH_PATH = vUri||vFilename
|
||||||
WHERE r.a_source_file_config_key= pSourceFileConfigKey
|
WHERE r.a_source_file_config_key= pSourceFileConfigKey
|
||||||
AND r.source_file_name = f.filename
|
AND r.source_file_name = f.filename
|
||||||
AND r.processing_status = 'INGESTED'
|
AND r.processing_status = 'INGESTED'
|
||||||
@@ -294,7 +294,7 @@ AS
|
|||||||
|
|
||||||
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
||||||
SET PROCESSING_STATUS = 'INGESTED'
|
SET PROCESSING_STATUS = 'INGESTED'
|
||||||
,ARCH_FILE_NAME = NULL
|
,ARCH_PATH = NULL
|
||||||
WHERE r.a_source_file_config_key = pSourceFileConfigKey
|
WHERE r.a_source_file_config_key = pSourceFileConfigKey
|
||||||
AND r.source_file_name = f.filename
|
AND r.source_file_name = f.filename
|
||||||
;
|
;
|
||||||
|
|||||||
@@ -223,7 +223,7 @@ AS
|
|||||||
|
|
||||||
-- Note: DBMS_CLOUD.EXPORT_DATA may create multiple parquet files (parallel execution)
|
-- Note: DBMS_CLOUD.EXPORT_DATA may create multiple parquet files (parallel execution)
|
||||||
-- Instead of tracking individual files, we store the archive directory prefix
|
-- Instead of tracking individual files, we store the archive directory prefix
|
||||||
-- ARCH_FILE_NAME will contain the directory URI where all parquet files are located
|
-- ARCH_PATH will contain the directory URI where all parquet files are located
|
||||||
vFilename := vUri; -- Store directory prefix instead of individual filename
|
vFilename := vUri; -- Store directory prefix instead of individual filename
|
||||||
|
|
||||||
-- Try to drop EXPORTED FILES ("regular data files")
|
-- Try to drop EXPORTED FILES ("regular data files")
|
||||||
@@ -234,7 +234,7 @@ AS
|
|||||||
BEGIN
|
BEGIN
|
||||||
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
||||||
SET PROCESSING_STATUS = 'ARCHIVED_AND_TRASHED' -- Status reflects file is archived and kept in TRASH
|
SET PROCESSING_STATUS = 'ARCHIVED_AND_TRASHED' -- Status reflects file is archived and kept in TRASH
|
||||||
,ARCH_FILE_NAME = vFilename -- Now contains directory prefix, not individual file
|
,ARCH_PATH = vFilename -- Now contains directory prefix, not individual file
|
||||||
,PARTITION_YEAR = ym_loop.year -- Record which partition year the data was archived to
|
,PARTITION_YEAR = ym_loop.year -- Record which partition year the data was archived to
|
||||||
,PARTITION_MONTH = ym_loop.month -- Record which partition month the data was archived to
|
,PARTITION_MONTH = ym_loop.month -- Record which partition month the data was archived to
|
||||||
WHERE r.a_source_file_config_key= pSourceFileConfigKey
|
WHERE r.a_source_file_config_key= pSourceFileConfigKey
|
||||||
@@ -313,7 +313,7 @@ AS
|
|||||||
|
|
||||||
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED r
|
||||||
SET PROCESSING_STATUS = 'INGESTED'
|
SET PROCESSING_STATUS = 'INGESTED'
|
||||||
,ARCH_FILE_NAME = NULL
|
,ARCH_PATH = NULL
|
||||||
WHERE r.a_source_file_config_key = pSourceFileConfigKey
|
WHERE r.a_source_file_config_key = pSourceFileConfigKey
|
||||||
AND r.source_file_name = f.filename
|
AND r.source_file_name = f.filename
|
||||||
;
|
;
|
||||||
@@ -568,7 +568,7 @@ AS
|
|||||||
|
|
||||||
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED
|
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED
|
||||||
SET PROCESSING_STATUS = 'INGESTED',
|
SET PROCESSING_STATUS = 'INGESTED',
|
||||||
ARCH_FILE_NAME = NULL,
|
ARCH_PATH = NULL,
|
||||||
PARTITION_YEAR = NULL,
|
PARTITION_YEAR = NULL,
|
||||||
PARTITION_MONTH = NULL
|
PARTITION_MONTH = NULL
|
||||||
WHERE A_SOURCE_FILE_RECEIVED_KEY = pSourceFileReceivedKey
|
WHERE A_SOURCE_FILE_RECEIVED_KEY = pSourceFileReceivedKey
|
||||||
@@ -609,7 +609,7 @@ AS
|
|||||||
|
|
||||||
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED
|
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED
|
||||||
SET PROCESSING_STATUS = 'INGESTED',
|
SET PROCESSING_STATUS = 'INGESTED',
|
||||||
ARCH_FILE_NAME = NULL,
|
ARCH_PATH = NULL,
|
||||||
PARTITION_YEAR = NULL,
|
PARTITION_YEAR = NULL,
|
||||||
PARTITION_MONTH = NULL
|
PARTITION_MONTH = NULL
|
||||||
WHERE A_SOURCE_FILE_CONFIG_KEY = pSourceFileConfigKey
|
WHERE A_SOURCE_FILE_CONFIG_KEY = pSourceFileConfigKey
|
||||||
@@ -649,7 +649,7 @@ AS
|
|||||||
|
|
||||||
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED
|
UPDATE CT_MRDS.A_SOURCE_FILE_RECEIVED
|
||||||
SET PROCESSING_STATUS = 'INGESTED',
|
SET PROCESSING_STATUS = 'INGESTED',
|
||||||
ARCH_FILE_NAME = NULL,
|
ARCH_PATH = NULL,
|
||||||
PARTITION_YEAR = NULL,
|
PARTITION_YEAR = NULL,
|
||||||
PARTITION_MONTH = NULL
|
PARTITION_MONTH = NULL
|
||||||
WHERE PROCESSING_STATUS = 'ARCHIVED_AND_TRASHED';
|
WHERE PROCESSING_STATUS = 'ARCHIVED_AND_TRASHED';
|
||||||
|
|||||||
@@ -75,6 +75,6 @@ sql "ADMIN/Cloudpass#34@ggmichalski_high" "@rollback_mars1057.sql"
|
|||||||
|
|
||||||
|
|
||||||
cd .\MARS_Packages\REL01_ADDITIONS\MARS-828
|
cd .\MARS_Packages\REL01_ADDITIONS\MARS-828
|
||||||
sql "ADMIN/Cloudpass#34@ggmichalski_high" "@install_mars828.sql"
|
echo 'yes' | sql "ADMIN/Cloudpass#34@ggmichalski_high" "@install_mars828.sql"
|
||||||
sql "ADMIN/Cloudpass#34@ggmichalski_high" "@rollback_mars828.sql"
|
echo 'yes' | sql "ADMIN/Cloudpass#34@ggmichalski_high" "@rollback_mars828.sql"
|
||||||
7z a -pMojeSuperHaslo#123 -mhe=on M828_arch.7z MARS-828\
|
7z a -pMojeSuperHaslo#123 -mhe=on M828_arch.7z MARS-828\
|
||||||
Reference in New Issue
Block a user