File tree Expand file tree Collapse file tree 2 files changed +24
-10
lines changed Expand file tree Collapse file tree 2 files changed +24
-10
lines changed Original file line number Diff line number Diff line change @@ -108,22 +108,33 @@ NOTICE: drop cascades to 1 other object
108
108
t
109
109
(1 row)
110
110
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
+
111
123
SELECT pglogical.drop_subscription('test_bidirectional');
112
124
drop_subscription
113
125
-------------------
114
126
1
115
127
(1 row)
116
128
117
129
\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';
119
136
count
120
137
-------
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
128
139
(1 row)
129
140
Original file line number Diff line number Diff line change @@ -65,9 +65,12 @@ SELECT pglogical.replicate_ddl_command($$
65
65
DROP TABLE public .basic_dml CASCADE;
66
66
$$);
67
67
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
+
68
71
SELECT pglogical .drop_subscription (' test_bidirectional' );
69
72
70
73
\c :subscriber_dsn
71
74
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 ' ;
You can’t perform that action at this time.
0 commit comments