Skip to content

Commit 5df29c3

Browse files
committed
Fix the test output
1 parent 347ecc7 commit 5df29c3

File tree

2 files changed

+24
-10
lines changed

2 files changed

+24
-10
lines changed

expected/bidirectional.out

Lines changed: 19 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -108,22 +108,33 @@ NOTICE: drop cascades to 1 other object
108108
t
109109
(1 row)
110110

111+
SELECT slot_name FROM pg_replication_slots WHERE database = current_database();
112+
slot_name
113+
--------------------------------------------
114+
pgl_postgres_test_provider_test_sube55bf37
115+
(1 row)
116+
117+
SELECT count(*) FROM pg_stat_replication WHERE application_name = 'test_bidirectional';
118+
count
119+
-------
120+
1
121+
(1 row)
122+
111123
SELECT pglogical.drop_subscription('test_bidirectional');
112124
drop_subscription
113125
-------------------
114126
1
115127
(1 row)
116128

117129
\c :subscriber_dsn
118-
SELECT count(1) FROM pg_stat_replication;
130+
SELECT slot_name FROM pg_replication_slots WHERE database = current_database();
131+
slot_name
132+
-----------
133+
(0 rows)
134+
135+
SELECT count(*) FROM pg_stat_replication WHERE application_name = 'test_bidirectional';
119136
count
120137
-------
121-
1
122-
(1 row)
123-
124-
SELECT slot_name FROM pg_replication_slots;
125-
slot_name
126-
--------------------------------------------
127-
pgl_postgres_test_provider_test_sube55bf37
138+
0
128139
(1 row)
129140

sql/bidirectional.sql

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -65,9 +65,12 @@ SELECT pglogical.replicate_ddl_command($$
6565
DROP TABLE public.basic_dml CASCADE;
6666
$$);
6767

68+
SELECT slot_name FROM pg_replication_slots WHERE database = current_database();
69+
SELECT count(*) FROM pg_stat_replication WHERE application_name = 'test_bidirectional';
70+
6871
SELECT pglogical.drop_subscription('test_bidirectional');
6972

7073
\c :subscriber_dsn
7174

72-
SELECT count(1) FROM pg_stat_replication;
73-
SELECT slot_name FROM pg_replication_slots;
75+
SELECT slot_name FROM pg_replication_slots WHERE database = current_database();
76+
SELECT count(*) FROM pg_stat_replication WHERE application_name = 'test_bidirectional';

0 commit comments

Comments
 (0)