@@ -10,6 +10,7 @@ DECLARE
10
10
column_value TEXT ;
11
11
payload_items TEXT [];
12
12
uniquecolumn TEXT ;
13
+ logtime TEXT ;
13
14
BEGIN
14
15
-- Set record row depending on operation
15
16
CASE TG_OP
26
27
EXECUTE format(' SELECT $1.%I::TEXT' , column_name)
27
28
INTO column_value
28
29
USING rec;
30
+ case
31
+ when
32
+ column_name = ' upload_document' then
33
+ -- RAISE NOTICE 'upload_document boolean';
34
+ if column_value = ' false' then
35
+ column_value = ' 0' ;
36
+ else
37
+ column_value = ' 1' ;
38
+ end if;
39
+ when
40
+ column_name = ' upload_document_required' then
41
+ -- RAISE NOTICE 'upload_document_required boolean';
42
+ if column_value = ' false' then
43
+ column_value = ' 0' ;
44
+ else
45
+ column_value = ' 1' ;
46
+ end if;
47
+ else
48
+ -- RAISE NOTICE ' not boolean';
49
+ end case;
29
50
payload_items := array_append(payload_items, ' "' || replace(column_name, ' "' , ' \" ' ) || ' ":"' || replace(column_value, ' "' , ' \" ' ) || ' "' );
30
51
END LOOP;
52
+ -- logtime := (select date_display_tz());
53
+ logtime := (SELECT to_char (now()::timestamptz at time zone ' UTC' , ' YYYY-MM-DD"T"HH24:MI:SS"Z"' ));
31
54
32
55
uniquecolumn := (SELECT c .column_name
33
56
FROM information_schema .key_column_usage AS c
40
63
|| ' {'
41
64
|| ' "topic":"' || ' db.postgres.sync' || ' ",'
42
65
|| ' "originator":"' || ' tc-postgres-delta-processor' || ' ",'
43
- || ' "timestamp":"' || ' 2019-08-19T08:39:48.959Z' || ' ",'
66
+ -- || '"timestamp":"' || '2019-08-19T08:39:48.959Z' || '",'
67
+ || ' "timestamp":"' || logtime || ' ",'
44
68
|| ' "mime-type":"' || ' application/json' || ' ",'
45
69
|| ' "payload": {'
46
70
57
81
RETURN rec;
58
82
END;
59
83
$body$ LANGUAGE plpgsql
84
+
60
85
61
86
62
87
CREATE TRIGGER "scorecard_trigger "
0 commit comments