DO $$
BEGIN
raise notice '%', (SELECT * from public.clientcalledthisfunction(1,2));
END $$;
CREATE OR REPLACE FUNCTION public.clientcalledthisfunction(userid1_ integer, userid2_ integer)
RETURNS integer
AS $$
DECLARE
result integer;
BEGIN
result:=(SELECT * from public.call_updatedata(userid1_, userid2_)) ;
RETURN result;
EXCEPTION WHEN others THEN
End $$ LANGUAGE plpgsql;
CREATE OR REPLACE FUNCTION public.call_updatedata(userid1_ integer, userid2_ integer)
RETURNS integer
AS $$
DECLARE
userdata_1 integer;
userdata_2 integer;
userdata_total integer;
BEGIN
SELECT * FROM public.updatedata(userid1_) INTO userdata_1;
SELECT * FROM public.updatedata(userid2_) INTO userdata_2;
userdata_total:=(userdata_1 + userdata_2);
RETURN userdata_total;
EXCEPTION WHEN others THEN
End $$ LANGUAGE plpgsql;
CREATE OR REPLACE FUNCTION public.updatedata(userid_ integer)
RETURNS integer
AS $$
DECLARE
userdata_ integer;
BEGIN
LOOP
SET TRANSACTION ISOLATION LEVEL SERIALIZABLE;
BEGIN
SAVEPOINT foo;
SELECT userdata FROM public.footable WHERE userid=userid_ INTO userdata_;
UPDATE public.footable SET userdata = userdata_ + 1 WHERE userid=userid_ ;
EXIT ;
EXCEPTION WHEN others THEN
ROLLBACK TO SAVEPOINT foo;
END;
END LOOP;
RETURN userdata_ + 1;
EXCEPTION WHEN others THEN
END $$ language plpgsql;
客户端calls public.clientcalledthisfunction()
功能;
我需要在函数中实现 ISOLATION LEVEL SERIALIZABLE
,SELECT + UPDATE
因为我不想“丢失更新” ...updatedata()
我只想在.public.updatedata function()
updatedata()
如果出现异常,则在函数中;我希望它回滚并再次通过循环savepoint foo
重试过程......select + update
但我会error
说"control reached end of function without RETURN"
......我不明白问题出在哪里。