londiste.global_add_table(): catch unique_violation

To avoid failure when both setup and replay add the table.

diff --git a/sql/londiste/functions/londiste.global_add_table.sql b/sql/londiste/functions/londiste.global_add_table.sql
index e64315cf088ef1fd704b1ac438659ed7e226c477..b3aebfc5946568fbcd1d8169d673c50b4616495d 100644 (file)
--- a/sql/londiste/functions/londiste.global_add_table.sql
+++ b/sql/londiste/functions/londiste.global_add_table.sql
@@ -43,6 +43,13 @@ begin
     select 200, 'Table added: ' || i_table_name
         into ret_code, ret_note;
     return;
+
+exception
+    -- seems the row was added from parallel connection (setup vs. replay)
+    when unique_violation then
+        select 200, 'Table already added: ' || i_table_name
+            into ret_code, ret_note;
+        return;
 end;
 $$ language plpgsql strict;