0

我正在尝试捕获表上的数据更改，并在插入或更新之后以及更新或删除之前执行以下触发器函数：

CREATE OR REPLACE FUNCTION cdc_test_function()
  RETURNS trigger AS
$BODY$
DECLARE op cdc_operation_enum;
BEGIN
    op = TG_OP;
    IF (TG_WHEN = 'BEFORE') THEN
        IF (TG_OP = 'UPDATE') THEN
            op = 'UPDATE_BEFORE';
        END IF;

        INSERT INTO cdc_test VALUES (DEFAULT, DEFAULT, op, DEFAULT, DEFAULT, OLD.*);
    ELSE
        IF (TG_OP = 'UPDATE') THEN
            op = 'UPDATE_AFTER';
        END IF;

        INSERT INTO cdc_test VALUES (DEFAULT, DEFAULT, op, DEFAULT, DEFAULT, NEW.*);
    END IF;

    RETURN NEW;
END;

我的更改表 (CDC_TEST) 正在正确捕获所有内容，并且我可以在我的 TEST 表中很好地插入和更新记录。但是，当我尝试 DELETE 时，它会在 CDC_TEST 中完美记录 DELETE 条目，但该记录仍保留在我的 TEST 表中。如果我禁用触发器，那么我可以从 TEST 中删除就好了。这是我用来创建表的代码以及我的枚举代码：

CREATE TABLE test
(
  test_id serial NOT NULL,
  value text NOT NULL,
  CONSTRAINT test_pkey PRIMARY KEY (test_id )
)

CREATE TABLE cdc_test
(
  cdc_test_id bigserial NOT NULL,
  cdc_timestamp timestamp with time zone DEFAULT now(),
  cdc_opeation cdc_operation_enum,
  cdc_user name DEFAULT "current_user"(),
  cdc_transaction_id bigint DEFAULT txid_current(),
  test_id integer,
  value text,
  CONSTRAINT cdc_test_pkey PRIMARY KEY (cdc_test_id )
)

CREATE TYPE cdc_operation_enum AS ENUM( 'DELETE', 'INSERT', 'UPDATE_BEFORE', 'UPDATE_AFTER', 'UPDATE' );
4

1 回答 1

3

OLD当触发器运行以进行删除和NEW更新时返回。

于 2011-09-21T19:13:17.877 回答