external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Adds detailed logs

pull/7563/head
gurkanindibay 2024-04-02 12:49:59 +03:00
parent 152b46da0a
commit 7b280315c1
2 changed files with 465 additions and 113 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

404
src/test/regress/expected/alter_database_from_nonmain_db.out
View File

@ -28,15 +28,51 @@ DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2";
NOTICE: issuing 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 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"; alter database "altered_database!'2" set tablespace "pg_default";
NOTICE: issuing 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2";
NOTICE: issuing 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 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"; alter database "altered_database!'2" set tablespace "pg_default";
NOTICE: issuing 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 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"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2";
NOTICE: issuing 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 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
NOTICE: issuing 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 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"; alter database "altered_database!'2" set tablespace "pg_default";
NOTICE: issuing 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
NOTICE: issuing 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 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"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2";
NOTICE: issuing 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 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
NOTICE: issuing 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 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"; alter database "altered_database!'2" set tablespace "pg_default";
NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE pg_default \c regression - - :master_port
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type;
NOTICE: issuing ALTER DATABASE "altered_database!'2" SET TABLESPACE pg_default node_type | result
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx ---------------------------------------------------------------------
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"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2";
NOTICE: issuing 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 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
NOTICE: issuing 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 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"; alter database "altered_database!'2" set tablespace "pg_default";
NOTICE: issuing 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
NOTICE: issuing 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 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"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2";
NOTICE: issuing 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
@ -226,6 +320,15 @@ alter database "altered_database!'2" with
IS_TEMPLATE false; 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') 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 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 \c regression - - :worker_2_port
set citus.log_remote_commands = true; set citus.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; 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 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; 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 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 alter database "altered_database!'2" with
ALLOW_CONNECTIONS true ALLOW_CONNECTIONS true
CONNECTION LIMIT 0 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; 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') 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 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 \c test_alter_db_from_nonmain_db - - :worker_1_port
set citus.log_remote_commands = true; set citus.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; 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') 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
set default_transaction_read_only = false; 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 \c regression - - :worker_1_port
set citus.log_remote_commands = true; set citus.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; 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; NOTICE: issuing ALTER DATABASE "altered_database!'2" OWNER TO test_owner_non_main_db;
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
set default_transaction_read_only = false; 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 \c regression - - :master_port
set citus.log_remote_commands = true; set citus.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; 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; NOTICE: issuing ALTER DATABASE "altered_database!'2" OWNER TO postgres;
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
set default_transaction_read_only = false; set default_transaction_read_only = false;
\c test_alter_db_from_nonmain_db - - :worker_2_port \c regression - - :master_port
set citus.log_remote_commands = true; SELECT * FROM public.check_database_on_all_nodes($$altered_database!''2$$) ORDER BY node_type;
set citus.grep_remote_commands = "%ALTER DATABASE%"; node_type | result
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') 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}
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx 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}
alter database "altered_database!'2" set default_transaction_read_only to DEFAULT; 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}
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') (3 rows)
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 test_alter_db_from_nonmain_db \c test_alter_db_from_nonmain_db
set citus.log_remote_commands = true; set citus.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; set citus.grep_remote_commands = "%ALTER DATABASE%";
alter database "altered_database!'2" set TIME ZONE DEFAULT; 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 timezone TO DEFAULT', 'postgres') 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
alter database "altered_database!'2" RESET TIME ZONE; \c "altered_database!'2" - - :master_port
NOTICE: issuing SELECT citus_internal.execute_command_on_remote_nodes_as_user('ALTER DATABASE "altered_database!''2" RESET timezone', 'postgres') 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
alter database "altered_database!'2" SET TIME ZONE INTERVAL '-08:00' HOUR TO MINUTE; \c "altered_database!'2" - - :master_port
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') 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
alter database "altered_database!'2" RESET TIME ZONE; 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" RESET timezone', 'postgres') 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
alter database "altered_database!'2" set default_transaction_isolation = 'serializable'; 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 default_transaction_isolation = ''serializable''', 'postgres') 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 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 \c regression - - :worker_2_port
set citus.log_remote_commands = true; set citus.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; 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; alter database "altered_database!'2" set statement_timeout = 1000;
NOTICE: issuing 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
NOTICE: issuing 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
set statement_timeout = 2000; \c "altered_database!'2" - - :master_port
alter database "altered_database!'2" set statement_timeout from current; select name,setting from pg_settings
NOTICE: issuing ALTER DATABASE "altered_database!'2" SET statement_timeout FROM CURRENT where name ='statement_timeout';
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx name | setting
NOTICE: issuing ALTER DATABASE "altered_database!'2" SET statement_timeout FROM CURRENT ---------------------------------------------------------------------
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx 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; alter database "altered_database!'2" set statement_timeout to DEFAULT;
NOTICE: issuing 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 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 DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
NOTICE: issuing ALTER DATABASE "altered_database!'2" RESET statement_timeout NOTICE: issuing ALTER DATABASE "altered_database!'2" RESET statement_timeout
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
alter database "altered_database!'2" set lock_timeout = 1201.5; \c "altered_database!'2" - - :master_port
NOTICE: issuing ALTER DATABASE "altered_database!'2" SET lock_timeout = 1201.5 select name,setting from pg_settings
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx where name ='statement_timeout';
NOTICE: issuing ALTER DATABASE "altered_database!'2" SET lock_timeout = 1201.5 name | setting
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx ---------------------------------------------------------------------
set lock_timeout = 1202.5; statement_timeout | 0
alter database "altered_database!'2" set lock_timeout from current; (1 row)
NOTICE: issuing ALTER DATABASE "altered_database!'2" SET lock_timeout FROM CURRENT
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx \c "altered_database!'2" - - :worker_1_port
NOTICE: issuing ALTER DATABASE "altered_database!'2" SET lock_timeout FROM CURRENT select name,setting from pg_settings
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx where name ='statement_timeout';
alter database "altered_database!'2" set lock_timeout to DEFAULT; name | setting
NOTICE: issuing ALTER DATABASE "altered_database!'2" SET lock_timeout TO DEFAULT ---------------------------------------------------------------------
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx statement_timeout | 0
NOTICE: issuing ALTER DATABASE "altered_database!'2" SET lock_timeout TO DEFAULT (1 row)
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx
alter database "altered_database!'2" RESET lock_timeout; \c "altered_database!'2" - - :worker_2_port
NOTICE: issuing ALTER DATABASE "altered_database!'2" RESET lock_timeout select name,setting from pg_settings
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx where name ='statement_timeout';
NOTICE: issuing ALTER DATABASE "altered_database!'2" RESET lock_timeout name | setting
DETAIL: on server postgres@localhost:xxxxx connectionId: xxxxxxx ---------------------------------------------------------------------
ALTER DATABASE "altered_database!'2" RESET ALL; statement_timeout | 0
NOTICE: issuing ALTER DATABASE "altered_database!'2" RESET ALL (1 row)
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 regression \c regression
set citus.enable_create_database_propagation=on; set citus.enable_create_database_propagation=on;
drop database "altered_database!'2"; drop database "altered_database!'2";

174
src/test/regress/sql/alter_database_from_nonmain_db.sql
View File

@ -28,9 +28,26 @@ set citus.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; set citus.grep_remote_commands = "%ALTER DATABASE%";
alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "pg_default";
alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; 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 "pg_default";
alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; 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 "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 "ts-needs\!escape2";
alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "pg_default";
alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; 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%"; set citus.grep_remote_commands = "%ALTER DATABASE%";
alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "pg_default";
alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; 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"; 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 "ts-needs\!escape2";
alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "pg_default";
alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; 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%"; set citus.grep_remote_commands = "%ALTER DATABASE%";
alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "pg_default";
alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; 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"; 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 "ts-needs\!escape2";
alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "pg_default";
alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; 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%"; set citus.grep_remote_commands = "%ALTER DATABASE%";
alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "pg_default";
alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; 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"; 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 "ts-needs\!escape2";
alter database "altered_database!'2" set tablespace "pg_default"; alter database "altered_database!'2" set tablespace "pg_default";
alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; 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 "pg_default";
alter database "altered_database!'2" set tablespace "ts-needs\!escape2"; alter database "altered_database!'2" set tablespace "ts-needs\!escape2";
\c test_alter_db_from_nonmain_db - - :worker_2_port \c test_alter_db_from_nonmain_db - - :worker_2_port
set citus.log_remote_commands = true; set citus.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; set citus.grep_remote_commands = "%ALTER DATABASE%";
alter database "altered_database!'2" rename to altered_database_renamed; alter database "altered_database!'2" rename to altered_database_renamed;
alter database altered_database_renamed rename to "altered_database!'2"; alter database altered_database_renamed rename to "altered_database!'2";
alter database "altered_database!'2" with alter database "altered_database!'2" with
ALLOW_CONNECTIONS true ALLOW_CONNECTIONS true
CONNECTION LIMIT 0 CONNECTION LIMIT 0
IS_TEMPLATE false; 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 \c regression - - :worker_2_port
set citus.log_remote_commands = true; set citus.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; set citus.grep_remote_commands = "%ALTER DATABASE%";
@ -102,16 +138,18 @@ alter database "altered_database!'2" with
ALLOW_CONNECTIONS false ALLOW_CONNECTIONS false
CONNECTION LIMIT 1 CONNECTION LIMIT 1
IS_TEMPLATE true; 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 alter database "altered_database!'2" with
ALLOW_CONNECTIONS true ALLOW_CONNECTIONS true
CONNECTION LIMIT 0 CONNECTION LIMIT 0
IS_TEMPLATE false; IS_TEMPLATE false;
\c regression \c regression
create role test_owner_non_main_db; 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.grep_remote_commands = "%ALTER DATABASE%";
set citus.enable_create_database_propagation=on; set citus.enable_create_database_propagation=on;
alter database "altered_database!'2" owner to test_owner_non_main_db; 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 \c test_alter_db_from_nonmain_db - - :worker_1_port
set citus.log_remote_commands = true; set citus.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; set citus.grep_remote_commands = "%ALTER DATABASE%";
alter database "altered_database!'2" owner to CURRENT_USER; alter database "altered_database!'2" owner to CURRENT_USER;
set default_transaction_read_only = false; 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 \c regression - - :worker_1_port
set citus.log_remote_commands = true; set citus.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; set citus.grep_remote_commands = "%ALTER DATABASE%";
alter database "altered_database!'2" owner to test_owner_non_main_db; alter database "altered_database!'2" owner to test_owner_non_main_db;
set default_transaction_read_only = false; 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 \c regression - - :master_port
set citus.log_remote_commands = true; set citus.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; set citus.grep_remote_commands = "%ALTER DATABASE%";
alter database "altered_database!'2" owner to CURRENT_USER; alter database "altered_database!'2" owner to CURRENT_USER;
set default_transaction_read_only = false; 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 \c test_alter_db_from_nonmain_db - - :worker_2_port
set citus.log_remote_commands = true; set citus.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; 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 log_duration from current;
alter database "altered_database!'2" set default_transaction_read_only to DEFAULT; alter database "altered_database!'2" set log_duration to DEFAULT;
alter database "altered_database!'2" RESET default_transaction_read_only; alter database "altered_database!'2" set log_duration = true;
alter database "altered_database!'2" SET TIME ZONE '-7'; \c "altered_database!'2" - - :master_port
alter database "altered_database!'2" set TIME ZONE LOCAL; 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.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; set citus.grep_remote_commands = "%ALTER DATABASE%";
alter database "altered_database!'2" set TIME ZONE DEFAULT; alter database "altered_database!'2" RESET log_duration;
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; \c "altered_database!'2" - - :master_port
alter database "altered_database!'2" set default_transaction_isolation = 'serializable'; 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 \c regression - - :worker_2_port
set citus.log_remote_commands = true; set citus.log_remote_commands = true;
set citus.grep_remote_commands = "%ALTER DATABASE%"; 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; 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" set statement_timeout to DEFAULT;
alter database "altered_database!'2" RESET statement_timeout; alter database "altered_database!'2" RESET statement_timeout;
alter database "altered_database!'2" set lock_timeout = 1201.5;
set lock_timeout = 1202.5; \c "altered_database!'2" - - :master_port
alter database "altered_database!'2" set lock_timeout from current; select name,setting from pg_settings
alter database "altered_database!'2" set lock_timeout to DEFAULT; where name ='statement_timeout';
alter database "altered_database!'2" RESET lock_timeout; \c "altered_database!'2" - - :worker_1_port
ALTER DATABASE "altered_database!'2" RESET ALL; 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 \c regression
set citus.enable_create_database_propagation=on; set citus.enable_create_database_propagation=on;