OceanBase 数据库 V4.x 版本的 XA 事务基本运维

obclient> SELECT * FROM gv$ob_transaction_participants WHERE GLOBALID <> 'NULL';

SELECT * FROM gv$ob_transaction_participants
WHERE GLOBALID <> 'NULL'
  AND state = 'REDO COMPLETE'
  AND last_request_time < date_sub(now(), INTERVAL 600 SECOND);

SELECT * FROM gv$ob_transaction_participants
WHERE GLOBALID <> 'NULL'
  AND state = 'REDO COMPLETE'
  AND COORD = LS_ID;

declare
  rc  PLS_INTEGER;
begin
  rc  := DBMS_XA.XA_ROLLBACK(DBMS_XA_XID(40,'2020','101'));
  DBMS_OUTPUT.PUT_LINE('xa rollback: ' || rc);
end;
/

set serveroutput on;
DECLARE
  CURSOR cur
  IS
    SELECT 
      GLOBALID gtrid,
      BRANCHID bqual,
      FORMATID formatid
    FROM gv$ob_transaction_participants
    WHERE ROLE = 'LEADER' 
      AND GLOBALID is not NULL
      AND state = 'REDO COMPLETE'
      AND COORD = LS_ID;
  l_xid DBMS_XA_XID := DBMS_XA_XID(0, '', '');
  l_ret PLS_INTEGER;
BEGIN
  FOR rec IN cur
  LOOP
    l_xid.formatid := rec.formatid;
    l_xid.gtrid    := hextoraw(rec.gtrid);
    l_xid.bqual    := hextoraw(rec.bqual);
    l_ret          := DBMS_XA.XA_ROLLBACK(xid => l_xid);
    dbms_output.put_line(l_ret);
  END LOOP;
END;
/