1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
CREATE OR REPLACE FUNCTION pgl_ddl_deploy.provider_node_name(p_driver pgl_ddl_deploy.driver)
RETURNS NAME
LANGUAGE plpgsql
AS $function$
DECLARE v_node_name NAME;
BEGIN
IF p_driver = 'pglogical' THEN
SELECT n.node_name INTO v_node_name
FROM pglogical.node n
INNER JOIN pglogical.local_node ln
USING (node_id);
RETURN v_node_name;
ELSEIF p_driver = 'native' THEN
RETURN NULL::NAME;
ELSE
RAISE EXCEPTION 'Unsupported driver specified';
END IF;
END;
$function$
;
|
