From 7b280315c1de9dd00f256f33019140601ff3d5f3 Mon Sep 17 00:00:00 2001 From: gurkanindibay Date: Tue, 2 Apr 2024 12:49:59 +0300 Subject: [PATCH] Adds detailed logs --- .../alter_database_from_nonmain_db.out | 404 ++++++++++++++---- .../sql/alter_database_from_nonmain_db.sql | 174 ++++++-- 2 files changed, 465 insertions(+), 113 deletions(-) diff --git a/src/test/regress/expected/alter_database_from_nonmain_db.out b/src/test/regress/expected/alter_database_from_nonmain_db.out index e5eb85c16..50908c68f 100644 --- a/src/test/regress/expected/alter_database_from_nonmain_db.out +++ b/src/test/regress/expected/alter_database_from_nonmain_db.out @@ -28,15 +28,51 @@ DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE "ts-needs\!escape2" DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + +\c test_alter_db_from_nonmain_db - - :worker_1_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "pg_default"; NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE pg_default DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE "ts-needs\!escape2" DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + +\c test_alter_db_from_nonmain_db - - :worker_1_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "pg_default"; NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE pg_default DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "pg_default", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "pg_default", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "pg_default", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + +\c test_alter_db_from_nonmain_db - - :worker_1_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE "ts-needs\!escape2" DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx @@ -65,11 +101,35 @@ NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE "ts-needs\! DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE "ts-needs\!escape2" DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + +\c regression - - :worker_1_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "pg_default"; NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE pg_default DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE pg_default DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "pg_default", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "pg_default", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "pg_default", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + +\c regression - - :worker_1_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE "ts-needs\!escape2" DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx @@ -118,11 +178,29 @@ NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE "ts-needs\! DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE "ts-needs\!escape2" DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + +\c regression - - :worker_2_port alter database "altered_database!'2" set tablespace "pg_default"; -NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE pg_default -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE pg_default -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "pg_default", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "pg_default", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "pg_default", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + +\c regression - - :worker_2_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE "ts-needs\!escape2" DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx @@ -171,11 +249,27 @@ NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE "ts-needs\! DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE "ts-needs\!escape2" DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + alter database "altered_database!'2" set tablespace "pg_default"; NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE pg_default DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE pg_default DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "pg_default", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "pg_default", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "pg_default", "daticurules": null, "datallowconn": true, "datconnlimit": -1, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE "ts-needs\!escape2" DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx @@ -226,6 +320,15 @@ alter database "altered_database!'2" with IS_TEMPLATE false; NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" WITH ALLOW_CONNECTIONS true CONNECTION LIMIT 0 IS_TEMPLATE false;', 'postgres') DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + \c regression - - :worker_2_port set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; @@ -237,6 +340,18 @@ NOTICE: issuing ALTER DATABASE "altered_database!'2" WITH ALLOW_CONNECTIONS fal DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx NOTICE: issuing ALTER DATABASE "altered_database!'2" WITH ALLOW_CONNECTIONS false CONNECTION LIMIT 1 IS_TEMPLATE true; DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": false, "datconnlimit": 1, "daticulocale": null, "datistemplate": true, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": false, "datconnlimit": 1, "daticulocale": null, "datistemplate": true, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": false, "datconnlimit": 1, "daticulocale": null, "datistemplate": true, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + +\c regression - - :worker_2_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" with ALLOW_CONNECTIONS true CONNECTION LIMIT 0 @@ -254,6 +369,15 @@ set citus.enable_create_database_propagation=on; alter database "altered_database!'2" owner to test_owner_non_main_db; NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" OWNER TO test_owner_non_main_db;', 'postgres') DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "test_owner_non_main_db", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "test_owner_non_main_db", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "test_owner_non_main_db", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + \c test_alter_db_from_nonmain_db - - :worker_1_port set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; @@ -261,6 +385,15 @@ alter database "altered_database!'2" owner to CURRENT_USER; NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" OWNER TO postgres;', 'postgres') DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx set default_transaction_read_only = false; +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + \c regression - - :worker_1_port set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; @@ -270,6 +403,15 @@ DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx NOTICE: issuing ALTER DATABASE "altered_database!'2" OWNER TO test_owner_non_main_db; DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx set default_transaction_read_only = false; +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "test_owner_non_main_db", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "test_owner_non_main_db", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "test_owner_non_main_db", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + \c regression - - :master_port set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; @@ -279,72 +421,176 @@ DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx NOTICE: issuing ALTER DATABASE "altered_database!'2" OWNER TO postgres; DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx set default_transaction_read_only = false; -\c test_alter_db_from_nonmain_db - - :worker_2_port -set citus.log_remote_commands = true; -set citus.grep_remote_commands = "%ALTER DATABASE%"; -alter database "altered_database!'2" set default_transaction_read_only from current; -NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" SET default_transaction_read_only FROM CURRENT', 'postgres') -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -alter database "altered_database!'2" set default_transaction_read_only to DEFAULT; -NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" SET default_transaction_read_only TO DEFAULT', 'postgres') -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -alter database "altered_database!'2" RESET default_transaction_read_only; -NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" RESET default_transaction_read_only', 'postgres') -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -alter database "altered_database!'2" SET TIME ZONE '-7'; -NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" SET timezone = ''-7''', 'postgres') -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -alter database "altered_database!'2" set TIME ZONE LOCAL; -NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" SET timezone TO DEFAULT', 'postgres') -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + node_type | result +--------------------------------------------------------------------- + coordinator (local) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} + worker node (remote) | {"database_properties": {"datacl": null, "datname": "altered_database!'2", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "ts-needs\\!escape2", "daticurules": null, "datallowconn": true, "datconnlimit": 0, "daticulocale": null, "datistemplate": false, "database_owner": "postgres", "datcollversion": null, "datlocprovider": "c"}, "pg_dist_object_record_for_db_exists": true, "stale_pg_dist_object_record_for_a_db_exists": false} +(3 rows) + \c test_alter_db_from_nonmain_db set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; -alter database "altered_database!'2" set TIME ZONE DEFAULT; -NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" SET timezone TO DEFAULT', 'postgres') +alter database "altered_database!'2" set default_transaction_read_only to true; +NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" SET default_transaction_read_only = ''true''', 'postgres') DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -alter database "altered_database!'2" RESET TIME ZONE; -NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" RESET timezone', 'postgres') +\c "altered_database!'2" - - :master_port +select name,setting from pg_settings + where name ='default_transaction_read_only'; + name | setting +--------------------------------------------------------------------- + default_transaction_read_only | on +(1 row) + +\c "altered_database!'2" - - :worker_1_port +select name,setting from pg_settings + where name ='default_transaction_read_only'; + name | setting +--------------------------------------------------------------------- + default_transaction_read_only | on +(1 row) + +\c "altered_database!'2" - - :worker_2_port +select name,setting from pg_settings + where name ='default_transaction_read_only'; + name | setting +--------------------------------------------------------------------- + default_transaction_read_only | on +(1 row) + +\c test_alter_db_from_nonmain_db +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; +alter database "altered_database!'2" reset default_transaction_read_only; +NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" RESET default_transaction_read_only', 'postgres') DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -alter database "altered_database!'2" SET TIME ZONE INTERVAL '-08:00' HOUR TO MINUTE; -NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" SET TIME ZONE INTERVAL ''@ 8 hours ago''', 'postgres') +\c "altered_database!'2" - - :master_port +select name,setting from pg_settings + where name ='default_transaction_read_only'; + name | setting +--------------------------------------------------------------------- + default_transaction_read_only | off +(1 row) + +\c "altered_database!'2" - - :worker_1_port +select name,setting from pg_settings + where name ='default_transaction_read_only'; + name | setting +--------------------------------------------------------------------- + default_transaction_read_only | off +(1 row) + +\c "altered_database!'2" - - :worker_2_port +select name,setting from pg_settings + where name ='default_transaction_read_only'; + name | setting +--------------------------------------------------------------------- + default_transaction_read_only | off +(1 row) + +\c test_alter_db_from_nonmain_db - - :worker_2_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; +alter database "altered_database!'2" set log_duration from current; +NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" SET log_duration FROM CURRENT', 'postgres') DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -alter database "altered_database!'2" RESET TIME ZONE; -NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" RESET timezone', 'postgres') +alter database "altered_database!'2" set log_duration to DEFAULT; +NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" SET log_duration TO DEFAULT', 'postgres') DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -alter database "altered_database!'2" set default_transaction_isolation = 'serializable'; -NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" SET default_transaction_isolation = ''serializable''', 'postgres') +alter database "altered_database!'2" set log_duration = true; +NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" SET log_duration = ''true''', 'postgres') DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c "altered_database!'2" - - :master_port +select name,setting from pg_settings + where name ='log_duration'; + name | setting +--------------------------------------------------------------------- + log_duration | on +(1 row) + +\c "altered_database!'2" - - :worker_1_port +select name,setting from pg_settings + where name ='log_duration'; + name | setting +--------------------------------------------------------------------- + log_duration | on +(1 row) + +\c "altered_database!'2" - - :worker_2_port +select name,setting from pg_settings + where name ='log_duration'; + name | setting +--------------------------------------------------------------------- + log_duration | on +(1 row) + +\c test_alter_db_from_nonmain_db - - :worker_2_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; +alter database "altered_database!'2" RESET log_duration; +NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" RESET log_duration', 'postgres') +DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c "altered_database!'2" - - :master_port +select name,setting from pg_settings + where name ='log_duration'; + name | setting +--------------------------------------------------------------------- + log_duration | off +(1 row) + +\c "altered_database!'2" - - :worker_1_port +select name,setting from pg_settings + where name ='log_duration'; + name | setting +--------------------------------------------------------------------- + log_duration | off +(1 row) + +\c "altered_database!'2" - - :worker_2_port +select name,setting from pg_settings + where name ='log_duration'; + name | setting +--------------------------------------------------------------------- + log_duration | off +(1 row) + \c regression - - :worker_2_port set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; -set default_transaction_isolation = 'read committed'; -alter database "altered_database!'2" set default_transaction_isolation from current; -NOTICE: issuing ALTER DATABASE "altered_database!'2" SET default_transaction_isolation FROM CURRENT -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -NOTICE: issuing ALTER DATABASE "altered_database!'2" SET default_transaction_isolation FROM CURRENT -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -alter database "altered_database!'2" set default_transaction_isolation to DEFAULT; -NOTICE: issuing ALTER DATABASE "altered_database!'2" SET default_transaction_isolation TO DEFAULT -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -NOTICE: issuing ALTER DATABASE "altered_database!'2" SET default_transaction_isolation TO DEFAULT -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -alter database "altered_database!'2" RESET default_transaction_isolation; -NOTICE: issuing ALTER DATABASE "altered_database!'2" RESET default_transaction_isolation -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -NOTICE: issuing ALTER DATABASE "altered_database!'2" RESET default_transaction_isolation -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx alter database "altered_database!'2" set statement_timeout = 1000; NOTICE: issuing ALTER DATABASE "altered_database!'2" SET statement_timeout = 1000 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx NOTICE: issuing ALTER DATABASE "altered_database!'2" SET statement_timeout = 1000 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -set statement_timeout = 2000; -alter database "altered_database!'2" set statement_timeout from current; -NOTICE: issuing ALTER DATABASE "altered_database!'2" SET statement_timeout FROM CURRENT -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -NOTICE: issuing ALTER DATABASE "altered_database!'2" SET statement_timeout FROM CURRENT -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c "altered_database!'2" - - :master_port +select name,setting from pg_settings + where name ='statement_timeout'; + name | setting +--------------------------------------------------------------------- + statement_timeout | 1000 +(1 row) + +\c "altered_database!'2" - - :worker_1_port +select name,setting from pg_settings + where name ='statement_timeout'; + name | setting +--------------------------------------------------------------------- + statement_timeout | 1000 +(1 row) + +\c "altered_database!'2" - - :worker_2_port +select name,setting from pg_settings + where name ='statement_timeout'; + name | setting +--------------------------------------------------------------------- + statement_timeout | 1000 +(1 row) + +\c regression - - :worker_2_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set statement_timeout to DEFAULT; NOTICE: issuing ALTER DATABASE "altered_database!'2" SET statement_timeout TO DEFAULT DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx @@ -355,32 +601,30 @@ NOTICE: issuing ALTER DATABASE "altered_database!'2" RESET statement_timeout DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx NOTICE: issuing ALTER DATABASE "altered_database!'2" RESET statement_timeout DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -alter database "altered_database!'2" set lock_timeout = 1201.5; -NOTICE: issuing ALTER DATABASE "altered_database!'2" SET lock_timeout = 1201.5 -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -NOTICE: issuing ALTER DATABASE "altered_database!'2" SET lock_timeout = 1201.5 -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -set lock_timeout = 1202.5; -alter database "altered_database!'2" set lock_timeout from current; -NOTICE: issuing ALTER DATABASE "altered_database!'2" SET lock_timeout FROM CURRENT -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -NOTICE: issuing ALTER DATABASE "altered_database!'2" SET lock_timeout FROM CURRENT -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -alter database "altered_database!'2" set lock_timeout to DEFAULT; -NOTICE: issuing ALTER DATABASE "altered_database!'2" SET lock_timeout TO DEFAULT -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -NOTICE: issuing ALTER DATABASE "altered_database!'2" SET lock_timeout TO DEFAULT -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -alter database "altered_database!'2" RESET lock_timeout; -NOTICE: issuing ALTER DATABASE "altered_database!'2" RESET lock_timeout -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -NOTICE: issuing ALTER DATABASE "altered_database!'2" RESET lock_timeout -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -ALTER DATABASE "altered_database!'2" RESET ALL; -NOTICE: issuing ALTER DATABASE "altered_database!'2" RESET ALL -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx -NOTICE: issuing ALTER DATABASE "altered_database!'2" RESET ALL -DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx +\c "altered_database!'2" - - :master_port +select name,setting from pg_settings + where name ='statement_timeout'; + name | setting +--------------------------------------------------------------------- + statement_timeout | 0 +(1 row) + +\c "altered_database!'2" - - :worker_1_port +select name,setting from pg_settings + where name ='statement_timeout'; + name | setting +--------------------------------------------------------------------- + statement_timeout | 0 +(1 row) + +\c "altered_database!'2" - - :worker_2_port +select name,setting from pg_settings + where name ='statement_timeout'; + name | setting +--------------------------------------------------------------------- + statement_timeout | 0 +(1 row) + \c regression set citus.enable_create_database_propagation=on; drop database "altered_database!'2"; diff --git a/src/test/regress/sql/alter_database_from_nonmain_db.sql b/src/test/regress/sql/alter_database_from_nonmain_db.sql index c9eb8f57f..453c5961e 100644 --- a/src/test/regress/sql/alter_database_from_nonmain_db.sql +++ b/src/test/regress/sql/alter_database_from_nonmain_db.sql @@ -28,9 +28,26 @@ set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; +\c test_alter_db_from_nonmain_db - - :worker_1_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; + +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; +\c test_alter_db_from_nonmain_db - - :worker_1_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "pg_default"; + +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; +\c test_alter_db_from_nonmain_db - - :worker_1_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; @@ -42,7 +59,17 @@ set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; +\c regression - - :worker_1_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "pg_default"; +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; +\c regression - - :worker_1_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; @@ -56,7 +83,15 @@ set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; +\c regression - - :worker_2_port alter database "altered_database!'2" set tablespace "pg_default"; +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; +\c regression - - :worker_2_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; @@ -70,7 +105,9 @@ set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; alter database "altered_database!'2" set tablespace "pg_default"; +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; @@ -79,21 +116,20 @@ alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; - - \c test_alter_db_from_nonmain_db - - :worker_2_port set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" rename to altered_database_renamed; - alter database altered_database_renamed rename to "altered_database!'2"; - alter database "altered_database!'2" with ALLOW_CONNECTIONS true CONNECTION LIMIT 0 IS_TEMPLATE false; +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + \c regression - - :worker_2_port set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; @@ -102,16 +138,18 @@ alter database "altered_database!'2" with ALLOW_CONNECTIONS false CONNECTION LIMIT 1 IS_TEMPLATE true; + +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; + +\c regression - - :worker_2_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" with ALLOW_CONNECTIONS true CONNECTION LIMIT 0 IS_TEMPLATE false; - - - - - \c regression create role test_owner_non_main_db; @@ -120,63 +158,133 @@ set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; set citus.enable_create_database_propagation=on; alter database "altered_database!'2" owner to test_owner_non_main_db; +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; \c test_alter_db_from_nonmain_db - - :worker_1_port set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" owner to CURRENT_USER; set default_transaction_read_only = false; +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; \c regression - - :worker_1_port set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" owner to test_owner_non_main_db; set default_transaction_read_only = false; - +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; \c regression - - :master_port set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" owner to CURRENT_USER; set default_transaction_read_only = false; +\c regression - - :master_port +SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type; +\c test_alter_db_from_nonmain_db +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; + +alter database "altered_database!'2" set default_transaction_read_only to true; + +\c "altered_database!'2" - - :master_port +select name,setting from pg_settings + where name ='default_transaction_read_only'; +\c "altered_database!'2" - - :worker_1_port +select name,setting from pg_settings + where name ='default_transaction_read_only'; +\c "altered_database!'2" - - :worker_2_port +select name,setting from pg_settings + where name ='default_transaction_read_only'; + +\c test_alter_db_from_nonmain_db +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; +alter database "altered_database!'2" reset default_transaction_read_only; + +\c "altered_database!'2" - - :master_port +select name,setting from pg_settings + where name ='default_transaction_read_only'; +\c "altered_database!'2" - - :worker_1_port +select name,setting from pg_settings + where name ='default_transaction_read_only'; +\c "altered_database!'2" - - :worker_2_port +select name,setting from pg_settings + where name ='default_transaction_read_only'; + \c test_alter_db_from_nonmain_db - - :worker_2_port set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; -alter database "altered_database!'2" set default_transaction_read_only from current; -alter database "altered_database!'2" set default_transaction_read_only to DEFAULT; -alter database "altered_database!'2" RESET default_transaction_read_only; -alter database "altered_database!'2" SET TIME ZONE '-7'; -alter database "altered_database!'2" set TIME ZONE LOCAL; +alter database "altered_database!'2" set log_duration from current; +alter database "altered_database!'2" set log_duration to DEFAULT; +alter database "altered_database!'2" set log_duration = true; +\c "altered_database!'2" - - :master_port +select name,setting from pg_settings + where name ='log_duration'; -\c test_alter_db_from_nonmain_db +\c "altered_database!'2" - - :worker_1_port +select name,setting from pg_settings + where name ='log_duration'; + +\c "altered_database!'2" - - :worker_2_port +select name,setting from pg_settings + where name ='log_duration'; + +\c test_alter_db_from_nonmain_db - - :worker_2_port set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; -alter database "altered_database!'2" set TIME ZONE DEFAULT; -alter database "altered_database!'2" RESET TIME ZONE; -alter database "altered_database!'2" SET TIME ZONE INTERVAL '-08:00' HOUR TO MINUTE; -alter database "altered_database!'2" RESET TIME ZONE; -alter database "altered_database!'2" set default_transaction_isolation = 'serializable'; +alter database "altered_database!'2" RESET log_duration; + + +\c "altered_database!'2" - - :master_port +select name,setting from pg_settings + where name ='log_duration'; +\c "altered_database!'2" - - :worker_1_port +select name,setting from pg_settings + where name ='log_duration'; +\c "altered_database!'2" - - :worker_2_port +select name,setting from pg_settings + where name ='log_duration'; + + + \c regression - - :worker_2_port set citus.log_remote_commands = true; set citus.grep_remote_commands = "%ALTER DATABASE%"; -set default_transaction_isolation = 'read committed'; -alter database "altered_database!'2" set default_transaction_isolation from current; -alter database "altered_database!'2" set default_transaction_isolation to DEFAULT; -alter database "altered_database!'2" RESET default_transaction_isolation; alter database "altered_database!'2" set statement_timeout = 1000; -set statement_timeout = 2000; -alter database "altered_database!'2" set statement_timeout from current; + +\c "altered_database!'2" - - :master_port +select name,setting from pg_settings + where name ='statement_timeout'; +\c "altered_database!'2" - - :worker_1_port +select name,setting from pg_settings + where name ='statement_timeout'; +\c "altered_database!'2" - - :worker_2_port +select name,setting from pg_settings + where name ='statement_timeout'; + + +\c regression - - :worker_2_port +set citus.log_remote_commands = true; +set citus.grep_remote_commands = "%ALTER DATABASE%"; alter database "altered_database!'2" set statement_timeout to DEFAULT; alter database "altered_database!'2" RESET statement_timeout; -alter database "altered_database!'2" set lock_timeout = 1201.5; -set lock_timeout = 1202.5; -alter database "altered_database!'2" set lock_timeout from current; -alter database "altered_database!'2" set lock_timeout to DEFAULT; -alter database "altered_database!'2" RESET lock_timeout; -ALTER DATABASE "altered_database!'2" RESET ALL; + +\c "altered_database!'2" - - :master_port +select name,setting from pg_settings + where name ='statement_timeout'; +\c "altered_database!'2" - - :worker_1_port +select name,setting from pg_settings + where name ='statement_timeout'; +\c "altered_database!'2" - - :worker_2_port +select name,setting from pg_settings + where name ='statement_timeout'; \c regression set citus.enable_create_database_propagation=on;