2020$node_subscriber -> start;
2121
2222my $publisher_connstr = $node_publisher -> connstr . ' dbname=postgres' ;
23- my $offset = 0;
23+ my $offset = 0;
2424
2525sub wait_for_subscription_sync
2626{
@@ -1169,13 +1169,15 @@ sub wait_for_subscription_sync
11691169# TEST: With a table included in multiple publications with different column
11701170# lists, we should catch the error when creating the subscription.
11711171
1172- $node_publisher -> safe_psql(' postgres' , qq(
1172+ $node_publisher -> safe_psql(
1173+ ' postgres' , qq(
11731174 CREATE TABLE test_mix_1 (a int PRIMARY KEY, b int, c int);
11741175 CREATE PUBLICATION pub_mix_1 FOR TABLE test_mix_1 (a, b);
11751176 CREATE PUBLICATION pub_mix_2 FOR TABLE test_mix_1 (a, c);
11761177) );
11771178
1178- $node_subscriber -> safe_psql(' postgres' , qq(
1179+ $node_subscriber -> safe_psql(
1180+ ' postgres' , qq(
11791181 DROP SUBSCRIPTION sub1;
11801182 CREATE TABLE test_mix_1 (a int PRIMARY KEY, b int, c int);
11811183) );
@@ -1192,17 +1194,20 @@ sub wait_for_subscription_sync
11921194# TEST: If the column list is changed after creating the subscription, we
11931195# should catch the error reported by walsender.
11941196
1195- $node_publisher -> safe_psql(' postgres' , qq(
1197+ $node_publisher -> safe_psql(
1198+ ' postgres' , qq(
11961199 ALTER PUBLICATION pub_mix_1 SET TABLE test_mix_1 (a, c);
11971200) );
11981201
1199- $node_subscriber -> safe_psql(' postgres' , qq(
1202+ $node_subscriber -> safe_psql(
1203+ ' postgres' , qq(
12001204 CREATE SUBSCRIPTION sub1 CONNECTION '$publisher_connstr ' PUBLICATION pub_mix_1, pub_mix_2;
12011205) );
12021206
12031207$node_publisher -> wait_for_catchup(' sub1' );
12041208
1205- $node_publisher -> safe_psql(' postgres' , qq(
1209+ $node_publisher -> safe_psql(
1210+ ' postgres' , qq(
12061211 ALTER PUBLICATION pub_mix_1 SET TABLE test_mix_1 (a, b);
12071212 INSERT INTO test_mix_1 VALUES(1, 1, 1);
12081213) );
0 commit comments