20
20
$node_subscriber -> start;
21
21
22
22
my $publisher_connstr = $node_publisher -> connstr . ' dbname=postgres' ;
23
- my $offset = 0;
23
+ my $offset = 0;
24
24
25
25
sub wait_for_subscription_sync
26
26
{
@@ -1169,13 +1169,15 @@ sub wait_for_subscription_sync
1169
1169
# TEST: With a table included in multiple publications with different column
1170
1170
# lists, we should catch the error when creating the subscription.
1171
1171
1172
- $node_publisher -> safe_psql(' postgres' , qq(
1172
+ $node_publisher -> safe_psql(
1173
+ ' postgres' , qq(
1173
1174
CREATE TABLE test_mix_1 (a int PRIMARY KEY, b int, c int);
1174
1175
CREATE PUBLICATION pub_mix_1 FOR TABLE test_mix_1 (a, b);
1175
1176
CREATE PUBLICATION pub_mix_2 FOR TABLE test_mix_1 (a, c);
1176
1177
) );
1177
1178
1178
- $node_subscriber -> safe_psql(' postgres' , qq(
1179
+ $node_subscriber -> safe_psql(
1180
+ ' postgres' , qq(
1179
1181
DROP SUBSCRIPTION sub1;
1180
1182
CREATE TABLE test_mix_1 (a int PRIMARY KEY, b int, c int);
1181
1183
) );
@@ -1192,17 +1194,20 @@ sub wait_for_subscription_sync
1192
1194
# TEST: If the column list is changed after creating the subscription, we
1193
1195
# should catch the error reported by walsender.
1194
1196
1195
- $node_publisher -> safe_psql(' postgres' , qq(
1197
+ $node_publisher -> safe_psql(
1198
+ ' postgres' , qq(
1196
1199
ALTER PUBLICATION pub_mix_1 SET TABLE test_mix_1 (a, c);
1197
1200
) );
1198
1201
1199
- $node_subscriber -> safe_psql(' postgres' , qq(
1202
+ $node_subscriber -> safe_psql(
1203
+ ' postgres' , qq(
1200
1204
CREATE SUBSCRIPTION sub1 CONNECTION '$publisher_connstr ' PUBLICATION pub_mix_1, pub_mix_2;
1201
1205
) );
1202
1206
1203
1207
$node_publisher -> wait_for_catchup(' sub1' );
1204
1208
1205
- $node_publisher -> safe_psql(' postgres' , qq(
1209
+ $node_publisher -> safe_psql(
1210
+ ' postgres' , qq(
1206
1211
ALTER PUBLICATION pub_mix_1 SET TABLE test_mix_1 (a, b);
1207
1212
INSERT INTO test_mix_1 VALUES(1, 1, 1);
1208
1213
) );
0 commit comments