Skip to content

Consolidate SQL scripts to *-0.000-25.000.sql #2832

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
labkey-adam merged 1 commit into from
Jan 7, 2026
Merged

Consolidate SQL scripts to *-0.000-25.000.sql #2832

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
302 changes: 301 additions & 1 deletion ...scripts/postgresql/etltest-0.00-16.30.sql → ...ripts/postgresql/etltest-0.000-25.000.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -621,4 +621,304 @@ END;

$BODY$
LANGUAGE plpgsql VOLATILE
COST 100;
COST 100;

/* 24.xxx SQL scripts */

CREATE OR REPLACE FUNCTION etltest.etltest
(IN transformrunid integer
, IN containerid entityid DEFAULT NULL::character varying
, INOUT rowsinserted integer DEFAULT 0
, INOUT rowsdeleted integer DEFAULT 0
, INOUT rowsmodified integer DEFAULT 0
, INOUT returnmsg character varying DEFAULT 'default message'::character varying
, IN debug character varying DEFAULT ''::character varying
, IN filterrunid integer DEFAULT NULL::integer
, INOUT filterstarttimestamp timestamp without time zone DEFAULT NULL::timestamp without time zone
, INOUT filterendtimestamp timestamp without time zone DEFAULT NULL::timestamp without time zone
, INOUT previousfilterrunid integer DEFAULT (-1)
, INOUT previousfilterstarttimestamp timestamp without time zone DEFAULT NULL::timestamp without time zone
, INOUT previousfilterendtimestamp timestamp without time zone DEFAULT NULL::timestamp without time zone
--, INOUT procVersion decimal DEFAULT 0
, IN testmode integer DEFAULT (-1)
, INOUT testinoutparam character varying DEFAULT ''::character varying
, INOUT runcount integer DEFAULT 1
, OUT return_status integer)
RETURNS record AS
$BODY$

/*
Test modes
1 normal operation
2 return code > 0
3 raise error
4 input/output parameter persistence
5 override of persisted input/output parameter
6 Run filter strategy, require filterRunId. Test persistence.
7 Modified since filter strategy, no source, require filterStartTimeStamp & filterEndTimeStamp,
populated from output of previous run
8 Modified since filter strategy with source, require filterStartTimeStamp & filterEndTimeStamp
populated from the filter strategy IncrementalStartTime & IncrementalEndTime
9 Sleep for 2 minutes before finishing

*/
BEGIN

IF testMode IS NULL
THEN
returnMsg := 'No testMode set';
return_status := 1;
RETURN;
END IF;

IF runCount IS NULL
THEN
runCount := 1;
ELSE
runCount := runCount + 1;
END IF;

IF testMode = 1
THEN
RAISE NOTICE '%', 'Test print statement logging';
rowsInserted := 1;
rowsDeleted := 2;
rowsModified := 4;
returnMsg := 'Test returnMsg logging';
return_status := 0;
RETURN;
END IF;

IF testMode = 2 THEN return_status := 1; RETURN; END IF;

IF testMode = 3
THEN
returnMsg := 'Intentional SQL Exception From Inside Proc';
RAISE EXCEPTION '%', returnMsg;
END IF;

IF testMode = 4 AND testInOutParam != 'after' AND runCount > 1
THEN
returnMsg := 'Expected value "after" for testInOutParam on run count = ' || runCount || ', but was ' || testInOutParam;
return_status := 1;
RETURN;
END IF;

IF testMode = 5 AND testInOutParam != 'before' AND runCount > 1
THEN
returnMsg := 'Expected value "before" for testInOutParam on run count = ' || runCount || ', but was ' || testInOutParam;
return_status := 1;
RETURN;
END IF;

IF testMode = 6
THEN
IF filterRunId IS NULL
THEN
returnMsg := 'Required filterRunId value not supplied';
return_status := 1;
RETURN;
END IF;
IF runCount > 1 AND (previousFilterRunId IS NULL OR previousFilterRunId >= filterRunId)
THEN
returnMsg := 'Required filterRunId was not persisted from previous run.';
return_status := 1;
RETURN;
END IF;
previousFilterRunId := filterRunId;
END IF;

IF testMode = 7
THEN
IF runCount > 1 AND (filterStartTimeStamp IS NULL AND filterEndTimeStamp IS NULL)
THEN
returnMsg := 'Required filterStartTimeStamp or filterEndTimeStamp were not persisted from previous run.';
return_status := 1;
RETURN;
END IF;
filterStartTimeStamp := localtimestamp;
filterEndTimeStamp := localtimestamp;
END IF;

IF testMode = 8
THEN
IF runCount > 1 AND ((previousFilterStartTimeStamp IS NULL AND previousFilterEndTimeStamp IS NULL)
OR (filterStartTimeStamp IS NULL AND filterEndTimeStamp IS NULL))
THEN
returnMsg := 'Required filterStartTimeStamp or filterEndTimeStamp were not persisted from previous run.';
return_status := 1;
RETURN;
END IF;
previousFilterStartTimeStamp := coalesce(filterStartTimeStamp, localtimestamp);
previousFilterEndTimeStamp := coalesce(filterEndTimeStamp, localtimestamp);
END IF;

IF testMode = 9
THEN
-- Sleep for 2 minutes
SELECT pg_sleep(120);
return_status := 1;
RETURN;
END IF;

-- set value for persistence tests
IF testInOutParam != ''
THEN
testInOutParam := 'after';
END IF;

return_status := 0;
RETURN;

END;
$BODY$
LANGUAGE plpgsql;

CREATE OR REPLACE FUNCTION etltest.etltest
(IN transformrunid integer
, IN containerid entityid DEFAULT NULL::character varying
, INOUT rowsinserted integer DEFAULT 0
, INOUT rowsdeleted integer DEFAULT 0
, INOUT rowsmodified integer DEFAULT 0
, INOUT returnmsg character varying DEFAULT 'default message'::character varying
, IN debug character varying DEFAULT ''::character varying
, IN filterrunid integer DEFAULT NULL::integer
, INOUT filterstarttimestamp timestamp without time zone DEFAULT NULL::timestamp without time zone
, INOUT filterendtimestamp timestamp without time zone DEFAULT NULL::timestamp without time zone
, INOUT previousfilterrunid integer DEFAULT (-1)
, INOUT previousfilterstarttimestamp timestamp without time zone DEFAULT NULL::timestamp without time zone
, INOUT previousfilterendtimestamp timestamp without time zone DEFAULT NULL::timestamp without time zone
--, INOUT procVersion decimal DEFAULT 0
, IN testmode integer DEFAULT (-1)
, INOUT testinoutparam character varying DEFAULT ''::character varying
, INOUT runcount integer DEFAULT 1
, OUT return_status integer)
RETURNS record AS
$BODY$

/*
Test modes
1 normal operation
2 return code > 0
3 raise error
4 input/output parameter persistence
5 override of persisted input/output parameter
6 Run filter strategy, require filterRunId. Test persistence.
7 Modified since filter strategy, no source, require filterStartTimeStamp & filterEndTimeStamp,
populated from output of previous run
8 Modified since filter strategy with source, require filterStartTimeStamp & filterEndTimeStamp
populated from the filter strategy IncrementalStartTime & IncrementalEndTime
9 Sleep for 2 minutes before finishing

*/
BEGIN

IF testMode IS NULL
THEN
returnMsg := 'No testMode set';
return_status := 1;
RETURN;
END IF;

IF runCount IS NULL
THEN
runCount := 1;
ELSE
runCount := runCount + 1;
END IF;

IF testMode = 1
THEN
RAISE NOTICE '%', 'Test print statement logging';
rowsInserted := 1;
rowsDeleted := 2;
rowsModified := 4;
returnMsg := 'Test returnMsg logging';
return_status := 0;
RETURN;
END IF;

IF testMode = 2 THEN return_status := 1; RETURN; END IF;

IF testMode = 3
THEN
returnMsg := 'Intentional SQL Exception From Inside Proc';
RAISE EXCEPTION '%', returnMsg;
END IF;

IF testMode = 4 AND testInOutParam != 'after' AND runCount > 1
THEN
returnMsg := 'Expected value "after" for testInOutParam on run count = ' || runCount || ', but was ' || testInOutParam;
return_status := 1;
RETURN;
END IF;

IF testMode = 5 AND testInOutParam != 'before' AND runCount > 1
THEN
returnMsg := 'Expected value "before" for testInOutParam on run count = ' || runCount || ', but was ' || testInOutParam;
return_status := 1;
RETURN;
END IF;

IF testMode = 6
THEN
IF filterRunId IS NULL
THEN
returnMsg := 'Required filterRunId value not supplied';
return_status := 1;
RETURN;
END IF;
IF runCount > 1 AND (previousFilterRunId IS NULL OR previousFilterRunId >= filterRunId)
THEN
returnMsg := 'Required filterRunId was not persisted from previous run.';
return_status := 1;
RETURN;
END IF;
previousFilterRunId := filterRunId;
END IF;

IF testMode = 7
THEN
IF runCount > 1 AND (filterStartTimeStamp IS NULL AND filterEndTimeStamp IS NULL)
THEN
returnMsg := 'Required filterStartTimeStamp or filterEndTimeStamp were not persisted from previous run.';
return_status := 1;
RETURN;
END IF;
filterStartTimeStamp := localtimestamp;
filterEndTimeStamp := localtimestamp;
END IF;

IF testMode = 8
THEN
IF runCount > 1 AND ((previousFilterStartTimeStamp IS NULL AND previousFilterEndTimeStamp IS NULL)
OR (filterStartTimeStamp IS NULL AND filterEndTimeStamp IS NULL))
THEN
returnMsg := 'Required filterStartTimeStamp or filterEndTimeStamp were not persisted from previous run.';
return_status := 1;
RETURN;
END IF;
previousFilterStartTimeStamp := coalesce(filterStartTimeStamp, localtimestamp);
previousFilterEndTimeStamp := coalesce(filterEndTimeStamp, localtimestamp);
END IF;

IF testMode = 9
THEN
-- Sleep for 30 seconds minutes
SELECT pg_sleep(30);
return_status := 1;
RETURN;
END IF;

-- set value for persistence tests
IF testInOutParam != ''
THEN
testInOutParam := 'after';
END IF;

return_status := 0;
RETURN;

END;
$BODY$
LANGUAGE plpgsql;
Loading