working historization.sql but with separate tx_history table
This commit is contained in:
parent
a1163bfc8d
commit
36c21505a3
37
.run/ImportHostingAssets into local.run.xml
Normal file
37
.run/ImportHostingAssets into local.run.xml
Normal file
@ -0,0 +1,37 @@
|
|||||||
|
<component name="ProjectRunConfigurationManager">
|
||||||
|
<configuration default="false" name="ImportHostingAssets into local" type="GradleRunConfiguration" factoryName="Gradle">
|
||||||
|
<ExternalSystemSettings>
|
||||||
|
<option name="env">
|
||||||
|
<map>
|
||||||
|
<entry key="HSADMINNG_POSTGRES_ADMIN_PASSWORD" value="password" />
|
||||||
|
<entry key="HSADMINNG_POSTGRES_ADMIN_USERNAME" value="postgres" />
|
||||||
|
<entry key="HSADMINNG_POSTGRES_JDBC_URL" value="jdbc:postgresql://localhost:5432/postgres" />
|
||||||
|
<entry key="HSADMINNG_POSTGRES_RESTRICTED_USERNAME" value="restricted" />
|
||||||
|
</map>
|
||||||
|
</option>
|
||||||
|
<option name="executionName" />
|
||||||
|
<option name="externalProjectPath" value="$PROJECT_DIR$" />
|
||||||
|
<option name="externalSystemIdString" value="GRADLE" />
|
||||||
|
<option name="scriptParameters" value="" />
|
||||||
|
<option name="taskDescriptions">
|
||||||
|
<list />
|
||||||
|
</option>
|
||||||
|
<option name="taskNames">
|
||||||
|
<list>
|
||||||
|
<option value=":importHostingAssets" />
|
||||||
|
<option value="--tests" />
|
||||||
|
<option value=""net.hostsharing.hsadminng.hs.migration.ImportHostingAssets"" />
|
||||||
|
</list>
|
||||||
|
</option>
|
||||||
|
<option name="vmOptions" />
|
||||||
|
</ExternalSystemSettings>
|
||||||
|
<ExternalSystemDebugServerProcess>false</ExternalSystemDebugServerProcess>
|
||||||
|
<ExternalSystemReattachDebugProcess>true</ExternalSystemReattachDebugProcess>
|
||||||
|
<EXTENSION ID="com.intellij.execution.ExternalSystemRunConfigurationJavaExtension">
|
||||||
|
<extension name="coverage" sample_coverage="false" />
|
||||||
|
</EXTENSION>
|
||||||
|
<DebugAllEnabled>false</DebugAllEnabled>
|
||||||
|
<RunAsTest>true</RunAsTest>
|
||||||
|
<method v="2" />
|
||||||
|
</configuration>
|
||||||
|
</component>
|
@ -33,37 +33,4 @@
|
|||||||
<RunAsTest>true</RunAsTest>
|
<RunAsTest>true</RunAsTest>
|
||||||
<method v="2" />
|
<method v="2" />
|
||||||
</configuration>
|
</configuration>
|
||||||
<configuration default="false" name="ImportHostingAssets" type="GradleRunConfiguration" factoryName="Gradle">
|
|
||||||
<ExternalSystemSettings>
|
|
||||||
<option name="env">
|
|
||||||
<map>
|
|
||||||
<entry key="HSADMINNG_POSTGRES_ADMIN_USERNAME" value="admin" />
|
|
||||||
<entry key="HSADMINNG_POSTGRES_RESTRICTED_USERNAME" value="restricted" />
|
|
||||||
</map>
|
|
||||||
</option>
|
|
||||||
<option name="executionName" />
|
|
||||||
<option name="externalProjectPath" value="$PROJECT_DIR$" />
|
|
||||||
<option name="externalSystemIdString" value="GRADLE" />
|
|
||||||
<option name="scriptParameters" value="" />
|
|
||||||
<option name="taskDescriptions">
|
|
||||||
<list />
|
|
||||||
</option>
|
|
||||||
<option name="taskNames">
|
|
||||||
<list>
|
|
||||||
<option value=":importHostingAssets" />
|
|
||||||
<option value="--tests" />
|
|
||||||
<option value=""net.hostsharing.hsadminng.hs.migration.ImportHostingAssets"" />
|
|
||||||
</list>
|
|
||||||
</option>
|
|
||||||
<option name="vmOptions" />
|
|
||||||
</ExternalSystemSettings>
|
|
||||||
<ExternalSystemDebugServerProcess>false</ExternalSystemDebugServerProcess>
|
|
||||||
<ExternalSystemReattachDebugProcess>true</ExternalSystemReattachDebugProcess>
|
|
||||||
<EXTENSION ID="com.intellij.execution.ExternalSystemRunConfigurationJavaExtension">
|
|
||||||
<extension name="coverage" sample_coverage="false" />
|
|
||||||
</EXTENSION>
|
|
||||||
<DebugAllEnabled>false</DebugAllEnabled>
|
|
||||||
<RunAsTest>true</RunAsTest>
|
|
||||||
<method v="2" />
|
|
||||||
</configuration>
|
|
||||||
</component>
|
</component>
|
@ -1,53 +0,0 @@
|
|||||||
-- ========================================================
|
|
||||||
-- First Example Entity with History
|
|
||||||
-- --------------------------------------------------------
|
|
||||||
|
|
||||||
CREATE TABLE IF NOT EXISTS customer (
|
|
||||||
"id" SERIAL PRIMARY KEY,
|
|
||||||
"reference" int not null unique, -- 10000-99999
|
|
||||||
"prefix" character(3) unique
|
|
||||||
);
|
|
||||||
|
|
||||||
CALL create_historicization('customer');
|
|
||||||
|
|
||||||
|
|
||||||
-- ========================================================
|
|
||||||
-- Second Example Entity with History
|
|
||||||
-- --------------------------------------------------------
|
|
||||||
|
|
||||||
CREATE TABLE IF NOT EXISTS package_type (
|
|
||||||
"id" serial PRIMARY KEY,
|
|
||||||
"name" character varying(8)
|
|
||||||
);
|
|
||||||
|
|
||||||
CALL create_historicization('package_type');
|
|
||||||
|
|
||||||
-- ========================================================
|
|
||||||
-- Third Example Entity with History
|
|
||||||
-- --------------------------------------------------------
|
|
||||||
|
|
||||||
CREATE TABLE IF NOT EXISTS package (
|
|
||||||
"id" serial PRIMARY KEY,
|
|
||||||
"name" character varying(5),
|
|
||||||
"customer_id" INTEGER REFERENCES customer(id)
|
|
||||||
);
|
|
||||||
|
|
||||||
CALL create_historicization('package');
|
|
||||||
|
|
||||||
|
|
||||||
-- ========================================================
|
|
||||||
-- query historical data
|
|
||||||
-- --------------------------------------------------------
|
|
||||||
|
|
||||||
|
|
||||||
ABORT;
|
|
||||||
BEGIN TRANSACTION;
|
|
||||||
SET LOCAL hsadminng.currentUser TO 'mih42_customer_aaa';
|
|
||||||
SET LOCAL hsadminng.currentTask TO 'adding customer_aaa';
|
|
||||||
INSERT INTO package (customer_id, name) VALUES (10000, 'aaa00');
|
|
||||||
COMMIT;
|
|
||||||
-- Usage:
|
|
||||||
|
|
||||||
SET hsadminng.timestamp TO '2022-07-12 08:53:27.723315';
|
|
||||||
SET hsadminng.timestamp TO '2022-07-12 11:38:27.723315';
|
|
||||||
SELECT * FROM customer_hv p WHERE prefix = 'aaa';
|
|
174
sql/historization-ng.sql
Normal file
174
sql/historization-ng.sql
Normal file
@ -0,0 +1,174 @@
|
|||||||
|
|
||||||
|
-- ========================================================
|
||||||
|
-- Historization
|
||||||
|
-- --------------------------------------------------------
|
||||||
|
|
||||||
|
drop PROCEDURE if exists tx_create_historical_view;
|
||||||
|
drop procedure if exists tx_create_historicization;
|
||||||
|
drop view if exists hs_hosting_asset_hv;
|
||||||
|
drop table if exists hs_hosting_asset_ex;
|
||||||
|
drop trigger if exists hs_hosting_asset_historicize_tg on hs_hosting_asset;
|
||||||
|
drop procedure if exists tx_historicize_tf;
|
||||||
|
drop type "tx_operation";
|
||||||
|
|
||||||
|
CREATE TYPE "tx_operation" AS ENUM ('INSERT', 'UPDATE', 'DELETE');
|
||||||
|
|
||||||
|
CREATE OR REPLACE FUNCTION tx_historicize_tf()
|
||||||
|
RETURNS trigger
|
||||||
|
LANGUAGE plpgsql STRICT AS $$
|
||||||
|
DECLARE
|
||||||
|
currentTask VARCHAR(127);
|
||||||
|
curContextId bigint;
|
||||||
|
"row" RECORD;
|
||||||
|
"alive" BOOLEAN;
|
||||||
|
"sql" varchar;
|
||||||
|
BEGIN
|
||||||
|
|
||||||
|
-- determine task
|
||||||
|
currentTask = current_setting('hsadminng.currentTask');
|
||||||
|
assert currentTask IS NOT NULL AND length(currentTask) >= 12,
|
||||||
|
format('hsadminng.currentTask (%s) must be defined and min 12 characters long, please use "SET LOCAL ...;"', currentTask);
|
||||||
|
assert length(currentTask) <= 127,
|
||||||
|
format('hsadminng.currentTask (%s) must not be longer than 127 characters"', currentTask);
|
||||||
|
|
||||||
|
IF (TG_OP = 'INSERT') OR (TG_OP = 'UPDATE') THEN
|
||||||
|
"row" := NEW;
|
||||||
|
"alive" := TRUE;
|
||||||
|
ELSE -- DELETE or TRUNCATE
|
||||||
|
"row" := OLD;
|
||||||
|
"alive" := FALSE;
|
||||||
|
END IF;
|
||||||
|
|
||||||
|
curContextId := txid_current()+bigIntHash(currentTask);
|
||||||
|
|
||||||
|
sql := format('INSERT INTO %3$I_ex ' ||
|
||||||
|
' VALUES (DEFAULT, curContextId, %1$L, %2$L, $1.*)', TG_OP, alive, TG_TABLE_NAME);
|
||||||
|
RAISE NOTICE 'sql: %', sql;
|
||||||
|
EXECUTE sql USING "row";
|
||||||
|
|
||||||
|
RETURN "row";
|
||||||
|
END; $$;
|
||||||
|
|
||||||
|
-- ------
|
||||||
|
|
||||||
|
CREATE OR REPLACE PROCEDURE tx_create_historical_view(baseTable varchar)
|
||||||
|
LANGUAGE plpgsql AS $$
|
||||||
|
DECLARE
|
||||||
|
createTriggerSQL varchar;
|
||||||
|
viewName varchar;
|
||||||
|
versionsTable varchar;
|
||||||
|
createViewSQL varchar;
|
||||||
|
baseCols varchar;
|
||||||
|
BEGIN
|
||||||
|
viewName = quote_ident(format('%s_hv', baseTable));
|
||||||
|
versionsTable = quote_ident(format('%s_ex', baseTable));
|
||||||
|
baseCols = (SELECT string_agg(quote_ident(column_name), ', ')
|
||||||
|
FROM information_schema.columns
|
||||||
|
WHERE table_schema = 'public' AND table_name = baseTable);
|
||||||
|
|
||||||
|
createViewSQL = format(
|
||||||
|
'CREATE OR REPLACE VIEW %1$s AS' ||
|
||||||
|
'(' ||
|
||||||
|
' SELECT %2$s' ||
|
||||||
|
' FROM %3$s' ||
|
||||||
|
' WHERE alive = TRUE' ||
|
||||||
|
' AND version_id IN' ||
|
||||||
|
' (' ||
|
||||||
|
' SELECT max(vt.version_id) AS history_id' ||
|
||||||
|
' FROM %3$s AS vt' ||
|
||||||
|
' JOIN tx_history as txh ON vt.tx_id = txh.tx_id' ||
|
||||||
|
' WHERE txh.tx_timestamp <= current_setting(''hsadminng.historical_timestamp'')::timestamp' ||
|
||||||
|
' GROUP BY id' ||
|
||||||
|
' )' ||
|
||||||
|
')',
|
||||||
|
viewName, baseCols, versionsTable
|
||||||
|
);
|
||||||
|
RAISE NOTICE 'sql: %', createViewSQL;
|
||||||
|
EXECUTE createViewSQL;
|
||||||
|
|
||||||
|
createTriggerSQL = 'CREATE TRIGGER ' || baseTable || '_historicize_tg' ||
|
||||||
|
' AFTER INSERT OR DELETE OR UPDATE ON ' || baseTable ||
|
||||||
|
' FOR EACH ROW EXECUTE PROCEDURE tx_historicize_tf()';
|
||||||
|
RAISE NOTICE 'sql: %', createTriggerSQL;
|
||||||
|
EXECUTE createTriggerSQL;
|
||||||
|
|
||||||
|
END; $$;
|
||||||
|
|
||||||
|
-- ------
|
||||||
|
|
||||||
|
CREATE OR REPLACE PROCEDURE tx_create_historicization(baseTable varchar)
|
||||||
|
LANGUAGE plpgsql AS $$
|
||||||
|
DECLARE
|
||||||
|
createHistTableSql varchar;
|
||||||
|
createTriggerSQL varchar;
|
||||||
|
viewName varchar;
|
||||||
|
versionsTable varchar;
|
||||||
|
createViewSQL varchar;
|
||||||
|
baseCols varchar;
|
||||||
|
BEGIN
|
||||||
|
|
||||||
|
-- create the history table
|
||||||
|
createHistTableSql = '' ||
|
||||||
|
'CREATE TABLE ' || baseTable || '_ex (' ||
|
||||||
|
' version_id serial PRIMARY KEY,' ||
|
||||||
|
' context_id bigint NOT NULL REFERENCES tx_context(contextid),' ||
|
||||||
|
' trigger_op tx_operation NOT NULL,' ||
|
||||||
|
' alive boolean not null,' ||
|
||||||
|
-- followed by all columns of the original table
|
||||||
|
' LIKE ' || baseTable ||
|
||||||
|
' EXCLUDING CONSTRAINTS' ||
|
||||||
|
' EXCLUDING STATISTICS' ||
|
||||||
|
')';
|
||||||
|
RAISE NOTICE 'sql: %', createHistTableSql;
|
||||||
|
EXECUTE createHistTableSql;
|
||||||
|
|
||||||
|
-- create the historical view
|
||||||
|
viewName = quote_ident(format('%s_hv', baseTable));
|
||||||
|
versionsTable = quote_ident(format('%s_ex', baseTable));
|
||||||
|
baseCols = (SELECT string_agg(quote_ident(column_name), ', ')
|
||||||
|
FROM information_schema.columns
|
||||||
|
WHERE table_schema = 'public' AND table_name = baseTable);
|
||||||
|
|
||||||
|
createViewSQL = format(
|
||||||
|
'CREATE OR REPLACE VIEW %1$s AS' ||
|
||||||
|
'(' ||
|
||||||
|
' SELECT %2$s' ||
|
||||||
|
' FROM %3$s' ||
|
||||||
|
' WHERE alive = TRUE' ||
|
||||||
|
' AND version_id IN' ||
|
||||||
|
' (' ||
|
||||||
|
' SELECT max(vt.version_id) AS history_id' ||
|
||||||
|
' FROM %3$s AS vt' ||
|
||||||
|
' JOIN tx_context as txc ON vt.context_id = txc.contextid' ||
|
||||||
|
' WHERE txc.txtimestamp <= current_setting(''hsadminng.historical_timestamp'')::timestamp' ||
|
||||||
|
' GROUP BY context_id' ||
|
||||||
|
' )' ||
|
||||||
|
')',
|
||||||
|
viewName, baseCols, versionsTable
|
||||||
|
);
|
||||||
|
RAISE NOTICE 'sql: %', createViewSQL;
|
||||||
|
EXECUTE createViewSQL;
|
||||||
|
|
||||||
|
createTriggerSQL = 'CREATE TRIGGER ' || baseTable || '_historicize_tg' ||
|
||||||
|
' AFTER INSERT OR DELETE OR UPDATE ON ' || baseTable ||
|
||||||
|
' FOR EACH ROW EXECUTE PROCEDURE tx_historicize_tf()';
|
||||||
|
RAISE NOTICE 'sql: %', createTriggerSQL;
|
||||||
|
EXECUTE createTriggerSQL;
|
||||||
|
|
||||||
|
END; $$;
|
||||||
|
|
||||||
|
|
||||||
|
call tx_create_historicization('hs_hosting_asset');
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
ROLLBACK;
|
||||||
|
BEGIN TRANSACTION;
|
||||||
|
call defineContext('historization testing', null, 'superuser-alex@hostsharing.net',
|
||||||
|
'hs_booking_project#D-1000000-hshdefaultproject:ADMIN');
|
||||||
|
-- 'hs_booking_project#D-1000300-mihdefaultproject:ADMIN');
|
||||||
|
update hs_hosting_asset set caption='lug00 a' where identifier='lug00' and type='MANAGED_WEBSPACE';
|
||||||
|
COMMIT;
|
||||||
|
|
||||||
|
SET hsadminng.historical_timestamp TO '2022-07-12 11:38:27.723315';
|
||||||
|
SELECT * FROM hs_hosting_asset_ex p WHERE identifier = 'lug00';
|
@ -1,143 +1,158 @@
|
|||||||
|
rollback;
|
||||||
|
drop table if exists hs_hosting_asset_versions;
|
||||||
|
drop table if exists hs_hosting_asset_ex;
|
||||||
|
drop view if exists hs_hosting_asset_hv;
|
||||||
|
drop procedure if exists tx_create_historicization;
|
||||||
|
drop view if exists tx_create_historical_view;
|
||||||
|
drop function if exists tx_historicize_tf();
|
||||||
|
drop table if exists tx_history;
|
||||||
|
drop type if exists tx_operation;
|
||||||
|
|
||||||
-- ========================================================
|
-- ========================================================
|
||||||
-- Historization
|
-- Historization
|
||||||
-- --------------------------------------------------------
|
-- --------------------------------------------------------
|
||||||
|
|
||||||
CREATE TABLE "tx_history" (
|
create table "tx_history"
|
||||||
"tx_id" BIGINT NOT NULL UNIQUE,
|
(
|
||||||
"tx_timestamp" TIMESTAMP NOT NULL,
|
"tx_id" bigint not null unique,
|
||||||
"user" VARCHAR(64) NOT NULL, -- references postgres user
|
"tx_timestamp" timestamp not null,
|
||||||
"task" VARCHAR NOT NULL
|
"user" varchar(64) not null, -- references postgres user
|
||||||
|
"task" varchar not null
|
||||||
);
|
);
|
||||||
|
|
||||||
CREATE TYPE "operation" AS ENUM ('INSERT', 'UPDATE', 'DELETE', 'TRUNCATE');
|
create type "tx_operation" as enum ('INSERT', 'UPDATE', 'DELETE', 'TRUNCATE');
|
||||||
|
|
||||||
-- see https://www.postgresql.org/docs/current/plpgsql-trigger.html
|
-- see https://www.postgresql.org/docs/current/plpgsql-trigger.html
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION historicize()
|
create or replace function tx_historicize_tf()
|
||||||
RETURNS trigger
|
returns trigger
|
||||||
LANGUAGE plpgsql STRICT AS $$
|
language plpgsql
|
||||||
DECLARE
|
strict as $$
|
||||||
currentUser VARCHAR(63);
|
declare
|
||||||
currentTask VARCHAR(127);
|
currentUser varchar(63);
|
||||||
"row" RECORD;
|
currentTask varchar(127);
|
||||||
"alive" BOOLEAN;
|
"row" record;
|
||||||
"sql" varchar;
|
"alive" boolean;
|
||||||
BEGIN
|
"sql" varchar;
|
||||||
|
begin
|
||||||
-- determine user_id
|
-- determine user_id
|
||||||
BEGIN
|
begin
|
||||||
currentUser := current_setting('hsadminng.currentUser');
|
currentUser := current_setting('hsadminng.currentUser');
|
||||||
EXCEPTION WHEN OTHERS THEN
|
exception
|
||||||
currentUser := NULL;
|
when others then
|
||||||
END;
|
currentUser := null;
|
||||||
IF (currentUser IS NULL OR currentUser = '') THEN
|
end;
|
||||||
RAISE EXCEPTION 'hsadminng.currentUser must be defined, please use "SET LOCAL ...;"';
|
if (currentUser is null or currentUser = '') then
|
||||||
END IF;
|
raise exception 'hsadminng.currentUser must be defined, please use "SET LOCAL ...;"';
|
||||||
RAISE NOTICE 'currentUser: %', currentUser;
|
end if;
|
||||||
|
raise notice 'currentUser: %', currentUser;
|
||||||
|
|
||||||
-- determine task
|
-- determine task
|
||||||
currentTask = current_setting('hsadminng.currentTask');
|
currentTask = current_setting('hsadminng.currentTask');
|
||||||
assert currentTask IS NOT NULL AND length(currentTask) >= 12,
|
assert currentTask is not null and length(currentTask) >= 12,
|
||||||
format('hsadminng.currentTask (%s) must be defined and min 12 characters long, please use "SET LOCAL ...;"', currentTask);
|
format('hsadminng.currentTask (%s) must be defined and min 12 characters long, please use "SET LOCAL ...;"',
|
||||||
|
currentTask);
|
||||||
assert length(currentTask) <= 127,
|
assert length(currentTask) <= 127,
|
||||||
format('hsadminng.currentTask (%s) must not be longer than 127 characters"', currentTask);
|
format('hsadminng.currentTask (%s) must not be longer than 127 characters"', currentTask);
|
||||||
|
|
||||||
IF (TG_OP = 'INSERT') OR (TG_OP = 'UPDATE') THEN
|
if (TG_OP = 'INSERT') or (TG_OP = 'UPDATE') then
|
||||||
"row" := NEW;
|
"row" := NEW;
|
||||||
"alive" := TRUE;
|
"alive" := true;
|
||||||
ELSE -- DELETE or TRUNCATE
|
else -- DELETE or TRUNCATE
|
||||||
"row" := OLD;
|
"row" := OLD;
|
||||||
"alive" := FALSE;
|
"alive" := false;
|
||||||
END IF;
|
end if;
|
||||||
|
|
||||||
sql := format('INSERT INTO tx_history VALUES (txid_current(), now(), %1L, %2L) ON CONFLICT DO NOTHING', currentUser, currentTask);
|
sql := format('INSERT INTO tx_history VALUES (txid_current(), now(), %1L, %2L) ON CONFLICT DO NOTHING', currentUser,
|
||||||
RAISE NOTICE 'sql: %', sql;
|
currentTask);
|
||||||
EXECUTE sql;
|
raise notice 'sql: %', sql;
|
||||||
sql := format('INSERT INTO %3$I_versions VALUES (DEFAULT, txid_current(), %1$L, %2$L, $1.*)', TG_OP, alive, TG_TABLE_NAME);
|
execute sql;
|
||||||
RAISE NOTICE 'sql: %', sql;
|
sql := format('INSERT INTO %3$I_ex VALUES (DEFAULT, txid_current(), %1$L, %2$L, $1.*)', TG_OP, alive, TG_TABLE_NAME);
|
||||||
EXECUTE sql USING "row";
|
raise notice 'sql: %', sql;
|
||||||
|
execute sql using "row";
|
||||||
|
|
||||||
RETURN "row";
|
return "row";
|
||||||
END; $$;
|
end; $$;
|
||||||
|
|
||||||
CREATE OR REPLACE PROCEDURE create_historical_view(baseTable varchar)
|
create or replace procedure tx_create_historical_view(baseTable varchar)
|
||||||
LANGUAGE plpgsql AS $$
|
language plpgsql as $$
|
||||||
DECLARE
|
declare
|
||||||
createTriggerSQL varchar;
|
createTriggerSQL varchar;
|
||||||
viewName varchar;
|
viewName varchar;
|
||||||
versionsTable varchar;
|
versionsTable varchar;
|
||||||
createViewSQL varchar;
|
createViewSQL varchar;
|
||||||
baseCols varchar;
|
baseCols varchar;
|
||||||
BEGIN
|
begin
|
||||||
|
|
||||||
viewName = quote_ident(format('%s_hv', baseTable));
|
viewName = quote_ident(format('%s_hv', baseTable));
|
||||||
versionsTable = quote_ident(format('%s_versions', baseTable));
|
versionsTable = quote_ident(format('%s_ex', baseTable));
|
||||||
baseCols = (SELECT string_agg(quote_ident(column_name), ', ')
|
baseCols = (select string_agg(quote_ident(column_name), ', ')
|
||||||
FROM information_schema.columns
|
from information_schema.columns
|
||||||
WHERE table_schema = 'public' AND table_name = baseTable);
|
where table_schema = 'public'
|
||||||
|
and table_name = baseTable);
|
||||||
|
|
||||||
createViewSQL = format(
|
createViewSQL = format(
|
||||||
'CREATE OR REPLACE VIEW %1$s AS' ||
|
'CREATE OR REPLACE VIEW %1$s AS' ||
|
||||||
'(' ||
|
'(' ||
|
||||||
' SELECT %2$s' ||
|
' SELECT %2$s' ||
|
||||||
' FROM %3$s' ||
|
' FROM %3$s' ||
|
||||||
' WHERE alive = TRUE' ||
|
' WHERE alive = TRUE' ||
|
||||||
' AND version_id IN' ||
|
' AND version_id IN' ||
|
||||||
' (' ||
|
' (' ||
|
||||||
' SELECT max(vt.version_id) AS history_id' ||
|
' SELECT max(vt.version_id) AS history_id' ||
|
||||||
' FROM %3$s AS vt' ||
|
' FROM %3$s AS vt' ||
|
||||||
' JOIN tx_history as txh ON vt.tx_id = txh.tx_id' ||
|
' JOIN tx_history as txh ON vt.tx_id = txh.tx_id' ||
|
||||||
' WHERE txh.tx_timestamp <= current_setting(''hsadminng.timestamp'')::timestamp' ||
|
' WHERE txh.tx_timestamp <= current_setting(''hsadminng.timestamp'')::timestamp' ||
|
||||||
' GROUP BY id' ||
|
' GROUP BY uuid' ||
|
||||||
' )' ||
|
' )' ||
|
||||||
')',
|
')',
|
||||||
viewName, baseCols, versionsTable
|
viewName, baseCols, versionsTable
|
||||||
);
|
);
|
||||||
RAISE NOTICE 'sql: %', createViewSQL;
|
raise notice 'sql: %', createViewSQL;
|
||||||
EXECUTE createViewSQL;
|
execute createViewSQL;
|
||||||
|
|
||||||
createTriggerSQL = 'CREATE TRIGGER ' || baseTable || '_historicize' ||
|
createTriggerSQL = 'CREATE TRIGGER ' || baseTable || '_tx_historicize_tf' ||
|
||||||
' AFTER INSERT OR DELETE OR UPDATE ON ' || baseTable ||
|
' AFTER INSERT OR DELETE OR UPDATE ON ' || baseTable ||
|
||||||
' FOR EACH ROW EXECUTE PROCEDURE historicize()';
|
' FOR EACH ROW EXECUTE PROCEDURE tx_historicize_tf()';
|
||||||
RAISE NOTICE 'sql: %', createTriggerSQL;
|
raise notice 'sql: %', createTriggerSQL;
|
||||||
EXECUTE createTriggerSQL;
|
execute createTriggerSQL;
|
||||||
|
|
||||||
END; $$;
|
end; $$;
|
||||||
|
|
||||||
CREATE OR REPLACE PROCEDURE create_historicization(baseTable varchar)
|
create or replace procedure tx_create_historicization(baseTable varchar)
|
||||||
LANGUAGE plpgsql AS $$
|
language plpgsql as $$
|
||||||
DECLARE
|
declare
|
||||||
createHistTableSql varchar;
|
createHistTableSql varchar;
|
||||||
createTriggerSQL varchar;
|
createTriggerSQL varchar;
|
||||||
viewName varchar;
|
viewName varchar;
|
||||||
versionsTable varchar;
|
versionsTable varchar;
|
||||||
createViewSQL varchar;
|
createViewSQL varchar;
|
||||||
baseCols varchar;
|
baseCols varchar;
|
||||||
BEGIN
|
begin
|
||||||
|
|
||||||
-- create the history table
|
-- create the history table
|
||||||
createHistTableSql = '' ||
|
createHistTableSql = '' ||
|
||||||
'CREATE TABLE ' || baseTable || '_versions (' ||
|
'CREATE TABLE ' || baseTable || '_ex (' ||
|
||||||
' version_id serial PRIMARY KEY,' ||
|
' version_id serial PRIMARY KEY,' ||
|
||||||
' tx_id bigint NOT NULL REFERENCES tx_history(tx_id),' ||
|
' tx_id bigint NOT NULL REFERENCES tx_history(tx_id),' ||
|
||||||
' trigger_op operation NOT NULL,' ||
|
' trigger_op tx_operation NOT NULL,' ||
|
||||||
' alive boolean not null,' ||
|
' alive boolean not null,' ||
|
||||||
|
' LIKE ' || baseTable ||
|
||||||
' LIKE ' || baseTable ||
|
' EXCLUDING CONSTRAINTS' ||
|
||||||
' EXCLUDING CONSTRAINTS' ||
|
' EXCLUDING STATISTICS' ||
|
||||||
' EXCLUDING STATISTICS' ||
|
')';
|
||||||
')';
|
raise notice 'sql: %', createHistTableSql;
|
||||||
RAISE NOTICE 'sql: %', createHistTableSql;
|
execute createHistTableSql;
|
||||||
EXECUTE createHistTableSql;
|
|
||||||
|
|
||||||
-- create the historical view
|
-- create the historical view
|
||||||
viewName = quote_ident(format('%s_hv', baseTable));
|
viewName = quote_ident(format('%s_hv', baseTable));
|
||||||
versionsTable = quote_ident(format('%s_versions', baseTable));
|
versionsTable = quote_ident(format('%s_ex', baseTable));
|
||||||
baseCols = (SELECT string_agg(quote_ident(column_name), ', ')
|
baseCols = (select string_agg(quote_ident(column_name), ', ')
|
||||||
FROM information_schema.columns
|
from information_schema.columns
|
||||||
WHERE table_schema = 'public' AND table_name = baseTable);
|
where table_schema = 'public'
|
||||||
|
and table_name = baseTable);
|
||||||
|
|
||||||
createViewSQL = format(
|
createViewSQL = format(
|
||||||
'CREATE OR REPLACE VIEW %1$s AS' ||
|
'CREATE OR REPLACE VIEW %1$s AS' ||
|
||||||
'(' ||
|
'(' ||
|
||||||
' SELECT %2$s' ||
|
' SELECT %2$s' ||
|
||||||
@ -153,14 +168,76 @@ BEGIN
|
|||||||
' )' ||
|
' )' ||
|
||||||
')',
|
')',
|
||||||
viewName, baseCols, versionsTable
|
viewName, baseCols, versionsTable
|
||||||
);
|
);
|
||||||
RAISE NOTICE 'sql: %', createViewSQL;
|
raise notice 'sql: %', createViewSQL;
|
||||||
EXECUTE createViewSQL;
|
execute createViewSQL;
|
||||||
|
|
||||||
createTriggerSQL = 'CREATE TRIGGER ' || baseTable || '_historicize' ||
|
createTriggerSQL = 'CREATE TRIGGER ' || baseTable || '_tx_historicize_tf' ||
|
||||||
' AFTER INSERT OR DELETE OR UPDATE ON ' || baseTable ||
|
' AFTER INSERT OR DELETE OR UPDATE ON ' || baseTable ||
|
||||||
' FOR EACH ROW EXECUTE PROCEDURE historicize()';
|
' FOR EACH ROW EXECUTE PROCEDURE tx_historicize_tf()';
|
||||||
RAISE NOTICE 'sql: %', createTriggerSQL;
|
raise notice 'sql: %', createTriggerSQL;
|
||||||
EXECUTE createTriggerSQL;
|
execute createTriggerSQL;
|
||||||
|
|
||||||
END; $$;
|
end; $$;
|
||||||
|
|
||||||
|
--- ==================================================
|
||||||
|
|
||||||
|
call tx_create_historicization('hs_hosting_asset');
|
||||||
|
|
||||||
|
-- and expanded:
|
||||||
|
|
||||||
|
create table hs_hosting_asset_ex
|
||||||
|
(
|
||||||
|
version_id serial primary key,
|
||||||
|
tx_id bigint not null references tx_history (tx_id),
|
||||||
|
trigger_op tx_operation not null,
|
||||||
|
alive boolean not null,
|
||||||
|
like hs_hosting_asset excluding constraints excluding statistics
|
||||||
|
);
|
||||||
|
|
||||||
|
create or replace view hs_hosting_asset_hv as
|
||||||
|
(
|
||||||
|
select uuid,
|
||||||
|
version,
|
||||||
|
bookingitemuuid,
|
||||||
|
type,
|
||||||
|
parentassetuuid,
|
||||||
|
assignedtoassetuuid,
|
||||||
|
identifier,
|
||||||
|
caption,
|
||||||
|
config,
|
||||||
|
alarmcontactuuid
|
||||||
|
from hs_hosting_asset_ex
|
||||||
|
where alive = true
|
||||||
|
and version_id in (select max(vt.version_id) as history_id
|
||||||
|
from hs_hosting_asset_ex as vt
|
||||||
|
join tx_history as txh on vt.tx_id = txh.tx_id
|
||||||
|
where txh.tx_timestamp <= current_setting('hsadminng.timestamp')::timestamp
|
||||||
|
group by uuid)
|
||||||
|
);
|
||||||
|
|
||||||
|
CREATE TRIGGER hs_hosting_asset_tx_historicize_tf
|
||||||
|
AFTER INSERT OR DELETE OR UPDATE ON hs_hosting_asset
|
||||||
|
FOR EACH ROW EXECUTE PROCEDURE tx_historicize_tf();
|
||||||
|
|
||||||
|
-- ===========================================================================================
|
||||||
|
|
||||||
|
rollback;
|
||||||
|
begin transaction;
|
||||||
|
call defineContext('historization testing', null, 'superuser-alex@hostsharing.net',
|
||||||
|
-- 'hs_booking_project#D-1000000-hshdefaultproject:ADMIN'); -- prod+test
|
||||||
|
-- 'hs_booking_project#D-1000300-mihdefaultproject:ADMIN'); -- prod
|
||||||
|
'hs_booking_project#D-1000300-mimdefaultproject:ADMIN'); -- test
|
||||||
|
-- update hs_hosting_asset set caption='lug00 b' where identifier = 'lug00' and type = 'MANAGED_WEBSPACE'; -- prod
|
||||||
|
update hs_hosting_asset set caption='mim00 d' where identifier = 'mim00' and type = 'MANAGED_WEBSPACE'; -- test
|
||||||
|
commit;
|
||||||
|
|
||||||
|
-- all versions
|
||||||
|
select txh.tx_timestamp, txh."user", txh.task, ha.*
|
||||||
|
from hs_hosting_asset_ex ha
|
||||||
|
join tx_history txh on ha.tx_id=txh.tx_id
|
||||||
|
where ha.identifier in ('lug00', 'mim00');
|
||||||
|
|
||||||
|
-- single version at point in time
|
||||||
|
set hsadminng.timestamp to '2024-08-27 04:15:00'; -- UTC
|
||||||
|
select uuid, version, identifier, caption from hs_hosting_asset_hv p where identifier in ('lug00', 'mim00');
|
||||||
|
Loading…
Reference in New Issue
Block a user