Skip to content
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

Jump to bottom

Parameter to ignore unchanged values #11

Merged
merged 2 commits into from
Jul 14, 2020
Merged

Parameter to ignore unchanged values #11

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
075316e
add optional parameter to ignore unchanged rows
ps2goat May 29, 2018
8dcb74d
remove extra newline
ps2goat May 29, 2018
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
14 changes: 10 additions & 4 deletions versioning_function.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ DECLARE
sys_period text;
history_table text;
manipulate jsonb;
ignore_unchanged_values bool;
commonColumns text[];
time_stamp_to_use timestamptz := current_timestamp;
range_lower timestamptz;
Expand All @@ -13,7 +14,7 @@ DECLARE
holder2 record;
pg_version integer;
BEGIN
-- version 0.2.0
-- version 0.2.1

IF TG_WHEN != 'BEFORE' OR TG_LEVEL != 'ROW' THEN
RAISE TRIGGER_PROTOCOL_VIOLATED USING
Expand All @@ -25,14 +26,19 @@ BEGIN
MESSAGE = 'function "versioning" must be fired for INSERT or UPDATE or DELETE';
END IF;

IF TG_NARGS != 3 THEN
IF TG_NARGS not in (3,4) THEN
RAISE INVALID_PARAMETER_VALUE USING
MESSAGE = 'wrong number of parameters for function "versioning"',
HINT = 'expected 3 parameters but got ' || TG_NARGS;
HINT = 'expected 3 or 4 parameters but got ' || TG_NARGS;
END IF;

sys_period := TG_ARGV[0];
history_table := TG_ARGV[1];
ignore_unchanged_values := TG_ARGV[3];

IF ignore_unchanged_values AND TG_OP = 'UPDATE' AND NEW IS NOT DISTINCT FROM OLD THEN
RETURN OLD;
END IF;

-- check if sys_period exists on original table
SELECT atttypid, attndims INTO holder FROM pg_attribute WHERE attrelid = TG_RELID AND attname = sys_period AND NOT attisdropped;
Expand Down Expand Up @@ -183,4 +189,4 @@ BEGIN

RETURN OLD;
END;
$$ LANGUAGE plpgsql;
$$ LANGUAGE plpgsql;