read database name inside the function (#3730)

pull/3697/head^2
SaitTalhaNisanci 2020-04-09 13:11:13 +03:00 committed by GitHub
parent 233e4a24d1
commit ebda3eff61
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 5 deletions

View File

@ -7,7 +7,7 @@
-- not done yet. -- not done yet.
SET citus.next_shard_id TO 580000; SET citus.next_shard_id TO 580000;
SELECT $definition$ SELECT $definition$
CREATE OR REPLACE FUNCTION test.maintenance_worker(p_dbname text DEFAULT current_database()) CREATE OR REPLACE FUNCTION test.maintenance_worker()
RETURNS pg_stat_activity RETURNS pg_stat_activity
LANGUAGE plpgsql LANGUAGE plpgsql
AS $$ AS $$
@ -19,7 +19,7 @@ BEGIN
FOR i IN 1 .. 200 LOOP FOR i IN 1 .. 200 LOOP
PERFORM pg_stat_clear_snapshot(); PERFORM pg_stat_clear_snapshot();
SELECT * INTO activity FROM pg_stat_activity SELECT * INTO activity FROM pg_stat_activity
WHERE application_name = 'Citus Maintenance Daemon' AND datname = p_dbname; WHERE application_name = 'Citus Maintenance Daemon' AND datname = current_database();
IF activity.pid IS NOT NULL THEN IF activity.pid IS NOT NULL THEN
RETURN activity; RETURN activity;
ELSE ELSE
@ -127,7 +127,7 @@ ALTER EXTENSION citus UPDATE TO '9.2-4';
* but we do not support explicitly updating it to to 9.3-1. * but we do not support explicitly updating it to to 9.3-1.
* Hence below update (to 9.3-1) command should fail. * Hence below update (to 9.3-1) command should fail.
*/ */
ALTER EXTENSION citus UPDATE TO '9.3-1'; ALTER EXTENSION citus UPDATE TO '9.3-1';
ERROR: extension "citus" has no update path from version "9.2-4" to version "9.3-1" ERROR: extension "citus" has no update path from version "9.2-4" to version "9.3-1"
ALTER EXTENSION citus UPDATE TO '9.3-2'; ALTER EXTENSION citus UPDATE TO '9.3-2';
-- show running version -- show running version

View File

@ -10,7 +10,7 @@
SET citus.next_shard_id TO 580000; SET citus.next_shard_id TO 580000;
SELECT $definition$ SELECT $definition$
CREATE OR REPLACE FUNCTION test.maintenance_worker(p_dbname text DEFAULT current_database()) CREATE OR REPLACE FUNCTION test.maintenance_worker()
RETURNS pg_stat_activity RETURNS pg_stat_activity
LANGUAGE plpgsql LANGUAGE plpgsql
AS $$ AS $$
@ -22,7 +22,7 @@ BEGIN
FOR i IN 1 .. 200 LOOP FOR i IN 1 .. 200 LOOP
PERFORM pg_stat_clear_snapshot(); PERFORM pg_stat_clear_snapshot();
SELECT * INTO activity FROM pg_stat_activity SELECT * INTO activity FROM pg_stat_activity
WHERE application_name = 'Citus Maintenance Daemon' AND datname = p_dbname; WHERE application_name = 'Citus Maintenance Daemon' AND datname = current_database();
IF activity.pid IS NOT NULL THEN IF activity.pid IS NOT NULL THEN
RETURN activity; RETURN activity;
ELSE ELSE