CREATE TABLE WATCH_TRANSACTION (
    TIME_STMP TIMESTAMP,
    CUR_TRANS  BIGINT,
    TR_ID      BIGINT NOT NULL,
    OP         VARCHAR(10),
    PROC       VARCHAR(255),
    SQL        BLOB SUB_TYPE 1 SEGMENT SIZE 80
);


create or alter trigger TRG_TRANS_WATCH_DISC on disconnect
as
declare variable sql blob sub_type text;
declare variable trid bigint;
declare variable proc varchar(255);
begin
    for
    select
      t2.mon$transaction_id, a.mon$remote_process, s.mon$sql_text
    from mon$transactions t1, mon$transactions t2, mon$statements s, mon$attachments a
    where
      t1.mon$transaction_id = current_Transaction
      and
      t1.mon$attachment_id = t2.mon$attachment_id
      and
      t2.mon$transaction_id = s.mon$transaction_id
    order by t2.mon$transaction_id
    into :trid,:proc,:sql
    do
    in autonomous transaction do
      insert into WATCH_TRANSACTION values ('now', current_transaction,  :trid, 'DIS', :proc, :sql);
end


create or alter trigger TRG_TRANS_WATCH_ROLL on disconnect
as
declare variable sql blob sub_type text;
declare variable trid bigint;
declare variable proc varchar(255);
begin
    for
    select
      t2.mon$transaction_id, a.mon$remote_process, s.mon$sql_text
    from mon$transactions t1, mon$transactions t2, mon$statements s, mon$attachments a
    where
      t1.mon$transaction_id = current_Transaction
      and
      t1.mon$attachment_id = t2.mon$attachment_id
      and
      t2.mon$transaction_id = s.mon$transaction_id
    order by t2.mon$transaction_id
    into :trid,:proc,:sql
    do
    in autonomous transaction do
      insert into WATCH_TRANSACTION values ('now', current_transaction,  :trid, 'ROLL', :proc, :sql);
end