PostGreSQL-控制交易

如何解决PostGreSQL-控制交易

我有一个存储过程，该存储过程又调用了其他几个存储过程；它们每个都返回true或false，并通过将错误存储到表中来内部处理错误。

类似这样的东西：

-- (MAIN STORED PROCEDURE)
BEGIN
 CALL STORED_PROC_1('WW','TT','FF',result);
 IF result = TRUE then
    CALL STORED_PROC_2('a','b','c',result);
    ...
 END IF;
END;

IF result != TRUE THEN
 ROLLBACK;
ELSE
 COMMIT;
END IF;

-- (END MAIN STORED PROCEDURE)

-------
--Example of Stored Procedure 1
CREATE OR REPLACE PROCEDURE STORED_PROC_1 (IN a TEXT,IN b TEXT,IN c TEXT,INOUT result boolean)
AS $BODY$
BEGIN

 -- DO SOME STUFF HERE

 IF ERROR_FOUND THEN
   INSERT INTO ERROR_LOG VALUES ('Error','Type of Error',CURRENT_DATE);
   --COMMIT; (I cannot do this commit here but I would like to save the information going into the ERROR_LOG table)
   result := FALSE;
 ELSE
   result := TRUE;
 END IF;
END;
$BODY$;

这实际上是我想要的；仅在全部返回TRUE时才提交； 问题是，在STORED_PROC_1或_2内，有一些错误处理会写入错误日志表，并且...如果有错误，它们将在结果中返回FALSE，进而将调用回滚，而我将丢失错误日志。

有没有一种方法可以创建一种可以向我加载错误信息并在ROLLBACK之后将其写入的内存表？还是有更好的方法来实现这一目标？

非常感谢。

解决方法

如果可以的话，我建议使用FUNCTION而不是PROCEDURE，因为它们在某种意义上内置了事务控制。如果FUNCTION失败，您将自动回滚其事务。

话虽如此，而不是直接执行插入操作，我将执行如下功能：

CREATE OR REPLACE FUNCTION func_logerror(error TEXT,errortype TEXT,date DATE DEFAULT CURRENT_DATE)
RETURNS SETOF ERROR_LOG
AS $$
DECLARE
BEGIN
    RETURN QUERY
    INSERT INTO ERROR_LOG VALUES (error,errortype,date) RETURNING *;
END;
$$;

根据您是否要在调用函数中使用结果，使用SELECT或PERFORM对其进行调用。

PERFORM * FROM func_logerror('Error','Type of Error',CURRENT_DATE);

---

阅读您的答案后，我想出了这个来帮助澄清。我建议根本不使用存储过程。而是以其他方式处理错误情况：

-- (MAIN STORED PROCEDURE)
CREATE OR REPLACE FUNCTION FUNC_MAIN()
RETURNS boolean
AS $$
DECLARE
    res    boolean;
BEGIN
    SELECT * INTO res FROM FUNC_1('WW','TT','FF');
    IF res = TRUE
    THEN
        SELECT * INTO res FROM FUNC_2('a','b','c');
        ...
    ELSE
        RETURN FALSE;
    END IF;
    RETURN res;
END;
$$;
-- (END MAIN STORED PROCEDURE)

-------
--Example of Stored Procedure 1
CREATE OR REPLACE FUNCTION FUNC_1 (a TEXT,b TEXT,c TEXT)
RETURNS boolean
AS $$
DECLARE
BEGIN
    -- ****complete data validation before writing to tables****
    -- If you hit any invalid data return out of the function before writing any persistent data
    -- Ex:
    IF COALESCE(a,'') = '' -- could be anything that may produce ERROR_FOUND from your example
    THEN
        RAISE WARNING 'FUNC_1 | param: a: must have a value'; 
        PERFORM * FROM "Schema".func_errlog('Error',CURRENT_DATE);
        RETURN FALSE;
    END IF;

    RETURN TRUE; -- If you've made it to the end of the function there should be no errors
END;
$$;

,

好吧，这就是现在的样子。

-- (MAIN STORED PROCEDURE)
BEGIN
 CALL STORED_PROC_1('WW','FF',result);
 IF result = TRUE then
    CALL STORED_PROC_2('a','c',result);
    ...
 END IF;
END;

IF result != TRUE THEN
 ROLLBACK;
ELSE
 COMMIT;
END IF;

-- (END MAIN STORED PROCEDURE)

-------
--Example of Stored Procedure 1
CREATE OR REPLACE PROCEDURE STORED_PROC_1 (IN a TEXT,IN b TEXT,IN c TEXT,INOUT result boolean)
AS $BODY$
BEGIN

 -- DO SOME STUFF HERE

 IF ERROR_FOUND THEN
   PERFORM * FROM "Schema".func_errlog('Error',CURRENT_DATE);
        IF FOUND
        THEN
          result := FALSE;
        END IF; 
 ELSE
   result := TRUE;
 END IF;
END;
$BODY$;

该功能基本上是您在此处提供的功能的副本。 因此，我仍然有相同的错误。在Main过程中，如果我调用ROLLBACK（由于错误，我想回滚所有内容，但是我想保存该错误，并且函数会保存它，但是稍后会受到ROLLBACK的影响... 难道我做错了什么？据我了解，这应该现在就可以工作了... 感谢您的支持。