mirror of https://github.com/citusdata/citus.git
Moves pg15 tests
gindibay
parent
66b433310c
commit
93dab80206
|
|
@ -34,6 +34,7 @@ test: alter_database_owner
|
||||||
test: distributed_triggers
|
test: distributed_triggers
|
||||||
test: create_single_shard_table
|
test: create_single_shard_table
|
||||||
test: create_drop_database_propagation
|
test: create_drop_database_propagation
|
||||||
|
test: pg15_create_drop_database_propagation
|
||||||
|
|
||||||
# don't parallelize single_shard_table_udfs to make sure colocation ids are sequential
|
# don't parallelize single_shard_table_udfs to make sure colocation ids are sequential
|
||||||
test: single_shard_table_udfs
|
test: single_shard_table_udfs
|
||||||
|
|
|
||||||
|
|
@ -976,230 +976,3 @@ SET client_min_messages TO ERROR;
|
||||||
DROP SCHEMA pg15 CASCADE;
|
DROP SCHEMA pg15 CASCADE;
|
||||||
DROP ROLE rls_tenant_1;
|
DROP ROLE rls_tenant_1;
|
||||||
DROP ROLE rls_tenant_2;
|
DROP ROLE rls_tenant_2;
|
||||||
|
|
||||||
|
|
||||||
-- create/drop database for pg > 15
|
|
||||||
|
|
||||||
|
|
||||||
\set create_drop_db_tablespace :abs_srcdir '/tmp_check/ts3'
|
|
||||||
CREATE TABLESPACE create_drop_db_tablespace LOCATION :'create_drop_db_tablespace';
|
|
||||||
|
|
||||||
\c - - - :worker_1_port
|
|
||||||
\set create_drop_db_tablespace :abs_srcdir '/tmp_check/ts4'
|
|
||||||
CREATE TABLESPACE create_drop_db_tablespace LOCATION :'create_drop_db_tablespace';
|
|
||||||
|
|
||||||
\c - - - :worker_2_port
|
|
||||||
\set create_drop_db_tablespace :abs_srcdir '/tmp_check/ts5'
|
|
||||||
CREATE TABLESPACE create_drop_db_tablespace LOCATION :'create_drop_db_tablespace';
|
|
||||||
|
|
||||||
\c - - - :master_port
|
|
||||||
create user create_drop_db_test_user;
|
|
||||||
set citus.enable_create_database_propagation=on;
|
|
||||||
SET citus.log_remote_commands = true;
|
|
||||||
set citus.grep_remote_commands = '%CREATE DATABASE%';
|
|
||||||
CREATE DATABASE mydatabase
|
|
||||||
WITH TEMPLATE = 'template0'
|
|
||||||
OWNER = create_drop_db_test_user
|
|
||||||
CONNECTION LIMIT = 10
|
|
||||||
ENCODING = 'UTF8'
|
|
||||||
STRATEGY = 'wal_log'
|
|
||||||
LOCALE = ''
|
|
||||||
LC_COLLATE = 'POSIX'
|
|
||||||
LC_CTYPE = 'POSIX'
|
|
||||||
ICU_LOCALE = 'und'
|
|
||||||
LOCALE_PROVIDER = 'icu'
|
|
||||||
COLLATION_VERSION = '1.0'
|
|
||||||
TABLESPACE = create_drop_db_tablespace
|
|
||||||
ALLOW_CONNECTIONS = true
|
|
||||||
IS_TEMPLATE = false
|
|
||||||
OID = 966345;
|
|
||||||
|
|
||||||
SELECT result from run_command_on_all_nodes(
|
|
||||||
$$
|
|
||||||
SELECT jsonb_agg(to_jsonb(q2.*)) FROM (
|
|
||||||
SELECT pd.datname, pg_encoding_to_char(pd.encoding) as encoding,
|
|
||||||
pd.datistemplate, pd.datallowconn, pd.datconnlimit,
|
|
||||||
pd.datcollate , pd. datctype , pd.datacl,
|
|
||||||
pa.rolname AS database_owner, pt.spcname AS tablespace
|
|
||||||
FROM pg_database pd
|
|
||||||
JOIN pg_authid pa ON pd.datdba = pa.oid
|
|
||||||
join pg_tablespace pt on pd.dattablespace = pt.oid
|
|
||||||
WHERE datname = 'mydatabase'
|
|
||||||
) q2
|
|
||||||
$$
|
|
||||||
) ORDER BY result;
|
|
||||||
|
|
||||||
|
|
||||||
drop database mydatabase;
|
|
||||||
|
|
||||||
SELECT result from run_command_on_all_nodes(
|
|
||||||
$$
|
|
||||||
SELECT jsonb_agg(to_jsonb(q2.*)) FROM (
|
|
||||||
SELECT pd.datname, pg_encoding_to_char(pd.encoding) as encoding,
|
|
||||||
pd.datistemplate, pd.datallowconn, pd.datconnlimit,
|
|
||||||
pd.datcollate , pd. datctype , pd.datacl,
|
|
||||||
pa.rolname AS database_owner, pt.spcname AS tablespace
|
|
||||||
FROM pg_database pd
|
|
||||||
JOIN pg_authid pa ON pd.datdba = pa.oid
|
|
||||||
join pg_tablespace pt on pd.dattablespace = pt.oid
|
|
||||||
WHERE datname = 'mydatabase'
|
|
||||||
) q2
|
|
||||||
$$
|
|
||||||
) ORDER BY result;
|
|
||||||
|
|
||||||
select citus_remove_node('localhost', :worker_2_port);
|
|
||||||
|
|
||||||
|
|
||||||
SET citus.log_remote_commands = true;
|
|
||||||
set citus.grep_remote_commands = '%CREATE DATABASE%';
|
|
||||||
|
|
||||||
CREATE DATABASE mydatabase2
|
|
||||||
WITH OWNER = create_drop_db_test_user
|
|
||||||
ENCODING = 'UTF8'
|
|
||||||
STRATEGY = 'wal_log'
|
|
||||||
LOCALE = 'en_US.utf8'
|
|
||||||
LC_COLLATE = 'POSIX'
|
|
||||||
LC_CTYPE = 'POSIX'
|
|
||||||
COLLATION_VERSION = '1.0'
|
|
||||||
TABLESPACE = create_drop_db_tablespace
|
|
||||||
ALLOW_CONNECTIONS = true
|
|
||||||
IS_TEMPLATE = false
|
|
||||||
OID = 966345;
|
|
||||||
|
|
||||||
SET citus.log_remote_commands = false;
|
|
||||||
SELECT result from run_command_on_all_nodes(
|
|
||||||
$$
|
|
||||||
SELECT jsonb_agg(to_jsonb(q2.*)) FROM (
|
|
||||||
SELECT pd.datname, pg_encoding_to_char(pd.encoding) as encoding,
|
|
||||||
pd.datistemplate, pd.datallowconn, pd.datconnlimit,
|
|
||||||
pd.datcollate , pd. datctype , pd.datacl,
|
|
||||||
pa.rolname AS database_owner, pt.spcname AS tablespace
|
|
||||||
FROM pg_database pd
|
|
||||||
JOIN pg_authid pa ON pd.datdba = pa.oid
|
|
||||||
join pg_tablespace pt on pd.dattablespace = pt.oid
|
|
||||||
WHERE datname = 'mydatabase2'
|
|
||||||
) q2
|
|
||||||
$$
|
|
||||||
) ORDER BY result;
|
|
||||||
|
|
||||||
|
|
||||||
SET citus.log_remote_commands = true;
|
|
||||||
select 1 from citus_add_node('localhost', :worker_2_port);
|
|
||||||
|
|
||||||
SET citus.log_remote_commands = false;
|
|
||||||
SELECT result from run_command_on_all_nodes(
|
|
||||||
$$
|
|
||||||
SELECT jsonb_agg(to_jsonb(q2.*)) FROM (
|
|
||||||
SELECT pd.datname, pg_encoding_to_char(pd.encoding) as encoding,
|
|
||||||
pd.datistemplate, pd.datallowconn, pd.datconnlimit,
|
|
||||||
pd.datcollate , pd. datctype , pd.datacl,
|
|
||||||
pa.rolname AS database_owner, pt.spcname AS tablespace
|
|
||||||
FROM pg_database pd
|
|
||||||
JOIN pg_authid pa ON pd.datdba = pa.oid
|
|
||||||
join pg_tablespace pt on pd.dattablespace = pt.oid
|
|
||||||
WHERE datname = 'mydatabase2'
|
|
||||||
) q2
|
|
||||||
$$
|
|
||||||
) ORDER BY result;
|
|
||||||
|
|
||||||
SET citus.log_remote_commands = true;
|
|
||||||
set citus.grep_remote_commands = '%DROP DATABASE%';
|
|
||||||
drop database mydatabase2;
|
|
||||||
|
|
||||||
SET citus.log_remote_commands = false;
|
|
||||||
|
|
||||||
SELECT result from run_command_on_all_nodes(
|
|
||||||
$$
|
|
||||||
SELECT jsonb_agg(to_jsonb(q2.*)) FROM (
|
|
||||||
SELECT pd.datname, pg_encoding_to_char(pd.encoding) as encoding,
|
|
||||||
pd.datistemplate, pd.datallowconn, pd.datconnlimit,
|
|
||||||
pd.datcollate , pd. datctype , pd.datacl,
|
|
||||||
pa.rolname AS database_owner, pt.spcname AS tablespace
|
|
||||||
FROM pg_database pd
|
|
||||||
JOIN pg_authid pa ON pd.datdba = pa.oid
|
|
||||||
join pg_tablespace pt on pd.dattablespace = pt.oid
|
|
||||||
WHERE datname = 'mydatabase'
|
|
||||||
) q2
|
|
||||||
$$
|
|
||||||
) ORDER BY result;
|
|
||||||
|
|
||||||
SET citus.log_remote_commands = true;
|
|
||||||
set citus.grep_remote_commands = '%CREATE DATABASE%';
|
|
||||||
|
|
||||||
-- create a template database with all options set and allow connections false
|
|
||||||
CREATE DATABASE my_template_database
|
|
||||||
WITH TEMPLATE = 'template0'
|
|
||||||
OWNER = create_drop_db_test_user
|
|
||||||
ENCODING = 'UTF8'
|
|
||||||
STRATEGY = 'wal_log'
|
|
||||||
LOCALE = 'en_US.utf8'
|
|
||||||
LC_COLLATE = 'POSIX'
|
|
||||||
LC_CTYPE = 'POSIX'
|
|
||||||
ICU_LOCALE = 'en-US'
|
|
||||||
LOCALE_PROVIDER = 'icu'
|
|
||||||
COLLATION_VERSION = '1.0'
|
|
||||||
TABLESPACE = create_drop_db_tablespace
|
|
||||||
ALLOW_CONNECTIONS = false
|
|
||||||
IS_TEMPLATE = true;
|
|
||||||
|
|
||||||
SET citus.log_remote_commands = false;
|
|
||||||
|
|
||||||
SELECT result from run_command_on_all_nodes(
|
|
||||||
$$
|
|
||||||
SELECT jsonb_agg(to_jsonb(q2.*)) FROM (
|
|
||||||
SELECT pd.datname, pg_encoding_to_char(pd.encoding) as encoding,
|
|
||||||
pd.datistemplate, pd.datallowconn, pd.datconnlimit,
|
|
||||||
pd.datcollate , pd. datctype , pd.datacl,
|
|
||||||
pa.rolname AS database_owner, pt.spcname AS tablespace
|
|
||||||
FROM pg_database pd
|
|
||||||
JOIN pg_authid pa ON pd.datdba = pa.oid
|
|
||||||
join pg_tablespace pt on pd.dattablespace = pt.oid
|
|
||||||
WHERE datname = 'my_template_database'
|
|
||||||
) q2
|
|
||||||
$$
|
|
||||||
) ORDER BY result;
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
SET citus.log_remote_commands = true;
|
|
||||||
|
|
||||||
--template databases could not be dropped so we need to change the template flag
|
|
||||||
SELECT result from run_command_on_all_nodes(
|
|
||||||
$$
|
|
||||||
UPDATE pg_database SET datistemplate = false WHERE datname = 'my_template_database'
|
|
||||||
$$
|
|
||||||
) ORDER BY result;
|
|
||||||
|
|
||||||
;
|
|
||||||
|
|
||||||
set citus.grep_remote_commands = '%DROP DATABASE%';
|
|
||||||
drop database my_template_database;
|
|
||||||
|
|
||||||
SET citus.log_remote_commands = false;
|
|
||||||
SELECT result from run_command_on_all_nodes(
|
|
||||||
$$
|
|
||||||
SELECT jsonb_agg(to_jsonb(q2.*)) FROM (
|
|
||||||
SELECT pd.datname, pg_encoding_to_char(pd.encoding) as encoding,
|
|
||||||
pd.datistemplate, pd.datallowconn, pd.datconnlimit,
|
|
||||||
pd.datcollate , pd. datctype , pd.datacl,
|
|
||||||
pa.rolname AS database_owner, pt.spcname AS tablespace
|
|
||||||
FROM pg_database pd
|
|
||||||
JOIN pg_authid pa ON pd.datdba = pa.oid
|
|
||||||
join pg_tablespace pt on pd.dattablespace = pt.oid
|
|
||||||
WHERE datname = 'my_template_database'
|
|
||||||
) q2
|
|
||||||
$$
|
|
||||||
) ORDER BY result;
|
|
||||||
|
|
||||||
|
|
||||||
\c - - - :master_port
|
|
||||||
drop tablespace create_drop_db_tablespace;
|
|
||||||
|
|
||||||
\c - - - :worker_1_port
|
|
||||||
drop tablespace create_drop_db_tablespace;
|
|
||||||
|
|
||||||
\c - - - :worker_2_port
|
|
||||||
drop tablespace create_drop_db_tablespace;
|
|
||||||
|
|
||||||
\c - - - :master_port
|
|
||||||
drop user create_drop_db_test_user;
|
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,235 @@
|
||||||
|
--
|
||||||
|
-- PG15
|
||||||
|
--
|
||||||
|
SHOW server_version \gset
|
||||||
|
SELECT substring(:'server_version', '\d+')::int >= 15 AS server_version_ge_15
|
||||||
|
\gset
|
||||||
|
\if :server_version_ge_15
|
||||||
|
\else
|
||||||
|
\q
|
||||||
|
|
||||||
|
-- create/drop database for pg > 15
|
||||||
|
|
||||||
|
|
||||||
|
\set create_drop_db_tablespace :abs_srcdir '/tmp_check/ts3'
|
||||||
|
CREATE TABLESPACE create_drop_db_tablespace LOCATION :'create_drop_db_tablespace';
|
||||||
|
|
||||||
|
\c - - - :worker_1_port
|
||||||
|
\set create_drop_db_tablespace :abs_srcdir '/tmp_check/ts4'
|
||||||
|
CREATE TABLESPACE create_drop_db_tablespace LOCATION :'create_drop_db_tablespace';
|
||||||
|
|
||||||
|
\c - - - :worker_2_port
|
||||||
|
\set create_drop_db_tablespace :abs_srcdir '/tmp_check/ts5'
|
||||||
|
CREATE TABLESPACE create_drop_db_tablespace LOCATION :'create_drop_db_tablespace';
|
||||||
|
|
||||||
|
\c - - - :master_port
|
||||||
|
create user create_drop_db_test_user;
|
||||||
|
set citus.enable_create_database_propagation=on;
|
||||||
|
SET citus.log_remote_commands = true;
|
||||||
|
set citus.grep_remote_commands = '%CREATE DATABASE%';
|
||||||
|
CREATE DATABASE mydatabase
|
||||||
|
WITH TEMPLATE = 'template0'
|
||||||
|
OWNER = create_drop_db_test_user
|
||||||
|
CONNECTION LIMIT = 10
|
||||||
|
ENCODING = 'UTF8'
|
||||||
|
STRATEGY = 'wal_log'
|
||||||
|
LOCALE = ''
|
||||||
|
LC_COLLATE = 'POSIX'
|
||||||
|
LC_CTYPE = 'POSIX'
|
||||||
|
ICU_LOCALE = 'und'
|
||||||
|
LOCALE_PROVIDER = 'icu'
|
||||||
|
COLLATION_VERSION = '1.0'
|
||||||
|
TABLESPACE = create_drop_db_tablespace
|
||||||
|
ALLOW_CONNECTIONS = true
|
||||||
|
IS_TEMPLATE = false
|
||||||
|
OID = 966345;
|
||||||
|
|
||||||
|
SELECT result from run_command_on_all_nodes(
|
||||||
|
$$
|
||||||
|
SELECT jsonb_agg(to_jsonb(q2.*)) FROM (
|
||||||
|
SELECT pd.datname, pg_encoding_to_char(pd.encoding) as encoding,
|
||||||
|
pd.datistemplate, pd.datallowconn, pd.datconnlimit,
|
||||||
|
pd.datcollate , pd. datctype , pd.datacl,
|
||||||
|
pa.rolname AS database_owner, pt.spcname AS tablespace
|
||||||
|
FROM pg_database pd
|
||||||
|
JOIN pg_authid pa ON pd.datdba = pa.oid
|
||||||
|
join pg_tablespace pt on pd.dattablespace = pt.oid
|
||||||
|
WHERE datname = 'mydatabase'
|
||||||
|
) q2
|
||||||
|
$$
|
||||||
|
) ORDER BY result;
|
||||||
|
|
||||||
|
|
||||||
|
drop database mydatabase;
|
||||||
|
|
||||||
|
SELECT result from run_command_on_all_nodes(
|
||||||
|
$$
|
||||||
|
SELECT jsonb_agg(to_jsonb(q2.*)) FROM (
|
||||||
|
SELECT pd.datname, pg_encoding_to_char(pd.encoding) as encoding,
|
||||||
|
pd.datistemplate, pd.datallowconn, pd.datconnlimit,
|
||||||
|
pd.datcollate , pd. datctype , pd.datacl,
|
||||||
|
pa.rolname AS database_owner, pt.spcname AS tablespace
|
||||||
|
FROM pg_database pd
|
||||||
|
JOIN pg_authid pa ON pd.datdba = pa.oid
|
||||||
|
join pg_tablespace pt on pd.dattablespace = pt.oid
|
||||||
|
WHERE datname = 'mydatabase'
|
||||||
|
) q2
|
||||||
|
$$
|
||||||
|
) ORDER BY result;
|
||||||
|
|
||||||
|
select citus_remove_node('localhost', :worker_2_port);
|
||||||
|
|
||||||
|
|
||||||
|
SET citus.log_remote_commands = true;
|
||||||
|
set citus.grep_remote_commands = '%CREATE DATABASE%';
|
||||||
|
|
||||||
|
CREATE DATABASE mydatabase2
|
||||||
|
WITH OWNER = create_drop_db_test_user
|
||||||
|
ENCODING = 'UTF8'
|
||||||
|
STRATEGY = 'wal_log'
|
||||||
|
LOCALE = 'en_US.utf8'
|
||||||
|
LC_COLLATE = 'POSIX'
|
||||||
|
LC_CTYPE = 'POSIX'
|
||||||
|
COLLATION_VERSION = '1.0'
|
||||||
|
TABLESPACE = create_drop_db_tablespace
|
||||||
|
ALLOW_CONNECTIONS = true
|
||||||
|
IS_TEMPLATE = false
|
||||||
|
OID = 966345;
|
||||||
|
|
||||||
|
SET citus.log_remote_commands = false;
|
||||||
|
SELECT result from run_command_on_all_nodes(
|
||||||
|
$$
|
||||||
|
SELECT jsonb_agg(to_jsonb(q2.*)) FROM (
|
||||||
|
SELECT pd.datname, pg_encoding_to_char(pd.encoding) as encoding,
|
||||||
|
pd.datistemplate, pd.datallowconn, pd.datconnlimit,
|
||||||
|
pd.datcollate , pd. datctype , pd.datacl,
|
||||||
|
pa.rolname AS database_owner, pt.spcname AS tablespace
|
||||||
|
FROM pg_database pd
|
||||||
|
JOIN pg_authid pa ON pd.datdba = pa.oid
|
||||||
|
join pg_tablespace pt on pd.dattablespace = pt.oid
|
||||||
|
WHERE datname = 'mydatabase2'
|
||||||
|
) q2
|
||||||
|
$$
|
||||||
|
) ORDER BY result;
|
||||||
|
|
||||||
|
|
||||||
|
SET citus.log_remote_commands = true;
|
||||||
|
select 1 from citus_add_node('localhost', :worker_2_port);
|
||||||
|
|
||||||
|
SET citus.log_remote_commands = false;
|
||||||
|
SELECT result from run_command_on_all_nodes(
|
||||||
|
$$
|
||||||
|
SELECT jsonb_agg(to_jsonb(q2.*)) FROM (
|
||||||
|
SELECT pd.datname, pg_encoding_to_char(pd.encoding) as encoding,
|
||||||
|
pd.datistemplate, pd.datallowconn, pd.datconnlimit,
|
||||||
|
pd.datcollate , pd. datctype , pd.datacl,
|
||||||
|
pa.rolname AS database_owner, pt.spcname AS tablespace
|
||||||
|
FROM pg_database pd
|
||||||
|
JOIN pg_authid pa ON pd.datdba = pa.oid
|
||||||
|
join pg_tablespace pt on pd.dattablespace = pt.oid
|
||||||
|
WHERE datname = 'mydatabase2'
|
||||||
|
) q2
|
||||||
|
$$
|
||||||
|
) ORDER BY result;
|
||||||
|
|
||||||
|
SET citus.log_remote_commands = true;
|
||||||
|
set citus.grep_remote_commands = '%DROP DATABASE%';
|
||||||
|
drop database mydatabase2;
|
||||||
|
|
||||||
|
SET citus.log_remote_commands = false;
|
||||||
|
|
||||||
|
SELECT result from run_command_on_all_nodes(
|
||||||
|
$$
|
||||||
|
SELECT jsonb_agg(to_jsonb(q2.*)) FROM (
|
||||||
|
SELECT pd.datname, pg_encoding_to_char(pd.encoding) as encoding,
|
||||||
|
pd.datistemplate, pd.datallowconn, pd.datconnlimit,
|
||||||
|
pd.datcollate , pd. datctype , pd.datacl,
|
||||||
|
pa.rolname AS database_owner, pt.spcname AS tablespace
|
||||||
|
FROM pg_database pd
|
||||||
|
JOIN pg_authid pa ON pd.datdba = pa.oid
|
||||||
|
join pg_tablespace pt on pd.dattablespace = pt.oid
|
||||||
|
WHERE datname = 'mydatabase'
|
||||||
|
) q2
|
||||||
|
$$
|
||||||
|
) ORDER BY result;
|
||||||
|
|
||||||
|
SET citus.log_remote_commands = true;
|
||||||
|
set citus.grep_remote_commands = '%CREATE DATABASE%';
|
||||||
|
|
||||||
|
-- create a template database with all options set and allow connections false
|
||||||
|
CREATE DATABASE my_template_database
|
||||||
|
WITH TEMPLATE = 'template0'
|
||||||
|
OWNER = create_drop_db_test_user
|
||||||
|
ENCODING = 'UTF8'
|
||||||
|
STRATEGY = 'wal_log'
|
||||||
|
LOCALE = 'en_US.utf8'
|
||||||
|
LC_COLLATE = 'POSIX'
|
||||||
|
LC_CTYPE = 'POSIX'
|
||||||
|
ICU_LOCALE = 'en-US'
|
||||||
|
LOCALE_PROVIDER = 'icu'
|
||||||
|
COLLATION_VERSION = '1.0'
|
||||||
|
TABLESPACE = create_drop_db_tablespace
|
||||||
|
ALLOW_CONNECTIONS = false
|
||||||
|
IS_TEMPLATE = true;
|
||||||
|
|
||||||
|
SET citus.log_remote_commands = false;
|
||||||
|
|
||||||
|
SELECT result from run_command_on_all_nodes(
|
||||||
|
$$
|
||||||
|
SELECT jsonb_agg(to_jsonb(q2.*)) FROM (
|
||||||
|
SELECT pd.datname, pg_encoding_to_char(pd.encoding) as encoding,
|
||||||
|
pd.datistemplate, pd.datallowconn, pd.datconnlimit,
|
||||||
|
pd.datcollate , pd. datctype , pd.datacl,
|
||||||
|
pa.rolname AS database_owner, pt.spcname AS tablespace
|
||||||
|
FROM pg_database pd
|
||||||
|
JOIN pg_authid pa ON pd.datdba = pa.oid
|
||||||
|
join pg_tablespace pt on pd.dattablespace = pt.oid
|
||||||
|
WHERE datname = 'my_template_database'
|
||||||
|
) q2
|
||||||
|
$$
|
||||||
|
) ORDER BY result;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
SET citus.log_remote_commands = true;
|
||||||
|
|
||||||
|
--template databases could not be dropped so we need to change the template flag
|
||||||
|
SELECT result from run_command_on_all_nodes(
|
||||||
|
$$
|
||||||
|
UPDATE pg_database SET datistemplate = false WHERE datname = 'my_template_database'
|
||||||
|
$$
|
||||||
|
) ORDER BY result;
|
||||||
|
|
||||||
|
;
|
||||||
|
|
||||||
|
set citus.grep_remote_commands = '%DROP DATABASE%';
|
||||||
|
drop database my_template_database;
|
||||||
|
|
||||||
|
SET citus.log_remote_commands = false;
|
||||||
|
SELECT result from run_command_on_all_nodes(
|
||||||
|
$$
|
||||||
|
SELECT jsonb_agg(to_jsonb(q2.*)) FROM (
|
||||||
|
SELECT pd.datname, pg_encoding_to_char(pd.encoding) as encoding,
|
||||||
|
pd.datistemplate, pd.datallowconn, pd.datconnlimit,
|
||||||
|
pd.datcollate , pd. datctype , pd.datacl,
|
||||||
|
pa.rolname AS database_owner, pt.spcname AS tablespace
|
||||||
|
FROM pg_database pd
|
||||||
|
JOIN pg_authid pa ON pd.datdba = pa.oid
|
||||||
|
join pg_tablespace pt on pd.dattablespace = pt.oid
|
||||||
|
WHERE datname = 'my_template_database'
|
||||||
|
) q2
|
||||||
|
$$
|
||||||
|
) ORDER BY result;
|
||||||
|
|
||||||
|
|
||||||
|
\c - - - :master_port
|
||||||
|
drop tablespace create_drop_db_tablespace;
|
||||||
|
|
||||||
|
\c - - - :worker_1_port
|
||||||
|
drop tablespace create_drop_db_tablespace;
|
||||||
|
|
||||||
|
\c - - - :worker_2_port
|
||||||
|
drop tablespace create_drop_db_tablespace;
|
||||||
|
|
||||||
|
\c - - - :master_port
|
||||||
|
drop user create_drop_db_test_user;
|
||||||
Loading…
Reference in New Issue