bug 309 - make sure sl_failover_targets gets created when upgrading to 2.2

diff --git a/src/backend/slony1_funcs.sql b/src/backend/slony1_funcs.sql
index 1519c6f16700071b1f8b0713574fbe1d891c0fb2..e0a63f6bc0d4084a8943fa6e45258bb0d5deeec9 100644 (file)
--- a/src/backend/slony1_funcs.sql
+++ b/src/backend/slony1_funcs.sql
@@ -5493,7 +5493,60 @@ create table @NAMESPACE@.sl_components (
                      STYPE=text,
                      INITCOND=''
                      );
-       end if;             
+       end if;
+       if not exists (select 1 from information_schema.views where table_schema='_@CLUSTERNAME@_' and table_name='sl_failover_targets') then
+          create view @NAMESPACE@.sl_failover_targets as
+                 select  set_id,
+                 set_origin as set_origin,
+                 sub1.sub_receiver as backup_id
+
+                 FROM
+                 @NAMESPACE@.sl_subscribe sub1
+                 ,@NAMESPACE@.sl_set set1
+                 where
+                 sub1.sub_set=set_id
+                 and sub1.sub_forward=true
+                 --exclude candidates where the set_origin
+                 --has a path a node but the failover
+                 --candidate has no path to that node
+                 and sub1.sub_receiver not in
+                 (select p1.pa_client from
+                 @NAMESPACE@.sl_path p1 
+                 left outer join @NAMESPACE@.sl_path p2 on
+                 (p2.pa_client=p1.pa_client 
+                 and p2.pa_server=sub1.sub_receiver)
+                 where p2.pa_client is null
+                 and p1.pa_server=set_origin
+                 and p1.pa_client<>sub1.sub_receiver
+                 )
+                 and sub1.sub_provider=set_origin
+                 --exclude any subscribers that are not
+                 --direct subscribers of all sets on the
+                 --origin
+                 and sub1.sub_receiver not in
+                 (select direct_recv.sub_receiver
+                 from
+                       
+                       (--all direct receivers of the first set
+                       select subs2.sub_receiver
+                       from @NAMESPACE@.sl_subscribe subs2
+                       where subs2.sub_provider=set1.set_origin
+                       and subs2.sub_set=set1.set_id) as
+                       direct_recv
+                       inner join
+                       (--all other sets from the origin
+                       select set_id from @NAMESPACE@.sl_set set2
+                       where set2.set_origin=set1.set_origin
+                       and set2.set_id<>sub1.sub_set)
+                       as othersets on(true)
+                       left outer join @NAMESPACE@.sl_subscribe subs3
+                       on(subs3.sub_set=othersets.set_id
+                       and subs3.sub_forward=true
+                       and subs3.sub_provider=set1.set_origin
+                       and direct_recv.sub_receiver=subs3.sub_receiver)
+                       where subs3.sub_receiver is null
+               );
+       end if;
        return p_old;
 end;
 $$ language plpgsql;