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

Adds follower ddl propagation

pull/7563/head
gurkanindibay 2024-03-25 13:16:41 +03:00
parent c049b5159f
commit 35c808e120
2 changed files with 37 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/test/regress/expected/multi_follower_sanity_check.out
View File

@ -22,6 +22,30 @@ SELECT pg_reload_conf();
t t
(1 row) (1 row)
\c - - - :follower_master_port
ALTER SYSTEM SET citus.enable_ddl_propagation = 'true';
SELECT pg_reload_conf();
pg_reload_conf
---------------------------------------------------------------------
t
(1 row)
\c - - - :follower_worker_1_port
ALTER SYSTEM SET citus.enable_ddl_propagation = 'true';
SELECT pg_reload_conf();
pg_reload_conf
---------------------------------------------------------------------
t
(1 row)
\c - - - :follower_worker_2_port
ALTER SYSTEM SET citus.enable_ddl_propagation = 'true';
SELECT pg_reload_conf();
pg_reload_conf
---------------------------------------------------------------------
t
(1 row)
\c - - - :follower_master_port \c - - - :follower_master_port
CREATE TABLE tab (a int); CREATE TABLE tab (a int);
ERROR: cannot execute CREATE TABLE in a read-only transaction ERROR: cannot execute CREATE TABLE in a read-only transaction

13
src/test/regress/sql/multi_follower_sanity_check.sql
View File

@ -10,6 +10,19 @@ SELECT pg_reload_conf();
ALTER SYSTEM SET citus.enable_ddl_propagation = 'true'; ALTER SYSTEM SET citus.enable_ddl_propagation = 'true';
SELECT pg_reload_conf(); SELECT pg_reload_conf();
\c - - - :follower_master_port
ALTER SYSTEM SET citus.enable_ddl_propagation = 'true';
SELECT pg_reload_conf();
\c - - - :follower_worker_1_port
ALTER SYSTEM SET citus.enable_ddl_propagation = 'true';
SELECT pg_reload_conf();
\c - - - :follower_worker_2_port
ALTER SYSTEM SET citus.enable_ddl_propagation = 'true';
SELECT pg_reload_conf();
\c - - - :follower_master_port \c - - - :follower_master_port
CREATE TABLE tab (a int); CREATE TABLE tab (a int);
\c - - - :follower_worker_1_port \c - - - :follower_worker_1_port