File tree Expand file tree Collapse file tree 4 files changed +17
-13
lines changed Expand file tree Collapse file tree 4 files changed +17
-13
lines changed Original file line number Diff line number Diff line change 1
1
SELECT * FROM pglogical_regress_variables()
2
2
\gset
3
3
\c :provider_dsn
4
+ DO $$
5
+ BEGIN
6
+ IF (SELECT setting::integer/100 FROM pg_settings WHERE name = 'server_version_num') = 904 THEN
7
+ CREATE EXTENSION IF NOT EXISTS pglogical_origin;
8
+ END IF;
9
+ END;$$;
4
10
SELECT * FROM pglogical.create_subscription(
5
11
subscription_name := 'test_bidirectional',
6
12
provider_dsn := (SELECT subscriber_dsn FROM pglogical_regress_variables()) || ' user=super',
@@ -114,6 +120,8 @@ SELECT pglogical.drop_subscription('test_bidirectional');
114
120
1
115
121
(1 row)
116
122
123
+ SET client_min_messages = 'warning';
124
+ DROP EXTENSION IF EXISTS pglogical_origin;
117
125
\c :subscriber_dsn
118
126
\a
119
127
SELECT slot_name FROM pg_replication_slots WHERE database = current_database();
Original file line number Diff line number Diff line change @@ -31,12 +31,6 @@ GRANT ALL ON SCHEMA public TO nonsuper;
31
31
\c :provider_dsn
32
32
SET client_min_messages = 'warning';
33
33
CREATE EXTENSION IF NOT EXISTS pglogical;
34
- DO $$
35
- BEGIN
36
- IF (SELECT setting::integer/100 FROM pg_settings WHERE name = 'server_version_num') = 904 THEN
37
- CREATE EXTENSION IF NOT EXISTS pglogical_origin;
38
- END IF;
39
- END;$$;
40
34
SELECT * FROM pglogical.create_node(node_name := 'test_provider', dsn := (SELECT provider_dsn FROM pglogical_regress_variables()) || ' user=super');
41
35
create_node
42
36
-------------
Original file line number Diff line number Diff line change @@ -3,6 +3,12 @@ SELECT * FROM pglogical_regress_variables()
3
3
\gset
4
4
5
5
\c :provider_dsn
6
+ DO $$
7
+ BEGIN
8
+ IF (SELECT setting::integer / 100 FROM pg_settings WHERE name = ' server_version_num' ) = 904 THEN
9
+ CREATE EXTENSION IF NOT EXISTS pglogical_origin;
10
+ END IF;
11
+ END;$$;
6
12
7
13
SELECT * FROM pglogical .create_subscription (
8
14
subscription_name := ' test_bidirectional' ,
67
73
68
74
SELECT pglogical .drop_subscription (' test_bidirectional' );
69
75
76
+ SET client_min_messages = ' warning' ;
77
+ DROP EXTENSION IF EXISTS pglogical_origin;
78
+
70
79
\c :subscriber_dsn
71
80
\a
72
81
SELECT slot_name FROM pg_replication_slots WHERE database = current_database();
Original file line number Diff line number Diff line change @@ -41,13 +41,6 @@ GRANT ALL ON SCHEMA public TO nonsuper;
41
41
SET client_min_messages = ' warning' ;
42
42
CREATE EXTENSION IF NOT EXISTS pglogical;
43
43
44
- DO $$
45
- BEGIN
46
- IF (SELECT setting::integer / 100 FROM pg_settings WHERE name = ' server_version_num' ) = 904 THEN
47
- CREATE EXTENSION IF NOT EXISTS pglogical_origin;
48
- END IF;
49
- END;$$;
50
-
51
44
SELECT * FROM pglogical .create_node (node_name := ' test_provider' , dsn := (SELECT provider_dsn FROM pglogical_regress_variables()) || ' user=super' );
52
45
53
46
\c :subscriber_dsn
You can’t perform that action at this time.
0 commit comments