项目给出了一个新的需求，利用触发器生成日志表，监听对数据库中关键表的增删改操作。将操作的数据拼成json格式作为一个clob存入oracle。
1 create or replace procedure Logging_Messages(tableName varchar2 default ‘%‘) is
2 cursor c_cl IS
3 SELECT column_name tcl
4 FROM user_tab_columns
5 WHERE table_name = upper(tableName);
6 newjson clob;
7 oldjson clob;
8 v_sql varchar2(32000);
9 V_TMP varchar2(32000);
10 begin
11 FOR cl IN c_cl LOOP
12 if newjson is null then
13 newjson := ‘{"‘ || cl.tcl || ‘":"‘‘||‘||‘:NEW.‘ || cl.tcl ||‘||‘‘"}‘;
14 else
15 newjson := newjson || ‘,‘ || ‘{"‘ || cl.tcl || ‘":"‘‘||‘||‘:NEW.‘ || cl.tcl ||‘||‘‘"}‘;
16 end if;
17 if oldjson is null then
18 oldjson := ‘{"‘ || cl.tcl || ‘":"‘‘||‘||‘:OLD.‘ || cl.tcl ||‘||‘‘"}‘;
19 else
20 oldjson := oldjson || ‘,‘ || ‘{"‘ || cl.tcl || ‘":"‘‘||‘||‘:OLD.‘ || cl.tcl ||‘||‘‘"}‘;
21 end if;
22 end LOOP;
23 DBMS_OUTPUT.put_line(‘newjson:‘||newjson);
24 DBMS_OUTPUT.put_line(‘oldjson:‘||oldjson);
25 V_TMP := Q‘{CREATE OR REPLACE TRIGGER [email protected][email protected]
26 BEFORE INSERT OR UPDATE OR DELETE ON @[email protected] FOR EACH ROW
27 DECLARE
28 json clob;
29 BEGIN
30 IF INSERTING THEN
31 json := ‘@newjson@‘;
32 DBMS_OUTPUT.put_line(‘json字符串是insert：‘||json);
33 insert into ddllog values(‘@TABLE_NAME@‘,‘insert‘,json,sysdate);
34 end if;
35
36 IF DELETING THEN
37 json := ‘@oldjson@‘;
38 DBMS_OUTPUT.put_line(‘json字符串是delete：‘||json);
39 insert into ddllog values(‘@TABLE_NAME@‘,‘delete‘,json,sysdate);
40 end if;
41
42 IF UPDATING THEN
43 json := ‘@newjson@‘;
44 DBMS_OUTPUT.put_line(‘json字符串是update：‘||json);
45 insert into ddllog values(‘@TABLE_NAME@‘,‘update‘,json,sysdate);
46 end if;
47
48 END [email protected][email protected];}‘;
49 V_TMP := REPLACE(V_TMP, ‘@[email protected]‘, tableName);
50 V_TMP := REPLACE(V_TMP, ‘@[email protected]‘, newjson);
51 V_SQL := REPLACE(V_TMP, ‘@[email protected]‘, oldjson);
52 DBMS_OUTPUT.put_line(V_SQL);
53 EXECUTE IMMEDIATE V_SQL;
54 end Logging_Messages;
为指定表建立监听的触发器，结果如下：
实现了预想的功能，感觉还有很大的完善空间。不过限于水平较低，慢慢来改吧。
时间： 2024-10-13 23:57:27