Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit 0d6531b

Browse files
author
Vladimir Ershov
committed
fix super user call
1 parent 05f245a commit 0d6531b

File tree

1 file changed

+8
-7
lines changed

1 file changed

+8
-7
lines changed

pgpro_scheduler--1.0.sql

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -121,6 +121,7 @@ BEGIN
121121
IF NOT is_superuser THEN
122122
RAISE EXCEPTION 'access denied';
123123
END IF;
124+
RETURN TRUE;
124125
END
125126
$BODY$ LANGUAGE plpgsql;
126127

@@ -718,7 +719,7 @@ $BODY$
718719
DECLARE
719720
cnt integer;
720721
BEGIN
721-
SELECT onlySuperUser();
722+
PERFORM schedule.onlySuperUser();
722723

723724
WITH a AS (DELETE FROM schedule.log RETURNING 1)
724725
SELECT count(*) INTO cnt FROM a;
@@ -751,7 +752,7 @@ DECLARE
751752
ii schedule.cron;
752753
oo schedule.cron_rec;
753754
BEGIN
754-
SELECT onlySuperUser();
755+
PERFORM schedule.onlySuperUser();
755756

756757
FOR ii IN SELECT * FROM schedule.cron LOOP
757758
oo := schedule._make_cron_rec(ii);
@@ -786,7 +787,7 @@ DECLARE
786787
oo schedule.cron_rec;
787788
BEGIN
788789
IF usename <> session_user THEN
789-
SELECT onlySuperUser();
790+
PERFORM schedule.onlySuperUser();
790791
END IF;
791792

792793
FOR ii IN SELECT * FROM schedule.cron WHERE owner = usename LOOP
@@ -822,7 +823,7 @@ DECLARE
822823
oo schedule.cron_rec;
823824
BEGIN
824825
IF usename <> session_user THEN
825-
SELECT onlySuperUser();
826+
PERFORM schedule.onlySuperUser();
826827
END IF;
827828

828829
FOR ii IN SELECT * FROM schedule.cron WHERE executor = usename LOOP
@@ -875,7 +876,7 @@ DECLARE
875876
ii record;
876877
oo schedule.cron_job;
877878
BEGIN
878-
SELECT onlySuperUser();
879+
PERFORM schedule.onlySuperUser();
879880
FOR ii IN SELECT * FROM schedule.at as at, schedule.cron as cron WHERE cron.id = at.cron AND at.active LOOP
880881
oo.cron = ii.id;
881882
oo.node = ii.node;
@@ -911,7 +912,7 @@ DECLARE
911912
oo schedule.cron_job;
912913
BEGIN
913914
IF usename <> session_user THEN
914-
SELECT onlySuperUser();
915+
PERFORM schedule.onlySuperUser();
915916
END IF;
916917

917918
FOR ii IN SELECT * FROM schedule.at as at, schedule.cron as cron WHERE cron.executor = usename AND cron.id = at.cron AND at.active LOOP
@@ -968,7 +969,7 @@ DECLARE
968969
sql_cmd text;
969970
BEGIN
970971
IF usename <> session_user THEN
971-
SELECT onlySuperUser();
972+
PERFORM schedule.onlySuperUser();
972973
END IF;
973974

974975
IF usename = '___all___' THEN

0 commit comments

Comments
 (0)