Skip to content

Commit 0ad774b

Browse files
committed
Add missing tests
1 parent ca53820 commit 0ad774b

File tree

2 files changed

+62
-0
lines changed

2 files changed

+62
-0
lines changed

expected/drop.out

Lines changed: 47 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,47 @@
1+
\c regression
2+
SELECT * FROM pglogical.drop_node(node_name := 'test_provider');
3+
ERROR: cannot drop node "test_provider" because replication slot "pgl_postgres_test_provider_test_sube55bf37" on the node is still active
4+
HINT: drop the subscriptions first
5+
SELECT slot_name, plugin, slot_type, database, active FROM pg_replication_slots;
6+
slot_name | plugin | slot_type | database | active
7+
--------------------------------------------+------------------+-----------+------------+--------
8+
pgl_postgres_test_provider_test_sube55bf37 | pglogical_output | logical | regression | t
9+
(1 row)
10+
11+
SELECT count(*) FROM pg_stat_replication;
12+
count
13+
-------
14+
1
15+
(1 row)
16+
17+
\c postgres
18+
SELECT * FROM pglogical.drop_subscription('test_subscription');
19+
drop_subscription
20+
-------------------
21+
1
22+
(1 row)
23+
24+
SELECT * FROM pglogical.drop_node(node_name := 'test_subscriber');
25+
drop_node
26+
-----------
27+
t
28+
(1 row)
29+
30+
\c regression
31+
SELECT * FROM pglogical.drop_node(node_name := 'test_provider');
32+
drop_node
33+
-----------
34+
t
35+
(1 row)
36+
37+
SELECT slot_name, plugin, slot_type, database, active FROM pg_replication_slots;
38+
slot_name | plugin | slot_type | database | active
39+
-----------+--------+-----------+----------+--------
40+
(0 rows)
41+
42+
SELECT count(*) FROM pg_stat_replication;
43+
count
44+
-------
45+
0
46+
(1 row)
47+

sql/drop.sql

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
\c regression
2+
SELECT * FROM pglogical.drop_node(node_name := 'test_provider');
3+
4+
SELECT slot_name, plugin, slot_type, database, active FROM pg_replication_slots;
5+
SELECT count(*) FROM pg_stat_replication;
6+
7+
\c postgres
8+
SELECT * FROM pglogical.drop_subscription('test_subscription');
9+
SELECT * FROM pglogical.drop_node(node_name := 'test_subscriber');
10+
11+
\c regression
12+
SELECT * FROM pglogical.drop_node(node_name := 'test_provider');
13+
14+
SELECT slot_name, plugin, slot_type, database, active FROM pg_replication_slots;
15+
SELECT count(*) FROM pg_stat_replication;

0 commit comments

Comments
 (0)